// 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 "serverhandlerbase.h" 

#include "TOBEXCON.H"

#include "btextnotifiers.h"

#include "serverasyncao.h"

#include <obexconstants.h>

#include <obexbttransportinfo.h>

#include <obexirtransportinfo.h>

#include "obexconstantsinternal.h"

#include "serverpacketaccessui.h"

CObexServerHandlerBase::CObexServerHandlerBase(CActiveConsole* aParent)

	: iAcceptPuts(ETrue), iParent(aParent)

    {

    }

void CObexServerHandlerBase::BaseConstructL(TTransport aTransport)

    {

	iTransportLayer = aTransport;

	switch (aTransport)

		{

		case (EBluetooth):

			InitBluetoothL();

			break;

		case (EIrda):

			{

			if(iParent->UseIrdaNickname())

				{

				TObexIrV3TransportInfo aInfo;

				aInfo.iTransportName = KObexIrTTPProtocolV3;

				aInfo.iReceiveMtu = iParent->iRecvMTU;

				aInfo.iTransmitMtu = iParent->iTransmitMTU;

				aInfo.iAddr.SetPort(KAutoBindLSAP);//default obex server for now

				_LIT8(KClassName, "OBEX");

				_LIT8(KAttributeName, "IrDA:TinyTP:LsapSel");

				aInfo.iClassName     = KClassName;

				aInfo.iAttributeName = KAttributeName;

				aInfo.iDiscoverySlots = iParent->iDiscoverySlots;

				aInfo.iDiscoveryAttempts = iParent->iDiscoveryAttempts;

				aInfo.iLocalDeviceNickname = iParent->GetIrdaNickname();

				aInfo.iLocalDeviceNicknameValid = ETrue;

				iServer = CObexServer::NewL(aInfo);

				}

			else

				{

				TObexIrV2TransportInfo aInfo;

				aInfo.iTransportName = KObexIrTTPProtocolV2;

				aInfo.iReceiveMtu = iParent->iRecvMTU;

				aInfo.iTransmitMtu = iParent->iTransmitMTU;

				aInfo.iAddr.SetPort(KAutoBindLSAP);//default obex server for now

				_LIT8(KClassName, "OBEX");

				_LIT8(KAttributeName, "IrDA:TinyTP:LsapSel");

				aInfo.iClassName     = KClassName;

				aInfo.iAttributeName = KAttributeName;

				aInfo.iDiscoverySlots = iParent->iDiscoverySlots;

				aInfo.iDiscoveryAttempts = iParent->iDiscoveryAttempts;

				iServer = CObexServer::NewL(aInfo);

				}

			User::LeaveIfError(iServer->Start(this));

/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 

			// API with TTP transport.

			// We get back an TObexIrTransportInfo because we asked for KObexIrTTPProtocol.

			const TObexIrTransportInfo* transportInfo = static_cast<const TObexIrTransportInfo*>(iServer->TransportInfo());

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

			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);

			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);

			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);

			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);

			iParent->Console()->Printf(_L("\tTinyTP port: 0x%02x\r\n"), transportInfo->iAddr.Port());

			TName wide;

			wide.Copy(transportInfo->iClassName);

			iParent->Console()->Printf(_L("\tclass name: %S\r\n"), &wide);

			wide.Copy(transportInfo->iAttributeName);

			iParent->Console()->Printf(_L("\tattribute name: %S\r\n"), &wide);

*/

			break;

			}

		case (EUsb):

			{

			TObexUsbProtocolInfo info;

			info.iTransport = KObexUsbProtocol;

			info.iInterfaceStringDescriptor = _L("TOBEX Server Interface");

			iServer = CObexServer::NewL (info);

			User::LeaveIfError(iServer->Start (this));

/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 

			// API with USB transport.

			// We get back an TObexUsbTransportInfo because we asked for KObexUsbProtocol.

			const TObexUsbTransportInfo* transportInfo = static_cast<const TObexUsbTransportInfo*>(iServer->TransportInfo());

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

			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);

			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);

			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);

			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);

			iParent->Console()->Printf(_L("\tinterface string desc: %S\r\n"), &transportInfo->iInterfaceStringDescriptor);

