// Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "Eclipse Public License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.eclipse.org/legal/epl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

//

#include "serverasyncao.h"

#include <e32cons.h>

#include <obexserver.h>

#include <obexobjects.h>

CServerAsyncAO* CServerAsyncAO::NewL(CObexServer& aObexServer)

	{

	CServerAsyncAO* self = new(ELeave) CServerAsyncAO(aObexServer);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CServerAsyncAO::CServerAsyncAO(CObexServer& aObexServer)

:CActive(EPriorityStandard),

 iObexServer(aObexServer)

	{

	CActiveScheduler::Add(this);

	}

void CServerAsyncAO::ConstructL()

	{

	iConsole = Console::NewL(_L("OBEX DLL Test Code"),TSize(55,12));

	}

CServerAsyncAO::~CServerAsyncAO()

	{

	delete iConsole;

	}

void CServerAsyncAO::CompletionIndication(CObex::TOperation aOpcode, TObexResponse aResponse)

	{

	_LIT(KPutIndication, "PutCompleteIndication\n");

	_LIT(KGetIndication, "GetCompleteIndication\n");

	_LIT(KSetPathIndication, "SetPathIndication\n");

	iState = ECompleteIndication;

	iDefaultResponse = aResponse;

	switch(aOpcode)

		{

		case CObex::EOpPut:

			iConsole->Printf(KPutIndication);

			break;

		case CObex::EOpGet:

			iConsole->Printf(KGetIndication);

			break;

		case CObex::EOpSetPath:

			iConsole->Printf(KSetPathIndication);

			break;

		default:

			User::Invariant();

		}

	iConsole->Printf(_L("Please enter the response code: 0x%x"), aResponse);

	iConsole->Read(iStatus);	

	SetActive();

	}

void CServerAsyncAO::RequestIndication(CObex::TOperation aOpcode, CObexBaseObject *aObject)

	{

	if(aOpcode == CObex::EOpPut)

		{

		iConsole->Printf(_L("Put"));

		}

	else if(aOpcode == CObex::EOpGet)

		{

		iConsole->Printf(_L("Get"));

		}

	else

		{

		User::Invariant();

		}

	iState = ERequestIndication;

	iObject = aObject;

	iConsole->Printf(_L("RequestIndication, press any key to continue\n"));

	iConsole->Read(iStatus);

	SetActive();

	}

void CServerAsyncAO::RunL()

	{

	TObexResponse resp = ERespSuccess; 

	TBuf<2> buf;

	TKeyCode key = iConsole->KeyCode();

	if(iState == ECompleteIndication)

		{

		buf.AppendFormat(_L("%x"), iDefaultResponse);

		do	{

			if(key == EKeyBackspace&&buf.Length()!=0)

				{

				buf.SetLength(buf.Length()-1);

				}

			else if( buf.Length() < buf.MaxLength())

				{

				buf.Append(key);

				}

			else 

				continue;

			iConsole->Printf(_L("%c"),key);

			}

		while((key = iConsole->Getch())!=EKeyEnter);

		iConsole->Printf(_L("\n"));

		TLex lex(buf);

		TUint value;

		TInt lex_err = lex.Val(value, EHex); 

		if(lex_err == KErrNone)

			{

			resp = static_cast<TObexResponse>(value);

			}

		else 

			{

			iConsole->Printf(_L("Input parsing failed, use success as default response\n"));

			}

		TInt ret = iObexServer.RequestCompleteIndicationCallback(resp);

		iConsole->Printf(_L("Server returned with error code %d\n\n"), ret);

		}

	else

		{

		TInt ret = iObexServer.RequestIndicationCallback(iObject);

		iConsole->Printf(_L("Server returned with error code %d\n\n"), ret);

		}

	}

void CServerAsyncAO::DoCancel()

	{

	iConsole->ReadCancel();

	}