/*

* 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>

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

    {

    }

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;

    }

// Ask IAP from user

void CSenHttpChannelImpl::ConstructL()

    {

    // Open connection to the file logger server

    TLSLOG_OPEN(KSenHttpChannelLogChannelBase, KSenHttpChannelLogLevel, KSenHttpChannelLogDir, KSenHttpChannelLogFile);

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenHttpChannelImpl::ConstructL - Log file opened")));

    // Open the RHTTPSession

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

    iSess.OpenL();

    // Store the string pool for this HTTP session

    iStringPool = iSess.StringPool();

    // Install this class as the callback for authentication requests

    InstallAuthenticationL( iSess );

    //Install Proxy Filter  

    iDeflateFilter = EFalse;

#ifdef EKA2

  //#ifndef _DEBUG 

    CHttpFilterProxyInterface::InstallFilterL( iSess );

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

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

    CHttpFilterAcceptHeaderInterface::InstallFilterL(iSess);

    TLSLOG_L(KSenHttpChannelLogChannelBase , KNormalLogLevel,"HTTPProxyFilter installed for EKA2 build.");

    TLSLOG_L(KSenHttpChannelLogChannelBase , KNormalLogLevel,"HTTPAcceptFilter 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 , KNormalLogLevel,"HTTPProxyFilter is NOT in use with EKA1.");

    TLSLOG_L(KSenHttpChannelLogChannelBase , KNormalLogLevel,"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;

#ifdef _SENDEBUG

    ListFilters();

#endif // _SENDEBUG

    }

// 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);

    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();

    // Close the log file and the connection to the server.

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("Log file closed.")));

    TLSLOG_CLOSE(KSenHttpChannelLogChannelBase);

    }

// This function expects that RConnection has been connected

// and that RConnection has already been opened!

/*

void CSenHttpChannelImpl::SetIapPrefsL(TUint32 aIapId, 

                                       RConnection& aConnection, 

                                       RSocketServ& aSocketServer)

    {

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

    if(iExplicitIapDefined && iIapId == aIapId )

        {

        return; // nothing to do

        }

    LOG_WRITEFORMAT((_L8("- SetIapPrefsL: Re-setting IAP ID (%d)"), aIapId));

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

    if( iExplicitIapDefined )

        {

         // Socket server opened once before for some other IAP

        LOG_WRITE_L("- SetIapPrefsL: Re-using existing RConnection => calling RConnection::Stop");

        aConnection.Stop();

        }

    else

        {

        aConnection.Stop(); // prompted from user

        iSess.DisconnectL();

        iSess.ConnectL();

        // Connect to a socket server    

        LOG_WRITE_L("- SetIapPrefsL: Connecting to new socket server");    

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

        // Open new connection

        LOG_WRITE_L("- SetIapPrefsL: Opening new RConnection using the socket server.");       

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

        }

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

    TCommDbConnPref pref;

    pref.SetIapId( aIapId );    

    TCommDbDialogPref dialogPref;

    dialogPref = ECommDbDialogPrefDoNotPrompt;

    pref.SetDialogPreference(dialogPref);

    // Start the connection with the new preferences

    LOG_WRITE_L("- SetIapPrefsL: Calling RConnection::Start with new IAP prefs");

    aConnection.Start(pref);

    // 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));

    // Remember the IAP id that is being set; there is

    // no direct API to query effective IAP ID from CommsDB.

    iExplicitIapDefined = ETrue;

    iIapId = aIapId;

    }

*/

