// 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 "csocketconnectordriver.h"

#include <msocketfactory.h>

#include <msocketconnector.h>

#include "cclientsocketdriver.h"

#include "thttptrhndtestpanic.h"

const TInt KPortNumber	= 80;

const TInt KSecurePortNumber	= 443;

GLREF_D TBool	gLongHostName;

GLREF_D TBool 	gInvalidConnectPort; 

CSocketConnectorDriver* CSocketConnectorDriver::NewL(MDriverObserver& aObserver, MSocketFactory& aSocketFactory)

/**

	@componentInternal		

	@param		aObserver		The driver observer.

	@param		aSocketFactory	The socket factory.

	@return		A pointer to a fully initialised object.

*/

	{

	return new (ELeave) CSocketConnectorDriver(aObserver, aSocketFactory);

	}

CSocketConnectorDriver::~CSocketConnectorDriver()

/**	

	Destructor

	@componentInternal		

*/

	{

	delete iClientSocketDriver;

	}

CSocketConnectorDriver::CSocketConnectorDriver(MDriverObserver& aObserver, MSocketFactory& aSocketFactory)

: CDriverBase(aObserver), iSocketFactory(aSocketFactory)

/**

	Constructor

	@componentInternal		

	@param		aObserver		The driver observer.

	@param		aSocketFactory	The socket factory.

*/

	{

	}

void CSocketConnectorDriver::SetDoubleConnectL()

/**

	Sets the command stack to have the following behaviour.

	It initiates a connect service in the provided socket factory. It expects a

	connection to be made - it creates a client socket driver to control the

	connected socket. The client socket driver is expected to close.

	Then a second connection is initiated and then immediately stopped. A wait

	delay is started and the test driver terminates once the wait has completed.

	@componentInternal

*/

	{

	// Create cmd stack

	AppendDoCmdL(EDoConnect);

	AppendExpectCmdL(EExpectConnected);

	AppendDoCmdL(EDoStartClientDriver);

	AppendExpectCmdL(EExpectClientClosed);

	AppendDoCmdL(EDoConnect);

	AppendDoCmdL(EDoStopConnect);

	AppendExpectCmdL(EExpectConnectError);

	}

void CSocketConnectorDriver::SetSingleConnectL()

/**

	Sets the command stack to have the following behaviour.

	It initiates a connect service in the provided socket factory. It expects a

	connection to be made - it creates a client socket driver to control the 

	connected socket. The client socket driver is expected to close.

	@componentInternal

*/

	{

	// Create cmd stack

	AppendDoCmdL(EDoConnect);

	AppendExpectCmdL(EExpectConnected);

	AppendDoCmdL(EDoStartClientDriver);

	AppendExpectCmdL(EExpectClientClosed);

	}

void CSocketConnectorDriver::SetSingleSecureConnectL()

/**

	Sets the command stack to have the following behaviour.

	It initiates a secure connect service in the provided socket factory. It expects a

	connection to be made - it creates a client socket driver to control the 

	connected socket. The client socket driver is expected to close.

	@componentInternal

*/

	{

	// Create cmd stack

	AppendDoCmdL(EDoSecureConnect);

	AppendExpectCmdL(EExpectConnected);

	AppendDoCmdL(EDoStartClientDriver);

	AppendExpectCmdL(EExpectClientClosed);

	}

/*

 *	Methods from CDriverBase

 */

void CSocketConnectorDriver::RunCmdL(TInt aCmd)

/**	

	@see		CDriverBase

	@componentInternal

*/

	{

	// Check the step number

	switch( aCmd )

		{

	case EDoConnect:

		{

		DoLog(_L("Socket Connector Driver - initiate connection"));

		if(gLongHostName)

			{

			iSocketConnector = &iSocketFactory.ConnectL(*this, _L8(": This is a long Invalid address to which connection cannot be established                                                                                       "), KPortNumber);

			}

		else

			{

			iSocketConnector = &iSocketFactory.ConnectL(*this, _L8("127.0.0.1"), KPortNumber);

			}

		} break;

	case EDoSecureConnect:

		{

		DoLog(_L("Socket Connector Driver - initiate secure connection"));

		iSecure = ETrue;

		if (!gInvalidConnectPort)

			{

			iSocketConnector = &iSocketFactory.ConnectL(*this, _L8("lon-cn-lxwaptest2.closedtest.intra"), KSecurePortNumber);	

			}

		else

			{

			iSocketConnector = &iSocketFactory.ConnectL(*this, _L8("lon-cn-lxwaptest2.closedtest.intra"), KPortNumber);

			}			

		} break;

	case EDoStartClientDriver:

		{

		__ASSERT_DEBUG( iClientSocketDriver, User::Invariant() );

		DoLog(_L("Socket Connector Driver - start client socket driver"));

		iClientSocketDriver->Start();		

		} break;

	case EDoStopConnect:

		{

		DoLog(_L("Socket Connector Driver - stop connection"));

		iSocketConnector->StopConnect();

		} break;

	default:

		__ASSERT_DEBUG( 0, THttpTrHndTestPanic::Panic(THttpTrHndTestPanic::EBadCommandId) );

		break;

		}

	}

/*

 *	Methods from MSocketConnectObserver

 */

void CSocketConnectorDriver::ConnectionMadeL(MInputStream& aInputStream, MOutputStream& aOutputStream)

/**	

	@see		MSocketConnectObserver

	@componentInternal

*/

	{

	DoLog(_L("Socket Connector Driver - connection made"));

	if( TestExpectedCmd(EExpectConnected, KErrNone) )

		{

		iClientSocketDriver = CClientSocketDriver::NewL(*this, *this, aInputStream, aOutputStream, iSecure);

		}

	}

TInt CSocketConnectorDriver::HandleConnectError(TInt aError)

/**	

	@see		MSocketConnectObserver

	@componentInternal

*/

	{

	DoLog(_L("Socket Connector Driver - connect error"));

	TestExpectedCmd(EExpectConnectError, aError);

	return KErrNone;

	}

void CSocketConnectorDriver::MSocketConnectObserver_Reserved()

/**	

	@see		MSocketConnectObserver

	@componentInternal

*/

	{

	User::Invariant();

	}

/*

 *	Methods from MClientDriverObserver

 */

void CSocketConnectorDriver::ClientClosed()

/**	

	@see		MClientDriverObserver

	@componentInternal

*/

	{

	DoLog(_L("Socket Connector Driver - client driver closed"));

	TestExpectedCmd(EExpectClientClosed, KErrNone);

	}