// Copyright (c) 2001-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 "CHttpAccepTtestBase.h"
#include <http.h>

const TInt KNothingExpected = 0;


CHttpAcceptTestBase::CHttpAcceptTestBase()
	{
	iExpectedStatusCode=KNothingExpected;
	iExpectedError=KNothingExpected;
	

	}

void CHttpAcceptTestBase::DoRunL()
	{
	iOpenTransactionCount = 0;
	CleanupStack::PushL ( TCleanupItem ( CHttpAcceptTestBase::Cleanup, this ) );
	OpenTestSessionL(); // set up session and transaction here
	
	iTransaction.SubmitL();
	CleanupStack::Pop (); 
	CActiveScheduler::Start();
	CloseTestSession(); // close any strings, transaction and session
	if (iTestFail==1)
		{
		User::Leave(KErrNoMemory);
		}
	}
	
TInt CHttpAcceptTestBase::RunError(TInt aErr)
	{
	iEngine->Utils().LogIt(_L("\nTest failed with error code %d\n"), aErr);
	return KErrNone;
	}

void CHttpAcceptTestBase::DoCancel()
	{}

CHttpAcceptTestBase::~CHttpAcceptTestBase()
	{}	

void CHttpAcceptTestBase::Cleanup ( TAny* aPtr )
	{
	CHttpAcceptTestBase& httpTestBase = *( CHttpAcceptTestBase* )aPtr;
 	httpTestBase.CloseTestSession ();
	}


/** set this object active */
void CHttpAcceptTestBase::CompleteOwnRequest()
	{
	TRequestStatus* stat = &iStatus;
	User::RequestComplete(stat,KErrNone);	
	if (!IsActive())
		SetActive();
	}


TInt CHttpAcceptTestBase::MHFRunError(TInt aError, 
										RHTTPTransaction /*aTransaction*/,
										const THTTPEvent& /*aEvent*/)
	{
	iEngine->Utils().LogIt(_L("\nTest failed with error code %d\n"), aError);
	return KErrNone;
	}


// validates a response against all expected outcomes
void CHttpAcceptTestBase::Validate(RHTTPTransaction aTransaction)
	{
	if (iExpectedNumberRedirects)
		{
		THTTPHdrVal hdr;
		TBool hasValue;
		RStringPool strP = aTransaction.Session().StringPool();
		hasValue = aTransaction.PropertySet().Property(strP.StringF(HTTP::ERedirectCount,RHTTPSession::GetTable()), hdr);
		if (hasValue && hdr.Int() != iExpectedNumberRedirects)
			{
			iTestFail = 1;
			iEngine->Utils().LogIt(_L("<Number of Redirects don't match expected number>\n"));
			}
		}
	}

