// Copyright (c) 2003-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:
//

#ifndef __CHTTPCLIENTHANDLER_H__
#define __CHTTPCLIENTHANDLER_H__

#include <e32base.h>
#include <http/framework/cprotocolhandler.h>
#include <http/framework/mrxdataobserver.h>
#include <http/framework/logging.h>

#include "mconnectionprefsprovider.h"
#include "mhttpbatchingpropertiescallback.h"
#include "timerlogger.h"

class CHttpTransportLayer;
class CHttpConnectionInfo;
class CHttpConnectionManager;
class CX509Certificate;
class CX500DistinguishedName;
class TCertInfo;
class TDNInfo;
class CHttpPipelineFallback;

/**
 * Enumeration for NTLM authentication state.
 */
enum {
        ENtlmIdle,
        ENtlmNegotiate,
        ENtlmAuthenticate
    };

class CHttpClientHandler : public CProtocolHandler, 
						   public MConnectionPrefsProvider,
						   public MRxDataObserver,
						   public MHttpBatchingPropertiesCallback,
						   public MProtHandlerInterface

	{
public:

	static CHttpClientHandler* NewL(TAny* aSession);
	virtual ~CHttpClientHandler();

private:	// methods from CProtocolHandler
	virtual void MHFRunL(RHTTPTransaction aTransaction, const THTTPEvent& aEvent);
	virtual TInt SessionServerCert(TCertInfo& aServerCert);
	virtual TInt TransactionServerCert(TCertInfo& aServerCert, RHTTPTransaction aTransaction);
	virtual void CreateCodecL();
	virtual CProtTransaction* CreateProtTransactionL(RHTTPTransaction aTransaction) ;
	virtual TBool ServiceL(CProtTransaction& aTrans);
	virtual void ClosedTransactionHook(CProtTransaction* aTrans);
	virtual void CancelTransactionHook(CProtTransaction& aTransaction);
	virtual void NotifyNewRequestBodyPart(CProtTransaction& aTransaction);
	virtual void GetInterfaceL(TUid aInterfaceId, MProtHandlerInterface*& aInterfacePtr);
	
private:	// methods from MConnectionPrefsProvider

	virtual TBool SupplyCommsConnection( RConnection*& aConnectionPtr );
	virtual TBool SupplySocketServerHandle ( TInt& aSocketServerHandle );
	virtual void SetCommsConnectionL( RConnection* aConnectionPtr );
	virtual void SetSocketServerHandleL ( TInt aSocketServerHandle );
	virtual void GetSecurityPrefs( TBool& aDialogPrompt, MSecurityPolicy*& aSecurityPolicy );
	virtual TBool ImmediateSocketShutdown();
	virtual TInt SessionId();
	virtual TInt GetRecvBufferSize();
	virtual TInt GetSocketImmediateCloseTimeout();

private:	// methods from MRxDataObserver
	
	virtual void SetStatusL(CRxData& aRxData, TInt aStatus);	

private:	// methods from MHttpBatchingPropertiesCallback

	virtual TInt GetMaxBatchingBufferSize();
	
private:	// methods from MProtHandlerInterface

	virtual const CCertificate* TransactionServerCert(RHTTPTransaction aTransaction);
	virtual const CCertificate*  SessionServerCert();

private:

	CHttpClientHandler(RHTTPSession aSession);
	void ConstructL();	
	
	CHttpConnectionInfo* PrepareTransactionL(RHTTPTransaction aTrans, TBool& aNeedTunnel, TBool& aCanPipeline);
	void CreateRequestUriL(TInt aMethodIndex, RHTTPTransaction aTrans, TPtrC8& aHost, TInt& aPort);
	TBool SetHostHeaderL(RHTTPTransaction aTrans, const TDesC8& aHost, TInt aPort);
	void AddTunnelInfoL(RHTTPTransaction aTrans, const TDesC8& aHost, TInt aPort);
	TBool SelectConnectionManagerL(const CHttpConnectionInfo& aConnectionInfo, RHTTPTransaction aTrans, TBool aCanPipeline, CHttpConnectionManager *&aManager);
	CHttpConnectionManager* SelectTunnelConnectionL(const CHttpConnectionInfo& aConnectionInfo, RHTTPTransaction aTrans, TBool aCanPipeline);
	CHttpConnectionManager* SelectNtlmConnectionL(const CHttpConnectionInfo& aConnectionInfo,RHTTPTransaction aTrans);
	TInt MaxNumConnectionManagers() const;
	void SetupProxyInformation(RHTTPTransaction aTrans);
	TBool CheckPipelineSupport(RHTTPTransaction aTrans);
	
	void GetCipherSuiteL(RHTTPTransaction aTransaction);
	
	TInt MaxNumTransactionsToPipeline() const;
	
	void __RecordConnectionManagerCreationL();
	void EnsureStrictConnectMethodHeaders(RHTTPTransaction aTransaction);
	TInt SetStatus(CRxData& aRxData, TInt aStatus);
	
#if defined (_DEBUG)
	TInt GetConnectionID(const CHttpConnectionManager* aConnectionManager);
	TInt GetConnectionID(const RHTTPTransaction &aTrans);
#endif

	static void GetCertInfoL(const CX509Certificate& aSource, TCertInfo& aDest);
	static void GetDNInfo(const CX500DistinguishedName& aSource, TDNInfo& aDest);
	
private:
	TBool                       iEnableOptimalPipeline;
	TBool						iUseProxy;
	TInt 						iRecvBufferSize;
	mutable TInt 				iMaxNumConnectionManagers;
	mutable TInt				iMaxNumTransactionsToPipeline;
	CHttpTransportLayer*		iTransportLayer;
	CHttpPipelineFallback*      iPipelineFallback;
	TBool*						iSessionClosingPtr; // Not owned, set in ConstructL
	const TStringTable&            iStringTable;
	RStringF					iProxyAddress;
	RPointerArray<CHttpConnectionManager>	iConnectionManagers;
	__FLOG_DECLARATION_MEMBER2
	
	};
	
#endif	// __CHTTPCLIENTHANDLER_H__