// Copyright (c) 2002-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:

// Name of the test harness : T_MSGCONNTEST

// Component: IMUT

// Owner: 

// Brief description of test harness:

// Tests the changes IMUT for multihoming which allows more than one connection 

// Detailed description of test harness:

// Implements a range of tests for IMUT testing the following

// funtionality:

// -Single default connection

// -Single specified connection

// -Two Default connections serially (both the connections being default) 

// -Two Default connections parallelly

// -Two Different connections serially(one Default and the other Specified)

// -Two Different connections parallelly

// -Two Connection , one default connection and another explicit connection

// to the default IAP.	

// Input files required to run test harness:

// Intermediate files produced while running test harness:	

// Output files produced by running test harness:

// \msglogs\T_MSGCONNTEST.WINS.DEB

// Description of how to build test harness:

// -Get the 3GComms code from the directory ---TYPHOON CODE-----  and build it

// -Get the messagiing code from //EPOC/development/messaging/3gcomm/msg/ (Perforce database)

// and build it.

// Description of how to run test harness:

// -Navigate to the directory \epoc32\release\wins\udeb from the command prompt

// -Run T_MsgConnTest.exe from this directory.

// -To view the test results check the file \epoc32\wins\c\MsgLogs\T_MSGCONNTEST.WINS.DEB

// 

//

#include <nd_err.h>

#include <imsk.h>

#include <iapprefs.h>

#include "t_ConnUtils.h"

#include "emailtestutils.h"

#define EActivePriorityLow		-1

#define ETestSingleDefaultConn '1'

#define ETestSingleSpecifiedConn '2'

#define ETestTwoDefaultSerialConns '3'

#define ETestTwoDefaultParallelConns '4'

#define ETestTwoDifferentSerialConns '5'

#define ETestTwoDifferentParallelConns '6'

#define ETestExplicitDefaultConn '7'

#define ETestAllCases 'a'

const TInt KMaxSizeOfBinaryData = 200;

LOCAL_D RTest g_Test(_L("T_MSG_CONN CImTextServerSession Test"));

LOCAL_D CTrapCleanup* theCleanup;

LOCAL_D CEmailTestUtils* gTestUtils; 

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

LOCAL_D TBuf<30> KPipexServer =_L("pop.dial.pipex.com");

LOCAL_D TBuf8<30> KPipexUser= _L8("USER abf75\r\n");

LOCAL_D TBuf8<30> KPipexPass= _L8("PASS oodifama\r\n");

LOCAL_D TInt KPopPort=110;

// Can use either the demon server or the fastmail.fm account

LOCAL_D TBuf<16> KDemonServer = _L("194.217.242.59");//_L("209.61.183.86");//

LOCAL_D TBuf8<30> KDemonUser = _L8("USER psion8\r\n");//_L8("USER catherine2k\r\n");//

LOCAL_D TBuf8<30> KDemonPass = _L8("PASS Bag8Nut\r\n");//_L8("PASS junkjunk\r\n");//

LOCAL_D TInt g_NoOfConnections;

LOCAL_D TInt g_Count;

//=======================================//

#if defined (__WINS__)

#define PDD_NAME	_L("ECDRV")

#define LDD_NAME	_L("ECOMM")

#define LDD_FNAME	_L("ECOMM")

#else

#define PDD_NAME	_L("EUART1")

#define PDD2_NAME	 _L("EUART2")

#define LDD_NAME	_L("ECOMM")

#define LDD_FNAME	_L("FCOMM")

#endif

TInt CTestHarnessUtil::CommInit()

	{

	TInt err=User::LoadPhysicalDevice(PDD_NAME);

	if (err!=KErrNone && err!=KErrAlreadyExists)

		return err;

	err=User::LoadLogicalDevice(LDD_NAME);

	if (err!=KErrNone && err!=KErrAlreadyExists)

		return err;

	return KErrNone;

	}

// Installs the scheduler

void CTestHarnessUtil::InitSchedulerL()

	{

	iScheduler = new (ELeave) CActiveScheduler();

	CActiveScheduler::Install( iScheduler );

	}

CTestHarnessUtil* CTestHarnessUtil::NewL()

	{

	CTestHarnessUtil* me = new (ELeave) CTestHarnessUtil();

	CleanupStack::PushL(me);

	me->ConstructL();

	CleanupStack::Pop(me);

	return me;

	}