void CHttpAcceptTestBase::MHFRunL(RHTTPTransaction aTransaction,
						 const THTTPEvent& aEvent)
	{
	if (aEvent.iStatus < 0)
		{
		if (aEvent.iStatus == iExpectedError)
			{
			iEngine->Utils().LogIt(_L("<The error event %d was expected>\n"), aEvent.iStatus);
			iExpectError = ETrue;
			}
		else 
			{
			iTestFail = 1;
			iEngine->Utils().LogIt(_L("<The error event %d was not expected>\n"), aEvent.iStatus);
			}
			if ( aEvent.iStatus != KErrNoMemory )			
		return;
		}

	switch (aEvent.iStatus)
		{
	case THTTPEvent::EGotResponseHeaders:
		{
		// HTTP response headers have been received
		iEngine->Utils().LogIt(_L("<EGotResponseHeaders (%d)\n"),aEvent.iStatus);
		
		TInt  statusCode = aTransaction.Response().StatusCode();
		iEngine->Utils().LogIt(_L("Status Code: %d \n"),statusCode);
		DumpRespHeaders(aTransaction);
		iEngine->SetCurrentStatusCode(aTransaction.Response().StatusCode());
		if (iExpectedStatusCode !=KNothingExpected && iExpectedStatusCode != aTransaction.Response().StatusCode() &&
			iExpectedStatusCode < THTTPEvent::ERedirectedPermanently)
			{
			iTestFail= ETrue;
			iEngine->Utils().LogIt(_L("<Unexpected status code: %d, Expected was %d>\n"), statusCode,iExpectedStatusCode);
			}
		else
			{
			iTestFail = EFalse;
			}
 		// To verify ETransferEncoding header field is removed from the response header
 		// on receiving the value of EChunked in it
 		THTTPHdrVal tmpVal;
 		RStringPool strP = aTransaction.Session().StringPool();
 			
 		if(aTransaction.Response().GetHeaderCollection().GetField(strP.StringF(
 			HTTP::ETransferEncoding,RHTTPSession::GetTable()),0,tmpVal) == KErrNone)
 			{
 			if(tmpVal.StrF().Index(RHTTPSession::GetTable()) == HTTP::EChunked ) 
				{
 				iEngine->Utils().LogIt(_L("EChunked Detected in Header. Hence the Test Fails"));
				iTestFail= ETrue;
				}
 			}
 		} break;
	case THTTPEvent::EGotResponseBodyData:
		{
		// Some (more) body data has been received (in the HTTP response)
		iEngine->Utils().LogIt(_L("<EGotResponseBodyData received (%d)>\n"),aEvent.iStatus);
		// for each chunk of data received we have to empty the buffer before to be able to receive 
		MHTTPDataSupplier* body = aTransaction.Response().Body();
		body->ReleaseData();
		} break;
	case THTTPEvent::EResponseComplete:
		{
		// The transaction's response is complete
		iEngine->Utils().LogIt(_L("<EResponseComplete received (%d)>\n"),aEvent.iStatus);
		} break;
	case THTTPEvent::ESucceeded:
		{
		if (iExpectedError < 0 && (!iExpectError))
			{
			iEngine->Utils().LogIt(_L("<Expected Error Code Not Recieved (%d)>\n"),iExpectedError);
			iTestFail = ETrue;
			}
		else
			{
			iTestFail = EFalse;
			}
		iEngine->Utils().LogIt(_L("<ESucceeded received from the VF (%d)>\n"),aEvent.iStatus);
		if (--iOpenTransactionCount == 0)	
			CActiveScheduler::Stop();
		} break;
	case THTTPEvent::EFailed:
		{
		iEngine->Utils().LogIt(_L("<EFailed received from the VF (%d)>\n"),aEvent.iStatus);
		Validate(aTransaction);
		if (--iOpenTransactionCount == 0)
			CActiveScheduler::Stop();
		} break;
	case KErrHttpRequestHasBody:
		iEngine->Utils().LogIt(_L("<KErrHttpRequestHasBody  received from the VF (%d)>\n"),aEvent.iStatus);
		break;
	case KErrHttpEntityHeaderMissingContentType:
		iEngine->Utils().LogIt(_L("<KErrHttpEntityHeaderMissingContentType  received from the VF (%d)>\n"),aEvent.iStatus);
		break;
	case KErrHttpRequestBodyMissing:
		{
		iEngine->Utils().LogIt(_L("<KErrHttpRequestBodyMissing  received from the VF(%d)>\n"),aEvent.iStatus);
		} break;
	case KErrTimedOut:							//-33
		{
		iEngine->Utils().LogIt(_L("<KErrTimedOut  received from the VF (%d)>\n"),aEvent.iStatus);
		if ((iExpectedError != 0) && (iExpectedError != KErrTimedOut))	
			{
			iTestFail = 1;
			iEngine->Utils().LogIt(_L("<The event received will cause a failure (%d)>\n"),aEvent.iStatus);
			}
		} break;
	case KErrHttpRedirectExceededLimit:			
		{
		iEngine->Utils().LogIt(_L("<KErrHttpRedirectExceededLimit received (%d)>\n"),aEvent.iStatus);
		if ((iExpectedError != 0) && (iExpectedError != KErrHttpRedirectExceededLimit))	
			{
			iTestFail = 1;
			iEngine->Utils().LogIt(_L("<The event received will cause a failure>\n"));
			}
		} break;
	case KErrHttpRedirectNoLocationField:	
		{
		iEngine->Utils().LogIt(_L("<KErrHttpRedirectNoLocationField received (%d)>\n"),aEvent.iStatus);
		if ((iExpectedError != 0) && (iExpectedError != KErrHttpRedirectNoLocationField))
			{
			iTestFail = 1;
			iEngine->Utils().LogIt(_L("<The event received will cause a failure>\n"));
			}
		} break;

	// 301( Moved Permanently) or 302(Found) or 307(Temporary Redirect) status code is 
	// obtained for a transaction with a method other than GET or HEAD and hence this event
	// has been sent by the filter.
	case THTTPEvent::ERedirectRequiresConfirmation:			
 		{
 		iEngine->Utils().LogIt(_L("<Redirect requires confirmation (%d)>\n"),aEvent.iStatus);
 		// Client has opted to Submit the transaction
		if(iExpectedStatusCode==200)
 			aTransaction.SubmitL();
 		else
		// client has opted to close the transaction
 			{
 			if (--iOpenTransactionCount == 0)
 				CActiveScheduler::Stop();
 			}
 		} break;
	case THTTPEvent::EGotResponseTrailerHeaders:
		{
		iEngine->Utils().LogIt(_L("<EGotResponseTrailerHeaders received (%d)>\n"),aEvent.iStatus);
		}
		break;
	default:
		{
		iEngine->Utils().LogIt(_L("<unrecognised event>\n %d"),aEvent.iStatus);
		if (aEvent.iStatus < THTTPEvent::ERedirectedPermanently)
			{
			iTestFail=1;
			iEngine->Utils().LogIt(_L("Test Failed: The event received was not expected and it's not just a warning\n"));
			iEngine->PressAnyKey();
			}
		} 
		break;
		}
	}