/*

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

    }

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

   	{

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

        }

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

        }

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

    if (!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;