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