/*

* Copyright (c) 2002-2006 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 FILES

#include "senserviceconnection.h"

#include "senhttpchanneltransportplugin.h"

#include "senhttpchannelimpl.h"

#include "senhttpsyncrequester.h"

#include "senxmlutils.h"

#include "senidentityprovider.h"

#include "senwspattern.h"

#include "senfragment.h"

#include "senelement.h"

#include "sendebug.h"

#include "msenproperty.h"

#include "senhttptransportproperties.h" // Utils\inc

#include "sentransportcontext.h"

#include "senlayeredhttptransportproperties.h" // internal Framework\inc

#include "msenmessagecontext.h"

#include "msenmessage.h"

#include "sensoapmessage2.h"

#include "rsendocument.h"

#include "senparser.h"

#include "senservicesession.h"

#include "senlogger.h"

#include "senclientsession.h"

#include <xmlengchunkcontainer.h>

#include <xmlengfilecontainer.h>

#include <xmlengserializer.h>

namespace

    {

/* Fix for compiler warning  #177-D

#ifdef _SENDEBUG 

    // logging constants

    _LIT(KLogDir,                   "SenHttpChannelObserver");

    _LIT(KLogFile,                  "SenHttpChannelObserver.log");

#endif*/

    _LIT8(KContentType,             "text/xml; charset=UTF-8");

    }

// Create instance of concrete ECOM interface implementation

//CSenHttpChannelTransportPlugin* CSenHttpChannelTransportPlugin::NewL(

//                                    MSenCoreServiceManager& aServiceManager)

//    {

//    CSenHttpChannelTransportPlugin* pNew = CSenHttpChannelTransportPlugin::NewLC(aServiceManager);

CSenHttpChannelTransportPlugin* CSenHttpChannelTransportPlugin::NewL(CSenTransportContext* apCtx)

    {

    CSenHttpChannelTransportPlugin* pNew = CSenHttpChannelTransportPlugin::NewLC(apCtx);

    CleanupStack::Pop();

    return pNew;

    }

CSenHttpChannelTransportPlugin* CSenHttpChannelTransportPlugin::NewLC(CSenTransportContext* apCtx)

    {

    if(apCtx == NULL)

        {

        User::Leave( KErrArgument );

        }

    MSenCoreServiceManager& core = apCtx->GetCoreL();

    CSenHttpChannelTransportPlugin* pNew = new (ELeave) CSenHttpChannelTransportPlugin(apCtx, core);

    CleanupStack::PushL(pNew);

    pNew->ConstructL();

    return pNew;

    }

CSenHttpChannelTransportPlugin::CSenHttpChannelTransportPlugin(CSenTransportContext* apCtx,

                                                               MSenCoreServiceManager& aCore)

:   CSenTransport(apCtx),

    iServiceManager(aCore),

    iRequester(NULL),

    iHttpChannel(NULL),

    iProperties(NULL),

    iConsumerMap(EFalse, ETrue), 

    iSessionMap(EFalse, EFalse), // iConsumerMap deletes the txnIds (using same "new reserved" TInt here!)

    iStatusCode(0)

    {

    }

CSenHttpChannelTransportPlugin::~CSenHttpChannelTransportPlugin()

    {

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::~CSenHttpChannelTransportPlugin()");

    iConsumerMap.Reset(); // deletes the txnIds!

    iSessionMap.Reset(); 

    delete iHttpChannel;

    delete iRequester;

    delete iProperties;

    delete ipCtx;

    ipCtx = NULL;

    TLSLOG(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,(_L("Got last data chunk.")));

    TLSLOG_CLOSE(KSenHttpChannelObserverLogChannelBase);

    }

