/*

* Copyright (c) 2004 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:  Access handler of the network session

*

*/

#ifndef __CPENGPUREDATAHANDLER_H__

#define __CPENGPUREDATAHANDLER_H__

//  INCLUDES

#include <E32Base.h>

#include <impspurecli.h>

#include "MPEngPureDataHandler.h"

#include "MPEngSessionStatusObserver.h"

// FORWARD DECLARATIONS

class CPEngSendDataOperation;

class CPEngSessionSlotId;

class RImpsEng;

class MPEngSessionManager;

class MPEngAccessHandler;

/**

 * CPEngPureDataHandler implementation.

 *

 * @since 3.0

 */

NONSHARABLE_CLASS( CPEngPureDataHandler ) :

        public CBase,

        public MPEngPureDataHandler,

        public MImpsPureHandler2,

        public MImpsErrorHandler2,

        public MPEngSessionStatusObserver

    {

public: /* Construction */

    /**

     * Instantiates CPEngPureDataHandler object.

     *

     * @return New CPEngPureDataHandler instance.

     */

    static CPEngPureDataHandler* NewL( RImpsEng& aSessClient,

    MPEngSessionManager& aSessManager,

    MPEngAccessHandler& aAccessHandler,

    const CPEngSessionSlotId& aSessionId );

    /**

     * Destructor.

     */

    ~CPEngPureDataHandler();

    //-----------------------------------------------------------------------

public: // new functions from MPEngPureDataHandler

    /**

     *  Close reference to the Pure data handler

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    void Close();

    /**

     *  Get Transfer buffer for out going message

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    TPtr8 TransferBufferL();

    /**

     *  Sends data from the transfer buffer to the network

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    TInt SendDataL( TRequestStatus& aStatus );

    /**

     *  Gets response for the message of given operation id

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    HBufC8* ResponseL( TInt aTransId );

    /**

     *  Cancel sendin operation of given transaction id

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    void CancelSending( TInt aTransId );

    /**

     *  Listen Incoming data

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    TInt ListenIncomingData( TRequestStatus& aStatus );

    /**

     *  Cancel incoming data listening

     *  @see <MPEngPureDataHandler.h>

     *  @since 3.0

     */

    void CancelListening();

public: // new functions from MImpsPureHandler

    /**

     * Observer method for pure message content.

     * @see <impspurecli.h>

     * @seince 3.0

     */

    void HandlePureDataL( TInt aOpId,

                          const TDesC8& aBuffer,

                          TImpsCspIdentifier& aCspId );

public: // new functions from MImpsErrorHandler

    /**

     * Observer method for error messages.

     * @see <impspurecli.h>

     * @seince 3.0

     */

    void HandleErrorL( TInt aStatus,

                       TInt aOpId,

                       const TDesC* aDescription,

                       const CImpsDetailed* aDetailedRes,

                       TImpsCspIdentifier& aCspId );

public: //  new function from the MPEngSessionStatusObserver

    /**

     *  Handle Session status change

     *  @see <MPEngSessionStatusObserver.h>

     *  @since 3.0

     */

    void StatusChangedL( TPEngNWSessionSlotState aNewState,

                         TPEngNWSessionSlotEvent aNewEvent );

public: // New functions

    /**

     *  Open new reference to the object

     *

     *  @since 3.0

     */

    void Open();

private: // new private functions

    /**

     *  Find operation

     *

     *  @since 3.0

     *  @return index in array

     */

    TInt FindOperation( TInt aOpId, TInt ( CPEngSendDataOperation:: *aIdFunc )() const ) const;

    TInt FindOperationL( TInt aOpId, TInt ( CPEngSendDataOperation:: *aIdFunc )() const ) const;

protected: // construction

    /**

     * C++ constructor. protected

     */

    CPEngPureDataHandler( MPEngSessionManager& aSessManager,

                          MPEngAccessHandler& aAccessHandler,

                          const CPEngSessionSlotId& aSessionId,

                          RImpsEng& aSessClient );

    /**

     * Symbian Second phase constructor

     */

    void ConstructL( RImpsEng& aSessClient );

private: //Data

    /// OWN: Access count

    TInt                                    iCount;

    /// OWN: Session manager

    MPEngSessionManager&                    iSessionManager;

    /// OWN: Access handler

    MPEngAccessHandler&						iAccessHandler;

    /// REF: Session Id

    const CPEngSessionSlotId&               iSessionId;

    /// OWN: Max number of active requests

    TInt                                    iMaxActive;

    /// OWN: Transfer buffer, OWNED

    HBufC8*                                 iTrasferBuffer;

    /// OWN: Incoming data queue, OWNED

    RPointerArray<HBufC8>                   iIncomingData;

    // Incoming data Request Status

    TRequestStatus*                         iIncReqStatus;

    /// REF: Main client of the IMPS Engine

    RImpsEng&                               iSessClient;

    /// OWN: Pure client

    RImpsPureClient2                        iPureClient;

    /// OWN: Send data operations]

    ///     Elements OWNed

    RPointerArray<CPEngSendDataOperation>   iOperations;

    /// OWN: Id which is used to do logs more human readable

    TInt                                    iConnectionLogsId;

    /// OWN: Logs Id iteration,

    TInt                                    iOpidIterator;

    /// OWN: Last served op Id

    TInt                                    iLastServerOpId;

    };

#endif  //__CPENGPUREDATAHANDLER_H__

// End of File