// 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 <es_sock.h>

#include <ir_sock.h>

#include <bautils.h>

#include <usbman.h>

#include <d32usbc.h>

#include <e32keys.h>

#include "clienthandler.h"

#include "TOBEXCON.H"

#include "btextnotifiers.h"

#include "obexconstantsinternal.h"

#define EPOCIDENT _L8("EPOC32 ER5")

CObexClientHandler::CObexClientHandler(CActiveConsole* aParent)

    : CActive(EPriorityNormal), iParent(aParent), iState(EIdle)

    {

    }

CObexClientHandler* CObexClientHandler::NewL(CActiveConsole* aParent, TTransport aTransport)

    {

    CObexClientHandler* self = new (ELeave) CObexClientHandler(aParent);

    CleanupStack::PushL (self);

    self->ConstructL(aTransport);

    CActiveScheduler::Add (self);

    CleanupStack::Pop ();

    return (self);

    }

void CObexClientHandler::ConstructL(TTransport aTransport)

    {

	if (aTransport == EBluetooth)

		{

		// Check if an address has been provided on the cmd line.

		TBuf<20> cmdline;

		User::CommandLine(cmdline);

		TInt ret = iDevAddr.SetReadable(cmdline);

		if (ret < KErrNone)

			{

			iParent->Console()->Printf(_L("\nNo address found on command line\n"));

			//Ask user which device address we should connect to...

			RNotifier notify;

			User::LeaveIfError(notify.Connect());

			TBTDeviceSelectionParamsPckg pckg;

			TBTDeviceResponseParamsPckg resPckg;

			TRequestStatus stat;

			notify.StartNotifierAndGetResponse(stat, KDeviceSelectionNotifierUid, pckg, resPckg);

			User::WaitForRequest(stat);

			notify.CancelNotifier(KDeviceSelectionNotifierUid);

			notify.Close();

			User::LeaveIfError(stat.Int()); 

			iDevAddr = resPckg().BDAddr();

			}

		// Find UUID to search for

		iParent->Console()->Printf(_L("\nPress F: FTP, Any other key: OPP"));

		TChar code (iParent->Console()->Getch());

		TUUID searchUUID;

		switch(code)

			{

		case 'f': case 'F':

			searchUUID = TUUID(0x1106); //FTP

			break;

		case 'o': case 'O':

		default:

			searchUUID = TUUID(0x1105); //OPP

			}

		//start the SDP Query

		delete iSdpServiceFinder;

		iSdpServiceFinder=0;

		iSdpServiceFinder = CRFCOMMServiceFinder::NewL(searchUUID, iDevAddr, *this);

		iSdpServiceFinder->FindPortL();

		iParent->Console()->Printf(_L("\nSearching for SDP service....\n"));

		// For bluetooth the client is created in SearchResult().

		}

	else if (aTransport == EIrda)

		{

		TObexIrProtocolInfo aInfo;

		aInfo.iTransport= KObexIrTTPProtocolV2;

		aInfo.iClassName     = _L8("OBEX");					//same for unicode and narrow builds

		aInfo.iAttributeName = _L8("IrDA:TinyTP:LsapSel");

		aInfo.iDiscoverySlots = iParent->iDiscoverySlots;

 		aInfo.iDiscoveryAttempts = iParent->iDiscoveryAttempts;	

		//now create the obex client...

	    iClient = CObexClient::NewL (aInfo);

	    iClient->SetFinalPacketObserver(this);

#ifdef ERROR_RESOLUTION_EXTENSION

		iClientErrorResolver = CObexClientErrorResolver::NewL(*iClient);

#endif // ERROR_RESOLUTION_EXTENSION

		}

	else if (aTransport == EUsb)

		{

		TObexUsbProtocolInfo aInfo;

		aInfo.iTransport = KObexUsbProtocol;

		aInfo.iInterfaceStringDescriptor = _L("TOBEX Client Interface");

		//now create the obex client...

	    iClient = CObexClient::NewL (aInfo);

	    iClient->SetFinalPacketObserver(this);

#ifdef ERROR_RESOLUTION_EXTENSION

		iClientErrorResolver = CObexClientErrorResolver::NewL(*iClient);

#endif // ERROR_RESOLUTION_EXTENSION

		}

	else if (aTransport == EWin32Usb)

		{

		TObexUsbProtocolInfo aInfo;

		aInfo.iTransport = _L("Win32Usb");

		//now create the obex client...

	    iClient = CObexClient::NewL (aInfo);

	    iClient->SetFinalPacketObserver(this);

#ifdef ERROR_RESOLUTION_EXTENSION

		iClientErrorResolver = CObexClientErrorResolver::NewL(*iClient);

#endif // ERROR_RESOLUTION_EXTENSION

		}

	else

		{

		User::Invariant();

		}

#ifdef EMPTY_HEADERS_TEST

	iObexEmptyHeaderTest = CObexEmptyHeaderTest::NewL();

#endif //EMPTY_HEADERS_TEST

    iFileObject = CObexFileObject::NewL();

    iObjectBuffer = CBufFlat::NewL(8);

    iObject = CObexBufObject::NewL(iObjectBuffer);

	iObexName = _L("");

	iGetType = _L("text/x-vcard");

	iFilename1 = _L("Contacts.vcf"); 

	iFilename2 = _L("Contacts2.vcf");

	iFilename3 = _L("Contacts3.vcf");

	iChallengePassword = _L("SecretPassword");

	iResponsePassword = _L("SecretPassword");

	iTargetHeaderObject = CObexNullObject::NewL();

	iTargetHeaderObject->SetTargetL(KRefTarget);

	iTargetHeaderObject->SetHeaderMask(KObexHdrTarget);

    }

