--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/common/tools/ats/smoketest/http/src/testhttpeboclientconditionalstep.cpp Wed Jan 06 13:41:51 2010 +0000
@@ -0,0 +1,314 @@
+// Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "Symbian Foundation License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.symbianfoundation.org/legal/sfl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+// Contains implementation of CHttpEboClientStep class
+// @internalAll
+//
+//
+
+// User Include
+#include "testhttpeboclientconditionalstep.h"
+
+// Standard headers used by default
+_LIT8(KUserAgent, "TestHttpEboClientConditional");
+_LIT8(KAccept, "*/*");
+_LIT8(KHttpUrl1, "http://www.google.co.in/");
+_LIT8(KHttpUrl2, "http://www.live.com/");
+_LIT8(KHttpUrl3, "http://www.search.com/");
+_LIT8(KHttpUrl4, "http://www.find.com/");
+
+/**
+Constructor: Sets the test step name.
+@internalTechnology
+@test
+*/
+CHttpEboClientConditionalStep::CHttpEboClientConditionalStep()
+ {
+
+ //Call base class method to set human readable name for test step
+ SetTestStepName(KTestHttpEboClientConditionalStep);
+ }
+
+
+/**
+Destructor
+@internalTechnology
+@test
+*/
+CHttpEboClientConditionalStep::~CHttpEboClientConditionalStep()
+ {
+ }
+
+
+/**
+Sets the proxy and HttpDataOptimiser implemetation to session
+based on the patameter values in ini file and calls InvokeHttpMethodL()
+@internalTechnology
+@test
+@param None
+@return None
+*/
+void CHttpEboClientConditionalStep::StartClientL()
+ {
+ if (!GetBoolFromConfig(ConfigSection(), KDisableTransOpt, iDisableTransOpt))
+ {
+ ERR_PRINTF2(_L("Problem in reading values from ini. \
+ \nExpected fields are: \n%S\n"
+ ),&KDisableTransOpt);
+ SetTestStepResult(EFail);
+ return;
+ }
+
+ RStringPool strP = iSess.StringPool();
+ RStringF method;
+
+ // method
+ method = strP.StringF(HTTP::EGET,RHTTPSession::GetTable());
+ TBuf8<256> url8;
+ TRAPD(err,InvokeHttpMethodL(url8, method));
+ if (err != KErrNone)
+ {
+ ERR_PRINTF2(_L("Teststep Failed: Leave occured in CTestHttpBufferSizeStep::InvokeHttpMethodL: %D\n"
+ ),err
+ );
+ SetTestStepResult(EFail);
+ }
+ method.Close();
+ }
+
+/**
+Invoke the http method
+This actually creates the transaction, sets the headers and HttpDataOptimiser implemetation to transaction
+and then starts the transaction
+@internalTechnology
+@test
+@param aUri Requested uri
+@param aMethod Requested method
+@return None
+*/
+void CHttpEboClientConditionalStep::InvokeHttpMethodL(const TDesC8& /*aUri*/, RStringF aMethod)
+ {
+ TUriParser8 uri1;
+ uri1.Parse( KHttpUrl1 );
+
+ // Opening transactions
+ RHTTPTransaction trans1 = iSess.OpenTransactionL(uri1, *this, aMethod);
+ CleanupClosePushL(trans1);
+ RHTTPHeaders hdr1 = trans1.Request().GetHeaderCollection();
+ SetHeaderL(hdr1, HTTP::EUserAgent, KUserAgent);
+ SetHeaderL(hdr1, HTTP::EAccept, KAccept);
+
+ TUriParser8 uri2;
+ uri2.Parse( KHttpUrl2 );
+ RHTTPTransaction trans2 = iSess.OpenTransactionL(uri2, *this, aMethod);
+ CleanupClosePushL(trans2);
+ RHTTPHeaders hdr2 = trans2.Request().GetHeaderCollection();
+ SetHeaderL(hdr2, HTTP::EUserAgent, KUserAgent);
+ SetHeaderL(hdr2, HTTP::EAccept, KAccept);
+
+ TUriParser8 uri3;
+ uri3.Parse( KHttpUrl3 );
+ RHTTPTransaction trans3 = iSess.OpenTransactionL(uri3, *this, aMethod);
+ CleanupClosePushL(trans3);
+ RHTTPHeaders hdr3 = trans3.Request().GetHeaderCollection();
+ SetHeaderL(hdr3, HTTP::EUserAgent, KUserAgent);
+ SetHeaderL(hdr3, HTTP::EAccept, KAccept);
+
+ TUriParser8 uri4;
+ uri4.Parse( KHttpUrl4 );
+ RHTTPTransaction trans4 = iSess.OpenTransactionL(uri4, *this, aMethod);
+ CleanupClosePushL(trans4);
+ RHTTPHeaders hdr4 = trans4.Request().GetHeaderCollection();
+ SetHeaderL(hdr4, HTTP::EUserAgent, KUserAgent);
+ SetHeaderL(hdr4, HTTP::EAccept, KAccept);
+
+ if (iDisableTransOpt)
+ {
+ iSess.SetupHttpDataOptimiser(*this);
+ THTTPHdrVal disableOptimiser(iSess.StringPool().StringF(HTTP::EDisableHTTPTransOptimiser,RHTTPSession::GetTable()));
+ trans3.PropertySet().SetPropertyL(iSess.StringPool().StringF(HTTP::EHTTPTransOptimiser,RHTTPSession::GetTable()), disableOptimiser);
+ }
+ else
+ {
+ trans1.SetupHttpDataOptimiser(*this);
+ trans2.SetupHttpDataOptimiser(*this);
+ trans4.SetupHttpDataOptimiser(*this);
+ }
+
+ trans1.SubmitL();
+ CActiveScheduler::Start();
+
+ trans2.SubmitL();
+ CActiveScheduler::Start();
+
+ trans3.SubmitL();
+ CActiveScheduler::Start();
+
+ trans4.SubmitL();
+ CActiveScheduler::Start();
+
+ CleanupStack::Pop(&trans4);
+ CleanupStack::Pop(&trans3);
+ CleanupStack::Pop(&trans2);
+ CleanupStack::Pop(&trans1);
+ }
+
+/**
+This is the implementation of interface method MHttpDataOptimiser::MHFRunL
+If there is a reponse body it will be copied to a file.
+Just printing the fired events to the log file.
+@internalTechnology
+@test
+@param aTransaction Transaction which is being processed currently
+@param THTTPEvent Event for which it is called
+@return None
+*/
+void CHttpEboClientConditionalStep::MHFRunL(RHTTPTransaction aTransaction, const THTTPEvent& aEvent)
+ {
+ switch (aEvent.iStatus)
+ {
+ case THTTPEvent::EGotResponseHeaders:
+ {
+ INFO_PRINTF2(_L("Processing Transaction %d\n"), aTransaction.Id());
+ 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:
+ {
+ // Get the body data supplier
+ iRespBody = aTransaction.Response().Body();
+ INFO_PRINTF1(_L("Receiving response body...\n"));
+
+ TPtrC8 bodyData;
+ TBool lastChunk = iRespBody->GetNextDataPart(bodyData);
+ if(bodyData.Size() > iChunkSize)
+ {
+ iChunkSize = bodyData.Size();
+ }
+ iRespBody->ReleaseData();
+ } break;
+ case THTTPEvent::EResponseComplete:
+ {
+ // The transaction's response is complete
+ INFO_PRINTF1(_L("\nTransaction Complete\n"));
+ } break;
+ case KErrHttpOptimiserFailsTrans:
+ {
+ INFO_PRINTF1(_L("Cancelling/Failing Transaction\n"));
+ aTransaction.Fail(THTTPFilterHandle::EProtocolHandler);
+ //CActiveScheduler::Stop();
+ } 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:
+ {
+ // 301(Moved Permanently), 302(Found) or 307(Temporary Redirect) status is received
+ // from a transaction and hence ERedirectRequiresConfirmation is sent by filter
+ // client has opted to close the transaction
+ INFO_PRINTF1(_L("Redirect requires confirmation\n"));
+ aTransaction.Close();
+ CActiveScheduler::Stop();
+ } break;
+ default:
+ {
+ INFO_PRINTF2(_L("<unrecognised event: %D>\n"), aEvent.iStatus);
+ // close off the transaction if it's an error
+ if (aEvent.iStatus < 0)
+ {
+ aTransaction.Close();
+ CActiveScheduler::Stop();
+ }
+ } break;
+ }
+ }
+
+
+/**
+This is the implementation of interface method MHttpDataOptimiser::MHFRunError
+@internalTechnology
+@test
+@param aError Error which has been raised.
+@param aTransaction Transaction which is being processed currently
+@param THTTPEvent Event which it is being handled currently.
+@return None
+*/
+TInt CHttpEboClientConditionalStep::MHFRunError(TInt aError, RHTTPTransaction /*aTransaction*/, const THTTPEvent& /*aEvent*/)
+ {
+ INFO_PRINTF2(_L("MHFRunError fired with error code %D\n"), aError);
+ return KErrNone;
+ }
+
+
+/**
+It enocodes the request data.
+@internalTechnology
+@test
+@param aHttpData Actual request.
+@param aEncodedData Encoded request.
+@return None
+*/
+void CHttpEboClientConditionalStep::EncodeL (const TDesC8& aHttpData, HBufC8* &aEncodedData)
+ {
+ INFO_PRINTF1(_L("######## CHttpEboClientStep::EncodeL ########\n"));
+ aEncodedData = aHttpData.AllocLC();
+ CleanupStack::Pop();
+ INFO_PRINTF1(_L("Encoded/Changed the request\n"));
+ }
+
+
+/**
+It decodes the responsing data before parsing.
+@internalTechnology
+@test
+@param aHttpData Actual response.
+@param aEncodedData Decoded response.
+@return None
+*/
+void CHttpEboClientConditionalStep::DecodeL (const TDesC8& aData, HBufC8*& aHttpData, TBool& /*aTransFail*/)
+ {
+ INFO_PRINTF1(_L("######## CHttpEboClientStep::DecodeL ########\n"));
+ aHttpData = aData.AllocLC();
+ CleanupStack::Pop();
+ INFO_PRINTF1(_L("Sent the actual response as a decoded response\n"));
+ }