// 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:
//

#include <eikenv.h> 

// =============================================== //
class CSendPopCommandMessage;

enum TTestMode{
	  ESingleDefaultConn = 0,
	  ESingleSpecifiedConn,
	  ETwoDefaultSerialConn,
	  ETwoDefaultParallelConn,
	  ETwoDifferentSerialConn,
	  ETwoDifferentParallelConn,
	  EExplicitDefaultConn
	  };

// Parent active object which controls the children the sequence of 
// Connect, Send and count messages and Disconnect.
class CTestHarnessParent : public CActive
	{
public:
	static CTestHarnessParent* NewL();
	static CTestHarnessParent* NewLC();
	void ChildFinished();
	CSendPopCommandMessage* MakeBasicConnectionLC(TDes& aServAddress, 
												TDes8& aUser, TDes8& aPass);
	CSendPopCommandMessage* MakeOverrideConnectionLC(TDes& aServAddress,
												TDes8& aUser, TDes8& aPass);
	CSendPopCommandMessage* MakeExplicitDefaultConnectionLC(TDes& aServAddress, 
												TDes8& aUser, TDes8& aPass);
	void TestSingleDefaultConnL();
	void TestSingleSpecifiedConnL();
	void TestTwoDefaultConnectionsSeriallyL();
	void TestTwoDefaultConnectionsParallellyL();
	void TestTwoDifferentConnectionsSeriallyL();
	void TestTwoDifferentConnectionsParallellyL();
	void TestExplicitDefaultConnL();
	void SetTestMode(TTestMode aTestMode);
private:
	CTestHarnessParent();
	~CTestHarnessParent();
	void ConstructL();
	void RunL();
	void DoCancel();
	void SingleDefaultConnection();
	void SingleSpecifiedConnection();
	void TwoSerialConnectionsL();
	void TwoParallelConnections();
	typedef enum TState{
	  EConnect = 0,
	  ESend,
	  EDisConnect,
	  EConnect2,
	  ESend2,
	  EDisConnect2,
	  EStop
	  };
	TState					iState;		
	CSendPopCommandMessage	*iPopCmdServiceA;
	CSendPopCommandMessage	*iPopCmdServiceB;
	TInt					iConnectionType;
	TTestMode				iTestMode;

	};

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

// Child active object whose instances will be controled by parent for 
// Connect,Send and count messages and Disconnect

class CSendPopCommandMessage : public CActive
	{
public: // functions                                 
	// construct/destruct
	static CSendPopCommandMessage *NewL(TDesC& aServerAddress, 
							TInt aPort, 
							TDesC8& aUser,
							TDesC8& aPass,
							CTestHarnessParent* aParent,
							CImIAPPreferences* aConnPref = NULL);

	static CSendPopCommandMessage *NewLC(TDesC& aServerAddress, 
							TInt aPort, 
							TDesC8& aUser,
							TDesC8& aPass,
							CTestHarnessParent* aParent,
							CImIAPPreferences* aConnPrefaConnPref = NULL);

	// issue request
	void RequestSend();
	void SetConnectionPrefs(CImIAPPreferences* aConnPref);
	void Complete(TInt aError);
	TInt RunError(TInt aError);
	void ConnectionL();
	void List();
	TBool IsChildCompleteSet();
	~CSendPopCommandMessage();
	void DisConnect();
	void SetLastError(TInt aError);
	TInt GetLastError();
private:
	void RunL();
	void QueueNextReceive();
	void ConstructL();
	void SetSelfComplete(TBool aComplete);

	CSendPopCommandMessage();
	CSendPopCommandMessage(TDesC& aServerAddress, 
							TInt aPort, 
							TDesC8& aUser,
							TDesC8& aPass,
							CTestHarnessParent* aParent,
							CImIAPPreferences* aConnPref);

	void Quit();
	void DisplayErrorReason(TInt& aReason);
	void DoCancel();
	typedef enum TSendState{
	  EConnect = 0,
	  EUserName,
	  EPassword,
	  EStat,
	  EList,
	  EQuit,
	  EComplete,
	  EConnectDone,
	  EQuitDone
	};
	CImTextServerSession*	iImSocket;
	TSendState				iSendState;
	TStreamId				iId;
	HBufC*					iBuf;
	TInt					iCurrentState;
	TInt					iLineStatus;
	TBool					iReceive;
	TSockXfrLength			iLen;
	TDesC&					iServerAddress;
	TInt					iPort;
	TDesC8&					iUserName;
	TDesC8&					iPass;
	CTestHarnessParent*		iParent;
	CImIAPPreferences*		iIAPPreferences;
	TInt					iLastError;
	TBool					iComplete;
	};

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

// Test harness calss which installs the scheduler and loads the logical 
// and physical device

class  CTestHarnessUtil : public CBase
	{
public:
	static CTestHarnessUtil* NewL();
	~CTestHarnessUtil();
private:
	void ConstructL();
	CTestHarnessUtil();
	void InitSchedulerL();
	TInt CommInit();
private:
	RFs					iFs;
	CActiveScheduler	*iScheduler;
	};

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