void CObexClientHandler::SearchResult(TInt aError, TUint8 aPort, TInt aProfileVersion)

	{

	if (aError != KErrNone)

		{

		iParent->Console()->Printf(_L("\r\n Could not find SDP service in remote device : error %d \r\n"),aError);	

		iParent->ClientErrored();

		return;

		}

	if (aProfileVersion >= 0)	

		{	

		iParent->Console()->Printf(_L("\nProfile Version 0x%04x\n"), aProfileVersion);	

		}	

	else	

		{	

		iParent->Console()->Printf(_L("\nProfile Version not supplied\n"));	

		}	

	iParent->Console()->Printf(_L("RFCOMM Port %d\n"), aPort);	

	TObexBluetoothProtocolInfo aInfo;

	aInfo.iAddr.SetBTAddr(iDevAddr);

	aInfo.iAddr.SetPort(aPort); 

	aInfo.iTransport     = KObexRfcommProtocol;

	TObexProtocolPolicy policy;

	policy.SetReceiveMtu(iParent->iRecvMTU);

	policy.SetTransmitMtu(iParent->iTransmitMTU);

	//now create the obex client...

	TRAP(aError, iClient = CObexClient::NewL(aInfo, policy));

	if (aError)

		{

		iParent->Console()->Printf(_L("\r\n Could not create client! : error %d \r\n"),aError);

		iParent->ClientErrored();

		return;

		}

	iClient->SetFinalPacketObserver(this);

#ifdef ERROR_RESOLUTION_EXTENSION

	TRAP(aError,iClientErrorResolver = CObexClientErrorResolver::NewL(*iClient));

	if (aError != KErrNone)

		{

		iParent->Console()->Printf(_L("\r\n Could not create client error resolver! : error %d \r\n"),aError);

		iParent->ClientErrored();

		return;

		}

#endif // ERROR_RESOLUTION_EXTENSION

	iParent->Console()->Printf(_L("\nSDP search complete OK!\n"));

	iParent->iTestMode = E_Client;

	iParent->Cancel(); // cancel request for key

	iParent->RequestCharacter(); // re-request, to re-display menu

	}

void CObexClientHandler::SetCurrentTestNumber()

{

	iCurrentTestNumber = 1;

}

void CObexClientHandler::ResetCurrentTestNumber()

{

	iCurrentTestNumber = 0;

}

void CObexClientHandler::MofpoFinalPacketStarted()

	{

	iParent->Console()->Printf(_L("\nFinal packet started\n"));

	}

void CObexClientHandler::MofpoFinalPacketFinished()

	{

	iParent->Console()->Printf(_L("\nFinal packet finished\n"));

	}

CObexClientHandler::~CObexClientHandler()

    {

    Cancel();

#ifdef EMPTY_HEADERS_TEST    

    delete iObexEmptyHeaderTest;

#endif //EMPTY_HEADERS_TEST

    delete iObject;

	delete iFileObject;

    delete iClient;

#ifdef ERROR_RESOLUTION_EXTENSION

	delete iClientErrorResolver;

#endif // ERROR_RESOLUTION_EXTENSION

	delete iObjectBuffer;

	delete iTargetHeaderObject;

	delete iSdpServiceFinder;

    }

void CObexClientHandler::Abort()

    {

    if((iState != EPutting)&&(iState != EGetting))

		iParent->Console()->Printf(_L("\r\n NOTE: Wrong Obex state for issuing abort\r\n"));

	iClient->Abort();

    }

void CObexClientHandler::Connect()

    {

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    TObexConnectInfo iLocalInfo = iClient->LocalInfo();

    iLocalInfo.iWho = _L8("");

    iLocalInfo.iWho = EPOCIDENT;  

    iLocalInfo.iWho.Append(_L8(" EikIrOBEXFile "));

    iClient->Connect(iStatus);

    SetActive();

    iState = EConnecting;

    }