/*

void CSenHttpChannelImpl::SetupConnectionWithIapPrefsL( TUint32 aIapId, 

                                                        RConnection& aConnection, 

                                                        RSocketServ& aSocketServer )

    {

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

    if(iExplicitIapDefined && iIapId == aIapId )

        {

        return; // nothing to do

        }

    LOG_WRITEFORMAT((_L8("- SetIapPrefsL, IAP ID (%d)"), aIapId));

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

    if( iExplicitIapDefined )

        {

         // Socket server opened once before for some other IAP

        LOG_WRITE_L("- SetIapPrefsL: Re-using existing RConnection => calling RConnection::Stop");

        aConnection.Stop();

        }

    else

        {

        // Connect to a socket server    

        LOG_WRITE_L("- SetIapPrefsL: Connecting to new socket server");    

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

        // Open new connection

        LOG_WRITE_L("- SetIapPrefsL: Opening new RConnection using the socket server.");       

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

        }

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

    TCommDbConnPref pref;

    pref.SetIapId( aIapId );    

    TCommDbDialogPref dialogPref;

    dialogPref = ECommDbDialogPrefDoNotPrompt;

    pref.SetDialogPreference(dialogPref);

    // Start the connection with the new preferences

    LOG_WRITE_L("- SetIapPrefsL: Calling RConnection::Start with new IAP prefs");

    aConnection.Start(pref);

    }

void CSenHttpChannelImpl::AttachSocketServerAndConnectionWithHttpSession( TUint32 aIapId, 

                                                                          RConnection& aConnection, 

                                                                          RSocketServ& aSocketServer )

    {

    if(iExplicitIapDefined && iIapId == aIapId )

        {

        return; // nothing to do

        }

    // 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));

    // Remember the IAP id that is being set, because *at the moment*,

    // there is NO direct API to query effective IAP ID from CommsDB.

    iExplicitIapDefined = ETrue;

    iIapId = aIapId;

    }

void CSenHttpChannelImpl::SetIapPrefsL( TUint32 aIapId, RConnection& aConnection, RSocketServ& aSocketServer )

    {

    SetupConnectionWithIapPrefsL( aIapId, aConnection, aSocketServer );

    AttachSocketServerAndConnectionWithHttpSession( aIapId, aConnection, aSocketServer );

    }        

*/

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

   	{

   	TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KNormalLogLevel, _L8("- SetIapPrefsL, IAP ID (%d)"), aIapId));

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

    if(iExplicitIapDefined && iIapId == aIapId )

        {

        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

        {

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

    /*

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

    */

	    TCommDbConnPref pref;

    #ifndef __SINGLE_CLICK_CONNECTIVITY_ENABLED__	    

	    pref.SetIapId( aIapId );

		#else

			pref.SetIapId( 0 );	 //By default IAP ID is "0". IAP selection will take care by RConnection

    #endif //__SINGLE_CLICK_CONNECTIVITY_ENABLED__	    

	    TCommDbDialogPref dialogPref;

	    if (aDialogPref)

	        {

	        dialogPref = ECommDbDialogPrefDoNotPrompt;

	        }

	    else

	        {

	        dialogPref = ECommDbDialogPrefPrompt;

	        }     

	    pref.SetDialogPreference(dialogPref);

  	// Start the connection with the new preferences

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

    TInt retVal =aConnection.Start(pref);

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

    // 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));

    // Remember the IAP id that is being set, because *at the moment*,

    // there is NO direct API to query effective IAP ID from CommsDB.

    if (!retVal)

        {

        iExplicitIapDefined = ETrue;

        iIapId = aIapId;

        }

    return retVal;

    }

TInt CSenHttpChannelImpl::SetSnapPrefsL( TUint32 aSnapId, TBool aDialogPref, RConnection& aConnection, RSocketServ& aSocketServer )

    {

    TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("- CSenHttpChannelImpl::SetSnapPrefsL, SNAP ID (%d)"), aSnapId));

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

    if(iExplicitIapDefined && iSnapId == aSnapId )

        {

        TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetSnapPrefsL: Sanp is same as currently in effect");

        return KErrNone;

        }

		else

			{

			TLSLOG_L(KSenHttpChannelLogChannelBase , KMinLogLevel,"- SetSnapPrefsL: Sanp is different with 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,"- SetSnapPrefsL: Re-using existing RConnection => calling RConnection::Stop");

        aConnection.Stop();

        }

    else

        {

        // Connect to a socket server    

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

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

        // Open new connection

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

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

        }

    // Set the SNAP selection preferences (SNAP ID)

    TConnSnapPref pref;

    pref.SetSnap(aSnapId);     

    // Start the connection with the new preferences

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

    TInt retVal = aConnection.Start(pref);

    TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KMinLogLevel, _L8("- SetSnapPrefsL, RConnection::Start returned: (%d)"), retVal));

    // 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()),