--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/applayerprotocols/httptransportfw/Test/Integration/src/testexplicitsessionstep.cpp	Tue Feb 02 01:09:52 2010 +0200
@@ -0,0 +1,196 @@
+// 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;
+	}