// 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:
// defines test class: CTextModeTestRespChunkSize
// 
//

#include "T_RespChunkSize.h"

// User include
#include "csrvaddrval.h"

// Constants used in CTextModeTestRespChunkSize test
_LIT8(KHttpSyncmlUrl, "http://WapTestIP/perl/dumpform.pl?req=req1.txt&resp=resp1.txt");

// It is noticed that trying to condence the below code to 80 lines has caused
// some problems with running the test harness.
_LIT8(KHttpSyncmlReqBody, "<?xml version=\"1.0\" encoding=\"UTF-8\"?><SyncML xmlns='SYNCML:SYNCML1.0'><SyncHdr><VerDTD>1.0</VerDTD><VerProto>SyncML/1.0</VerProto><SessionID>1</SessionID><MsgID>1</MsgID><Target><LocURI>servlet/fde.sync.SyncML</LocURI></Target><Source><LocURI>ABCDEFG</LocURI></Source><Cred><Meta><Type xmlns='syncml:metinf'>syncml:auth-basic</Type><Format xmlns='syncml:metinf'>b64</Format></Meta><Data>c3ltYmlhbjpmMXN5bmNtbAA=</Data></Cred></SyncHdr><SyncBody><Alert><CmdID>1</CmdID><Data>200</Data><Item><Target><LocURI>CALENDAR</LocURI></Target><Source><LocURI>C:\\Documents\\Agenda</LocURI></Source><Meta><Anchor xmlns='syncml:metinf'><Last xmlns='syncml:metinf'>20010320T105418Z</Last><Next xmlns='syncml:metinf'>20010320T145358Z</Next></Anchor></Meta></Item></Alert><Final/></SyncBody></SyncML>");
_LIT8(KHttpSyncmlUserAgent, "EPOC SyncML Client");
_LIT8(KHttpSyncmlContentType, "application/vnd.syncml-xml");
_LIT8(KProxyAddr, "127.0.0.1:8000");

const TInt KHttpSyncmlContentLength = 783;