*/

			break;

			}

		case (EWin32Usb):

			{

			TObexUsbProtocolInfo aInfo;

			aInfo.iTransport = _L("Win32Usb");

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

			iServer = CObexServer::NewL (aInfo);

			User::LeaveIfError(iServer->Start (this));

/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 

			// API with Win32USB transport.

			// We get back an TObexUsbTransportInfo because we asked for KObexUsbProtocol.

			const TObexUsbTransportInfo* transportInfo = static_cast<const TObexUsbTransportInfo*>(iServer->TransportInfo());

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

			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);

			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);

			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);

			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);

			iParent->Console()->Printf(_L("\tinterface string desc: %S\r\n"), &transportInfo->iInterfaceStringDescriptor);

*/

			break;

			}

		}

#ifdef ASYNC_INDICATION

    iServerAsyncAO = CServerAsyncAO::NewL(*iServer);

#endif

	}

void CObexServerHandlerBase::InitBluetoothL()

	{

	TBTServiceSecurity serv;

	serv.SetUid(KObexTestUid);

	// UPF - change security here for Bluetooth security testing

	serv.SetAuthentication(EFalse);

	serv.SetAuthorisation(EFalse);

	serv.SetEncryption(EFalse);

	// now set up Obex...

	TObexBluetoothProtocolInfo info;

	info.iTransport = KObexRfcommProtocol;

	info.iAddr.SetPort(KRfcommPassiveAutoBind);

	info.iAddr.SetSecurity(serv);

	TObexProtocolPolicy policy;

	policy.SetReceiveMtu(iParent->iRecvMTU);

	policy.SetTransmitMtu(iParent->iTransmitMTU);

	iServer  = CObexServer::NewL(info, policy);

	iServer->SetReadActivityObserver(this);

	User::LeaveIfError(iServer->Start (this));

	// We get back an TObexBtTransportInfo because we asked for KObexRfcommProtocol.

	const TObexBtTransportInfo* transportInfo = static_cast<const TObexBtTransportInfo*>(iServer->TransportInfo());

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

	iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);

	iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);

	iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);

	iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);

	iParent->Console()->Printf(_L("\tRFCOMM port: 0x%02x\r\n"), transportInfo->iAddr.Port());

	// SDP registration 

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

	User::LeaveIfError(iSdpdb.Open(iSdp));

	TSdpServRecordHandle handle;

	iSdpdb.CreateServiceRecordL(TUUID(0x1105), handle);

	iSdpdb.UpdateAttributeL(handle, 0x100, _L8("Obex push server"));

	TSdpServRecordHandle ftphandle;

	iSdpdb.CreateServiceRecordL(TUUID(0x1106), ftphandle);

	iSdpdb.UpdateAttributeL(ftphandle, 0x100, _L8("File transfer server"));

	// Protocol Descriptor List (same for both profiles)

	iProtDescList = CSdpAttrValueDES::NewDESL(0);

	iProtDescList

	->StartListL()

		->BuildDESL()

		->StartListL()

			->BuildUUIDL(TUUID(TUint16(0x0100))) // L2CAP

		->EndListL()

		->BuildDESL()

		->StartListL()

			->BuildUUIDL(TUUID(TUint16(0x0003))) // RFCOMM

			->BuildUintL(TSdpIntBuf<TInt8>(transportInfo->iAddr.Port()))

		->EndListL()

		->BuildDESL()

		->StartListL()

			->BuildUUIDL(TUUID(TUint16(0x0008))) // OBEX

		->EndListL()

	->EndListL();

	iSdpdb.UpdateAttributeL(handle, 4, *iProtDescList);

	iSdpdb.UpdateAttributeL(ftphandle, 4, *iProtDescList); // put into both records

	delete iProtDescList;

	iProtDescList = NULL;

	// Supported formats list (OPP only)

	iProtDescList = CSdpAttrValueDES::NewDESL(0);

	iProtDescList->StartListL()

		->BuildUintL(TSdpIntBuf<TUint8>(0xFF)) // Accept any type of object

	->EndListL();

	iSdpdb.UpdateAttributeL(handle, 0x0303, *iProtDescList);

	delete iProtDescList;

	iProtDescList = NULL;

	// Add OPP to the supported profiles list

	iProtDescList = CSdpAttrValueDES::NewDESL(0);

	iProtDescList->StartListL()

		->BuildDESL()

		->StartListL()

			->BuildUUIDL(TUUID(0x1105)) // OPP Profile

			->BuildUintL(TSdpIntBuf<TUint16>(0x0100)) // Profile version

		->EndListL()

	->EndListL();

	iSdpdb.UpdateAttributeL(handle, 9, *iProtDescList); // profile list

	delete iProtDescList;

	iProtDescList = NULL;

	// Add FTP to the supported profiles list

	iProtDescList = CSdpAttrValueDES::NewDESL(0);

	iProtDescList->StartListL()

		->BuildDESL()

		->StartListL()

			->BuildUUIDL(TUUID(0x1106)) // FTP Profile

			->BuildUintL(TSdpIntBuf<TUint16>(0x0100)) // Profile version

		->EndListL()

	->EndListL();

	iSdpdb.UpdateAttributeL(ftphandle, 9, *iProtDescList); // profile list

	delete iProtDescList;

	iProtDescList = NULL;

	// Set host name

	RSocketServ ss;

	ss.Connect();

	RHostResolver hr;

	User::LeaveIfError(hr.Open(ss,KBTAddrFamily,KBTLinkManager));

	User::LeaveIfError(hr.SetHostName(_L("Symbian Push Server")));

	ss.Close();

	// Enable enquiry and page scan

	User::LeaveIfError(RProperty::Set(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothSetScanningStatus, EInquiryAndPageScan));

	}

