// 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 "emailtestutils.h"
#include "scripttestutils.h"
#include <iapprefs.h>
#include <es_sock.h>
#include <commdb.h>
#include <cdbpreftable.h>
#include <imsk.h>
#include <commdbconnpref.h>
#include <bacline.h>
#include <cemailaccounts.h>
#include <commsdattypesv1_1.h>
#include <commsdat.h>
using namespace CommsDat;

// For loading the serial comms device drivers 
#if defined (__WINS__)
	#define PDD_NAME		_L("ECDRV")
	#define LDD_NAME		_L("ECOMM")
#else
	#define PDD_NAME		_L("EUART1")
	#define LDD_NAME		_L("ECOMM")
#endif


_LIT(KSmtsTest, "T_SMTS02 - Testing SMTS Server MTM using dial out with On-line");
RTest test(KSmtsTest);

_LIT(KTestParams,"-testparams");
enum TCmdLineArgs
	{
	EArgProgramName,
	EArgTestParams,
	EArgServerAddress,
	EArgEmail,
	EArgEnd
	};

_LIT(KImskOutFile, "c:\\logs\\email\\imsk25.out");
_LIT(KImskScrFile, "c:\\logs\\email\\imsk25.scr");
_LIT(KSmtsComponent,"SMTS");
_LIT(KSmtsRFCEmails,"RFC822\\");

LOCAL_D CTrapCleanup* theCleanup;
LOCAL_D CEmailTestUtils* testUtils;
LOCAL_D TMsvId smtpService;
LOCAL_D CBaseServerMtm* serverMtm;
LOCAL_D CActiveScheduler* scheduler;
LOCAL_D TInt globalError;
LOCAL_D RConnection gConnection;
LOCAL_D RSocketServ gSocketServ;



LOCAL_C void DisplayProgress()
	{
 	TImSmtpProgress temp;
	TPckgC<TImSmtpProgress> paramPack(temp);

	const TDesC8& progBuf =serverMtm->Progress();
	paramPack.Set(progBuf);
	TImSmtpProgress progress=paramPack();	

	TBuf<128> logString;
	//  State of Smtp session?
	TInt state = progress.Status();
	switch(state)
		{
		case EMsgOutboxProgressWaiting:
			testUtils->WriteComment(_L("Waiting to start\n"));
			break;
		case EMsgOutboxProgressDone:
			testUtils->WriteComment(_L("Connection Closed.\n"));
			logString.Format(_L("%d messages: Sent %d, failed to send %d, didn't attempt to send %d.\n"), 
				progress.SendTotal(),
				progress.Sent(),
				progress.FailedToSend(),
				progress.NotSent());
			testUtils->WriteComment(logString);
			break;
		case EMsgOutboxProgressConnecting:
			logString.Format(_L("Connecting to SMTP server. Sending %d messages.\n"),
				progress.SendTotal());
			testUtils->WriteComment(logString);
			break;
		case EMsgOutboxProgressSending:
			logString.Format(_L("Sending message No.%d/%d. Transmitted %d bytes of %d            \n"),     
				progress.MsgNo()+1,
				progress.SendTotal(),
				progress.iSendFileProgress.iBytesSent,
				progress.iSendFileProgress.iBytesToSend);
			testUtils->WriteComment(logString);
			break;
		}
	}

class CSmtpTimer : public CTimer
	{
public:
	static CSmtpTimer* NewL(CTestActive& aActive);
	void StartL();
private:
	CSmtpTimer(CTestActive& aActive);
	void RunL();	
	CTestActive& iSmtpActive;
	};

CSmtpTimer::CSmtpTimer(CTestActive& aActive)
: CTimer(EPriorityLow),	iSmtpActive(aActive)

	{}


CSmtpTimer* CSmtpTimer::NewL(CTestActive& aActive)
	{
	CSmtpTimer* self = new(ELeave) CSmtpTimer(aActive);
	CleanupStack::PushL(self);
	CActiveScheduler::Add(self);
	CleanupStack::Pop();
	return self;
	}

void CSmtpTimer::StartL()
	{
	CTimer::ConstructL();
	TRequestStatus* status=&iStatus;
	User::RequestComplete(status,KErrNone);
	SetActive();
	}