// CTextModeTestRespChunkSize-----------------------------------
/**
	This function is called to create a new instance of the class 
	CTextModeTestCookies

	@param aDummyProxyPort	This variable holds a dummy non existing proxy 
							port
	@param aRespChunkSize	This variable holds the response chunk size
	@param aIniSettingsFile	The script file that holds the sections
							from which the value has to be retrieved
	@leave 					KErrNoMemory if there is insufficient memory to allocate for the object
*/
CTextModeTestRespChunkSize* CTextModeTestRespChunkSize::NewL(TInt aDummyProxyPort, TInt aRespChunkSize, CScriptFile* aIniSettingsFile)
	{
	CTextModeTestRespChunkSize* self = new(ELeave) CTextModeTestRespChunkSize(aDummyProxyPort, aRespChunkSize, aIniSettingsFile);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

/**
	Destructor which deletes dummy server
*/
CTextModeTestRespChunkSize::~CTextModeTestRespChunkSize()
	{
	delete iDummyServer;
	}

void CTextModeTestRespChunkSize::MHFRunL(RHTTPTransaction aTransaction,
					 const THTTPEvent& aEvent)
	{
	switch (aEvent.iStatus)
		{
		case THTTPEvent::EGotResponseHeaders:
			{
			// HTTP response headers have been received
			DumpRespHeaders(aTransaction);
			} break;
		case THTTPEvent::ESubmit:
			{
			} break;
		case THTTPEvent::EGotResponseBodyData:
			{
			// Some (more) body data has been received (in the HTTP response)
			DumpResponseBody(aTransaction);
			} break;
		case THTTPEvent::EResponseComplete:
			{
			// The transaction's response is complete
			iEngine->Utils().LogIt(_L("<Transaction Complete>"));
			} break;
		case THTTPEvent::ESucceeded:
			{
			iEngine->Utils().LogIt(_L("<Transaction validated successfully>"));
			CActiveScheduler::Stop();
			} break;
		case THTTPEvent::EFailed:
			{
			iEngine->Utils().LogIt(
				_L("<Transaction NOT validated successfully>"));
			iFailureError = KErrTestFailed;
			CActiveScheduler::Stop();
			} break;
		default:
			{
			iEngine->Utils().LogIt(_L("<unrecognised event> %d")
				,aEvent.iStatus);
			if (aEvent.iStatus < 0)
				{
				iFailureError = aEvent.iStatus;
				CActiveScheduler::Stop();
				}
			} 
			break;
		}
	}

TInt CTextModeTestRespChunkSize::MHFRunError(TInt aError, 
											 RHTTPTransaction aTransaction,
					 const THTTPEvent& aEvent)
	{
	iEngine->Utils().LogIt(
	  _L("\nMHFRunL left: error code %d on transaction ID=%d for event %d\n"), 
	  aError, aTransaction.Id(), aEvent.iStatus);
	return KErrNone;
	}

TBool CTextModeTestRespChunkSize::GetNextDataPart(TPtrC8& aDataChunk)
	{
	aDataChunk.Set(KHttpSyncmlReqBody());
	return ETrue;
	}

void CTextModeTestRespChunkSize::ReleaseData()
	{
	// do nothing
	}

TInt CTextModeTestRespChunkSize::OverallDataSize()
	{
	__ASSERT_DEBUG(KHttpSyncmlContentLength == KHttpSyncmlReqBody().Length(), 
		User::Invariant());
	return KHttpSyncmlReqBody().Length();
	}

const TDesC& CTextModeTestRespChunkSize::TestName()
	{
	_LIT(KHeaderTestName,"CTextModeTestRespChunkSize");
	return KHeaderTestName;
	}

void CTextModeTestRespChunkSize::DoRunL()
/**
	This function is called to initiate the tests.
	It may leave with a system wide error code.
*/
	{
	iSession.OpenL();
	CleanupClosePushL(iSession);
	RHTTPConnectionInfo connInfo = iSession.ConnectionInfo();

	// Open the HTTP session, with a proxy specified to be the dummy server
	RStringPool strP = iSession.StringPool();
	THTTPHdrVal proxyUsage(strP.StringF(HTTP::EUseProxy, RHTTPSession::GetTable()));
	connInfo.SetPropertyL(strP.StringF(HTTP::EProxyUsage, RHTTPSession::GetTable()), proxyUsage);
	RStringF proxy = strP.OpenFStringL(KProxyAddr());
	CleanupClosePushL(proxy);
	THTTPHdrVal proxyAddr(proxy);
	connInfo.SetPropertyL(strP.StringF(HTTP::EProxyAddress, RHTTPSession::GetTable()), proxyAddr);
	CleanupStack::PopAndDestroy(&proxy);

	// Open a POST transactions, specifying this object as the request 
	// body data supplier
	TUriParser8 up;

	// Replace the hostname in the url
	HBufC8* newUrl8 = TSrvAddrVal::ReplaceHostNameL(KHttpSyncmlUrl(), iIniSettingsFile);
	CleanupStack::PushL(newUrl8);
	TPtr8 newUrlPtr8 = newUrl8->Des();

	up.Parse(newUrlPtr8);

	iTransaction = iSession.OpenTransactionL(up, *this, strP.StringF(HTTP::EPOST,RHTTPSession::GetTable()));
	
	CleanupStack::PopAndDestroy(newUrl8);

	RHTTPRequest rq = iTransaction.Request();
	rq.SetBody(*this);
	RHTTPHeaders hdr = rq.GetHeaderCollection();
	THTTPHdrVal length(KHttpSyncmlContentLength);
	hdr.SetFieldL(strP.StringF(HTTP::EContentLength,RHTTPSession::GetTable()), length);
	RStringF contType = strP.OpenFStringL(KHttpSyncmlContentType());
	CleanupClosePushL(contType);
	hdr.SetFieldL(strP.StringF(HTTP::EContentType,RHTTPSession::GetTable()), THTTPHdrVal(contType));
	RStringF userAgent = strP.OpenFStringL(KHttpSyncmlUserAgent());
	CleanupClosePushL(userAgent);
	hdr.SetFieldL(strP.StringF(HTTP::EUserAgent,RHTTPSession::GetTable()), THTTPHdrVal(userAgent));

	// Submit the transaction and start the proxy
	iTransaction.SubmitL();
	iDummyServer->ListenL();
	
	// Go!
	iFailureError = KErrNone;
	CActiveScheduler::Start();

	// check if we are making a leave.  If leaving then destroy the memory allocated
	if (iFailureError != KErrNone)
		{
		CleanupStack::PopAndDestroy(3, &iSession); // close userAgent, contType and iSession;
		User::LeaveIfError(iFailureError);
		}

	// Get the completion code and inform the engine.  Anything other than 
	// HTTP/200 status is a failure
	// for this test.
	iEngine->SetCurrentStatusCode(iTransaction.Response().StatusCode());
	iExpectedStatusCode = 200;

	// Close anything opened
	CleanupStack::PopAndDestroy(3, &iSession); // close userAgent, contType and iSession;
	}

TInt CTextModeTestRespChunkSize::RunError(TInt aErr)
	{
	iEngine->Utils().LogIt(_L("\nTest failed with error code %d\n"), aErr);
	return KErrNone;
	}

void CTextModeTestRespChunkSize::DoCancel()
	{
	}

CTextModeTestRespChunkSize::CTextModeTestRespChunkSize(TInt aDummyProxyPort, 
										TInt aRespChunkSize, 
										CScriptFile* aIniSettingsFile)
	: iDummyProxyPort(aDummyProxyPort), iRespChunkSize(aRespChunkSize), 
	  iIniSettingsFile(aIniSettingsFile)
	{
	}

/**
	Create a dummy HTTP server which will listen on port 8000.
*/
void CTextModeTestRespChunkSize::ConstructL()
	{
	iDummyServer = CDummyServer::NewL(iDummyProxyPort, iRespChunkSize);
	}