// Copyright (c) 2001-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:

// $Workfile: btsendop.cpp $

// $Author: Stevep $

// $Revision: 10 $

// $Date: 25/03/02 9:32 $

// 

//

//class include

#include "btsendop.h"

//system includes

#include <btmsgtypeuid.h>	//KUidMsgTypeBt

#include "btmtmcmds.h"	//EBtMtmCmdSend

//#include <bttypes.h>

//user includes

//#include "btcmtm.h"	//EBtcCmdSend

//#include "btmsgtypeuid.h" //KUidMsgTypeBt

const TInt KPacketBufferSize=20000; // Packet buffer size

CBtServerSendOperation* CBtServerSendOperation::NewL(CMsvServerEntry& aSendObj,	const TObexBluetoothProtocolInfo& aBtProtocolInfo, TInt aConnectTimeoutMicroSeconds, TInt aPutTimeoutMicroseconds, const TDesC* aConnectPassword, TRequestStatus& aObserverRequestStatus)

/**

 * Second phase constructor.

 *

 * @param aSendObj Reference to the object to send.

 * @param aBtProtocolInfo Protocol info to initialise the CObexCleint

 * @param aConnectTimeoutMicroSeconds Timeout period for Connect operation in microseconds.

 * @param aPutTimeoutMicroseconds Timeout period for Put operation in microseconds.

 * @param aConnectPassword Pointer to the password for Bluetooth validation.

 * @param aObserverRequestStatus Canonical TRequestStatus for control of active object.

 * @leave KErrXXX System-wide error codes

 */

	{

	CBtServerSendOperation* self=new(ELeave) CBtServerSendOperation(aSendObj, aBtProtocolInfo, aConnectTimeoutMicroSeconds, aPutTimeoutMicroseconds, aObserverRequestStatus);

	CleanupStack::PushL(self);

	self->ConstructL(aConnectPassword);

	CleanupStack::Pop(); //self

	return self;

	}

CBtServerSendOperation::CBtServerSendOperation(CMsvServerEntry& aSendObj, const TObexBluetoothProtocolInfo& aBtProtocolInfo, TInt aConnectTimeoutMicroSeconds, TInt aPutTimeoutMicroSeconds, TRequestStatus& aObserverRequestStatus)

	:CObexServerSendOperation(KUidMsgTypeBt, aSendObj, aConnectTimeoutMicroSeconds, aPutTimeoutMicroSeconds, aObserverRequestStatus),

		iBtProtocolInfo(aBtProtocolInfo),iBTObexPortNumber(0)	//default bitwise copy constructor should suffice

/**

 * Constructor.

 *

 * @param aSendObj Reference to the object to send.

 * @param aBtProtocolInfo Protocol info to initialise the CObexCleint

 * @param aConnectTimeoutMicroSeconds Timeout period for Connect operation in microseconds.

 * @param aPutTimeoutMicroseconds Timeout period for Put operation in microseconds.

 * @param aConnectPassword Pointer to the password for Bluetooth validation.

 * @param aTargetID Unsigned Int32 containing target ID if present.

 * @param aSendTargetID TBool for flag to send target ID or not.

 * @param aObserverRequestStatus Canonical TRequestStatus for control of active object.

 */

	{

	}

CBtServerSendOperation::~CBtServerSendOperation()

	{

	delete iSdpUtils;

	iLinkAdapter.Close();

	iSocketServ.Close();

	}

void CBtServerSendOperation::InitialiseObexClientL()

/**

 * Initialises the Obex client to use Bluetooth as the transport mechanism with the parameters as specified in the

 * constructor.

 *

 * @leave KErrXXX System-wide error codes 

 */

	{

	//Prevent the link from going into low power modes before the SDP query takes place. 

	PreventLowPowerModes(); 

	// trigger SDP Lookup

	iSdpUtils = CObexSdpUtils::NewL(*this);

	User::LeaveIfError(iSdpUtils != NULL);

	TBTDevAddr devAddr = iBtProtocolInfo.iAddr.BTAddr();

	iSdpUtils->RemoteBtObexQueryL(devAddr);

	// tell the obex server module we're async

	iAsyncInit = ETrue;

	}