void CObexClientHandler::RemoteAddress()

	{

	TSockAddr aAddr;

	iClient->RemoteAddr( aAddr);

	TBTDevAddr addr = static_cast <TBTSockAddr>(aAddr).BTAddr();

	TChar aChar;

	iParent->Console()->Printf(_L("Remote Address = "));

	for(TInt count = 0; count < addr.Des().Length(); count++) 

		{

		aChar = (addr.Des()[count] & 0xf0)>>4;

		if (aChar <= 9)

			aChar += 0x30;

		else if ((aChar >= 0x0a) && (aChar <= 0x0f))

			aChar += 'A' - 0x0a;

		iParent->Console()->Printf(_L("%C"),(TUint)aChar);

		aChar = (addr.Des()[count] & 0x0f);

		if (aChar <= 9)

			aChar += 0x30;

		else if ((aChar >= 0x0a) && (aChar <= 0x0f))

			aChar += 'A' - 0x0a;

		iParent->Console()->Printf(_L("%C"),(TUint)aChar);

		}

    iParent->Console()->Printf(_L("\r\n"));

	}

void CObexClientHandler::Disconnect()

    {

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

	iClient->Disconnect(iStatus);

    SetActive();

    iState = EDisconnecting;

    }

void CObexClientHandler::GetByNameL()

    {

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	SetName(iObexName);

    iObject->SetNameL (iObexName);

    iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

    }

void CObexClientHandler::GetByTypeL()

    {

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	TBuf8<300> buf;

	buf.Copy(iGetType);

	buf.Append(0);

	iObject->SetTypeL (buf);

    iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

    }

void CObexClientHandler::Put(TDes& aFilename)

    {

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

	TInt err;

	err = SetUpObject (aFilename);

	if( err != KErrNone)

		{

		iParent->Console()->Printf(_L("\r\n Couldnt set up object : error %d \r\n"),err);

		return;

		}

	// Start the timer.

	iStartTime.HomeTime();

	iClient->Put(*iFileObject,iStatus);

	SetActive();

	iState = EPutting;

	}

void CObexClientHandler::GetReferenceL(TInt aReferenceId)

	{

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

	iParent->iRefHandler->CreateReferenceL(*iObject, *iObjectBuffer, aReferenceId, iParent->iTransport);

	iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGettingReference;

	}

//multiple HTTP packets sent in a single Obex packet

void CObexClientHandler::HTTPTest1L() //tam

	{

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	SetName(iObexName);

    iObject->SetNameL (iObexName);

	//now add in the HTTP headers

	iObject->AddHttpL(_L8("Test 1 HTTP header 1\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 2\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 3\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 4\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 5\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 6\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 7\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 8\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 9\r\n"));

	iObject->AddHttpL(_L8("Test 1 HTTP header 10\r\n"));

	iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

	}

//multiple HHTP packets sent in multiple Obex packets

void CObexClientHandler::HTTPTest2L()

	{

	TBuf8<520> localBuf;

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	SetName(iObexName);

    iObject->SetNameL (iObexName);

	for ( TUint x = 0; x < 10; x++ ) //should be 10*512 HTTP packets,

		{							//		which is in excess of the 4K Tranport size

		localBuf = _L8("Test 2 HTTP Header");

		localBuf.AppendFill(TUint(x + '1'), 500);

		iObject->AddHttpL(localBuf);

		}

	iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

	}

//single HHTP packet too large for an Obex packet will not go

void CObexClientHandler::HTTPTest3L()

	{

	HBufC8* localBuf = HBufC8::NewL(5020);

	TPtr8 ptr = localBuf->Des();

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	SetName(iObexName);

    iObject->SetNameL (iObexName);

	ptr = _L8("Test 3 HTTP Header ");

	ptr.AppendFill(TUint('A'), 5000);

	iObject->AddHttpL(ptr);

	iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

	}

//a single (too) large HTTP packet, with multiple HTTP packets

//large one ignored, multiple smaller should all go

void CObexClientHandler::HTTPTest4L()

	{

	HBufC8* localBuf = HBufC8::NewL(5020);

	TPtr8 ptr = localBuf->Des();

    if(IsActive())

		{

		iParent->Console()->Printf(_L("\r\nError: Client handler already active\r\n"));

		return;

		}

    iObject->Reset ();

	SetName(iObexName);

    iObject->SetNameL (iObexName);

	ptr = _L8("Test 4 HTTP header 1");

	iObject->AddHttpL(ptr);

    //now for the excessively large header

	ptr = _L8("Test 4 HTTP header 2");

	ptr.AppendFill(TUint('B'), 5000);

	iObject->AddHttpL(ptr);

	//and a reasonable header again

	ptr = _L8("Test 4 HTTP header 3");

	iObject->AddHttpL(ptr);

	iClient->Get(*iObject, iStatus);

    SetActive();

    iState = EGetting;

	}

void CObexClientHandler::AppParamsTestL()