// 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 "clocaltestserver.h"
#include "httptestutils.h"
#include "mlocaltestserverobserver.h"
#include "ctestserverstreammanager.h"
#include "chttpclienttestparams.h"

const TUint16 KListeningPort = 80;  
const TInt KDefaultBufferSize = 16 * 1024;

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

CLocalTestServer::CLocalTestServer(CHTTPTestUtils& aTestUtils, MLocalTestServerObserver& aObserver, CHttpClientTestParamArray& aTestParamArray)
: iTestUtils(aTestUtils), iObserver(aObserver), iTestParamArray(aTestParamArray)
	{
	}
	
void CLocalTestServer::ConstructL()
	{
	_LIT8(KTxtTCP, "TCP");
	THttpTransportConstructionParams params(*this); 
	iTCPLayer = CHttpTransportLayer::NewL(KTxtTCP(), params);	
	}

CLocalTestServer::~CLocalTestServer()
	{
	iStreamManagers.ResetAndDestroy();
	iStreamManagers.Close();
	StopServer();
	delete iTCPLayer;
	}

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

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

void CLocalTestServer::ResetServer()
	{
	iStreamManagers.ResetAndDestroy();
	}
	
// From MSocketListenObserver
void CLocalTestServer::ConnectionReceivedL(MInputStream& aInputStream, MOutputStream& aOutputStream)
	{
	// New connection received, create a new stream manager to manage the requests and responses
/*	const TInt connectionCount = iStreamManager.Count();
*/	
	CLocalTestServerStreamManager* newStreamMgr = CLocalTestServerStreamManager::NewL(iTestUtils, &aInputStream, &aOutputStream, iTestParamArray);
	CleanupStack::PushL(newStreamMgr);
	User::LeaveIfError(iStreamManagers.Append(newStreamMgr));
	CleanupStack::Pop(newStreamMgr);

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

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

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

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

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

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

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

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