/*

* Copyright (c) 2002-2005 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 <uri8.h>

#include <es_sock.h>

#include <in_sock.h>

#include <http.h>

#include "sendebug.h" // filelogging and debugging MACROS

#include "SenServiceConnection.h" // KErrSenNoHttpResponseBody

#include "SenElement.h"

#include "SenXmlUtils.h"

#include "SenHttpTransportProperties.h"

#include "senhttpchannelimpl.h"

#include "senhttpeventhandler.h"

#include "sentxnstate.h"

#include "senatomtxnstate.h"

#include "senrfiletxnstate.h"

#include "senhttpchannel.h"

#include "senlayeredhttptransportproperties.h"

#include "msenidentitymanager.h"

#include "senlogger.h"

#include "senhttpchanneltransportplugin.h"

//For HTTPProxyFilter

#include <httpfilterproxyinterface.h>

#include <httpfilteracceptheaderinterface.h>

#include <httpfiltercommonstringsext.h>

#include <deflatefilterinterface.h>

#ifndef __ENABLE_ALR__

#include <versioninfo.h>  // VersionInfo

#include <extendedconnpref.h>

#endif

// CONSTANTS

namespace

    {

    _LIT(KTxnStateNullPanicText,            "TxnState is NULL");

    // Minimum granularity for array initialization

    const TInt KMinimumArrayGranularity =   1;

#ifdef _SENDEBUG

    // logging constants

    //_LIT(KLogFileDir, "SenHttpChannel");

   // _LIT(KLogFileName, "SenHttpChannel.log");

    _LIT(KDateFormat,"%D%M%Y%/0%1%/1%2%/2%3%/3 %:0%H%:1%T%:2%S.%C%:3");

    // Size of buffer used when submitting request bodies

    const TInt KMaxHeaderNameLen = 16;

    const TInt KMaxHeaderValueLen = 128;

    const TInt KMaxFilterNameLen = 16;

#endif

    }

//

// Implementation of CSenHttpChannelImpl

//

CSenHttpChannelImpl::CSenHttpChannelImpl(MSenIdentityManager& aManager)

:

    iIapId(KErrNone),

    iManager(aManager),

    iSessionAuthentication(NULL),

    iPasswordFromUser(EFalse),

    iExplicitIapDefined(EFalse),

    iProxyHostPort(NULL),

    iXopResponse(EFalse),

    iHasHttpContentType(ETrue)

#ifndef __ENABLE_ALR__

    , iOCCenabled(EFalse)

#endif    

    {

//    IsOCCImplementedSDK();

    }

CSenHttpChannelImpl* CSenHttpChannelImpl::NewL(MSenIdentityManager& aManager)

    {

    CSenHttpChannelImpl* pNew = NewLC(aManager);

    CleanupStack::Pop(pNew);

    return pNew;

    }

CSenHttpChannelImpl* CSenHttpChannelImpl::NewLC(MSenIdentityManager& aManager)

    {

    CSenHttpChannelImpl* pNew = new (ELeave) CSenHttpChannelImpl(aManager);

    CleanupStack::PushL(pNew);

    pNew->ConstructL();

    return pNew;

    }

CSenHttpChannelImpl* CSenHttpChannelImpl::NewL(MSenIdentityManager& aManager,

                                               TUint32 aIapId)

    {

    CSenHttpChannelImpl* pNew = NewLC(aManager, aIapId);

    CleanupStack::Pop(pNew);

    return pNew;

    }

CSenHttpChannelImpl* CSenHttpChannelImpl::NewLC(MSenIdentityManager& aManager,

                                                TUint32 aIapId)

    {

    CSenHttpChannelImpl* pNew = new (ELeave) CSenHttpChannelImpl(aManager);

    CleanupStack::PushL(pNew);

    pNew->ConstructL(aIapId); 

    return pNew;

    }

#ifndef __ENABLE_ALR__

// On return, aMajor and aMinor contain the version information

TInt CSenHttpChannelImpl::GetS60PlatformVersion(TUint& aMajor, TUint& aMinor)

	{   

	TInt ret = KErrNone;

	// Connect to the file server session

	RFs fsSession;

	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::GetS60PlatformVersion()")));	

	ret = fsSession.Connect();

	if(ret == KErrNone)

		{

		CleanupClosePushL(fsSession); // Obtain the version numberTUint major;

		VersionInfo::TPlatformVersion platformVersion;  

		TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "--- GetS60PlatformVersion getting Version info");		

		ret = VersionInfo::GetVersion(platformVersion, fsSession);   

		CleanupStack::PopAndDestroy();  // fsSession		

		if (ret == KErrNone)       

			{     

			aMajor = platformVersion.iMajorVersion;  

			aMinor = platformVersion.iMinorVersion;   

		   	TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("--- GetS60PlatformVersion Version: Major [%d], Minor[%d]"), aMajor, aMinor));

			}		

		}

	TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("--- GetS60PlatformVersion returns [%d]"), ret));

	return ret;

	}

// On return, aMajor and aMinor contain the version information

TBool CSenHttpChannelImpl::IsOCCImplementedSDK()

	{   

	TBool occ = EFalse;

	// Obtain the version number

	TUint major;

	TUint minor;	

	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::IsOCCImplementedSDK()")));		

	TInt ret = GetS60PlatformVersion(major, minor);

	if (ret == KErrNone)

		{

		if(major == 5 && minor == 2)

			{

			occ = ETrue;

			iOCCenabled = ETrue;

			TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("---- IsOCCImplementedSDK() returns TRUE")));

			}

		else

			{

			TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("---- IsOCCImplementedSDK() returns False")));

			}

		}

	return occ;

	}

#endif	

// Ask IAP from user

void CSenHttpChannelImpl::ConstructL()

    {

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL()")));

    // Open the RHTTPSession

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - Opening HTTP/TCP session.")));

    iSess.OpenL();

    // Store the string pool for this HTTP session

    iStringPool = iSess.StringPool();

	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - Calling InstallAuthenticationL()")));

    // Install this class as the callback for authentication requests

    InstallAuthenticationL( iSess );

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - Completed InstallAuthenticationL()")));

    //Install Proxy Filter  

    iDeflateFilter = EFalse;

#ifdef EKA2

  //#ifndef _DEBUG 

  	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - Installing  HTTPProxyFilter for EKA2 build.")));

    CHttpFilterProxyInterface::InstallFilterL( iSess );

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - HTTPProxyFilter installed for EKA2 build.")));

    iSess.StringPool().OpenL(HttpFilterCommonStringsExt::GetLanguageTable());

    iSess.StringPool().OpenL(HttpFilterCommonStringsExt::GetTable());

	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - Installing  HTTPAcceptProxyFilter for EKA2 build.")));

    CHttpFilterAcceptHeaderInterface::InstallFilterL(iSess);

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() - HTTPAcceptProxyFilter installed for EKA2 build.")));

  //#else

  //  LOG_WRITE_L("HTTPProxyFilter is NOT in use with EKA2 debug builds.");

  //#endif

#else // __INSTALL_HTTP_PROXY_FILTER__ is not defined by macro in .mmp

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"HTTPProxyFilter is NOT in use with EKA1.");

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"HTTPAcceptProxyFilter is NOT in use with EKA1.");

#endif // __INSTALL_HTTP_PROXY_FILTER__

    iTransObs = CSenHttpEventHandler::NewL(this);//, &iLog);

    iTxnStates =

        new (ELeave) CArrayPtrFlat<CSenTxnState>(KMinimumArrayGranularity);

    iBasicConnectionTries = 0;

#ifndef __ENABLE_ALR__

    IsOCCImplementedSDK();

#endif    

#ifdef _SENDEBUG

    ListFilters();

#endif // _SENDEBUG

	TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL() Completed")));

    }

// Forces preselected IAP to be used!

void CSenHttpChannelImpl::ConstructL( TUint32 aIapId )

    {

    // Initialize

//    SetupConnectionWithIapPrefsL( aIapId, iConnection, iSockServ );

    ConstructL();

//    AttachSocketServerAndConnectionWithHttpSession( aIapId, iConnection, iSockServ );

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"CSenHttpChannelImpl::ConstructL - Setting IAP id");

//    Use local variable (new RSocketServer each time; handle is given to RHTTPSession via RConnectionInfo..)

//    RSocketServ server; // with "anon" (local) socket servers, should we keep array of open ones in case of pending txns?

//    SetIapPrefsL(aIapId, iConnection, server);

#ifndef __ENABLE_ALR__

	IsOCCImplementedSDK();

#endif	

	if(aIapId > 0)

		{

    	const TInt result = SetIapPrefsL(aIapId, ETrue, iConnection, iSockServ);

    	User::LeaveIfError( result );

    	}

    }

CSenHttpChannelImpl::~CSenHttpChannelImpl()

    {

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"CSenHttpChannelImpl::~CSenHttpChannelImpl()");

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"Closing http session.");

    iSess.Close();

    if (iTransObs) //might be NULL if constructor failed ---

        {

        delete iTransObs;   

        iTransObs = NULL;

        }

    if (iTxnStates) //might be NULL if constructor failed--- 

        {

        iTxnStates->ResetAndDestroy();

        delete iTxnStates;

        iTxnStates = NULL;

        }

    if(iProxyHostPort)

        {

        delete iProxyHostPort;

        iProxyHostPort = NULL;

        }

    if(iMultiPartContentType.params.Count())

        {

        iMultiPartContentType.params.Close();

        }

    if(iDeflateFilter)

        {

        REComSession::DestroyedImplementation(KDeflateFilterUid); 	

        }

    iConnection.Close();

    iSockServ.Close();

    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"CSenHttpChannelImpl::~CSenHttpChannelImpl() Completed");

    }

TInt CSenHttpChannelImpl::SetIapPrefsL( TUint32 aIapId, TBool aDialogPref, RConnection& aConnection, RSocketServ& aSocketServer )

   	{

   	TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("- SetIapPrefsL	, aIapId (%d)"), aIapId));

   	TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("- SetIapPrefsL	, iIapId (%d)"), iIapId));

    // Check whether IAP ID is not equal with the one that is currently in effect:

    if(iExplicitIapDefined || iIapId == aIapId && iIapId > 0)

        {

        TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetIapPrefsL: Iap Id is same as currently in effect");

        return KErrNone;

        }

	else

		{

		TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetIapPrefsL: Iap Id different with the currently in effect");

		}    

    // Check if socket server (connection) is already open..

    if( iExplicitIapDefined )

        {

         // Socket server opened once before for some other IAP

        TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetIapPrefsL: Re-using existing RConnection => calling RConnection::Stop");

        aConnection.Stop();

        }

    else

        {

        if(aConnection.SubSessionHandle())

        	{

            TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetSnapPrefsL: Re-using existing RConnection => calling RConnection::Stop");

        	aConnection.Stop();

        	}

        else

            {

            // Connect to a socket server    

            TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetIapPrefsL: Connecting to new socket server");    

            User::LeaveIfError( aSocketServer.Connect() );       

            // Open new connection

            TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetIapPrefsL: Opening new RConnection using the socket server.");       

            User::LeaveIfError( aConnection.Open(aSocketServer) );        

            }

        }

    // Set the IAP selection preferences (IAP ID, do not prompt)    

	TInt retVal = SetID(aIapId, aDialogPref, aConnection, aSocketServer);	        

    // Get the connection "handle" from the HTTP session    

    RHTTPConnectionInfo connInfo = iSess.ConnectionInfo();

    // Attach socket server

    connInfo.SetPropertyL(iStringPool.StringF(  HTTP::EHttpSocketServ,

                                                RHTTPSession::GetTable()),

                                                THTTPHdrVal(aSocketServer.Handle()));

    // Attach connection  

    TInt connPtr = REINTERPRET_CAST(TInt, &aConnection);

    connInfo.SetPropertyL(iStringPool.StringF(  HTTP::EHttpSocketConnection, 

                                                RHTTPSession::GetTable()), 

                                                THTTPHdrVal(connPtr));                                                    

    return retVal;

    }

TInt CSenHttpChannelImpl::SetID(TUint32 aId, TBool aDialogPref, RConnection& aConnection, RSocketServ& aSocketServer, TBool aSNAP)

{

   /*

    * Single click connectivity feature has been implemented by CSock (RConnection class).

    * According to this client no need to set the IAP ID. 

    * Automatically RConnection will use the suitable IAP

    */

    TInt retVal = KErrNone;

    TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("CSenHttpChannelImpl  called with ID [%d]"), aId));