void CSmtpTimer::RunL()
	{
	test.Console()->SetPos(0, 10);
	DisplayProgress();

	if (!iSmtpActive.IsActive())   //this is how you check if the MTM is finished or not!
		{
		iSmtpActive.Cancel();
		CActiveScheduler::Stop();
		return;
		}
	else
		After(4000000);
	}


LOCAL_C void TestSendingMessagesL()
	{
	CTestActive* testActive = new (ELeave) CTestActive();
	CleanupStack::PushL(testActive);

	CMsvEntrySelection* sendSel = new(ELeave) CMsvEntrySelection();
	CleanupStack::PushL(sendSel);

	testUtils->iServerEntry->SetEntry(KMsvGlobalOutBoxIndexEntryId);
	User::LeaveIfError(testUtils->iServerEntry->GetChildren(*sendSel));
	TInt count=sendSel->Count();
	if (!count)
		{
		testUtils->WriteComment(_L("\t No messages to send in the outbox"));
		CleanupStack::PopAndDestroy(2); //testActive, sendsel
		return;
		}
	TBuf<100> logString;
	testUtils->WriteComment(_L("Issuing CopyFromLocal request...\n"));
	logString.Format(_L("\t messages to send in the outbox - %d"), count);
	testUtils->WriteComment(logString);

	testUtils->InstantiateSmtpServerMtmL();
	serverMtm=testUtils->iSmtpServerMtm;
	
	serverMtm->CopyFromLocalL(*sendSel,smtpService, testActive->iStatus);
	CSmtpTimer* timer=CSmtpTimer::NewL(*testActive);
	CleanupStack::PushL(timer);

	testActive->StartL();
	timer->StartL();
	CActiveScheduler::Start();
	//check progress
	DisplayProgress();
	logString.Zero();
	logString.Format(_L("\t CopyFromLocalL completed with %d"), testActive->iStatus.Int());
	testUtils->WriteComment(logString);
 	TImSmtpProgress temp;	
	TPckgC<TImSmtpProgress> paramPack(temp);

	const TDesC8& progBuf =serverMtm->Progress();
	paramPack.Set(progBuf);
	TImSmtpProgress progress=paramPack();	
	globalError=progress.Error();
	CleanupStack::PopAndDestroy(3); //testActive, sendsel, /*timer*/
	}


LOCAL_C void InitL()
	{
	scheduler = new (ELeave) CActiveScheduler;
	CleanupStack::PushL(scheduler);
	CActiveScheduler::Install( scheduler );

	testUtils = CEmailTestUtils::NewLC(test);
	testUtils->WriteComment(KSmtsTest);
	testUtils->FileSession().Delete(KImskOutFile);
	testUtils->FileSession().Delete(KImskScrFile);
	testUtils->CleanMessageFolderL();
	testUtils->ClearEmailAccountsL();

	if (!testUtils->FileSession().MkDir(KEmailDataDir))
		{
		testUtils->Printf(_L("Created c:\\logs\\email directory\n"));
		}
		
	testUtils->GoClientSideL();
	smtpService = testUtils->CreateSmtpServiceL();

	}

LOCAL_C void ClosedownL()
	{
	if (globalError==-245 || globalError==-183 || globalError == -36|| !globalError)
		testUtils->TestHarnessCompleted();
	else
		testUtils->TestHarnessFailed(globalError);

	gConnection.Stop();
	gConnection.Close();
	CleanupStack::PopAndDestroy(2);  //testUtils, ischeduler
	}


