// Copyright (c) 2003-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 <f32file.h>
#include "TestObexErrorCodes.h"

/**
 * Static NewL
 *
 * @return Base class*
 */
CTestObexErrorCodesClient* CTestObexErrorCodesClient::NewL(CControllerConsoleTest* aOwner)
	{
	CTestObexErrorCodesClient* self = new(ELeave) CTestObexErrorCodesClient;
	CleanupStack::PushL(self);
	self->ConstructL(aOwner);
	self->StartIrdaClientL();
	CleanupStack::Pop( self );

	return self;
	}




/**
*
* CTestObexErrorCodesClient
*
*/

CTestObexErrorCodesClient::CTestObexErrorCodesClient()
	{
	}

/**
*
* ~CTestObexErrorCodesClient
*
*/

CTestObexErrorCodesClient::~CTestObexErrorCodesClient()
	{
	delete iClient;
   	}

void CTestObexErrorCodesClient::Stop()
	{
	iOwner->iConsole->Printf(_L("About to Stop the iClient ..\n"));


	}


void CTestObexErrorCodesClient::Start()
	{
//Start the test

	iClient->Connect();	//should fail with appropriate error code


	}




void CTestObexErrorCodesClient::StartIrdaClientL()
	{

	iOwner->iConsole->Printf(_L("About to load the CObexClient...\n"));

	TObexIrProtocolInfo aInfo;
	aInfo.iTransport     = _L("IrTinyTP");
	aInfo.iClassName     = _L8("OBEX");
	aInfo.iAttributeName = _L8("IrDA:TinyTP:LsapSel");


	iClient  = CObexClientHandler::NewL (this, aInfo);
		

	iBuf = CBufFlat::NewL(5000);//5000 - what should I put??
	iObject  = CObexBufObject::NewL (iBuf);
	iOwner->iConsole->Printf(_L("Irda Client loaded Success \n"));

	
	
	}

void CTestObexErrorCodesClient::CallBack(TRequestStatus aStatus, TTestProgress aActivity)
	{
	
	//first of all establish what has just happened.
	if ( aActivity == EConnecting ) //then it's time for the first PUT
		{
		iClient->Put();
		iErrorCode = ERespContinue;
		}
	else if (aActivity == EPutting )
		{
		iOwner->iConsole->Printf(_L("Put Complete with Code %d \n"), aStatus.Int());
		if ( iErrorCode < ERespDatabaseLocked )
			{
			iErrorCode++;
			iClient->Put();
			}
		}

	}




CObexClientHandler* CObexClientHandler::NewL(CTestObexErrorCodesClient* aOwner,
											 TObexProtocolInfo& aObexProtocolInfoPtr)
	{
	CObexClientHandler* self = new(ELeave) CObexClientHandler;
	CleanupStack::PushL(self);
	self->ConstructL(aOwner, aObexProtocolInfoPtr);
	CleanupStack::Pop( self );

	return self;
	
	}

CObexClientHandler::~CObexClientHandler()
	{
	delete iClient;
	}

void CObexClientHandler::Connect()
	{
	if (!IsActive() )
		{
		iActivity = EConnecting;

		iClient->Connect(iStatus);
		SetActive();
		}
	else
		iOwner->iOwner->iConsole->Printf(_L("\r\nError: Client handler already active\r\n"));
	}

void CObexClientHandler::Disconnect()
	{
	if (!IsActive() )
		{
		iActivity = EDisconnecting;
		iClient->Disconnect(iStatus);
		SetActive();
		}
	else
		iOwner->iOwner->iConsole->Printf(_L("\r\nError: Client handler already active\r\n"));

	}

CObexClientHandler::CObexClientHandler()
    : CActive(EPriorityNormal)
	{
	}

void CObexClientHandler::ConstructL(CTestObexErrorCodesClient* aOwner,
									TObexProtocolInfo& aObexProtocolInfoPtr)
	{
	iOwner = aOwner;

    iFileObject = CObexFileObject::NewL();


	iClient = CObexClient::NewL(aObexProtocolInfoPtr);
    CActiveScheduler::Add(this);			// Add to active scheduler
	iActivity = EIdle;
	}

void CObexClientHandler::DoCancel()
	{
	iClient->Abort();
	}

void CObexClientHandler::RunL()
	{
	
	iOwner->CallBack(iStatus, iActivity);
		
	}

void CObexClientHandler::Put()
	{
    if(IsActive())
		{

		iOwner->iOwner->iConsole->Printf(_L("\r\nError: Client handler already active\r\n"));
		return;
		}

	TInt err;

	TRAP(err, iFileObject->InitFromFileL (_L("Contacts.vcf")));

	if (err != KErrNone)
		{
		RFs fs;
		RFile f;
		if ((fs.Connect () != KErrNone) || 
			(f.Create (fs, _L("Contacts.vcf"), EFileShareExclusive | EFileWrite) != KErrNone))
			iOwner->iOwner->iConsole->Printf(_L("\r\nError reading 'Contacts.vcf'.\r\nI tried to create this file for you, but failed to do that too. Sorry.\r\n\r\n"));
		else
			{
			f.Write (_L8("Test file for sending from EPOC\r\n\r\nLooks like obex is sending OK!!\r\n"));
			f.Close ();
			iOwner->iOwner->iConsole->Printf(_L("\r\nFile 'Contacts.vcf' did not exist, so I've created one.\r\nPlease try again.\r\n\r\n"));
			}
		fs.Close ();
		}


	if( err != KErrNone)
		{
		iOwner->iOwner->iConsole->Printf(_L("\r\n Couldnt set up object : error %d \r\n"),err);
		return;
		}

	iClient->Put(*iFileObject,iStatus);
	SetActive();
	iActivity = EPutting;
	}