void CSenHttpChannelTransportPlugin::ConstructL()

    {

    TLSLOG_OPEN(KSenHttpChannelObserverLogChannelBase,KSenHttpChannelObserverLogLevel,KSenHttpChannelObserverLogDir,KSenHttpChannelObserverLogFile	);

    // Open connection to the file logger server

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ConstructL(): log file opened.");

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ConstructL - Version 2 [2006-05-09]");

    if( ipCtx )

        {

        // Attempt to find pre-defined IAP ID from transport context

        CSenWSDescription& initializer = ipCtx->GetInitializerL();

        TUint32 predefinedIapId;

        if( initializer.DescriptionClassType() == MSenServiceDescription::EWSPattern )

            {

            // Check if <ConsumerPolicy/> was defined in SC initializer (constructor argument)

            // and if IAP was predefined

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- Initializer XML SD type is: EWSPattern.");

            CSenWSPattern* pConsumerPolicy = (CSenWSPattern*)&initializer;

            TInt retVal = pConsumerPolicy->ConsumerIapId( predefinedIapId );

            if( retVal==KErrNone && predefinedIapId < (TUint)KErrNotFound ) // IAP ID must be 0...INT_MAX, since (TUInt)KErrNotFound == INT_MAX+1

                {

                iHttpChannel = CSenHttpChannelImpl::NewL(iServiceManager, predefinedIapId);

                }

            else

                {

                // Check if <ProviderPolicy/> was defined in SC initializer (constructor argument)

                // and if IAP was predefined

                retVal = initializer.IapId( predefinedIapId );

                if( retVal==KErrNone && predefinedIapId < (TUint)KErrNotFound )

                    {

                    iHttpChannel = CSenHttpChannelImpl::NewL(iServiceManager, predefinedIapId);

                    }

                }

            }

        else if( initializer.DescriptionClassType() == MSenServiceDescription::EWSDescription )

            {

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- Initializer XML SD type is EWSDescription.");

            TUint32 predefinedIapId(0);

            TInt retVal = initializer.IapId( predefinedIapId );

            if( retVal==KErrNone && predefinedIapId < (TUint)KErrNotFound ) // IAP ID must be 0...INT_MAX, since (TUInt)KErrNotFound == INT_MAX+1

                {

                iHttpChannel = CSenHttpChannelImpl::NewL(iServiceManager, predefinedIapId);

                }

            }

        if( !iHttpChannel )

            {

            // Check if **the service session** contains <ProviderPolicy/>

            CSenServiceSession* pSession = (CSenServiceSession*)ipCtx->GetSession();

            if( pSession )

                {

                // Check if IAP was predefined / try to figure out if IAP ID was

                // set in <ProviderPolicy/> of this session (XML SD):

                TInt retVal = pSession->IapId( predefinedIapId );

                if( retVal == KErrNone && predefinedIapId < (TUint)KErrNotFound ) // IAP ID must be 0...INT_MAX, since (TUInt)KErrNotFound == INT_MAX+1

                    {

                    iHttpChannel = CSenHttpChannelImpl::NewL(iServiceManager, predefinedIapId);

                    }

                }

            }

        }

    if( !iHttpChannel )

        {

        // IAP ID was not found from transport context

        iHttpChannel = CSenHttpChannelImpl::NewL( iServiceManager );

        }

    iRequester = CSenHttpSyncRequester::NewL( iHttpChannel, this );

    }

// Messaging methods start:

TInt CSenHttpChannelTransportPlugin::SubmitL(const TDesC8& aEndpoint,

                                      const TDesC8& aMessage,

                                      const TDesC8& aTransportProperties,

                                      HBufC8*& aResponse,

                                      MSenRemoteServiceConsumer& aConsumer )

    {

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::SubmitL:");

    // Sanity check the endpoint

    if (aEndpoint.Length() <= 0)

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- No endpoint!");

        return KErrSenNoEndpoint;

        }

    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- Endpoint: %S"), &aEndpoint));

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,"- Message:");

    TLSLOG_ALL(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,( aMessage ));

    CSenLayeredHttpTransportProperties& properties = LayeredPropertiesL();

    properties.ReadFromL(aTransportProperties, MSenLayeredProperties::ESenMessageLayer);

    ApplyPropertiesL();    

    HBufC8* pRespContentType = NULL;

    // Uses HttpSyncRequester class:

    TInt statusCode(KErrNone);

    TInt leaveCode(KErrNone);

    TRAP( leaveCode, iRequester->SubmitL(aEndpoint,           // endpoint

                                         properties,

                                         aMessage,            // request body

                                         pRespContentType,    // response content type

                                         aResponse,           // response body

                                         statusCode); )

	// Propagate data traffic counters to consumer

    aConsumer.SetDataTrafficDetails(iDetails);  	

    properties.ShrinkTo(MSenLayeredProperties::ESenConsumerSessionLayer);                                                                                

    if(leaveCode!=KErrNone) 

        {

        // SubmitL leaved, return leave code instead of status code

        statusCode = leaveCode;

        }

    delete pRespContentType; // not used currently

    return statusCode;

    }

// async request

