// Copyright (c) 2004-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 "cpipeliningconfigtest.h"
#include <uri8.h>

CPipeliningConfigTest* CPipeliningConfigTest::NewLC(const TDesC& aTestName)
	{
	CPipeliningConfigTest* me = new (ELeave) CPipeliningConfigTest();
	CleanupStack::PushL(me);
	me->ConstructL(aTestName);
	return me;
	}
	
CPipeliningConfigTest::CPipeliningConfigTest()
	{
	}	

void CPipeliningConfigTest::ConstructL(const TDesC& aTestName)
	{
	iTestName=aTestName.AllocL();
	}

CPipeliningConfigTest::~CPipeliningConfigTest()
	{
	iTransactionUris.ResetAndDestroy();
	delete iTestName;
	}



const TDesC& CPipeliningConfigTest::TestCaseName() const
	{
	return *iTestName;
	}
	
	
TInt CPipeliningConfigTest::TotalTransactionCount() const
	{
	return iTransactionUris.Count();
	}
	
	
TInt CPipeliningConfigTest::TransactionCount(TInt /*aConnectionIndex*/) const
	{
	return 0;
	}
	
	
RHTTPTransaction CPipeliningConfigTest::GetTransactionL(TInt aIndex, 
														RHTTPSession aSession, 
											 			MHTTPTransactionCallback& aClient)
	{
	
	if (aIndex >= iTransactionUris.Count())
		{
		User::Invariant();
		}
	
	CheckAndSetSessionSettingsL(aSession);
	
	RStringF method = aSession.StringPool().StringF(HTTP::EGET,RHTTPSession::GetTable());
	TUriParser8 uri; 
	uri.Parse(*(iTransactionUris[aIndex]));
	return aSession.OpenTransactionL(uri, aClient, method);
	}
	
	
TBool CPipeliningConfigTest::BatchTransactions() const
	{
	return ETrue;
	}
	

TInt CPipeliningConfigTest::ExpectedError(RHTTPTransaction /*aTrans*/)
	{
	return KErrNone;
	}
	
	
const TDesC8& CPipeliningConfigTest::GetRawRequest(TInt /*aConnectionIndex*/, 
												   TInt /*aTransIndex*/)
	{
	User::Invariant();
	return KNullDesC8();
	}
	
	
const TDesC8& CPipeliningConfigTest::GetRawResponse(TInt /*aConnectionIndex*/, 
													TInt /*aTransIndex*/)
	{
	User::Invariant();
	return KNullDesC8();
	}
	
	
TInt CPipeliningConfigTest::ConnectionCount() const
	{
	return 0;
	}
	
TInt CPipeliningConfigTest::RealExpectedConnectionCount() const
	{
	return iExpectedNumberConnections;
	}
	

TBool CPipeliningConfigTest::EnableBatching() const
	{
	return ETrue;
	}	
	
	
void CPipeliningConfigTest::ProcessHeadersL(RHTTPTransaction /*aTrans*/)
	{
	}
	
	
void CPipeliningConfigTest::CheckAndSetSessionSettingsL(RHTTPSession aSession)	
	{
	RStringPool stringPool = aSession.StringPool();
	RHTTPConnectionInfo sessionSettings = aSession.ConnectionInfo();
	
	if (iMaxNumberTransactionsToPipeline > 0)
		{
		RStringF maxToPipelineSetting = stringPool.StringF(HTTP::EMaxNumTransactionsToPipeline,
														   aSession.GetTable());
		THTTPHdrVal value;
		if (sessionSettings.Property(maxToPipelineSetting, value) == EFalse)
			{
			value.SetInt(iMaxNumberTransactionsToPipeline);
			sessionSettings.SetPropertyL(maxToPipelineSetting,value); 		
			}
		}
	
	
	if (iMaxNumberTransportHandlers > 0)
		{
		RStringF maxTransportHandlers = stringPool.StringF(HTTP::EMaxNumTransportHandlers,
														   aSession.GetTable());
		THTTPHdrVal value;
		if (sessionSettings.Property(maxTransportHandlers, value) == EFalse)
			{
			value.SetInt(iMaxNumberTransportHandlers);
			sessionSettings.SetPropertyL(maxTransportHandlers,value); 		
			}
		}
	}
	
	
void CPipeliningConfigTest::SetMaxNumberTransactionsToPipeline(TInt aMaxNumberTransactionsToPipeline)
	{	
	iMaxNumberTransactionsToPipeline = aMaxNumberTransactionsToPipeline;
	}
	
	
void CPipeliningConfigTest::SetMaxNumberTransportHandlers(TInt aMaxNumberTransportHandlers)
	{
	iMaxNumberTransportHandlers = aMaxNumberTransportHandlers;
	}
	
	
void CPipeliningConfigTest::AddTransactionUrisL(const TDesC8& aUri, TInt aRepeatNumber)
	{
	for (TInt ii = 0; ii< aRepeatNumber; ++ii)
		{
		HBufC8* uri = aUri.AllocLC();
		User::LeaveIfError(iTransactionUris.Append(uri));
		CleanupStack::Pop(uri);
		} 
	}	
	
	
	
void CPipeliningConfigTest::ClearTransactionUris()
	{
	iTransactionUris.ResetAndDestroy();
	}
	
	
void CPipeliningConfigTest::SetExpectedNumberConnections(TInt aExpectedNumberConnections)
	{
	iExpectedNumberConnections = aExpectedNumberConnections;
	}

TBool CPipeliningConfigTest::TransportHandlerPriority() const	
	{
	return EFalse;		
	}