CObexServerHandlerBase::~CObexServerHandlerBase ()

    {

    Stop();

	if (iTransportLayer == EBluetooth)

		{

		// security now cleared with socket closure

		iSdpdb.Close();

		iSdp.Close();

		}

#ifdef PACKET_ACCESS_EXTENSION

	delete iPacketAccessUi;

#endif // PACKET_ACCESS_EXTENSION

#ifdef ASYNC_INDICATION		

	delete iServerAsyncAO;

#endif

    delete iServer;

	delete iProtDescList;

    }

void CObexServerHandlerBase::RemoteAddress()

	{

	TSockAddr aAddr;

	iServer->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 CObexServerHandlerBase::Start()

    {

    if (iServer)

		{

		iServer->Start(this);

		}

    }

void CObexServerHandlerBase::Stop()

    {

	if (iServer)

		{

		iServer->Stop();

		}

    }

void CObexServerHandlerBase::SetTargetChecking(CObexServer::TTargetChecking aValue)

	{

    iServer->SetTargetChecking(aValue);

	}

// MObexServerNotify interface functions

void CObexServerHandlerBase::ErrorIndication (TInt aError)

    {

    iParent->Console()->Printf(_L("Obex Server Error: %d\r\n"), aError);

    }

void CObexServerHandlerBase::TransportUpIndication ()

    {

    iParent->Console()->Printf(_L("\r\nTransport layer now connected\r\n\r\n"));

    }

void CObexServerHandlerBase::TransportDownIndication ()

    {

    iParent->Console()->Printf(_L("\r\nTransport layer has gone down\r\n\r\n"));

    if (iObject)

		{

		if(!iObject->BytesReceived())

			{

			return;

			}

		iParent->Console()->Printf(_L("\r\nWe have received part of an Obex object\r\n\r\n"));

		iObject->Reset();//close file handle

		}

    }

#ifdef ASYNC_INDICATION

void CObexServerHandlerBase::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& /*aInfo*/)

