// Copyright (c) 1998-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 "testenv.h"

#include <agentclient.h>

#include "nd_err.h"

#include "imsk.h"

#include <s32mem.h>

#include <s32file.h>

#include <iapprefs.h>

#include "EmailTestUtils.h"

const TInt KMaxSizeOfBinaryData = 200;

LOCAL_D RTest test(_L("IMSK CImTextServerSession Test"));

LOCAL_D CTrapCleanup* theCleanup;

LOCAL_D TBuf8<KMaxSizeOfBinaryData> someBinaryData=_L8("");

LOCAL_D RFs theFs;	

LOCAL_D CActiveScheduler* scheduler;

LOCAL_D CEmailTestUtils* testUtils; 

#define EActivePriorityLow		-1

const TUid KUidMsvMessageDriveStream={0x1000163E};

LOCAL_C void DisplayErrorReason(TInt& aReason)

	{

	if (aReason!=KErrNone)

		{

		testUtils->WriteComment(_L("\nERROR - "));

		}

	TBuf<64> logString;

	switch (aReason)

		{

	case KErrNone:

		testUtils->WriteComment(_L("Session completed successfully"));

		break;

	case KErrCancel:

		testUtils->WriteComment(_L("Session cancelled"));

		logString.Format(_L(" Session Cancelled %d"),KErrCancel);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tSession Cancelled"),KErrCancel);

		break;

	case KErrAlreadyExists:

		testUtils->WriteComment(_L(" something Already Exists"));

		logString.Format(_L(" something Already Exists %d"),KErrAlreadyExists);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tsomething Already Exists"),KErrAlreadyExists);

		break;

	case KErrEof:

		testUtils->WriteComment(_L("No messages to send"));

		logString.Format(_L(" No messages to send %d"),KErrEof);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tNo messages to send"),KErrEof);

		break;

	case KErrNoMemory:

		testUtils->WriteComment(_L("No memory"));

		logString.Format(_L(" No Memory %d"),KErrNoMemory);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tNo Memory"),KErrNoMemory);

		break;

	case KErrAccessDenied:

		testUtils->WriteComment(_L("Switch link off"));

		logString.Format(_L(" Switch link off %d"),KErrAccessDenied);

		testUtils->WriteComment(logString);

	//	log->AppendError(_L8("\t\tSwitch link off"),KErrAccessDenied);

		break;

	case KErrExitNoModem:

		testUtils->WriteComment(_L("No modem"));

		logString.Format(_L(" No Modem %d"),KErrExitNoModem);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tNo Modem"),KErrExitNoModem);

		break;

	case KErrExitLoginFail:

		testUtils->WriteComment(_L("Login failed"));

		logString.Format(_L(" Login Failed %d"),KErrExitLoginFail);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tLogin Failed"),KErrExitLoginFail);

		break;

	case KErrExitModemError:

		testUtils->WriteComment(_L("Modem error"));

		logString.Format(_L(" Modem Error %d"),KErrExitModemError);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tModem Error"),KErrExitModemError);

		break;

	case KErrExitScriptError:

		testUtils->WriteComment(_L("Script error"));

		logString.Format(_L(" Script Error %d"),KErrExitScriptError);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tScript Error"),KErrExitScriptError);

		break;

	case KImskErrorDNSNotFound:

		testUtils->WriteComment(_L("Failed to find SMTP server"));

		logString.Format(_L(" Failed to find SMTP server %d"),KImskErrorDNSNotFound);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tFailed to find SMTP server"),KImskErrorDNSNotFound);

		break;

	case KErrTimedOut:

		testUtils->WriteComment(_L("Timed out waiting to communicate to server"));

		logString.Format(_L(" Timed out waiting to communicate to server %d"),KErrTimedOut);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tTimed out waiting to communicate to server"),KErrTimedOut);

		break;

	case KErrDisconnected:

		testUtils->WriteComment(_L("Server disconnected from socket"));

		logString.Format(_L(" Server disconnected from socket %d"),KErrDisconnected);

		testUtils->WriteComment(logString);

//		log->AppendError(_L8("\t\tServer disconnected from socket"),KErrDisconnected);

		break;

	default:

		// unknown error 

//		testUtils->WriteComment(TRefByValue<const TDesC>_L("%d"),aReason);

		logString.Format(_L(" Error %d"),aReason);

		testUtils->WriteComment(logString);

	//	log->AppendError(_L8("\t\tError"),aReason);

		break;

		}

	}