void CBtServerSendOperation::RemoteBtObexQueryResult(TInt aError, TInt aPortNumber, TBool /*aObexObjectPushProfileSupported*/, 

									 TInt /*aObexObjectPushProfileVersion*/, TObexSupportedFormatsList /*aSupportedFormats*/)

	/**

	 * SDP Query result, parameters have the following meaning:

	 *

	 * @param aError If this is anything but KErrNone then the query has not completed correctly and all other parameters are meaningless.

	 * @param aPortNumber - The RFCOMM port number that the remote device supports OBEX on

	 * @param aObexObjectPushProfileSupported - ETrue if the remote device supports the Bluetooth OBEX Push Profile

	 * @param aObexObjectPushProfileVersion - Version of Bluetooth OBEX Push Profile supported (only valid if aObexObjectPushProfileSupported == ETrue)

	 * @param aSupportedFormats - Structure containing a list of the OBEX Object formats supported by the remote device

	 */

	{

	if(aError)

		{

		// finish the async init at this point

		TRequestStatus* status = &iStatus;

		User::RequestComplete(status, aError);

		}

	else

		{

		// remember the port number

		iBTObexPortNumber = aPortNumber;

		// finish the async init at this point

		TRequestStatus* status = &iStatus;

		User::RequestComplete(status, KErrNone);

		}

	}

void CBtServerSendOperation::SecondPhaseObexClientInitL()

/**

 * Fills in the iBtProtocolInfo structure with the results of the SDP Lookup.

 */

	{

	delete iSdpUtils;

	iSdpUtils = NULL;

	// use the port number to complete initialisation

	TRfcommSockAddr& sockAddr = iBtProtocolInfo.iAddr;

	sockAddr.SetPort(iBTObexPortNumber);

	// setting of receive & transmit packet buffer size.

	TObexProtocolPolicy obexProtocolPolicy;

	obexProtocolPolicy.SetReceiveMtu(KPacketBufferSize);

	obexProtocolPolicy.SetTransmitMtu(KPacketBufferSize);

	// Initialise Obex client object.

	iObexClient = CObexClient::NewL(iBtProtocolInfo,obexProtocolPolicy); 

	}

void CBtServerSendOperation::PreConnectOperations()

	{

	}

void CBtServerSendOperation::PostConnectOperations()

	{

	// If the connection attempt has failed and we are not going to retry the connection,

	// make sure that the link is allowed to go into low power modes.

	const TDesC8* progressDes;

 	TRAPD(error, progressDes = &ProgressL());

	if (error == KErrNone)

		{

		TPckgBuf<TObexMtmProgress> package;

		package.Copy(*progressDes);

		if (package().iSendState == TObexMtmProgress::ESendError)

			{

			AllowLowPowerModes();

			}

		}

	}

void CBtServerSendOperation::PreSendOperations()

	{

	// Try to ensure the link does not go into a low power mode.

	// Note that we may already be preventing low power modes as a result of attempting

	// to do this prior to the connection setup. In this case, calling it again does

	// nothing.

	// Note that as the obex connection is setup, this should not fail. If for some reason

	// it does, this would result in a slower file transfer.

	PreventLowPowerModes();

	}

void CBtServerSendOperation::PostSendOperations()

	{

	// Allow the link to go into low power modes

	AllowLowPowerModes();

	}

void CBtServerSendOperation::DoCancel()

	{

	// As the transfer is being cancelled, allow the link to go into low power modes

	AllowLowPowerModes();

	delete iSdpUtils;

	iSdpUtils = NULL;

	CObexServerSendOperation::DoCancel();

	}

void CBtServerSendOperation::AllowLowPowerModes()

	{

	// Allow the link to go into low power modes

	if (iPreventingLowPowerModes)

		{

		iLinkAdapter.AllowLowPowerModes(EAnyLowPowerMode);

		iPreventingLowPowerModes = EFalse;

		}

	iLinkAdapter.Close();

	iSocketServ.Close();

	}

void CBtServerSendOperation::PreventLowPowerModes()

	{

	// Prevent the link from going into low power modes. This means the connect and send

	// operations will be much quicker.

	if (iPreventingLowPowerModes)

		{

		return;

		}

	// Connect to the socket server

	if (!iSocketServ.Handle())

		{

		if (iSocketServ.Connect() != KErrNone)

			{

			return;

			}

		}

	// Open the bluetooth link adapter

	if (!iLinkAdapter.IsOpen())

		{

		TBTDevAddr devAddr = iBtProtocolInfo.iAddr.BTAddr();

		if (iLinkAdapter.Open(iSocketServ, devAddr) != KErrNone)

			{

			return;

			}

		}

	if (iLinkAdapter.PreventLowPowerModes(EAnyLowPowerMode) == KErrNone)

		{

		iPreventingLowPowerModes = ETrue;

		}

	}