// 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:

//

/**

 @file

 @internalComponent

*/

#ifndef __OCSPHTTPFILTER_H__

#define __OCSPHTTPFILTER_H__

#include <http/mhttpfilter.h>

#include <http/rhttpsession.h>

#include <http/cecomfilter.h>

#include <http.h>

// Forward declarations

class TCustomDataSupplier;

/**

 * An http filter which logs the requests sent to the responder

 * @see MHTTPFilter

 */

class COCSPHTTPFilter : public CEComFilter, public MHTTPFilter

	{

public:

	/** Installs the user-agent filter

		@param  aSession the session to install the filter into.

		@return Pointer to the newly installed plugin

	*/

	static CEComFilter* InstallFilterL(TAny* aSession);

	~COCSPHTTPFilter();

	// Methods from MHTTPFilterBase

	virtual void MHFRunL(RHTTPTransaction aTransaction, const THTTPEvent& aEvent);

	virtual TInt MHFRunError(TInt aError, RHTTPTransaction aTransaction,

							 const THTTPEvent& aEvent);

	// Methods from MHTTPFilter

	virtual void MHFUnload(RHTTPSession aSession, THTTPFilterHandle aHandle);

	virtual void MHFLoad(RHTTPSession aSession, THTTPFilterHandle aHandle);

protected:

	COCSPHTTPFilter();

	void ConstructL(const RHTTPSession& aSession);

	// Log the transaction

	void LogTransactionStartL(const RHTTPTransaction& aTransaction);

	void LogTransactionEndL(const RHTTPTransaction& aTransaction);

	// Read test parameters using Publish & Subscribe method

	void ReadTestParameters(TInt& aNumDelayResp, TInt& aCountDropResp,

			TInt& aCountCorruptHTTPDataHeader, TInt& aCountCorruptHTTPDataBodySizeLarge, TInt& aCountCorruptHTTPDataBodySizeSmall,

			TInt& aCountCorruptOCSPData, 

			TInt& aCountInternalErrorResp, TInt& aCountTryLaterResp,

			TInt& aCountSigValidateFailure);

	// To maintain persistence between retry attempts store the updated counts back

	void WriteTestParameters(TInt aCountDropResp,

			TInt aCountCorruptHTTPDataHeader, TInt aCountCorruptHTTPDataBodySizeLarge, TInt aCountCorruptHTTPDataBodySizeSmall,

			TInt aCountCorruptOCSPData, 

			TInt aCountInternalErrorResp, TInt aCountTryLaterResp,

			TInt aCountSigValidateFailure);

protected:

 	RStringF     	iFilterName; // name of this filter (appears in filter lists)

	TInt         	iLoadCount;  // reference count - unloads filter when reaches 0

	RStringPool		iStringPool; // for the filter name

	RFs			 	iFs;

	RFile 		 	iLogFile;

	TBool		 	iLogLineCompleted; // To prevent double logging of end time

	TBool		 	iDataSupplied;

	// HTTP custom data supplier for returning canned responses

	TCustomDataSupplier* iCustomDataSupplier;

	};

/**

 * Custom HTTP body data supplier to send back canned responses

 * @see MHTTPDataSupplier

 */

class TCustomDataSupplier : public MHTTPDataSupplier

	{

public:

	TCustomDataSupplier(TPtrC8& aData, RHTTPTransaction& aTransaction);

public:

	// Methods from MHTTPDataSupplier

	TBool GetNextDataPart(TPtrC8& aDataPart);

	void ReleaseData();

	TInt OverallDataSize();

	TInt Reset();

private:

	TBool iDataSupplied;

	RHTTPTransaction* iTransaction;

	MHTTPDataSupplier* iOriginalSupplier;

	TPtrC8 iData;

	RBuf8 iCorruptData;

	};

#endif //__OCSPHTTPFILTER_H__