/*
* 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: Header declaration
*
*/








#ifndef IDWSF_SESSION_CONSUMER_H
#define IDWSF_SESSION_CONSUMER_H

// INCLUDES
#include <e32base.h>
#include <e32des8.h>    // HBufC8

#include "msenremoteserviceconsumer.h"
#include "senpointermap.h"

#include "idwsfmessage.h"


// DATA TYPES
typedef RSenPointerMap<TDesC8, HBufC8> RSentMessagesPointerMap;

// FORWARD DECLARATIONS
class CIdWsfMessage;
class RFileLogger;

//class CSenPolicy; // deprecated, not in use

// CLASS DECLARATION
class CIdWsfSessionConsumer : public CBase, public MSenRemoteServiceConsumer
    {
    public: // Constructors and destructor
        
        static CIdWsfSessionConsumer* NewL(MSenRemoteServiceConsumer& aServiceConsumer,
                                           RFileLogger& aLogger);

        static CIdWsfSessionConsumer* NewLC(MSenRemoteServiceConsumer& aServiceConsumer,
                                            RFileLogger& aLogger);

        virtual ~CIdWsfSessionConsumer();

        // New functions

        /**
        * Expects() is called by CIdWsfServiceSession to check
        * whether or not this consumer expects certain response
        */
        virtual TBool Expects(const TDesC8& aRefToMessageID);

        const TDesC8& Id() const;
        TInt SetSessionL(MSenRemoteServiceSession& iServiceSession);

        TInt HandleIdWsfMessageL( CIdWsfMessage* apMessage,
                                  const TInt aTxnId,
                                  MSenProperties* aResponseTransportProperties,
                                  TBool aCompleteMessage );

        TInt HandleMessageL( HBufC8* aMessage,
                             const TInt aTxnId,
                             MSenProperties* aResponseTransportProperties );

        TInt HandleErrorL( HBufC8* aError,
                           const TInt aErrorCode,
                           const TInt aTxnId,
                           MSenProperties* aResponseTransportProperties );

        void SetStatusL(const TInt status);

        TInt MessageForSendingL(const TDesC8& aBody,
                                const TDesC8& aReceivedMessageId,
                                CIdWsfMessage*& aMessage);

        void SetSentMessageIdL(const TDesC8& aSentMessageId);
        TPtrC8 SentMessageId();
        void SetReceivedMessageIdL(const TDesC8& aReceivedMessageId);
        TPtrC8 ReceivedMessageId();
        CSenIdentifier& Identifier() const;
        TDesC8* BodyL(const TDesC8& aMessageID) const;
        MSenTransport& TransportL();
        virtual TInt ChunkByTxnIdL(TInt aTxnId, CSenChunk*& aChunk);    
        virtual void FileProgress(TInt aTxnId, TBool aIncoming, TBool aIsSoap,
                const TDesC8& aSoapOrCid, TInt aProgress);
		virtual void SetDataTrafficDetails( TSenDataTrafficDetails& aDetails) ; 	
    protected:
        RFileLogger* Log() const;

    
    private: 
    
        /**
        * C++ default constructor.
        */
        CIdWsfSessionConsumer(MSenRemoteServiceConsumer& aServiceConsumer,
                              RFileLogger& aLogger);
        
        /**
        * By default Symbian 2nd phase constructor is private.
        */
        void ConstructL();



    private: // Data
        MSenRemoteServiceConsumer& iConsumer;
        RFileLogger& iLogger;
        HBufC8* iSentMessageId;     // owned
        HBufC8* iReceivedMessageId; // owned
        RSentMessagesPointerMap iSentMessages; // owned
    };
    
#endif // IDWSF_SESSION_CONSUMER_H

// End of File