// Copyright (c) 1999-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 "smtptests.h"
#include <cemailaccounts.h>
#include <iapprefs.h>

// Strings....
_LIT(KErrUseService, "[%4d] Error! you have to select a service for use before you can access it!");
_LIT(KErrOperation,  "Operation didn't complete as expected. Expected status: [%d], actual status: [%d]");
_LIT(KPopAccountName, "POP");

const TInt KMaxErrorText = 100;

//
//
// CSmtpClientTest
//

CSmtpClientTest* CSmtpClientTest::NewL(CEmailTestUtils& aTestUtils, RTest& aTest)
	{
	CSmtpClientTest* self = new (ELeave) CSmtpClientTest(aTestUtils, aTest);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CSmtpClientTest::~CSmtpClientTest()
	{
	}

void CSmtpClientTest::ConstructL()
	{
	CEmailClientTest::ConstructL();
	}

CSmtpClientTest::CSmtpClientTest(CEmailTestUtils& aTestUtils, RTest& aTest) : CEmailClientTest(aTestUtils, aTest)
	{
	}



//
//
// CCreateSmtpService
//

void CCreateSmtpService::StartL(TRequestStatus& aStatus)
	{
	// create pop account (pop account also creates smtp service)
	CEmailAccounts* account = CEmailAccounts::NewLC();

	CImIAPPreferences* smtpIAP = CImIAPPreferences::NewLC();
				
	TSmtpAccount accountId = account->CreateSmtpAccountL(*iDetails,*iSettings, *smtpIAP, EFalse);

	// get pop service for the account
	TMsvId service = accountId.iSmtpService;
	
	// select this service
	CMsvEntry& msvEntry = *(iTestHarness.EmailTestUtils().iMsvEntry);
	msvEntry.SetEntryL(service);
	iEntry = msvEntry.Entry();
	iEntry.SetVisible(ETrue);
	iTestHarness.iCurrentServiceId = service;
	iTestHarness.EmailTestUtils().iSmtpServiceId = service;

	CleanupStack::PopAndDestroy(2, account); // smtpIAP, account

	// If the SMTP Client MTM doesn't already exist, then Instantiate it 
	if (!iTestHarness.EmailTestUtils().iSmtpClientMtm)
		iTestHarness.EmailTestUtils().InstantiateSmtpClientMtmL();

	TRequestStatus* status = &aStatus;
	User::RequestComplete(status, KErrNone);
	}

CCreateSmtpService* CCreateSmtpService::NewL(CEmailClientTest& aTestHarness)
	{
	CCreateSmtpService* self = new (ELeave) CCreateSmtpService(aTestHarness);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CCreateSmtpService::CCreateSmtpService(CEmailClientTest& aTestHarness) : CCreateEmailService(aTestHarness), iTestHarness(aTestHarness)
	{
	}

void CCreateSmtpService::ConstructL()
	{
	iSettings = new(ELeave) CImSmtpSettings();
	}

CCreateSmtpService::~CCreateSmtpService()
	{
	delete iSettings;
	}

CImSmtpSettings& CCreateSmtpService::Settings()
	{
	return *iSettings;
	}


//
//
// CCreateSmtpClientMtm
//

CCreateSmtpClientMtm::CCreateSmtpClientMtm(CEmailClientTest& aTest) : iTest(aTest)
	{
	}

void CCreateSmtpClientMtm::StartL(TRequestStatus& aStatus)
	{
	iTest.EmailTestUtils().InstantiatePopClientMtmL();
	TRequestStatus* status = &aStatus;
	User::RequestComplete(status, KErrNone);
	}



//
//
// CCheckSmtpOperation
//

CCheckSmtpOperation::CCheckSmtpOperation(TInt aExpectedStatus, CSmtpClientTest& aTestHarness) : iTestHarness(aTestHarness), iExpectedStatus(aExpectedStatus)
	{
	}

void CCheckSmtpOperation::StartL(TRequestStatus& aStatus)
	{
	TInt err = KErrNone;

	TImSmtpProgress temp;	
	TPckgC<TImSmtpProgress> paramPack(temp);
	paramPack.Set(iTestHarness.CurrentOperation().ProgressL());
	TImSmtpProgress progress=paramPack();	

	if (progress.Error() != iExpectedStatus)
		{
		TBuf<KMaxErrorText> logString;
		logString.Format(KErrOperation, iExpectedStatus, progress.Error());
		iTestHarness.LogComment(logString);
		err = KErrUnknown;
		}

	TRequestStatus* status = &aStatus;
	User::RequestComplete(status, err);
	}


//
//
// CSmtpUseService
//

CSmtpUseService::CSmtpUseService(CSmtpClientTest& aTestHarness) : iTestHarness(aTestHarness)
	{
	}

void CSmtpUseService::StartL(TRequestStatus& aStatus)
	{
	TInt err = KErrNone;

	// Select current folder
	CMsvEntry& entry = *(iTestHarness.EmailTestUtils().iMsvEntry);
	entry.SetEntryL(iTestHarness.iSelectedFolder);
		
	// Check it is a service which is selected
	if(entry.Entry().iType == KUidMsvServiceEntry)
		{
		// Make sure that the Root folder is selected
		iTestHarness.iSelectedFolder = KMsvRootIndexEntryId;

		// Change the Harness & Test Utils to use this SMTP service id
		iTestHarness.EmailTestUtils().iSmtpServiceId = entry.Entry().Id();
		iTestHarness.iCurrentServiceId = entry.Entry().Id();

		// If the Smtp Client MTM doesn't already exist, then Instantiate it 
		if (!iTestHarness.EmailTestUtils().iSmtpClientMtm)
			iTestHarness.EmailTestUtils().InstantiateSmtpClientMtmL();
		}
	else
		{
		TBuf<KMaxErrorText> logString;
		logString.Format(KErrUseService, iDebugInfo.LineNumber());
		iTestHarness.LogComment(logString);

		err = KErrUnknown;
		}

	TRequestStatus* status = &aStatus;
	User::RequestComplete(status, err);
	}

//
//
// CCopySelectionAndMonitor
//
CCopySelectionAndMonitor::CCopySelectionAndMonitor(CEmailClientTest& aParentTestHarness, TBool aSynchronise) : CActive(EPriorityNormal), iParentTestHarness(aParentTestHarness), iSynchronise(aSynchronise)
	{
	CActiveScheduler::Add(this);
	}



void CCopySelectionAndMonitor::LogCommentFormat(TRefByValue<const TDesC> format,...)
	{
	// Build parameter list.
	VA_LIST list;
	VA_START(list, format);
	TBuf<0x100> buf;
	buf.FormatList(format, list);

	// Log the debug buffer.
	iParentTestHarness.EmailTestUtils().WriteComment(buf);
	}


void CCopySelectionAndMonitor::StartL(TRequestStatus& aStatus)
	{
	iParentTestHarness.MsvTestUtils().iMsvEntry->SetEntryL(iParentTestHarness.iSelectedFolder);
	iReportStatus = &aStatus;
	iParentTestHarness.SetCurrentOperation(iParentTestHarness.MsvTestUtils().iMsvEntry->CopyL(*(iParentTestHarness.iCurrentSelection), iParentTestHarness.iDestinationFolder, iStatus));
	
	// Call funtion to return IAP and Poll to find connection state 
	RTimer timer; 
	TRequestStatus timerStatus; // Request status associated with timer
	timer.CreateLocal(); // Create for this thread
	
	//initialise to unused values
	TInt progressState = KInvalidState;
	TInt connectState = KInvalidState;
	TInt iap = KInvalidIAP;
	TInt connection_progress_state = 0;

	do
		{
		TImSmtpProgress temp;	
		TPckgC<TImSmtpProgress> paramPack(temp);
		paramPack.Set(iParentTestHarness.CurrentOperation().ProgressL());
		TImSmtpProgress progress = paramPack();	

		progressState = progress.Status();
		if((connectState != progress.ConnectionState()) || (iap != progress.ConnectionIAP()) )
			{
			connectState = progress.ConnectionState();
			iap = progress.ConnectionIAP();
			LogCommentFormat(_L("[%4d] Progress state =  %d, Connect State = %d, IAP = %d"), iDebugInfo.LineNumber(), progressState, connectState, iap);
			
			//Check that the relevant states are reached in the correct order
			if ((connectState == ECsdStartingDialling) || (connectState == ECsdStartingConnect))
					connection_progress_state = 1;
			if (connectState == ECsdConnectionOpen && connection_progress_state == 1)
					connection_progress_state = 2;
			if (connectState == KLinkLayerOpen && connection_progress_state == 2)
					connection_progress_state = 3;

		}

		
		// wait 500 microseconds and then re-test progress!
		timer.After(timerStatus,500);
		User::WaitForRequest(timerStatus); 

	
		} while (progressState == EMsgOutboxProgressConnecting);

	timer.Close();

	if (connection_progress_state != 3)
		{
		LogCommentFormat(_L("[%4d] Local Connection Progress state =  %d, Connect State = %d, IAP = %d"), iDebugInfo.LineNumber(), connection_progress_state, connectState, iap);
		iConnectionError = ETrue;
		}

	aStatus = KRequestPending;
	SetActive();
	}

void CCopySelectionAndMonitor::RunL()
	{
	if (iConnectionError)
		User::RequestComplete(iReportStatus, KErrUnknown);	
	else
		User::RequestComplete(iReportStatus, iStatus.Int());
	}

void CCopySelectionAndMonitor::DoCancel()
	{
	iParentTestHarness.CurrentOperation().Cancel();
	}


CCopySelectionAndMonitor::~CCopySelectionAndMonitor()
	{
	}