// Copyright (c) 2003-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 <chttptransportlayer.h>

#include "CPipeliningTestServer.h"
#include "httptestutils.h"
#include "MPipeliningTestCase.h"
#include "MPipeliningTestObserver.h"
#include "CTestServerStreamManager.h"

const TUint16 KListeningPort = 80;

CPipeliningTestServer* CPipeliningTestServer::NewL(CHTTPTestUtils& aTestUtils, MPipeliningTestObserver& aObserver)
	{
	CPipeliningTestServer* self = new (ELeave) CPipeliningTestServer(aTestUtils, aObserver);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CPipeliningTestServer::CPipeliningTestServer(CHTTPTestUtils& aTestUtils, MPipeliningTestObserver& aObserver)
: iTestUtils(aTestUtils), iObserver(aObserver)
	{
	}
	
void CPipeliningTestServer::ConstructL()
	{
	_LIT8(KTxtTCP, "TCP");
	THttpTransportConstructionParams params(*this); 
	iTCPLayer = CHttpTransportLayer::NewL(KTxtTCP(), params);
	}

CPipeliningTestServer::~CPipeliningTestServer()
	{
	StopServer();
	iStreamManager.ResetAndDestroy();
	iStreamManager.Close();
	delete iTCPLayer;
	}

void CPipeliningTestServer::StartServerL()
	{
	iTCPLayer->ListenL(*this, KListeningPort);
	}

void CPipeliningTestServer::StopServer()
	{
	if( iTCPLayer != NULL )
		{
		iTCPLayer->StopListen();
		}
	}

void CPipeliningTestServer::ResetServer()
	{
	iStreamManager.ResetAndDestroy();
	}
	
void CPipeliningTestServer::SetTestCase(MPipeliningTestCase* aTestCase)
	{
	iTestCase = aTestCase;
	
	_LIT(KTxtTransCount, "Total transaction in test case = %d");
	iTestUtils.LogIt(KTxtTransCount(), iTestCase->TotalTransactionCount());

	_LIT(KTxtConnectionCount, "Total connections in test case = %d");
	iTestUtils.LogIt(KTxtConnectionCount(), iTestCase->ConnectionCount());
	}

TInt CPipeliningTestServer::ConnectionCount() const
	{
	return iStreamManager.Count();
	}
	
// From MSocketListenObserver
void CPipeliningTestServer::ConnectionReceivedL(MInputStream& aInputStream, MOutputStream& aOutputStream)
	{
    _LIT(KTestCaseLocalAndRemoteHost, "TSWDEFECT1 JKUN-7VVGB6");
    if(iTestCase->TestCaseName().CompareF(KTestCaseLocalAndRemoteHost) == 0)
        {
        ResetServer();
        }
	// New connection received, create a new stream manager to manage the requests and responses
	const TInt connectionCount = iStreamManager.Count();
	
	CTestServerStreamManager* newStreamMgr = CTestServerStreamManager::NewL(iTestUtils, connectionCount, iTestCase, &aInputStream, &aOutputStream);
	CleanupStack::PushL(newStreamMgr);
	User::LeaveIfError(iStreamManager.Append(newStreamMgr));
	CleanupStack::Pop(newStreamMgr);

	_LIT(KTxtConnection, "Server - Client connection received and connected.");
	iTestUtils.LogIt(KTxtConnection());
	}
	
TInt CPipeliningTestServer::HandleListenError(TInt aError)
	{
	_LIT(KTxtListenError, "Server listening error: Error code = %d");
	iTestUtils.LogIt(KTxtListenError(), aError);

	iObserver.EndTest(aError);
	return KErrNone;
	}
	
void CPipeliningTestServer::MSocketListenObserver_Reserved()
	{
	}

// From MConnectionPrefsProvider
TBool CPipeliningTestServer::SupplyCommsConnection(RConnection*& /*aConnectionPtr*/)
	{
	return EFalse;
	}
	

void CPipeliningTestServer::SetCommsConnectionL(RConnection* /*aConnectionPtr*/)
	{
	//do nothing
	}
	
void CPipeliningTestServer::GetSecurityPrefs(TBool& aDialogPrompt, MSecurityPolicy*& aSecurityPolicy)
	{
	aDialogPrompt = EFalse;
	aSecurityPolicy = NULL;
	}

TBool CPipeliningTestServer::ImmediateSocketShutdown()
	{
	return EFalse;
	}

TInt CPipeliningTestServer::SessionId()
	{
	return KErrNotSupported;
	}

TBool CPipeliningTestServer::SupplySocketServerHandle ( TInt& /*aSocketServerHandle*/ )
  	{
  	return 0;
  	}
  	
void CPipeliningTestServer::SetSocketServerHandleL ( TInt /*aSocketServerHandle*/ )	
  	{	
  	// do nothing
  	}

TInt CPipeliningTestServer::GetRecvBufferSize()
	{
	return KDefaultBufferSize;
	}