TInt CSenHttpChannelTransportPlugin::SendL( const TDesC8& aEndpoint,

                                            const TDesC8& aMessage,

                                            const TDesC8& aTransportProperties,

                                            MSenServiceSession& aReplyTo,

                                            MSenRemoteServiceConsumer& aConsumer, // "adressee", could be CSenIdentifier

                                            TInt& aTxnId )

    {

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::SendL:");

    // Sanity check the endpoint

    if (aEndpoint.Length() <= 0)

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- No endpoint!");

        return KErrSenNoEndpoint;

        }

    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- Endpoint: %S"), &aEndpoint));

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,"- Content:");

    TLSLOG_ALL(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,(aMessage));

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,"- Properties:");

    TLSLOG_ALL(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,(aTransportProperties));

    CSenLayeredHttpTransportProperties& properties = LayeredPropertiesL();

    properties.ReadFromL(aTransportProperties, MSenLayeredProperties::ESenMessageLayer);

    ApplyPropertiesL();    

    // Reset the status code to zero. Async callbacks may then later update iStatusCode.

    iStatusCode = 0;

    // Note: regardless of name, SubmitL() is an async method in HttpChannel class

    TInt* submitID = new (ELeave) TInt(KErrNone);

    CleanupStack::PushL(submitID);

    TInt leaveCode(KErrNone);

    CSenSoapEnvelope2* pSoapEnvelope2 = NULL;

    TInt err(KErrNone);

    MSenMessageContext* pMsgCtx = aConsumer.MessageContextByTxnIdL(aTxnId, err);

    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- aConsumer.MessageContextByTxnIdL(%d) returned: %d"), aTxnId, err));

    if( pMsgCtx )

        {

        MSenMessage* pMessage = pMsgCtx->MessageL();

        if( pMessage )

            {

            if( pMessage->IsSafeToCast(MSenMessage::ESoapEnvelope2 ))

                {

                pSoapEnvelope2 = (CSenSoapEnvelope2*)pMessage;

                properties.SetPropertyL(KAcceptLocalName, KMimeAccept);

                TRAP( leaveCode, (*submitID) = iHttpChannel->SendL( *this, aEndpoint, *pSoapEnvelope2, properties ); ) 

               }

            else if( pMessage->IsSafeToCast(MSenMessage::EAtomMessage ))

                {

                CSenAtomEntry* pAtomEntry = (CSenAtomEntry*)pMessage;

                TRAP( leaveCode, (*submitID) = iHttpChannel->SendL( *this, aEndpoint, *pAtomEntry, properties ); ) 

               }

            else

                {

                TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KNormalLogLevel, _L8("- MSenMessage type is: %d"), pMessage->Type()));

                TRAP( leaveCode, (*submitID) = iHttpChannel->SendL(*this, aEndpoint, aMessage, properties); )

                }

            }

        else

            {

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- MSenMessage arch. is not used.");            

			RFile &file = pMsgCtx->ChunkL()->RequestFileHandle() ; //pMsgCtx->ChunkL() must not be null !!

			if (file.SubSessionHandle())

				{

				TRAP( leaveCode, (*submitID) = iHttpChannel->SendL(*this, aEndpoint, file, properties);)

				}

			else

				{

				TRAP( leaveCode, (*submitID) = iHttpChannel->SendL(*this, aEndpoint, aMessage, properties);)

				}

			}

        }

    else

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"Fatal(!): message context not found!");

        }    

    TInt timeOutSec(0);

    LayeredPropertiesL().MaxTimeToLiveL(timeOutSec);

    properties.ShrinkTo(MSenLayeredProperties::ESenConsumerSessionLayer);

    if(leaveCode==KErrNone)

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- iHttpChannel returned OK.");

        // No leave occurred

        aTxnId = *submitID;

        if (timeOutSec)

           {

           iHttpChannel->EnableTimeOutL(aTxnId, timeOutSec);

           }

        TInt retVal = iSessionMap.Append(&aReplyTo, submitID);

        if(retVal==KErrNone)

            {

            retVal = iConsumerMap.Append(&aConsumer, submitID);

            if(retVal!=KErrNone)

                {

                TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- iConsumerMap.Append failed: %d"), retVal ));

                // Last entry to iSessionMap must be removed

                TInt removeRetVal = iSessionMap.Remove(*submitID);

#ifdef _SENDEBUG

                if(removeRetVal==KErrNotFound)

                    {

                    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- MAJOR: Could not remove session by txnId(%d)"), *submitID));

                    }

#endif // _SENDEBUG

                removeRetVal = 0; // not used in release builds

                }

            }

        else

            {

            TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMinLogLevel, _L8("- FATAL: iConsumerMap.Append failed: %d"), retVal ));

            }

        CleanupStack::Pop(submitID);

        }

    else

        {

        CleanupStack::PopAndDestroy(submitID);

        }

    return leaveCode;

    }

