--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/webservices/wsoviplugin/src/wsovisessionconsumer.cpp	Thu Jan 07 16:19:19 2010 +0200
@@ -0,0 +1,167 @@
+/*
+* 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
+