LOCAL_C void doMainL()
	{
	InitL();

	// Load the serial comms device drivers.  If this is not done,
	// connecting via NT-RAS returns KErrNotFound (-1).
	TInt driverErr;
	driverErr=User::LoadPhysicalDevice(PDD_NAME);
	if (driverErr!=KErrNone && driverErr!=KErrAlreadyExists)
		User::Leave(driverErr);
	driverErr=User::LoadLogicalDevice(LDD_NAME);
	if (driverErr!=KErrNone && driverErr!=KErrAlreadyExists)
		User::Leave(driverErr);


	testUtils->WriteComment(_L(" Create 2 ISPs - pipex and demon by running T_CREATEDB.  Set demon as the default ISP."));
	testUtils->WriteComment(_L(" Run T_EDITDB and select  '1) outgoing connection pref'.  Set Ranking 1 - IAP to Demon."));
	testUtils->WriteComment(_L(" press page down and set ranking 2 IAP to pipex.")); 
	//overwrite the setings with test code one.  Don't want the default settings.

	// Handle command line arguments
	CCommandLineArguments* cmdLineArg=CCommandLineArguments::NewLC();
	TInt count = cmdLineArg->Count();
	TBool isCmdLine=FALSE;
	if (count>2)	// Command line arguments?
		{
		if ((!(cmdLineArg->Arg(EArgTestParams).Compare(KTestParams))) && count==EArgEnd)
			isCmdLine=TRUE;
		}	


	CImSmtpSettings* settings = new(ELeave) CImSmtpSettings();
	CleanupStack::PushL(settings);
	settings->Reset();

	if (isCmdLine)
		{
		TBuf<100> buf;
		TLex lex(cmdLineArg->Arg(EArgServerAddress));
		buf=lex.NextToken();
		test.Printf(_L("Server address: %S\n"),&buf);
		settings->SetServerAddressL(buf);
		}
	else
		{
		_LIT(KSmtpServer, "smtp.demon.co.uk");
		settings->SetServerAddressL(KSmtpServer);
		}
	settings->SetEmailAliasL(_L("SMTP Test1"));

	if (isCmdLine)
		{
		TBuf<100> buf;
		TLex lex(cmdLineArg->Arg(EArgEmail));
		buf=lex.NextToken();
		test.Printf(_L("Mail: %S\n"),&buf);
		settings->SetEmailAddressL(buf);
		settings->SetReplyToAddressL(buf);
		settings->SetReceiptAddressL(buf);
		}
	else
		{
		_LIT(KSmtpEmailAddress, "<test@psion9.demon.co.uk>");
		settings->SetEmailAddressL(KSmtpEmailAddress);
		settings->SetReplyToAddressL(KSmtpEmailAddress);
		settings->SetReceiptAddressL(KSmtpEmailAddress);
		}

	settings->SetBodyEncoding(EMsgOutboxMIME);
	settings->SetPort(25);

	CImIAPPreferences* prefs = CImIAPPreferences::NewLC();
	// Add IAP's to iIAPPreferences
	TImIAPChoice iap;
	
	TInt iapID = 0;
	CMDBSession* dbSession = CMDBSession::NewL(CMDBSession::LatestVersion());
	CleanupStack::PushL(dbSession);
	CCDConnectionPrefsRecord *connPrefRecord = static_cast<CCDConnectionPrefsRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdConnectionPrefsRecord));
	CleanupStack::PushL(connPrefRecord);
	
	connPrefRecord->iDirection = ECommDbConnectionDirectionOutgoing;
	connPrefRecord->iRanking = 1;
	if(!connPrefRecord->FindL(*dbSession))
		{
		User::Leave(KErrNotFound);		
		}			
	iapID = connPrefRecord->iDefaultIAP;
	
	CleanupStack::PopAndDestroy(2); //dbSession, connPrefRecord

	iap.iIAP = iapID;
	iap.iDialogPref = ECommDbDialogPrefDoNotPrompt;
	prefs->AddIAPL(iap);
	CEmailAccounts* accounts = CEmailAccounts::NewLC();

	TSmtpAccount smtpAccountId;
	accounts->GetSmtpAccountL(smtpService,smtpAccountId); 
	accounts->SaveSmtpSettingsL(smtpAccountId, *settings);
	accounts->SaveSmtpIapSettingsL(smtpAccountId, *prefs);
	
	CleanupStack::PopAndDestroy(4, cmdLineArg); // accounts, prefs, settings, cmdLineArg
	
	testUtils->WriteComment(_L(" smtp server created"));

	TParse dir;
	testUtils->ResolveFile(KSmtsComponent,KSmtsRFCEmails,dir);
	testUtils->GoServerSideL();
	
	testUtils->CreateMessageFilesL(smtpService,KMsvGlobalOutBoxIndexEntryId,dir.FullName());
	testUtils->WriteComment(_L(" Messages created in the outbox"));
	testUtils->WriteComment(_L("Instantiated smtp server mtm"));
	
	testUtils->iServerEntry->SetEntry(smtpService);
	TBuf<64> logString;
	logString.Format(_L(" IAP is %d"),iapID);
	
	testUtils->WriteComment(logString);

	gSocketServ.Connect();
	User::LeaveIfError(gConnection.Open(gSocketServ));	
	testUtils->TestStart(1,_L("SocketServ startDialout called"));
	TRequestStatus status;
	gConnection.Start(status);

	TInt err=0;
	while(status==KRequestPending)
		{
		CActiveScheduler::Current()->RunIfReady(err,0);
		User::WaitForAnyRequest();
		}
	testUtils->TestFinish(1,status.Int());
	if (status.Int())
		{
		ClosedownL();
		return;
		}
	testUtils->WriteComment(_L("Genconn startDialout successful"));
	TUint32 address=0;
	TUint32 activeIAP;
	TBuf<KCommsDbSvrMaxColumnNameLength> settingName;

	settingName.Copy(TPtrC(IAP));
	settingName.Append(TChar('\\'));
	settingName.Append(TPtrC(COMMDB_ID));
	address = gConnection.GetIntSetting(settingName, activeIAP);
	
	logString.Zero();
	logString.Format(_L(" Active iap from genconn is %d"),address);
	testUtils->WriteComment(logString);

	testUtils->TestStart(2,_L("sending msgs with IAP same as active IAP"));
	TestSendingMessagesL();
	testUtils->TestFinish(2,globalError);


	if (globalError)
		{
		ClosedownL();
		return;
		}
	gConnection.Stop();
	gConnection.Close();			
	
	testUtils->TestStart(3,_L("sending msgs with IAP different to active IAP"));
	testUtils->CreateMessageFilesL(smtpService,KMsvGlobalOutBoxIndexEntryId,dir.FullName());

	logString.Zero();
	testUtils->WriteComment(logString);
	gSocketServ.Connect();
	globalError=gConnection.Open(gSocketServ);	
	if (!globalError)
		{
		CMDBSession* dbSession = CMDBSession::NewL(CMDBSession::LatestVersion());
		CleanupStack::PushL(dbSession);
		connPrefRecord = static_cast<CCDConnectionPrefsRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdConnectionPrefsRecord));
		CleanupStack::PushL(connPrefRecord);
		
		connPrefRecord->iDirection = ECommDbConnectionDirectionOutgoing;
		connPrefRecord->iRanking = 2;		
		connPrefRecord->FindL(*dbSession);				
		iapID = connPrefRecord->iDefaultIAP;
		
		CleanupStack::PopAndDestroy(2);	//dbSession, connPrefRecord	

		TCommDbMultiConnPref prefs;
		TInt rank=1;
		TCommDbConnPref pref;
		pref.SetDirection(ECommDbConnectionDirectionOutgoing);
		pref.SetBearerSet(KCommDbBearerPSD | KCommDbBearerCSD);

		pref.SetDirection(ECommDbConnectionDirectionOutgoing);
		pref.SetBearerSet(KCommDbBearerPSD | KCommDbBearerCSD);
		iap.iIAP = 	iapID;
		iap.iDialogPref = ECommDbDialogPrefDoNotPrompt;

		pref.SetIapId(iap.iIAP);
		pref.SetDialogPreference(iap.iDialogPref);
		User::LeaveIfError(prefs.SetPreference(rank, pref));

		prefs.SetConnectionAttempts(rank);
		gConnection.Start(prefs, status);

		
		while(status==KRequestPending)
			{
			CActiveScheduler::Current()->RunIfReady(err,0);
			User::WaitForAnyRequest();
			}

		}
	if (globalError || status.Int())
		{
		if (!globalError)
			globalError=status.Int();
		ClosedownL();
		return;
		}
	address=0;
	settingName.Copy(TPtrC(KCDTypeNameIAP));
	settingName.Append(TChar('\\'));
	settingName.Append(TPtrC(KCDTypeNameRecordTag));
	err = gConnection.GetIntSetting(settingName, activeIAP);

	logString.Zero();
	logString.Format(_L(" Active IAP from genconn is %d"),address);
	testUtils->WriteComment(logString);
	TestSendingMessagesL();
	globalError=(globalError==-183)? 0 : globalError;

	testUtils->TestFinish(3,globalError);
	testUtils->WriteComment(_L("Test 3 should complete with -183"));
	ClosedownL();
	}


GLDEF_C TInt E32Main()
	{	
	__UHEAP_MARK;
	test.Start(_L("T_SMTS02 Test SMTP server MTM class"));
	theCleanup=CTrapCleanup::New();
	TRAPD(ret,doMainL());		
	test(ret==KErrNone);
	delete theCleanup;	
	test.End();
	test.Close();
	__UHEAP_MARKEND;
	User::Heap().Check();
	return(KErrNone);
	}