void CSenHttpChannelTransportPlugin::ResponseReceivedL(TInt aRequestId,

                                                       const TAny* /* aContentType */,

                                                       HBufC8* apContent, 

                                                       CSenHttpTransportProperties* aHttpProperties)

    {

    iHttpChannel->DisableTimeOutL(aRequestId);

    CleanupStack::PushL(apContent);

#ifdef _SENDEBUG    

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseReceivedL:");

    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KNormalLogLevel, _L8("- Request's txnID: %d"), aRequestId));

    if ( apContent )

        {

        TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMaxLogLevel, _L8("- apContent:")));

        TLSLOG_ALL(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,(*apContent));

        }

    else

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"Fatal(!): - apContent == NULL.");

        }

#endif // _SENDEBUG

    TInt index = iSessionMap.FindValue(aRequestId);

    if(index != KErrNotFound)

        {

        // session found OK

        MSenServiceSession* pSession =

            iSessionMap.KeyAt(index);

        iSessionMap.Remove(aRequestId); // does not delete anything

        index = iConsumerMap.FindValue(aRequestId);

        if(index != KErrNotFound)

            {

            // consumer found OK

            MSenRemoteServiceConsumer* pConsumer =

                iConsumerMap.KeyAt(index);

            iConsumerMap.Remove(aRequestId); // deletes TxnId

            CleanupStack::Pop(apContent);

            pSession->SendToConsumerL(apContent, aRequestId, *pConsumer, aHttpProperties);

	        pConsumer->SetDataTrafficDetails(iDetails);                                              

            }

        else

            {

            CleanupStack::PopAndDestroy(apContent);

#ifdef _SENDEBUG

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseReceivedL:");

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- pending consumer not found, txn cancelled?");

#endif // _SENDEBUG

            }

        }

    else

        {

        CleanupStack::PopAndDestroy(apContent);

#ifdef _SENDEBUG

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseReceivedL:");

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- pending session not found, txn cancelled?");

#endif // _SENDEBUG

        }

    }

// Method to catch async error responses from httpchannel

void CSenHttpChannelTransportPlugin::ResponseErrorL(TInt aRequestId, TInt aErrorCode, HBufC8* apErrorBody,CSenHttpTransportProperties* aHttpProperties)

    {

    CleanupStack::PushL(apErrorBody);

    iHttpChannel->DisableTimeOutL(aRequestId);

#ifdef _SENDEBUG    

    TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseErrorL:");

    TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KNormalLogLevel, _L8("- Request's txnID: %d"), aRequestId));

    if ( apErrorBody )

        {

        TLSLOG_FORMAT((KSenHttpChannelObserverLogChannelBase,KMaxLogLevel, _L8("- apErrorBody:")));

        TLSLOG_ALL(KSenHttpChannelObserverLogChannelBase,KMaxLogLevel,(*apErrorBody));

        }

    else

        {

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"Fatal(!): - apErrorBody == NULL.");

        }

#endif // _SENDEBUG

    iStatusCode = aErrorCode;

    TInt index = iSessionMap.FindValue(aRequestId);

    if(index != KErrNotFound)

        {

        // session found OK

        MSenServiceSession* pSession =

            iSessionMap.KeyAt(index);

        iSessionMap.Remove(aRequestId); // does not delete anything

        index = iConsumerMap.FindValue(aRequestId);

        if(index != KErrNotFound)

            {

            // consumer found OK

            MSenRemoteServiceConsumer* pConsumer =

                iConsumerMap.KeyAt(index);

            iConsumerMap.Remove(aRequestId); // deletes TxnId

            CleanupStack::Pop(apErrorBody);

            pSession->SendErrorToConsumerL(aErrorCode, 

                                          apErrorBody, 

                                          aRequestId, 

                                          *pConsumer,

                                          aHttpProperties);

            apErrorBody = NULL;

            pConsumer->SetDataTrafficDetails(iDetails);                                                                                        

            }

        else

            {

            CleanupStack::PopAndDestroy(apErrorBody);

#ifdef _SENDEBUG

       		TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseErrorL:");

            TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- pending consumer not found, txn cancelled?");

#endif // _SENDEBUG

            }

        }

    else

        {

        //CleanupStack::PopAndDestroy(apErrorBody);

        CleanupStack::Pop(apErrorBody); // for EPSK-76XFAN

#ifdef _SENDEBUG

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"CSenHttpChannelTransportPlugin::ResponseErrorL:");

        TLSLOG_L(KSenHttpChannelObserverLogChannelBase,KMinLogLevel,"- pending session not found, txn cancelled?");

#endif // _SENDEBUG

        }

    }

/*

RFileLogger* CSenHttpChannelTransportPlugin::Log() const

    {

    return (RFileLogger*) &iLogger;

    }

*/

TInt CSenHttpChannelTransportPlugin::SetPropertiesL(const TDesC8& aProperties,

                                                    MSenLayeredProperties::TSenPropertiesLayer aTargetLayer,