#else

TInt CObexServerHandlerBase::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& /*aInfo*/)

#endif

    {

	iParent->Console()->Printf(_L("\r\nCObexServerHandler::ObexConnectIndication"));

	iParent->Console()->Printf(_L("\r\nConnected to machine with OBEX version %d.%d\r\n"), 

		     aRemoteInfo.VersionMajor (), aRemoteInfo.VersionMinor ());

	if ( aRemoteInfo.iWho.Length() > 0 )

		{

		iParent->Console()->Printf(_L("EWho received from remote side ="));

		for(TInt count = 0; count < aRemoteInfo.iWho.Length(); count++) 

			{

			TChar aChar;

			aChar = (aRemoteInfo.iWho[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 = (aRemoteInfo.iWho[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"));

		}

	else

		iParent->Console()->Printf(_L("No Who Header received\r\n"));

	if ( aRemoteInfo.iTargetHeader.Length() > 0 )

		{

		iParent->Console()->Printf(_L("ETarget received from remote side ="));

		for(TInt count = 0; count < aRemoteInfo.iTargetHeader.Length(); count++) 

			{

			TChar aChar;

			aChar = (aRemoteInfo.iTargetHeader[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 = (aRemoteInfo.iTargetHeader[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"));

		}

	else

		iParent->Console()->Printf(_L("No Target Header received\r\n"));

#ifndef ASYNC_INDICATION

	return KErrNone;

#endif	

    } 

void CObexServerHandlerBase::ObexDisconnectIndication (const TDesC8& /*aInfo*/)

    {

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

    }

#ifdef ASYNC_INDICATION

void CObexServerHandlerBase::PutRequestIndication ()

#else

CObexBufObject* CObexServerHandlerBase::PutRequestIndication ()

#endif

    {

	iStartTime.HomeTime();

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

    iObject->Reset ();

#ifdef ASYNC_INDICATION

	iServerAsyncAO->RequestIndication(CObex::EOpPut, iAcceptPuts?iObject:NULL);

#else

	return iAcceptPuts?iObject:NULL;

#endif

    }

TInt CObexServerHandlerBase::PutPacketIndication ()

    {

    // Only output % received if performance logging is disabled.

	if(!iParent->iPerformanceLoggingEnabled)

		{

		TUint length = iObject->Length();

		TUint received = iObject->BytesReceived();

		TUint8 percent = 0;

	    if (length > 0)

			{

			percent = TUint8((100 * received) / length);

			iParent->Console()->Printf(_L("\r%d %%      "), percent);

			}

	    else

			{

			iParent->Console()->Printf(_L("\r%d Bytes      "), iObject->BytesReceived ());

			}

		}

    return (KErrNone);

    }

#ifdef ASYNC_INDICATION

void CObexServerHandlerBase::PutCompleteIndication()

#else

TInt CObexServerHandlerBase::PutCompleteIndication()

#endif

    {

	TTime finishTime;

	finishTime.HomeTime();

	TTimeIntervalMicroSeconds diff = finishTime.MicroSecondsFrom(iStartTime);	

	iParent->Console()->Printf(_L("\nObject Received in %d"), diff.Int64());

    TPtrC name=iObject->Name();

	TBuf<100> type;

	type.Copy(iObject->Type());

	iParent->Console()->Printf(_L("\r\nSuccessfully received '%S'\r\nType[%d]: '%S'\r\n"), &name, type.Length(), &type);

	TInt err = KErrNone;

	if (iParent->DisplayHeaders())

		{

		// No need to put header on the cleanup stack, as there are no leaving functions during its lifetime

		CObexHeader* header = NULL;

		TRAP(err, header = CObexHeader::NewL());

		if (err)

			{

			iParent->iConsole->Printf(_L("Error allocating memory to display\r\n"));

			}

		iObject->HeaderSet().SetMask(NULL);

		iObject->HeaderSet().First();

		while (err == KErrNone)