/*

* 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 SEN_HOSTLET_TRANSPORT_PLUGIN

#define SEN_HOSTLET_TRANSPORT_PLUGIN

#include <e32base.h>

#include <s32strm.h>

#include <e32std.h>

#include <MSenProperties.h>

#include "sentransport.h"

#include "senpointermap.h" // from Utils\inc

// CONSTANTS

_LIT8(KSenHostletTransportUriScheme, "hostlet");

// FORWARD DECLARE

class MSenProvider;

class CSenProvider;

class CSenActiveHostletRequest;

class CSenHostletRequest;

class CSenHostletResponse;

class CSenSyncRequester;

class CSenLayeredXmlProperties;

class CSenTransportProperties;

class MSenTransportContext;

// TYPEDEFS

typedef RSenPointerMap<MSenRemoteServiceConsumer, TInt> RConsumerMap;

typedef RSenPointerMap<MSenServiceSession, TInt> RSessionMap;

typedef RSenPointerMap<CSenActiveHostletRequest, TInt> RLocalRequestMap;

class CSenHostletTransportPlugin : public CSenTransport

    {

    public: 

        // Constructors:

        static CSenHostletTransportPlugin* NewL(CSenTransportContext* apCtx);

        static CSenHostletTransportPlugin* NewLC(CSenTransportContext* apCtx);

        // Destructor:

        virtual ~CSenHostletTransportPlugin();

         // from MSenTransport

        virtual TInt SubmitL(const TDesC8& aEndpoint,

                             const TDesC8& aMessage,

                             const TDesC8& aTransportProperties,

                             HBufC8*& aResponse,

                             MSenRemoteServiceConsumer& aConsumer);

        virtual TInt SendL(const TDesC8& aEndpoint,

                           const TDesC8& aMessage,

                           const TDesC8& aTransportProperties,

                           MSenServiceSession& aReplyTo,

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

                           TInt& aTxnId);

        virtual TInt SetPropertiesL(const TDesC8& aProperties, 

                                    MSenLayeredProperties::TSenPropertiesLayer aTargetLayer,

									MSenRemoteServiceConsumer* aConsumer);

        virtual TInt PropertiesL(HBufC8*& aProperties);

        virtual TInt CompleteTransaction(const TInt aTxnId, const TInt aStatus = KErrNone);

        virtual TInt CancelTransaction(const TInt aTxnId);

        virtual TPtrC8 CSenHostletTransportPlugin::UriSchemeL();

        virtual MSenProperties& PropertiesL();

        //RConsumerMap ConsumerMap();

        //RSessionMap SessionMap();

    private:

        void ConstructL();

        CSenHostletTransportPlugin(CSenTransportContext* apCtx);

        // Helper, to locally "proxy" the provider, which was invoked *last* time

        MSenProvider& ProviderL(const TDesC8& aEndpoint);

    private: // member data

        CSenSyncRequester* ipRequester;

        CSenProvider* iInvokedProvider;

        TInt iStatusCode ;

        TInt iTransactionID;

        //RConsumerMap iConsumerMap; // values owned (TxnIds), keys not (consumers)

        //RSessionMap iSessionMap;   // values NOT owned (TxnIds), neither keys (sessions)

        RLocalRequestMap iRequestMap;

        CSenLayeredXmlProperties* ipLayeredXmlProperties;

    } ;

class CSenActiveHostletRequest : public CActive

    {

    friend class CSenHostletTransportPlugin;

    public:

        enum TLocalRequestState

            {

            EInvokeService = 1,

            ECompleteTransaction

            };

        // Standard 2 phased constructor

        static CSenActiveHostletRequest* NewLC(const TDesC8& aEndpoint,

                                               MSenServiceSession& aReplyTo,

                                               MSenRemoteServiceConsumer& aConsumer,

                                               TInt aTxnId,

                                               RLocalRequestMap& aRequestMap,

                                               MSenTransport& aParent,

                                               MSenTransportContext& aParentCtx);

        // C++ destructor

        virtual ~CSenActiveHostletRequest();

        MSenServiceSession& Session() const;

        MSenRemoteServiceConsumer& Consumer() const;

        TInt TxnId() const;

        // TPtrC8 TransportProperties() const;

        RLocalRequestMap& RequestMap();

        // This method is called when txn is ready to be completed

        // Note that this sets this AO in active state(!)

        TInt Complete(TRequestStatus*& aStatus, TInt aCompletionCode = KErrNone); 

        virtual void RunL(); 

        virtual void DoCancel();

        virtual TInt RunError(TInt aError);

    private:

        // 2nd phase constructor

        void ConstructL();

        // C++ constructor

        CSenActiveHostletRequest(const TDesC8& aEndpoint,

                                 MSenServiceSession& aReplyTo,

                                 MSenRemoteServiceConsumer& aConsumer,

                                 TInt aTxnId,

                                 RLocalRequestMap& aRequestMap,

                                 MSenTransport& aParent,

                                 MSenTransportContext& aParentCtx);

        CSenChunk* CSenActiveHostletRequest::FindChunkL(const TInt aTxnId, TInt& aIndex) ;                      

        CSenTransportProperties* NewPropertiesByTypeL( MSenProperties::TSenPropertiesClassType aType, const TDesC8& aPropertiesAsXml );

    private: // Data

        const TDesC8&               iEndpoint;

        TInt                        iCompletionCode;

        MSenServiceSession&         iReplyTo;

        MSenRemoteServiceConsumer&  iConsumer;

        TInt                        iTxnId;

        RLocalRequestMap&           iRequestMap;

        MSenTransport&              iParent;

        MSenTransportContext&       iParentContext;

        TPtrC8                      iMessage;

        TPtrC8                      iProperties; 

    };

#endif // SEN_HOSTLET_TRANSPORT_PLUGIN