// Copyright (c) 2008-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 <es_enum.h>
#include "testexplicitsessionstep.h"

_LIT8(KProxy, "10.29.23.12:9003");

CTestExplicitSessionStep::CTestExplicitSessionStep()
	{
	SetTestStepName(KTestExplicitSessionStep); 
	}


CTestExplicitSessionStep::~CTestExplicitSessionStep()
	{
	}
	

void CTestExplicitSessionStep::StartClientL()
	{
	TPtrC uri;
	TInt iap = 0;
	
    if (!GetStringFromConfig(ConfigSection(), KIniUri, uri) ||
    	!GetIntFromConfig(ConfigSection(), KIAP, iap)
    	)
		{
		ERR_PRINTF3(_L("Problem in reading values from ini.			\
						\nExpected fields are: \n%S\n%d"
					  ),&KIniUri, iap);
		SetTestStepResult(EFail);
		return;
		}

	TBuf8<256> url8;
	url8.Copy(uri);
	TUriParser8 uriP; 
	uriP.Parse( url8 );

	iExplicitSession.OpenL(uriP, iap);
	iSession = iExplicitSession.HTTPSession();
	RStringPool strP = iSession.StringPool();
	
/*
	THTTPHdrVal val;
	RHTTPConnectionInfo cF = iSession.ConnectionInfo();
	cF.Property(strP.StringF(HTTP::EHttpSocketConnection, RHTTPSession::GetTable()), val);
	RConnection* conn = reinterpret_cast<RConnection*>(val.Int());
	TConnectionInfoBuf buf;
	conn->GetConnectionInfo(1, buf);
	TInt iapId = buf().iIapId;	
*/	
	
	RStringF method;
	iSession.ConnectionInfo().SetPropertyL(iSess.StringPool().StringF(HTTP::EProxyUsage,RHTTPSession::GetTable()), iSess.StringPool().StringF(HTTP::EUseProxy,RHTTPSession::GetTable()));
	RStringF proxy = iSession.StringPool().OpenFStringL(KProxy());
	CleanupClosePushL(proxy);
	iSession.ConnectionInfo().SetPropertyL(iSession.StringPool().StringF(HTTP::EProxyAddress,RHTTPSession::GetTable()), proxy);
	CleanupStack::PopAndDestroy(&proxy);

	
	method = strP.StringF(HTTP::EGET,RHTTPSession::GetTable());		
	TRAPD(err,InvokeHttpMethodL(url8, method));
	if (err != KErrNone)
		{
		ERR_PRINTF2(_L("Teststep Failed: Leave occured in CTestExplicitSessionStep::InvokeHttpMethodL: %D\n"
					  ),err
				   );
		SetTestStepResult(EFail);
		}
	method.Close(); 
	iExplicitSession.CancelStart();
	RHTTPSession ss = iExplicitSession();
	iExplicitSession.Close();

	iExplicitSession.OpenL(uriP, iap, EFalse);
	TRequestStatus iStatus = KRequestPending;
	iExplicitSession.StartConnection(iStatus);
	iExplicitSession.Close();
	
	iExplicitSession.OpenL(uriP, iap);
	iExplicitSession.Close();
	
	TRAP(err, iExplicitSession.OpenL(uriP, KConnectionTypeDefault));
	iStatus = KRequestPending;
	iExplicitSession.StartConnection(iStatus);
	iExplicitSession.Close();
	}


void CTestExplicitSessionStep::InvokeHttpMethodL(const TDesC8& aUri, RStringF aMethod)
	{
	TUriParser8 uri; 
	uri.Parse( aUri );
	
	iTrans = iSession.OpenTransactionL(uri, *this, aMethod);
	RHTTPHeaders hdr = iTrans.Request().GetHeaderCollection();

	iTrans.SubmitL();
	CActiveScheduler::Start();
	}


void CTestExplicitSessionStep::MHFRunL(RHTTPTransaction aTransaction, const THTTPEvent& aEvent)
	{
	switch (aEvent.iStatus)
		{
		case THTTPEvent::EGotResponseHeaders:
			{
			RHTTPResponse resp = aTransaction.Response();
			TInt status = resp.StatusCode();
			RStringF statusStr = resp.StatusText();
			TBuf<32> statusStr16;
			statusStr16.Copy(statusStr.DesC());
			INFO_PRINTF3(_L("Status: %D (%S)\n"),status, &statusStr16);

			if (resp.HasBody() && (status >= 200) && (status < 300) && (status != 204))
				{
				TInt dataSize = resp.Body()->OverallDataSize();
				if (dataSize >= 0)
					INFO_PRINTF2(_L("Response body size is %d\n"), dataSize);
				else
					INFO_PRINTF1(_L("Response body size is unknown\n"));
				}
			} break;
		case THTTPEvent::EGotResponseBodyData:
			{
			MHTTPDataSupplier* respBody;
			respBody = aTransaction.Response().Body();
			INFO_PRINTF1(_L("Receiving response body...\n"));
			
			TPtrC8 bodyData;
			respBody->GetNextDataPart(bodyData);
			respBody->ReleaseData();
			} break;
		case THTTPEvent::EResponseComplete:
			{
			INFO_PRINTF1(_L("\nTransaction Complete\n"));
			} break;
		case THTTPEvent::ESucceeded:
			{
			INFO_PRINTF1(_L("Transaction Successful\n"));
			aTransaction.Close();
			CActiveScheduler::Stop();
			} break;
		case THTTPEvent::EFailed:
			{
			INFO_PRINTF1(_L("Transaction Failed\n"));
			aTransaction.Close();
			CActiveScheduler::Stop();
			} break;
		case THTTPEvent::ERedirectedPermanently:
			{
			INFO_PRINTF1(_L("Permanent Redirection\n"));
			} break;
		case THTTPEvent::ERedirectedTemporarily:
			{
			INFO_PRINTF1(_L("Temporary Redirection\n"));
			} break;
		case THTTPEvent::ERedirectRequiresConfirmation:
 			{
			INFO_PRINTF1(_L("Redirect requires confirmation\n"));
 			aTransaction.Close();
 			CActiveScheduler::Stop();
 			} break;
		default:
			{
			INFO_PRINTF2(_L("<unrecognised event: %D>\n"), aEvent.iStatus);
			if (aEvent.iStatus < 0)
				{
				aTransaction.Close();
				CActiveScheduler::Stop();
				}
			} break;
		}
	}


TInt CTestExplicitSessionStep::MHFRunError(TInt aError, RHTTPTransaction /*aTransaction*/, const THTTPEvent& /*aEvent*/)
	{
	INFO_PRINTF2(_L("MHFRunError fired with error code %D\n"), aError);
	return KErrNone;
	}