#ifndef __ENABLE_ALR__	    

	if (iOCCenabled == EFalse)	    

		{

#endif		

		if (aSNAP == EFalse)

			{

			TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- SetIAPID");

		    TCommDbConnPref pref;		

			pref.SetIapId( aId );

			TCommDbDialogPref dialogPref;

		    if (aDialogPref)

		        {

		        dialogPref = ECommDbDialogPrefDoNotPrompt;

		        }

		    else

		        {

		        dialogPref = ECommDbDialogPrefPrompt;

		        }

	    	pref.SetDialogPreference(dialogPref);

	    	retVal = aConnection.Start(pref);

			TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("RConnection->Start retVal [%d]"), retVal));

			}

		else

			{

			TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- SetSNAPID");

			// Set the SNAP selection preferences (SNAP ID)

		    TConnSnapPref pref;

		    pref.SetSnap(aId);		    

		    // Start the connection with the new preferences

		    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetSnapPrefsL: Calling RConnection::Start with new SNAP prefs");

		    TInt retVal = aConnection.Start(pref);

			}

#ifndef __ENABLE_ALR__			

		}   

	else

		{

		if (aSNAP == EFalse)

			{

			/* If IAP id is zero, it is interpreted as

		    * client's request for not requesting any specific IAP.

		    * Default value is 0.

		    * 

		    * If IAP id is set, SNAP id shall be zero.

		    * If IAP id is set, SNAP purpose shall be CMManager::ESnapPurposeUnknown.

		    * If IAP id is set, Connection selection dialog shall be disabled.

		    * If IAP id is set, bearer set shall be EExtendedConnBearerUnknown.

		    * If IAP id is set, forced roaming is disabled automatically.

		    * Either SNAP purpose, SNAP id, or IAP id shall be given, or Connection

		    * selection dialog shall be enabled.

		    */

		    TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Setting up OCC with IAP Settings");

			TConnPrefList prefList;

			TExtendedConnPref extPrefs;

			//extPrefs.SetSnapPurpose( CMManager::ESnapPurposeUnknown);

			//TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Setting up OCC Silent Connection");

			//extPrefs.SetNoteBehaviour(TExtendedConnPref::ENoteBehaviourConnSilent);

			//extPrefs.SetBearerSet(TExtendedConnBearer::EExtendedConnBearerUnknown);

			if(aId != 0)

				{

				extPrefs.SetIapId(aId);

				extPrefs.SetSnapId(0);

				}

			else

				{

				extPrefs.SetSnapPurpose(CMManager::ESnapPurposeInternet);

				extPrefs.SetConnSelectionDialog(ETrue);

				}

			prefList.AppendL(&extPrefs);

			retVal = aConnection.Start(prefList);

			if(retVal == KErrNone)

			    {

			    if(aId == 0)

			    	{

                    aConnection.GetIntSetting( _L("IAP\\Id"), iIapId);

                    TName name;

                    retVal = aConnection.Name(name);

                    if(retVal == KErrNone)

                        {

                        TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("IAP Name [%S]"), &name));

                        }

                    TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("GetIntSetting returned IAP [%d]"), iIapId));			    

			    	}

			    else

			    	{	

			    	iIapId = aId;

			    	}

			    }

			 else

			    {

                TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("IAP ->Start retVal [%d]"), retVal));

			    }

		    }

		else

		    {

		    /**

		    * Sets SNAP id. If SNAP id is zero, it is interpreted as 

		    * client's request for not requesting any specific SNAP.

		    * Default value is 0.

		    *

		    * If SNAP id is set, IAP id shall be zero.

		    * If SNAP id is set, SNAP purpose shall be CMManager::ESnapPurposeUnknown.

		    * If SNAP id is set, Connection selection dialog shall be disabled.

		    * Either SNAP purpose, SNAP id, or IAP id shall be given, or Connection

		    * selection dialog shall be enabled.

		    */

			TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Setting up OCC with SNAP Settings");

			TConnPrefList prefList;

			TExtendedConnPref extPrefs;

			//extPrefs.SetSnapPurpose( CMManager::ESnapPurposeUnknown);

			//TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Setting up OCC Silent Connection");

			//extPrefs.SetNoteBehaviour(TExtendedConnPref::ENoteBehaviourConnSilent);

			//extPrefs.SetBearerSet(TExtendedConnBearer::EExtendedConnBearerUnknown);

			if(aId == 0)

				{

				TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Setting SnapPurpose Internet");

				if(aDialogPref) //If it fails because of unavailibility of access points

					{

					TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "- Fails because of unavailibility of access points");

					extPrefs.SetSnapPurpose(CMManager::ESnapPurposeUnknown);

					extPrefs.SetConnSelectionDialog(ETrue);

					}

				else

					{

					extPrefs.SetSnapPurpose(CMManager::ESnapPurposeInternet);

					//extPrefs.SetNoteBehaviour(TExtendedConnPref::ENoteBehaviourConnSilent);					

					}

				}

			else

				{

				extPrefs.SetSnapId(aId);

				extPrefs.SetIapId(0);	

				extPrefs.SetSnapPurpose(CMManager::ESnapPurposeUnknown);

				extPrefs.SetConnSelectionDialog(EFalse);

				}

			prefList.AppendL(&extPrefs);

			TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel, "SetID: RConnection Start");

			retVal = aConnection.Start(prefList);

			TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("RConnection Start retval[%d]"), retVal));

			if(retVal == KErrNone)

				{