/*
* 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: Forwards client request messages to server operations.
*
*
*/


#ifndef CPOSLMOPERATIONMANAGER_H
#define CPOSLMOPERATIONMANAGER_H

#include <badesca.h>
#include "EPos_MPosLmServerOperationObserver.h"

class CPosLmServer;
class CPosLmServerOperation;
class MPosLmServerManagerObserver;

/**
* Forwards client request messages to server operations.
*/
class CPosLmOperationManager :
    public CBase, public MPosLmServerOperationObserver
    {

    public: // Data types

    /**
    * Operation manager type.
    */
    enum TPosOperationManagerType
        {
        EPosInitializerManager = 0,     /** Manager handles initialization. */
        EPosMaxNumberOfManagers
        };

    public:  // Constructors and destructor

        /**
        * Two-phased constructor.
        *
        * @param[in] aType Operation manager type.
        * @param[in,out] aObserver An observer.
        */
        static CPosLmOperationManager* NewL(
            CPosLmServer& aServer,
            TPosOperationManagerType aType,
            MPosLmServerManagerObserver* aObserver );

        /**
        * Destructor.
        */
        virtual ~CPosLmOperationManager();

    public: // From MPosLmServerOperationObserver.

        /**
        * Called to report status of a server operation.
        *
        * @param[in] aServerOperation The object which handles the server operation.
        * @param[in] aStatus The status of the server operation.
        */
        void HandleOperationStatus(
            CPosLmServerOperation* aServerOperation,
            TInt aStatus );

    public: // New functions

        /**
        * Forwards a client request to an operation depending on the message
        * function type and the database URI . If no operation matches the URI
        * a new operation is created.
        *
        * @param[in] aMessage A client request message.
        * @param[in] aUri A database URI.
        * @param[in] aSession The session associated with the message.
        */
        void AddRequestL(
            const RMessage2& aMessage,
            const TDesC& aUri,
            TAny* aSession );

        /**
        * Gets the number of running server operations this manager currently
        * manages.
        *
        * @return The number of running server operations.
        */
        TInt Count();

        /**
        * Removes messages associated with a specific session from the
        * server operations
        *
        * @param[in] aSession A pointer to a session.
        */
        void RemoveSessionMessages( TAny* aSession );

    private:

        /**
        * C++ default constructor.
        *
        * @param[in] aType Operation manager type.
        * @param[in,out] aObserver An observer.
        */
        CPosLmOperationManager(
            CPosLmServer& aServer,
            TPosOperationManagerType aType,
            MPosLmServerManagerObserver* aObserver
            );

        /**
        * By default Symbian 2nd phase constructor is private.
        */
        void ConstructL();

        /**
        * Returns the server operation associated with the specified URI. If no
        * operation exists it will be created.
        *
        * @param[in] aUri A database URI.
        * @param[in] aSession Requestor of the operation
        * @return A server operation corresponding the URI.
        */
        CPosLmServerOperation* OperationL( const TDesC& aUri, TAny* aSession );
        CPosLmServerOperation* FindOperationL( const TDesC& aUri );
        CPosLmServerOperation* CreateOperationL( const TDesC& aUri );

    private:    // Data

        CPosLmServer& iServer;
    
        // Array of running operations. Element position matches a URI.
        RPointerArray<CPosLmServerOperation> iOperations;

        // Array of URIs. Element position matches an operation.
        CDesCArrayFlat* iUriArray;

        // The type of this manager.
        TPosOperationManagerType iType;

        // Operation manager observer
        MPosLmServerManagerObserver* iObserver;

    };

#endif      // CPOSLMOPERATIONMANAGER_H