/*
* Copyright (c) 2008 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 <SenXmlUtils.h>

#include "wsovisessionconsumer.h"
#include "sendebug.h"
#include <SenServiceConnection.h>
#include "senlogger.h"
#include "wsovicons.h"
#include "SenHttpTransportProperties.h"

CWSOviSessionConsumer* CWSOviSessionConsumer::NewL( MSenRemoteServiceConsumer& aServiceConsumer)
    {
    CWSOviSessionConsumer* pSelf =
        CWSOviSessionConsumer::NewLC(aServiceConsumer);
    CleanupStack::Pop(pSelf);
    return pSelf;
    }

CWSOviSessionConsumer* CWSOviSessionConsumer::NewLC( MSenRemoteServiceConsumer& aServiceConsumer)
    {
    CWSOviSessionConsumer* pSelf =
                        new (ELeave) CWSOviSessionConsumer( aServiceConsumer);
    CleanupStack::PushL(pSelf);
    pSelf->ConstructL();
    return pSelf;
    }

CWSOviSessionConsumer::~CWSOviSessionConsumer()
    {
    iSentMessages.Reset();
    iSendReplyTo.Reset();
    iTranspProp.Reset();
    }

CWSOviSessionConsumer::CWSOviSessionConsumer( MSenRemoteServiceConsumer& aServiceConsumer)
:   iConsumer(aServiceConsumer),
    iSentMessages(ETrue, ETrue),
    iSendReplyTo(ETrue, ETrue),
    iTranspProp(ETrue, ETrue)
    {
    }


const TDesC8& CWSOviSessionConsumer::Id() const
    {
    return iConsumer.Id();
    }

TInt CWSOviSessionConsumer::SetSessionL(MSenRemoteServiceSession& aServiceSession)
    {
    iConsumer.SetSessionL(aServiceSession);
    return KErrNone;
    }


TInt CWSOviSessionConsumer::HandleMessageL( HBufC8* apMessage,
                                             const TInt aTxnId,
                                             MSenProperties* aResponseTransportProperties )
    {
    return iConsumer.HandleMessageL(apMessage, aTxnId, aResponseTransportProperties);
    }

TInt CWSOviSessionConsumer::HandleErrorL( HBufC8* apError,
                                           const TInt aErrorCode,
                                           const TInt aTxnId,
                                           MSenProperties* aResponseTransportProperties )
    {
    return iConsumer.HandleErrorL(apError, aErrorCode, aTxnId, aResponseTransportProperties);
    }

void CWSOviSessionConsumer::SetStatusL(const TInt status)
    {
    TLSLOG_L(KSenCoreServiceManagerLogChannelBase  , KMinLogLevel,"CWSOviSessionConsumer::SetStatusL");
    iConsumer.SetStatusL(status);
    }

TInt CWSOviSessionConsumer::MessageForSendingL(CSenHttpTransportProperties*& /*aTP*/,
                                           CWSOviMessageContext*& /*aCtx*/)
    {
    TLSLOG_L(KSenCoreServiceManagerLogChannelBase  , KMinLogLevel,"CWSOviSessionConsumer::MessageForSendingL");
    return KErrNone;
    }

void CWSOviSessionConsumer::ConstructL()
    {
    }


const TDesC8& CWSOviSessionConsumer::TransportProperties(
        const TDesC8& aMessageID) const
    {
    TInt index = iTranspProp.Find(aMessageID);
    if (index != KErrNotFound)
        {
        const TDesC8* tp = iTranspProp.ValueAt(index);
        if (tp)
            {
            return *tp;
            }
        }
    return KNullDesC8;
    }

MSenTransport& CWSOviSessionConsumer::TransportL()
    {
    return iConsumer.TransportL();
    }
    
TInt CWSOviSessionConsumer::ChunkByTxnIdL(TInt aTxnId, CSenChunk*& aChunk)
    {
    return iConsumer.ChunkByTxnIdL(aTxnId, aChunk);
    }

void CWSOviSessionConsumer::FileProgress(TInt /*aTxnId*/, TBool /*aIncoming*/, TBool /*aIsSoap*/,
                const TDesC8& /*aSoapOrCid*/, TInt /*aProgress*/)
    {
    }

CSenIdentifier& CWSOviSessionConsumer::Identifier() const
    {
    return iConsumer.Identifier();
    }

    
TBool CWSOviSessionConsumer::HasAuthenticationCallback()
    {
    return iConsumer.HasAuthenticationCallback();
    }

TInt CWSOviSessionConsumer::ReauthenticationNeededL(CSenIdentityProvider*& aIdp)
	{
	return iConsumer.ReauthenticationNeededL(aIdp);
	}

void CWSOviSessionConsumer::SetDataTrafficDetails( TSenDataTrafficDetails&  aDetails)  
	{
	iConsumer.SetDataTrafficDetails(aDetails);
	}
// End of file