// 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:
// defines test classes: CTestEngine
// 
//

#include "ctestengine.h"
#if !defined __CTESTMESSAGECOMPOSER_H__
#include "ctestmessagecomposer.h"
#endif
#if !defined CTESTMESSAGEPARSER_H_
#include "ctestmessageparser.h"
#endif

#define KTestRequestHeader _L8("HTTP MESSAGE PERFORMANCE LOGGER\n\n\n")

_LIT(KFilePath, "c:\\logs\\http\\");
_LIT(KFileName, "c:\\logs\\http\\msg_peformance_logger.txt");
_LIT(KTestHttpMessageComposer,"Composing HTTP Request Message \n \n \n");
_LIT(KTestHttpMessageParser,"Parsing HTTP Response Message \n \n \n");
_LIT(KTestHttpMessagePeformanceTitle, "HTTP Message Performance Test Harness");
CTestEngine* CTestEngine::NewL()
	{
	CTestEngine* self = new (ELeave) CTestEngine();
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CTestEngine::~CTestEngine()
	{
	delete iTestUtils;
	}

const TDesC& CTestEngine::TestName()
		{
		_LIT(KTestName, "HTTP message Test");
		return KTestName;
		}
CTestEngine::CTestEngine()
	{
	iStartTime = 0;
	iEndTime = 0;
	}

void CTestEngine::ConstructL()
	{
	iTestUtils = CHTTPTestUtils::NewL(KTestHttpMessagePeformanceTitle());
	iTestUtils->InitCommsL();
	}

void CTestEngine::DoRunL()
	{

	}
void CTestEngine::DoCancel()
	{
	}
void CTestEngine::RunTestsL()
	{
	//Tests for composer
	iTestUtils->StartTestL(_L("Test 1 for composition of http message having multiple Headers with no body"));
	TestComposeMessageL(1);
	iTestUtils->EndTest(iTestFailed);
	iTestUtils->StartTestL(_L("Test 2 for composition of http message having 8 Headers with no body"));
	TestComposeMessageL(2);
	iTestUtils->EndTest(iTestFailed);
	//Tests for parser
	iTestUtils->StartTestL(_L("Test 1 for http message parser"));
	//Message to be parsed : "HTTP/1.1 200 OK\r\nDate: Tue, 04 Aug 2009 10:49:50 GMT\r\nServer: Apache/2.2.11 (Unix)\r\nLast-Modified: Thu, 16 Jul 2009 12:06:00 GMT\r\nETag: 4c0f49-329-46ed17eb73a00 \r\nAccept-Ranges: bytes\r\n\r\n "
	TestParseMessageL(1);
	iTestUtils->EndTest(iTestFailed);
	iTestUtils->StartTestL(_L("Test 2 for http message parser"));
	//Message to be parsed : "HTTP/1.1 200 OK\r\nDate: Tue, 04 Aug 2009 10:49:59 GMT\r\nServer: Apache/2.2.11 (Unix)\r\nLast-Modified: Thu, 16 Jul 2009 12:06:00 GMT\r\nETag: 4c134b-cbc-46ed17eb73a00 \r\nAccept-Ranges: bytes\r\nContent-Length: 3260\r\nKeep-Alive: timeout=5, max=88\r\nConnection: Keep-Alive\r\nContent-Type: image/png\r\n\r\n "
	TestParseMessageL(2);
	iTestUtils->EndTest(iTestFailed);
	iTestUtils->StartTestL(_L("Test 3 for http message parser"));
	//Message to be parsed : "HTTP/1.1 200 OK\r\nDate: Tue, 04 Aug 2009 10:49:59 GMT\r\nServer: Apache\r\nConnection: Close\r\nTransfer-Encoding: chunked\r\nContent-Type: text/html\r\n\r\n "
	TestParseMessageL(3);
	iTestUtils->EndTest(iTestFailed);
	iTestUtils->StartTestL(_L("Test 4 for http message parser"));
	//Message to be parsed : "HTTP/1.1 200 OK\r\nDate: Tue, Date: Tue, 22 Sep 2009 04:27:56 GMT\r\nServer: Apache\r\nContent-Encoding: gzip\r\nContent-Length: 6355\r\nContent-Type: text/html\r\nExpires: Tue, 22 Sep 2009 04:27:56 GMT\r\nCache-Control: 	max-age=0, no-cache\r\nPragma: no-cache\r\nConnection: close\r\nVary: Accept-Encoding\r\n\r\n "
	TestParseMessageL(4);
	iTestUtils->EndTest(iTestFailed);
	}
	
void CTestEngine::TestComposeMessageL(TInt aNumberofHeaders)
	{
	iTestFailed	= EFalse;
	CTestMessageComposer* messagecomposer = CTestMessageComposer::NewL(*this);
	CleanupStack::PushL(messagecomposer);
	messagecomposer->SetHeaderL(aNumberofHeaders);
	StartTimer();
	messagecomposer->StartRequest();
	CActiveScheduler::Start();
	EndTimer(KTestHttpMessageComposer);
	CleanupStack::PopAndDestroy(messagecomposer);
	}

void CTestEngine::TestParseMessageL(TInt aMessageType)
	{
	CTestMessageParser* messageparser = CTestMessageParser::NewL(*this);
	CleanupStack::PushL(messageparser);
	StartTimer();
	messageparser->StartRequest(aMessageType);
	CActiveScheduler::Start();
	EndTimer(KTestHttpMessageParser);
	CleanupStack::PopAndDestroy(messageparser);
	}
	
	void CTestEngine::NotifyError(TInt /*aError*/)
	{
	}

void CTestEngine::NotifyStart()
	{
	}

void CTestEngine::NotifyComplete()
	{
	CActiveScheduler::Stop();	
	}

void CTestEngine::LogIt(const TDesC& aComment)
	{
	TInt err = iFs.Connect();
	if(err == KErrNone)
		{
		iFs.MkDirAll(KFilePath);
		err = iFile.Open(iFs, KFileName, EFileWrite);
		if(err == KErrNotFound)
			{
			iFile.Create(iFs, KFileName, EFileWrite);
			iFile.Write(KTestRequestHeader);
			}
		TFileText file;
		file.Set(iFile);
		file.Write(aComment);
		iFile.Close();
		iFs.Close();
		}
	else	
		{
		User::InfoPrint(_L("Cannot write to file"));
		}
	}

	void CTestEngine::StartTimer()
			{
			iStartTime = User::FastCounter();
			}
	
	void CTestEngine::EndTimer(const TDesC& aComment)
			{
			iEndTime = User::FastCounter();
			iTimeDifference = iEndTime-iStartTime;	
			_LIT(KTimeDiff, ",%ld microseconds\n");
			RBuf myBuf;
			myBuf.Create (aComment.Length()+64);
			myBuf.Append (aComment );
			myBuf.AppendFormat(KTimeDiff, iTimeDifference.Int64());
		    LogIt(myBuf);
			myBuf.Close();
			iStartTime = 0;
			iEndTime = 0;			
			}