/*

* Copyright (c) 2008 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:

*

*/

#if !defined(PTCPCLIENTTESTS_H)

#define PTCPCLIENTTESTS_H

#include <e32base.h>

#include <testexecutestepbase.h>

#include "proxyprotocol.h"

#include <comms-infras/eintsock.h>

#include "es_mbuf.h"

#include "testtcpserver.h"

#include <elements/nm_node.h>

#include "mtcpclienttestcase.h"

#include <cchunkmanager.h>

#include <rmemchunk.h>

_LIT8 ( KTestCase1, "testcase1" );

_LIT8 ( KMissingContentLength, "HTTP/1.1 200 OK\r\nST: testcase1\r\nEXT: \r\nSERVER: Apache 9.x, UPnP/1.0\r\nUSN: uuid:ae30fdec-16e3-4d75-ac72-b61c5d6d30d5::urn:schemas-upnp-org:device:BinaryLight:1\r\nCACHE-CONTROL: max-age=900\r\nLOCATION: http://10.192.196.204:54042/\r\n\r\n");

NONSHARABLE_CLASS(CTcpClientTestBase) : protected CActive

	{

public:

	static void StartTestL(const TDesC& aTestName, CProxyProvd* aProvd);

	virtual void RunL();

protected:		

	CTcpClientTestBase(CProxyProvd* aProvd);

	virtual ~CTcpClientTestBase();

	//Utilities function to be use in RunTest()

	void Reschedule();

	CTestExecuteLogger iLogger;

	void CompleteSelf ( TInt aError );

	void FinishTest(TVerdict result);

	enum TState

		{

		ECreateTestServer = 0,

		ECreateTestClient,

		ESendRequestData,

		ECleanup,

		EComplete,

		};

	RMemoryAllocator 			iAllocator;

	CChunkManager*  iChunkManager;		

	TState				iState;	

private:

	//Implemented you own of these		

	virtual TVerdict RunTestL() = 0;

	virtual void Cleanup();

	void DoCancel();

	void ConstructL();

	void SetLoggerL();

	CTestExecuteLogger& Logger();	

	static CTcpClientTestBase* CreateTestL(const TDesC& aTestName, CProxyProvd* aProvd);

private:

	CProxyProvd* iProvd;

	TBool iReschedule; //Determines whether rescheduling is required

	};

inline CTestExecuteLogger& CTcpClientTestBase::Logger()

	{

	return iLogger;

	}

class MTestServerObserver

	{

public:

	/**

	Callback method which returns the responses.

	@param aObserverInfo bundle containg the response.

	*/

	virtual void OnTestServerEventL ( TInt aError ) = 0;

	virtual MTcpClientTestCase* GetTestCase ( ) = 0;

	virtual CTestExecuteLogger& GetLogger ( ) = 0;

	//virtual void OnTestServerEventL ( TBool aFlag) = 0;

	/**

	Callback method which handles the errors of OnPnPEventL.

	@param aError error code.

	*/

	//virtual void OnTestServerError (TInt aError) = 0;

	};

/*class MTestClientObserver

	{

public:

	/**

	Callback method which returns the responses.

	@param aObserverInfo bundle containg the response.

	*

	virtual void OnTestClientEventL ( TObserverBundle& aObserverInfo) = 0;

	/**

	Callback method which handles the errors of OnPnPEventL.

	@param aError error code.

	*

	virtual void OnTestClientError (TInt aError) = 0;

	};

*/

//----------------------------------------------------------//

/////////////////// CTcpClientTestUPnP /////////////////////////

//////Testcase: Send the test data from the test client/////////

//----------------------------------------------------------//

NONSHARABLE_CLASS(CTcpClientTestUPnP) : public CTcpClientTestBase,

										public Messages::ASimpleNodeIdBase,

										public MTestServerObserver,

										public MTcpClientTestCase

	{

public:

	static CTcpClientTestUPnP* NewL ( CProxyProvd* aProvd );

	//MTestServerObserver

	void OnTestServerEventL ( TInt aError );

	MTcpClientTestCase* GetTestCase ();

	CTestExecuteLogger& GetLogger ();

	//MTcpClientTestCase

	const TDesC& TestCaseName () const;

	TInt TotalTransactionCount () const;	

	TInt TransactionCount () const;

	const TDesC8& GetRawRequest ( TInt aTransIndex );

	const TDesC8& GetRawResponse ( TInt aTransIndex );

	~CTcpClientTestUPnP ();

	void ReceivedL ( const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage );

private:

	CTcpClientTestUPnP ( CProxyProvd* aProvd );

	void ConstructL ();

	virtual TVerdict RunTestL ();

private:	

	CTestTcpServer*		iTestServer;

	Messages::TNodeId 	iClientId;

	RTimer				iTimer;

	//TState				iState;

	};

#endif //PTCPCLIENTTESTS_H