// 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: IRS.CPP $
// $Author: Stevep $
// $Revision: 8 $
// $Date: 25/03/02 8:49 $
// 
//

//class include
#include "IRS.H"

//system includes
#include <msventry.h>
#include <ircmtm.h>	// For the send command

//user includes
#include <irheader.h>
#include "sendopn.h"
const TInt KErrIrObexClientSubsequentPutFailed = -5511;

EXPORT_C CIrSrvMtm* CIrSrvMtm::NewL(CRegisteredMtmDll& aRegisteredMtmDll, CMsvServerEntry*  aEntry)
/**
 * NewL factory function. Calls ReleaseLibrary() if construction fails.
 *
 * @param aRegisteredMtmDll Registration data for MTM DLL.
 * @param aEntry Context on which to operate.
 * @return Pointer to a newly constructed CIrSrvMtm.
 * @leave KErrXXX System-wide error codes
 */
	{
	CIrSrvMtm* mysvrmtm = new CIrSrvMtm(aRegisteredMtmDll, aEntry);
	if (mysvrmtm==NULL)
		{
		aRegisteredMtmDll.ReleaseLibrary();
		User::Leave(KErrNoMemory);
		}
	CleanupStack::PushL(mysvrmtm);
	mysvrmtm->ConstructL();
	CleanupStack::Pop();
	return mysvrmtm;
	}

CIrSrvMtm::CIrSrvMtm(CRegisteredMtmDll& aRegisteredMtmDll, CMsvServerEntry* aEntry):
	CObexSrvMtm(aRegisteredMtmDll, aEntry)
/**
 * Constructor. Calls CObexSrvMtm's constructor in initialisation list.
 * @param aRegisteredMtmDll Registration data for MTM DLL.
 * @param aEntry Context on which to operate.
 */
	{
	__DECLARE_NAME(_S("CIrSrvMtm"));
	}

/**
 * Destructor. Deletes the header member
 */

EXPORT_C CIrSrvMtm::~CIrSrvMtm()
	{
	delete iHeader;
	}

EXPORT_C void CIrSrvMtm::StartCommandL (CMsvEntrySelection& aSelection, 
										TInt aCommand, 
										const TDesC8& aParameter, 
										TRequestStatus& aStatus)
/**
 * Instantiates and initiates a CIrServerSemdOperation class to begin sending the specified OBEX object
 * via Infrared. Called in response to InvokeAsyncFunctionL() in the client MTM, and passes through
 * all the arguments passed in to that function. Only supports aCommand==EIrMtmCmdSend
 * @param aSelection Entry to operate on.
 * @param aCommand Command to start. Only EIrMtmCmdSend is supported.
 * @param aParameter Package buffer containing timeout, port and password info needed for the send operation.
 * @param aStatus Used to notify observer of completion.
 * @leave KErrNotSupported if aCommand!=EIrMtmCmdSend
 * @leave KErrXXX if aCommand!= EIrMtmCmdSend
 */
	{
	switch (aCommand)
		{
		//The only supported command is EIrcCmdSend; switch statement used for potential future extension
		case CIrClientMtm::EIrcCmdSend:
			{
			TPckgBuf<CIrClientMtm::STimeouts> sendParamsBuf;
			sendParamsBuf.Copy(aParameter);
			iTimeouts = sendParamsBuf();
						
			//Zeroth selection is the TMsvId of the entry to send.
			iEntry = iServerEntry->NewEntryL(aSelection[0]);
			
			TMsvEntry messageEntry=iEntry->Entry();
			messageEntry.SetSendingState(KMsvSendStateSending);
			iEntry->ChangeEntry(messageEntry);

			//Construct a header 
			delete iHeader;
			iHeader = NULL;
			iHeader = CIrHeader::NewL();

			//Get the entry's store
			CMsvStore* store = iEntry->ReadStoreL();
			CleanupStack::PushL(store);
			
			//read the header from the store, and destroy the store
			iHeader->RestoreL(*store);
			CleanupStack::PopAndDestroy();	//store

			iProtocolInfo = iHeader->IrProtocolInfo();

			iFirstSendAttempt = ETrue;

			aStatus = KRequestPending;
			iReportStatus = &aStatus;

			SendL();

			break;
			}
		default:
			User::Leave(KErrNotSupported);
		}

	}

/**
 * Creates a server send operation to perform the send
 */


void CIrSrvMtm::SendL()
	{
	// Password is not supported for IR
	TPtrC connectPassword;
	// connectPassword.Set(sendParamsBuf().iConnectPassword);

	//Now make the send operation, which will start automatically. aStatus is passed in to
	//report completion.

	delete iSendOperation;
	iSendOperation = NULL;
    
    //If NewL() leaves , the progress should be recorded 
	
	iSendOperation = CIrServerSendOperation::NewL(*iEntry, iProtocolInfo,
		iTimeouts.iConnectTimeout, iTimeouts.iPutTimeout, &connectPassword, iStatus, !iFirstSendAttempt);

	SetActive();
	}

/**
 * Obtains progress information, which, if valid, results in calling Send()
 */

EXPORT_C void CIrSrvMtm::DoRunL()
	{
	// If the first attempt to send the message fails then retry with OBEX::IrXfer

	TPckgBuf<TObexMtmProgress> package;
	package.Copy(iSendOperation->ProgressL());
	TInt error = package().iError;
	
	if ((error != KErrNone) && (iFirstSendAttempt))
		{
		// If we have made only one send attempt so far, we will retry now

		// If the error code indicates that we have not found the OBEX class
		// name, change to use the OBEX:IrXfer class name as some older
		// implementations only understand that one.
		if (error == KErrIrObexClientPeerDoesNotHaveObex)
			{
			iProtocolInfo.iClassName = KIrXferClassName;
			}

		iFirstSendAttempt = EFalse;
       if(error == KErrIrObexClientSubsequentPutFailed)
			{
			User::RequestComplete(iReportStatus, KErrNone);
			}
		else
			{
			SendL();
			}
		}
	else
		{
		// Always report with a no error, any failure is recorded in the progress.
		User::RequestComplete(iReportStatus, KErrNone);
		}
	}