// create our own active scheduler class

class CExampleScheduler : public CActiveScheduler

	{

public:

	void Error (TInt aError) const;

	};

void CExampleScheduler::Error(TInt aError) const

	{

	DisplayErrorReason(aError);

//	User::Panic(_L("CExampleScheduler-error"),aError);

	}

// create an active object to send the message

class CSendMessage : public CActive

	{

public: // functions

	// construct/destruct

	CSendMessage();

	static CSendMessage *NewL();

	static CSendMessage *NewLC();

	void ConstructL();

	~CSendMessage();

	// issue request

	void RequestSendL();

	void QueueNextReceive();

	void RunL();

	void DoCancel();

private:

	CImTextServerSession*	iImSocket;

	TInt					iCtr;

	TStreamId				iId;

	HBufC*					iBuf;

	TInt					iCurrentState;

	TInt					iLineStatus;

	TBool					iReceive;

	TSockXfrLength			iLen;

	CImIAPPreferences*		iIAPPreferences;

	};

CSendMessage::CSendMessage() // construct high-priority active object

	: CActive(EActivePriorityLow)

	{

	}

CSendMessage  *CSendMessage::NewLC()

	{

	CSendMessage* self=new (ELeave) CSendMessage();

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

CSendMessage  *CSendMessage::NewL()

	{

	CSendMessage* self=NewLC();

	CleanupStack::Pop();

	return self;

	}

void CSendMessage::ConstructL()

	{

	iCtr=0;

	CActiveScheduler::Add(this); // add to active scheduler

	iImSocket= CImTextServerSession::NewL();

	iReceive=EFalse;

	}

CSendMessage::~CSendMessage()

	{ 

	Cancel(); // make sure we're cancelled

	delete iImSocket;

	delete iBuf;

	delete iIAPPreferences;

	}

void  CSendMessage::DoCancel()

	{

	iImSocket->Cancel();

	}

void  CSendMessage::RunL()

	{

	TBuf<64> logString;

	TInt error;

	TInt length=0;

	switch (iCtr)

		{

	case 0:	// iSocket.Connect()

		if(iStatus.Int()!=KErrNone)

			{

			error=iStatus.Int();

			DisplayErrorReason(error);

			CActiveScheduler::Stop();

			}

		else

			{	

			iReceive=ETrue;

			QueueNextReceive();

			iCtr++;

			}

		break;

	case 4:	// have set encryption

		iReceive=EFalse;

		RequestSendL();

		iCtr++;

		break;

	case 3:

		iCtr++;

	case 1:	// response from sending user name

	case 2:	// response from sending password

	//case 3:

	case 5:

		someBinaryData=_L8("");

		if(iStatus.Int()!=KErrNone)

			{

//			testUtils->WriteComment(TRefByValue<const TDesC>_L("Error during receipt %d"),iStatus.Int());

			logString.Format(_L(" Error during receipt%d"),iStatus.Int());

			testUtils->WriteComment(logString);

	//		log->AppendError(_L8("\t\tError during receipt"),iStatus.Int());

			CActiveScheduler::Stop();

			}

		else

			{

			TBuf8<40> buffer;

			TBuf<40> buffer16;

			iLineStatus=iImSocket->GetCurrentTextLine(buffer);

			buffer16.Copy(buffer);

			test.Printf(TRefByValue<const TDesC>_L("%S"),&buffer16);

			if(iReceive)

				{

				if(iLineStatus==EBufferTooSmall)

					{

					while(iLineStatus!=ECRLFTerminated)

						{

						iLineStatus=iImSocket->GetCurrentTextLine(buffer);

						test.Printf(TRefByValue<const TDesC>_L("%S"),&buffer);

						}

					}

				iReceive=EFalse;

				RequestSendL();

				iCtr++;

				}

			else

				{

				iReceive=ETrue;

 				QueueNextReceive();

				}

			}

		break;

	case 6:	// test BinaryDataReceive()

		if(iStatus.Int()!=KErrNone)

			{

			test.Printf(TRefByValue<const TDesC>_L("Error during receipt %d"),iStatus.Int());

			logString.Format(_L(" Error during receipt%d"),iStatus.Int());

			testUtils->WriteComment(logString);

//			log->AppendError(_L8("\t\tError during receipt"),iStatus.Int());

			CActiveScheduler::Stop();

			break;

			}

		length=someBinaryData.Length();

		if (length>2)

			{

			TBuf<KMaxSizeOfBinaryData> buffer16;

			buffer16.Copy(someBinaryData);

			test.Printf(TRefByValue<const TDesC>_L("%S"),&buffer16);

			if ((someBinaryData[length-3]=='.' && someBinaryData[length-2]==0x0D && someBinaryData[length-1]==0x0A)

				||(someBinaryData[length-3]=='-' && someBinaryData[length-2]=='E' && someBinaryData[length-1]=='R'))

				{

				// got ".CRLF" string (-ERR string) from LIST command, so go onto next state

				iReceive=EFalse;

				RequestSendL();

				iCtr++;

				break;

				}

			}

		// queue a read

		iReceive=ETrue;

		iImSocket->ReceiveBinaryData(iStatus,someBinaryData,someBinaryData.MaxLength());

		SetActive();

		break;

	default:

		iCtr=6;

		RequestSendL();

		break;

	case 7:

		iImSocket->LogError(_L8("\t\tEnd of POP3 test session; completion code="),iStatus.Int());

		iLineStatus=iImSocket->GetCurrentTextLine(buffer);

		test.Printf(TRefByValue<const TDesC>_L("Final %S\n "),&buffer);

		CActiveScheduler::Stop();

		TInt error=iStatus.Int();

		DisplayErrorReason(error);

		if (error==KErrNone)

			testUtils->WriteComment(_L("PASSED test"));

		else

			testUtils->WriteComment(_L("FAILED test"));

		break;

		} // end of switch

	}

void CSendMessage::RequestSendL()

	{

	_LIT8(KImUser,"USER abf75\r\n");

	_LIT8(KImPass,"PASS oodifama\r\n");

	_LIT8(KImStat,"STAT\r\n");

	_LIT8(KImList,"LIST\r\n");

	_LIT8(KImQuit,"QUIT\r\n");

	TRequestStatus* p=&iStatus;

	switch(iCtr)

		{

	case 0:

		test.Next(_L("QueueConnect"));

		delete iIAPPreferences;

		iIAPPreferences = 0;

		iIAPPreferences = CImIAPPreferences::NewLC();

		CleanupStack::Pop(); // iIAPPrefernces

		// Add IAP's to iIAPPreferences

		TImIAPChoice iap;

		iap.iIAP = 3;

		iap.iDialogPref = ECommDbDialogPrefPrompt;

//		iIAPPreferences->AddIAPL(iap,0);

		iap.iIAP = 3;

		iap.iDialogPref = ECommDbDialogPrefPrompt;

//		iIAPPreferences->AddIAPL(iap,1);

		iImSocket->QueueConnectL(iStatus,_L("158.43.128.67"),110,*iIAPPreferences);

//		iImSocket->QueueConnectL(iStatus,_L("0:0:0:0:0:0:194.217.242.23"),110,*iIAPPreferences);

		test.Next(_L("Connect Queued"));

		testUtils->WriteComment(_L("Connect Queued"));

		break;

	case 1:

//        iImSocket->LogText(_L8("First IAP should fail (scripted)"));

 //       iImSocket->LogText(_L8("Second IAP should fail (iap 30 doesn't exist)"));

  //      iImSocket->LogText(_L8("Third should work iap 3 demon"));

        testUtils->WriteComment(_L("IP address of client is "));

        testUtils->WriteComment(iImSocket->LocalName());

//        test.Printf(_L("\n"));

		TUint32 convalue;

		TInt err;

		err=iImSocket->GetIAPValue(convalue);

		if(err==KErrNone)

			test.Printf(_L("GetIAPValue returned %u\n"),convalue);

		else 

			test.Printf(_L("GetIAPValue error %d\n"),err);

		err=iImSocket->GetIAPBearer(convalue);

		if(err==KErrNone)

			test.Printf(_L("GetIAPBearer returned %u\n"),convalue);

		else 

			test.Printf(_L("GetIAPBearer error %d\n"),err);

		iImSocket->Send(iStatus,KImUser());

		testUtils->WriteComment(_L("\tSent Message USER abf75"));

		break;

	case 2:

		iImSocket->Send(iStatus,KImPass());

		testUtils->WriteComment(_L("\tSent Message PASS oodifama"));

		break;

	case 3:

/*		iImSocket->SetSecurity(EImskEncryptionTLS1);

		iImSocket->LogText(_L8("**************************************"));

		iImSocket->LogText(_L8("Testing the logging code"));

		iImSocket->LogText(_L8("You can add your own logging text to this log file"));

		iImSocket->LogText(_L8("**************************************"));

*/		User::RequestComplete(p,KErrNone);

		break;

	case 4:

		iImSocket->Send(iStatus,KImStat());

		testUtils->WriteComment(_L("\tSent Message STAT"));

		break;

	case 5:

		iImSocket->Send(iStatus,KImList());

		testUtils->WriteComment(_L("\tSent Message LIST"));

		break;

	case 6:

		iImSocket->Send(iStatus,KImQuit());

		testUtils->WriteComment(_L("\tSent Message QUIT"));

		break;

		}

	SetActive();

	}

void CSendMessage::QueueNextReceive()

	{

	iImSocket->QueueReceiveNextTextLine(iStatus);

	SetActive();

	}

//

LOCAL_C void Init()

	{

	scheduler = new (ELeave) CActiveScheduler;

	CActiveScheduler::Install( scheduler );

	User::LeaveIfError(theFs.Connect());

	theFs.SetSessionPath(_L("C:\\"));

	}

LOCAL_C void Closedown()

	{

	theFs.Close( );

	delete scheduler;

	}

//

LOCAL_C void doMainL()

	{

	Init();

	theFs.SetSessionPath(_L("c:\\"));

	theFs.MkDir(_L("c:\\logs\\"));

	theFs.MkDir(_L("c:\\logs\\email\\"));

	testUtils = CEmailTestUtils::NewLC(test);

	testUtils->WriteComment(_L("T_IMSK01 Testing Imail Text Socket"));

	testUtils->WriteComment(_L("Please make sure that pipex is the default IAP."));

//	log=CImLog::NewL(_L("c:\\logs\\email\\T_IMSK.log"),EAppend);

//	CleanupStack::PushL(log);

//	log->AppendComment(_L8("********** T_IMSK01 Testing Imail Text Socket **********"));

//	log->AppendComment(_L8("\tInit() Completed"));

	// Set up the timeout in the comms database as it is needed by imsk.

	TUint32 timeoutInMts = 5; // ( five minutes )

//	TBuf<64> logString;

//	logString.Format(_L(" IAP is %u"),IAP);

//	testUtils->WriteComment(logString);

	CSendMessage *aSendMessage = CSendMessage::NewLC();

	aSendMessage->RequestSendL();

 	CActiveScheduler::Start();

	testUtils->WriteComment(_L("**********       T_IMSK Tests Complete       **********"));

	testUtils->TestHarnessCompleted();

	CleanupStack::PopAndDestroy(aSendMessage);

	CleanupStack::PopAndDestroy(testUtils);

	Closedown();

	}

GLDEF_C TInt E32Main()

	{

	test.Title();

	test.Start(_L("Testing Imail Text Socket"));

	__UHEAP_MARK;

	theCleanup=CTrapCleanup::New();

	test (theCleanup!=NULL);

	TRAPD(ret,doMainL());		

	test (ret==KErrNone);

	delete theCleanup;

	__UHEAP_MARKEND;

	test.End();

	return 0;

	}