/*

* Copyright (c) 2002 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:  Incoming data handler

*                it handles incoming data from the network server

*

*/

#ifndef __CPENGINCOMINGDATAHANDLER_H__

#define __CPENGINCOMINGDATAHANDLER_H__

//  INCLUDES

#include <e32base.h>

// FORWARD DECLARATIONS

class MPEngPureDataHandler;

class MPEngIncomingTransactionHandler;

class MPEngTransactionFactory;

class MPEngRequestHandlerObserver;

// CLASS DECLARATION

/**

 *  Incoming data handler

 *  it handles incoming data from the network server

 *

 *  @lib PEngServer2

 *  @since 3.0

 */

NONSHARABLE_CLASS( CPEngIncomingDataHandler ) :

        public CActive

    {

public:  // Constructors and destructor

    /**

     *  Two-phased constructor.

     *  @since 3.0

     *  @param aPureDataHandler pure data handler

     *  @param aTransactionFactories transaction factories od CPS session

     *  @param aRequestHandlerObserver request handler observer

     */

    static CPEngIncomingDataHandler* NewL(

        MPEngPureDataHandler& aPureDataHandler,

        RPointerArray<MPEngTransactionFactory>&

        aTransactionFactories,

        MPEngRequestHandlerObserver& aRequestHandlerObserver );

    static CPEngIncomingDataHandler* NewLC(

        MPEngPureDataHandler& aPureDataHandler,

        RPointerArray<MPEngTransactionFactory>&

        aTransactionFactories,

        MPEngRequestHandlerObserver& aRequestHandlerObserver );

    /**

     *  Destructor.

     */

    virtual ~CPEngIncomingDataHandler();

public: // New functions

    /**

     *  Start listener

     *

     *  @since 3.0

     */

    void StartListeningL();

public:		// Function from the CActive

    /**

     * CActive RunL()

     * @since 3.0

     */

    void RunL();

    /**

     * CActive RunError()

     * @since 3.0

     * @param aError The leave code

     * @return KErrNone

     */

    TInt RunError( TInt aError );

    /**

     * Implements cancellation of an outstanding request.

     * This function is called as part of the active object’s Cancel()

     * @since 3.0

     */

    void DoCancel();

private:  // New functions

    /**

     * Handle new incoming data from the VW server

     * @since 3.0

     */

    void HandleIncomingDataL();

private:

    /**

     * C++ default constructor.

     */

    CPEngIncomingDataHandler(

        MPEngPureDataHandler& aPureDataHandler,

        RPointerArray<MPEngTransactionFactory>&

        aTransactionFactories,

        MPEngRequestHandlerObserver& aRequestHandlerObserver );

    /**

     * By default Symbian 2nd phase constructor is private.

     */

    void ConstructL();

private:    // Data

    /// REF: Pure data handler

    MPEngPureDataHandler&						iPureDataHandler;

    /// REF: Transaction factories

    RPointerArray<MPEngTransactionFactory>&		iTransactionFactories;

    /// REF: Request handler observer

    MPEngRequestHandlerObserver&				iRequestHandlerObserver;

    /// OWN: Incoming transaction handler

    MPEngIncomingTransactionHandler*			iTransactionHandler;

    };

#endif      // __CPENGINCOMINGDATAHANDLER_H__

// End of File