// 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 <minputstream.h>

#include <moutputstream.h>

#include "CTestServerStreamManager.h"

#include "httptestutils.h"

#include "MPipeliningTestCase.h"

#include "ctestcasepipelinefallback.h"

const TInt KTimeOut = 50000000;

const TInt KResponseBatchSize = 5;

_LIT8(KTxtConnectionClose, "Connection: Close");

CTestServerStreamManager* CTestServerStreamManager::NewL(CHTTPTestUtils& aTestUtils, TInt aConnectionIndex, MPipeliningTestCase* aTestCase, MInputStream* aInputStream, MOutputStream* aOutputStream)

	{

	CTestServerStreamManager* self = new (ELeave) CTestServerStreamManager(aTestUtils, aConnectionIndex, aTestCase, aInputStream, aOutputStream);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CTestServerStreamManager::CTestServerStreamManager(CHTTPTestUtils& aTestUtils, TInt aConnectionIndex, MPipeliningTestCase* aTestCase, MInputStream* aInputStream, MOutputStream* aOutputStream)

: CTimer(EPriorityNormal), iTestUtils(aTestUtils), iInputStream(aInputStream), iOutputStream(aOutputStream), iTestCase(aTestCase), iConnectionIndex(aConnectionIndex)

	{

	CActiveScheduler::Add(this);

	iTransCount = iTestCase->TransactionCount(iConnectionIndex);

	iInputStream->Bind(*this);

	iOutputStream->Bind(*this);

	}

CTestServerStreamManager::~CTestServerStreamManager()

	{

	Cancel();

	if(iInputStream!=NULL)

		iInputStream->Close();

	if(iOutputStream!=NULL)

		iOutputStream->Close();

	delete iDataStore;

	delete iDataToSend;

	delete iHttpTimer;

	delete iASW;

	}

void CTestServerStreamManager::ConstructL()

	{

	CTimer::ConstructL();

	iHttpTimer = new(ELeave) CHttpTimer(*this);

	iASW = new(ELeave) CActiveSchedulerWait();

	}

// From MInputStreamObserver

void CTestServerStreamManager::ReceivedDataIndL(const TDesC8& aBuffer)

	{

	// Got data

	_LIT(KTxtGotData, "Server - received request data.");

	iTestUtils.LogIt(KTxtGotData());

	iTestUtils.DumpData(aBuffer, ETrue);

	if(iDataStore==NULL)

		iDataStore = aBuffer.AllocL(); // First data chunk received

	else

		{

		// Already got data before so append the data to the existing data

		TInt newLength = (iDataStore->Length()) + aBuffer.Length();

		iDataStore = iDataStore->ReAllocL( newLength );

		TPtr8 buf = iDataStore->Des();

		buf.Append(aBuffer);

		}

	iInputStream->ReceivedDataRes();

	_LIT(KTxtTitle, "Defect Fix INC036954");

	if (iTestCase->TestCaseName().Match(KTxtTitle) == 0)

		{

		iInputStream->ShutdownReq();

		}

	else

		{

		// Try processing the requests

		SendDataL();

		}

	}

void CTestServerStreamManager::SecureServerCnf()

	{

	}

void CTestServerStreamManager::InputStreamCloseInd(TInt aError)

	{

	_LIT(KTxtInputClosed, "Server - Input stream %d closed. Error: %d.");

	iTestUtils.LogIt(KTxtInputClosed(), iConnectionIndex+1, aError);

	iInputStream = NULL;

	}

void CTestServerStreamManager::MInputStreamObserver_Reserved()

	{

	User::Invariant();

	}

// From MOutputStreamObserver

void CTestServerStreamManager::SendDataCnfL()

	{

	_LIT(KTxtDataSent, "Server - Data Sent.");

	iTestUtils.LogIt(KTxtDataSent());

	if( iMoreResponseBatches )

		{

		// If there is more batches to process try and process them

		iMoreResponseBatches = EFalse;

		TRAPD(err, SendDataL());

		if(err!=KErrNone)

			{

			_LIT(KTxtSendError, "Server - Error %d sending data. Closing stream.");

			iTestUtils.LogIt(KTxtSendError(), err);

			iInputStream->ShutdownReq();

			}

		}

	else

		{

		delete iDataToSend;

		iDataToSend = NULL;

		// Do we need to close the connection

		if(iCloseConnection)

			{

			_LIT(KTxtCloseConn, "Server - Closing connection.");

			iTestUtils.LogIt(KTxtCloseConn());

			if( (iTestCase->TestCaseName().Match(_L("Test Case 3")) == 0) || (iTestCase->TestCaseName().Match(_L("CINC073400")) == 0) || (iTestCase->TestCaseName().Match(_L("Test Case 19")) == 0) )

				{

				TTimeIntervalMicroSeconds32 time(5000000);

				iHttpTimer->After(time);

				iASW->Start();

				}

			if(iInputStream)

				iInputStream->ShutdownReq();

			}

			_LIT(KTxtTitle, "Defect Fix CINC077703");

		if (iTestCase->TestCaseName().Match(KTxtTitle) == 0)

			{

			iInputStream->ShutdownReq();

			}

		}

	}

void CTestServerStreamManager::SecureClientCnf()

	{

	}

void CTestServerStreamManager::OutputStreamCloseInd(TInt aError)

	{

	_LIT(KTxtOutputClosed, "Server - Output stream %d closed. Error: %d.");

	iTestUtils.LogIt(KTxtOutputClosed(), iConnectionIndex+1, aError);

	iOutputStream = NULL;

	}

void CTestServerStreamManager::MOutputStreamObserver_Reserved()

	{

	}

TBool CTestServerStreamManager::ProcessRequestL()

	{

	TBool processingRequest = ETrue;

	TInt currentBatch = 0;

	_LIT(KDefectTitle, "Defect Fix CDEF143497");

   while((iTestCase->TestCaseName().Match(KDefectTitle) == 0) && (processingRequest && (iCurrentTrans <= iTransCount)) && (currentBatch<KResponseBatchSize))

    	{

    	// Do we have enough data to respond to the current transaction?

		TPtrC8 rawRequest = iTestCase->GetRawRequest(iConnectionIndex, iCurrentTrans);

		TInt requestLength = rawRequest.Length();

		TPtrC8 dataWindow = iDataStore->Mid(iDataPos);        

        // Prepare the response data to send

        iDataPos += requestLength;

        processingRequest = ETrue;

        TPtrC8 rawResponse = iTestCase->GetRawResponse(iConnectionIndex, iCurrentTrans);

        if(iDataToSend==NULL)

        iDataToSend = rawResponse.AllocL();

        else

        {

        TInt responseLength = rawResponse.Length();

        iDataToSend = iDataToSend->ReAllocL( (iDataToSend->Length()) + responseLength );

        TPtr8 buffer = iDataToSend->Des();

        buffer.Append(rawResponse);

        }

        // Check for a Connection: Close in the request

        iCloseConnection = IsConnectionCloseInData(rawRequest, rawResponse);

        if(iCloseConnection)

        processingRequest = EFalse;

        ++iCurrentTrans;

        ++currentBatch;

        if( processingRequest && currentBatch==KResponseBatchSize)

            iMoreResponseBatches = ETrue;

        else

            iMoreResponseBatches = EFalse;

		if(iDataToSend!=NULL)

		return ETrue;

		return EFalse;            

		} 

	while( (processingRequest && (iCurrentTrans < iTransCount)) && (currentBatch<KResponseBatchSize) )

		{

		// Do we have enough data to respond to the current transaction?

		TPtrC8 rawRequest = iTestCase->GetRawRequest(iConnectionIndex, iCurrentTrans);

		TInt requestLength = rawRequest.Length();

		TPtrC8 dataWindow = iDataStore->Mid(iDataPos);

		// Test pipeline fallback scenario

	    _LIT(KTxtTitle, "Test Case Pipeline Fallback");

	    if (iTestCase->TestCaseName().Match(KTxtTitle) == 0)

	        {

	        CTestCasePipelineFallback* pipelineFallback = (CTestCasePipelineFallback*)(iTestCase);

	        if(pipelineFallback->FallingBack())

	            {

	            _LIT(KTxtSendError, "Fallingback .");

	            iTestUtils.LogIt(KTxtSendError());

	            // we are fallingback. We should receive the exact request size as we

	            // will be processing the request one by one

	            if(dataWindow.Length() > requestLength)

	                {

	                User::Leave(KErrCancel);

	                }	            

	            }

	        else

	            {

                _LIT(KTxtSendError, "Not Fallingback.");

                iTestUtils.LogIt(KTxtSendError());

	            // If we are not fallingback then we need to close the connection twice

	            // We are pipelining as well as batching. Shutdown the connection

	            // First time we get only one request. Just process.

	            if(dataWindow.Length() > requestLength)

	                {

	                _LIT(KTxtSendError, "Incremented and shutdown.");

	                iTestUtils.LogIt(KTxtSendError());

	                // We have to shut down 2 times

	                iInputStream->ShutdownReq();

	                pipelineFallback->IncFallingBack();

	                break;

	                }	            

	            }

	        }

		if( requestLength <= dataWindow.Length() )

			{

			// Check that the raw request and the actual request match

			if( dataWindow.FindF(rawRequest) != 0 )

				{

				_LIT(KTxtRequestDataMismatch, "Server - Fail. Request data for transaction %d does not match expected data.");

				iTestUtils.LogIt(KTxtRequestDataMismatch(), iCurrentTrans+1);

				_LIT(KTxtExpectedData, "Server - Expected data: %S");

				iTestUtils.LogIt(KTxtExpectedData(), &rawRequest);

				iTestUtils.LogIt(KTxtExpectedData(), &dataWindow);

				User::Leave(KErrNotFound);

				}

			// Prepare the response data to send

			iDataPos += requestLength;

			processingRequest = ETrue;

			TPtrC8 rawResponse = iTestCase->GetRawResponse(iConnectionIndex, iCurrentTrans);

			if(iDataToSend==NULL)

				iDataToSend = rawResponse.AllocL();

			else

				{

				TInt responseLength = rawResponse.Length();

				iDataToSend = iDataToSend->ReAllocL( (iDataToSend->Length()) + responseLength );

				TPtr8 buffer = iDataToSend->Des();

				buffer.Append(rawResponse);

				}

			// Check for a Connection: Close in the request

			iCloseConnection = IsConnectionCloseInData(rawRequest, rawResponse);

			if(iCloseConnection)

				processingRequest = EFalse;

			++iCurrentTrans;

			++currentBatch;

			}

		else

			{

			// No more requests can be processed

			processingRequest = EFalse;

			}

		// Flag that we have more processing to do with we are still processing the data

		// but we have reached the maximum batch size.

		if( processingRequest && currentBatch==KResponseBatchSize)

			iMoreResponseBatches = ETrue;

		else

			iMoreResponseBatches = EFalse;

		}

	if(iDataToSend!=NULL)

		return ETrue;

	return EFalse;

	}

TBool CTestServerStreamManager::IsConnectionCloseInData(const TDesC8& aRequest, const TDesC8& aResponse) const

	{

	if( (aRequest.FindF(KTxtConnectionClose()) != KErrNotFound) || (aResponse.FindF(KTxtConnectionClose()) != KErrNotFound) )

		{

		// Either the request or response has Connection: Close header

		_LIT(KTxtConnectionCloseDetected, "Server - Connection: Close detected in request or response, transaction: %d");

		iTestUtils.LogIt(KTxtConnectionCloseDetected(), iCurrentTrans+1);

		return ETrue;

		}

	return EFalse;

	}

void CTestServerStreamManager::SendDataL()

	{

	Cancel();

	_LIT(KTcTitle, "CRecvTimeOut");

	if (iTestCase->TestCaseName().Match(KTcTitle) == 0)

		{

		_LIT(KTxtTimeout, "Server - Data Send Timeout.");

		iTestUtils.LogIt(KTxtTimeout());

		After(61000000);

		return;

		}

	if( !iMoreResponseBatches )

		{

		// Try processing the requests

		if( ProcessRequestL() )

			{

			// We have enough, send the response.

			iOutputStream->SendDataReqL(*iDataToSend);

			_LIT(KTxtSendData, "Server - Sending response data.");

			iTestUtils.LogIt(KTxtSendData());

			iTestUtils.DumpData(*iDataToSend, ETrue);

			}

		else

			{

			After(KTimeOut); // Start the inactivity timer

			}

		}

	}

void CTestServerStreamManager::RunL()

	{

	_LIT(KTcTitle, "CRecvTimeOut");

	if (iTestCase->TestCaseName().Match(KTcTitle) == 0)

		{

		_LIT(KTxtTimeout, "TC-Receive Timeout Timer RunL.");

		iTestUtils.LogIt(KTxtTimeout());

		return;

		}

	if( iStatus.Int() == KErrNone )

		{

		// The connection has timed out.

		_LIT(KTxtTimedOut, "Server - Fail, Connection %d timed out. Current transaction: %d");

		iTestUtils.LogIt(KTxtTimedOut(), iConnectionIndex+1, iCurrentTrans+1);

		iInputStream->ShutdownReq();

		}

	}

MHttpResponse* CTestServerStreamManager::CurrentResponse()

	{

	return NULL;

	}

void CTestServerStreamManager::OnReceiveTimeOut()

	{

	}

void CTestServerStreamManager::OnSendTimeOut()

	{

	}

TInt CTestServerStreamManager::SendTimeOutVal()

	{

	return 0;

	}

void CTestServerStreamManager::TimeOut()

	{

	iASW->AsyncStop();	

	}

CHttpTimer::CHttpTimer(MTimerClient& aClient)

:CActive(EPriorityStandard), iClient(aClient)

	{

	CActiveScheduler::Add(this);

	iTimer.CreateLocal();

	}

CHttpTimer::~CHttpTimer()

	{

	Cancel();

	iTimer.Close();	

	}

void CHttpTimer::After(TTimeIntervalMicroSeconds32 anInterval)

	{

	iTimer.After(iStatus, anInterval);	

	SetActive();

	}

void CHttpTimer::DoCancel()

	{

	}

void CHttpTimer::RunL()

	{

	iClient.TimeOut();

	}