void CTestHarnessUtil::ConstructL()

	{

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

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

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

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

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

	InitSchedulerL();

	CommInit();

	}

CTestHarnessUtil::CTestHarnessUtil()

	{

	}

CTestHarnessUtil::~CTestHarnessUtil()

	{

	delete iScheduler;

	iFs.Close();

	}

//=====================================//

//CTestHarnessParent

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

	: CActive(EPriorityHigh)

	{

	}

CTestHarnessParent  *CTestHarnessParent::NewLC()

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

CTestHarnessParent  *CTestHarnessParent::NewL()

	{

	CTestHarnessParent* self=NewLC();

	CleanupStack::Pop();

	return self;

	}

void CTestHarnessParent::ConstructL()

	{

	iState=EConnect;

	iPopCmdServiceA=NULL;

	iPopCmdServiceB=NULL;

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

	}

CTestHarnessParent::~CTestHarnessParent()

	{ 

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

	if(iPopCmdServiceA!=NULL)

		{

		delete iPopCmdServiceA;

		iPopCmdServiceA=NULL;

		}

	if(iPopCmdServiceB!=NULL)

		{

		delete iPopCmdServiceB;

		iPopCmdServiceB=NULL;

		}	

	}

void CTestHarnessParent::TestSingleDefaultConnL()

	{

	gTestUtils->WriteComment(_L("Test Single Default Connection Started"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceA->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Single Default Connection"));

	gTestUtils->WriteComment(_L("\r\n"));

	}	

void CTestHarnessParent::TestSingleSpecifiedConnL()

	{

	gTestUtils->WriteComment(_L("Test Single Specified Connection Started"));

	iPopCmdServiceA=MakeOverrideConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceA->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Single Specified Connection"));

	gTestUtils->WriteComment(_L("\r\n"));

	}	

void CTestHarnessParent::TestTwoDefaultConnectionsSeriallyL()

	{

	gTestUtils->WriteComment(_L("Test Two Default Serial Connections Started"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceB=MakeBasicConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceA->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Test Two Default Serial Connections "));

	gTestUtils->WriteComment(_L("\r\n"));

	}

void  CTestHarnessParent::TestTwoDefaultConnectionsParallellyL()

	{

	gTestUtils->WriteComment(_L("Test Two Default Parallel Connections Started"));

	gTestUtils->WriteComment(_L("\nFirst Connection Start"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceA->ConnectionL();

	gTestUtils->WriteComment(_L("\nSecond Connection Start"));

	iPopCmdServiceB=MakeBasicConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceB->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Test Two Default Parallel Connections "));

	gTestUtils->WriteComment(_L("\r\n"));

	}

void CTestHarnessParent::TestTwoDifferentConnectionsSeriallyL()

	{

	gTestUtils->WriteComment(_L("Test Two Different Serial Connections Started"));

	gTestUtils->WriteComment(_L("\nFirst Connection Start"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceB=MakeOverrideConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceA->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Test Two Different Serial Connections "));

	gTestUtils->WriteComment(_L("\r\n"));

	}

void  CTestHarnessParent::TestTwoDifferentConnectionsParallellyL()

	{

	gTestUtils->WriteComment(_L("Test Two Differenet Parallel Connections Started"));

	gTestUtils->WriteComment(_L("\nFirst Connection Start"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceA->ConnectionL();

	gTestUtils->WriteComment(_L("\nSecond Connection Start"));

	iPopCmdServiceB=MakeOverrideConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceB->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Test Two Different Parallel Connections "));

	gTestUtils->WriteComment(_L("\r\n"));

	}

void CTestHarnessParent::TestExplicitDefaultConnL()

	{

	gTestUtils->WriteComment(_L("Test Explicit-Default Parallel Connections Started"));

	gTestUtils->WriteComment(_L("\nFirst Connection Start"));

	iPopCmdServiceA=MakeBasicConnectionLC(KPipexServer, 

												KPipexUser, 

												KPipexPass);

	iPopCmdServiceA->ConnectionL();

	gTestUtils->WriteComment(_L("\nSecond Connection Start"));

	iPopCmdServiceB=MakeExplicitDefaultConnectionLC(KDemonServer, 

												KDemonUser, 

												KDemonPass);

	iPopCmdServiceB->ConnectionL();

	iState = ESend;

	iStatus = KRequestPending;

	SetActive();

	CActiveScheduler::Start();

	gTestUtils->WriteComment(_L("End of Test Explicit-Default Parallel Connections"));

	gTestUtils->WriteComment(_L("\r\n"));

	}

void CTestHarnessParent::DoCancel()

	{

	}

void CTestHarnessParent::SetTestMode(TTestMode aTestMode)

	{

	iTestMode=aTestMode;

	}

// Called by active scheduler if there is an outstanding task

void CTestHarnessParent::RunL()

	{

	switch(iTestMode)

		{

		case ESingleDefaultConn:

			SingleDefaultConnection();

		break;

		case ESingleSpecifiedConn:

			SingleDefaultConnection();

		break;

		case ETwoDefaultSerialConn: 

		case ETwoDifferentSerialConn:

			TwoSerialConnectionsL();

		break;

		case ETwoDefaultParallelConn:

		case ETwoDifferentParallelConn:

		case EExplicitDefaultConn:

			TwoParallelConnections();

		break;

		default:

		break;

		}

	}

void CTestHarnessParent::TwoSerialConnectionsL()

	{

	switch (iState)

		{

		case EConnect:

		break;

		case ESend:	

			g_Count=g_NoOfConnections;

			iState=EDisConnect;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceA->IsChildCompleteSet())

				{

				if(iPopCmdServiceA->iStatus.Int() == KErrNone || 

							iPopCmdServiceA->iStatus.Int() == KErrInUse)

					{

					iPopCmdServiceA->List();

					}

				}

			else

				ChildFinished();

		break;

		case EDisConnect:

			g_Count=g_NoOfConnections;

			iState=EConnect2;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceA->IsChildCompleteSet())

				{

				iPopCmdServiceA->DisConnect();

				}

			else

				ChildFinished();

		break;

		case EConnect2:

			g_Count=g_NoOfConnections;

			iPopCmdServiceB->ConnectionL();

			iState=ESend2;

			iStatus = KRequestPending;

			SetActive();

		break;

		case ESend2:

			g_Count=g_NoOfConnections;

			iState=EDisConnect2;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceB->IsChildCompleteSet())

				{

				if(iPopCmdServiceB->iStatus.Int() == KErrNone || 

							iPopCmdServiceB->iStatus.Int() == KErrInUse)

					{

					iPopCmdServiceB->List();

					}

				}

			else

				ChildFinished();

			break;

		case EDisConnect2:

			g_Count=g_NoOfConnections;

			iState=EStop;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceB->IsChildCompleteSet())

				{

				iPopCmdServiceB->DisConnect();

				}

			else

				ChildFinished();

		break;

		case EStop:

			CActiveScheduler::Stop();

		break;

		default:

		break;

		}

	}

void CTestHarnessParent::TwoParallelConnections()

	{

	switch (iState)

		{

		case EConnect:

		break;

		case ESend:	// have set encryption

			g_Count=g_NoOfConnections;

			iState=EDisConnect;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceA->IsChildCompleteSet())

				{

				if(iPopCmdServiceA->iStatus.Int() == KErrNone || 

						iPopCmdServiceA->iStatus.Int() == KErrInUse)

					{

					iPopCmdServiceA->List();

					}

				}

			else

				ChildFinished();

			if(!iPopCmdServiceB->IsChildCompleteSet())

				{

				if(iPopCmdServiceB->iStatus.Int() == KErrNone || 

						iPopCmdServiceB->iStatus.Int() == KErrInUse)

					{

					iPopCmdServiceB->List();

					}

				}

			else

				ChildFinished();

		break;

		case EDisConnect:

			g_Count=g_NoOfConnections;

			iState=EStop;

			iStatus = KRequestPending;

			SetActive();

			if(!iPopCmdServiceA->IsChildCompleteSet())

				iPopCmdServiceA->DisConnect();

			else

				ChildFinished();

			if(!iPopCmdServiceB->IsChildCompleteSet())

				iPopCmdServiceB->DisConnect();

			else

				ChildFinished();

		break;

		case EStop:

			CActiveScheduler::Stop();

		break;

		default:

		break;

		} // end of switch

	}

void CTestHarnessParent::SingleDefaultConnection()

	{

	switch (iState)

		{

		case EConnect:

		break;

		case ESend:	

			g_Count=g_NoOfConnections;