/*

* Copyright (c) 2005-2009 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:  Notifier client side active object

*

*/

#ifndef __MDENOTIFIERAOAO_H__

#define __MDENOTIFIERAOAO_H__

// INCLUDE FILES

#include <e32base.h>

#include "mdccommon.h"

#include "mdecondition.h"

// forward declarations

class RMdEEngineSession;

class CMdESessionImpl;

class CMdENamespaceDef;

class CMdERelation;

class TMdERelation;

// local constants

const TInt KDefaultBufferSize = 1024; // 1 KB

/**

* CMdENotifierAO

* An active object that receives notifications from server

* side whenever a registrated event has occurred.

*/

NONSHARABLE_CLASS(CMdENotifierAO) : public CActive

    {

    public: // Constructors and destructors

		/**

		 * Two-phased constructor.

		 * @param aSessionImpl session impl

		 * @param aSession the server handler

		 * @return the created instance

		 */

		 static CMdENotifierAO* NewL(

		     CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession );

        /**

        * Two-phased constructor.

        * @param aSessionImpl session impl

        * @param aSession the server handler

        * @return the created instance

        */

        static CMdENotifierAO* NewLC(

            CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession );

        /**

        * Destructor.

        */

        virtual ~CMdENotifierAO();

        /**

        * register for receiving events

        * @param aMode observer mode: object, event or relation

        * @param aObserver observer to be notified when event occurs

        * @param aCondition condition when to notify

        */

        void RegisterL( TUint32 aType, TAny* aObserver, CMdECondition* aCondition, CMdENamespaceDef& aNamespaceDef );

        /**

        * compares an observer against one stored in this AO

        * @param aMode observer mode: object, event or relation

        * @param aObserver observer pointer

        */

        TBool Match( TUint32 aType, TAny* aObserver, CMdENamespaceDef& aNamespaceDef );

        /**

        * ID of this client side notifier object

        */

        TInt Id();

    protected: // Functions from base classes

        /**

        * From CActive

        * Callback function.

        * Invoked to handle responses from the server.

        */

        void RunL();

        /**

        * From CActive

        * Handles errors that occur during notifying the observer.

        */

        TInt RunError(TInt aError);

        /**

        * From CActive

        * Cancels any outstanding operation.

        */

        void DoCancel();

    private: // Constructors and destructors

        /**

        * constructor

        * @param aSessionImpl session impl

        * @param aSession the server handler

        */

        CMdENotifierAO(

            CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession );

        /**

        * 2nd phase constructor

        */

        void ConstructL();

        /**

        * notify the corresponding client observer pointer

        * @param aItem the item (in coded form) to be notified

        * @param aStatus what has actually happened with the item

        */

        void DoNotifyObserver();

		void DecodeIdBufferL();

		void DecodeDataBufferL();

		void DecodeRelationItemBufferL();

    private: // Data

        /** the session impl. */

        CMdESessionImpl& iSessionImpl;

        /** the session */

        RMdEEngineSession& iSession;

        /** observer to be notified, actual class depends on type */

        TAny* iObserver;

        /** notifier type */

        TUint32 iType;

		/** Namespace definition's ID */

        TDefId iNamespaceDefId;

        /** size of result block */

        TPckgBuf<TInt> iResultSize;

        CMdCSerializationBuffer* iDataBuffer;

		RArray<TItemId> iIdArray;

		RPointerArray<HBufC> iUriArray;

		RArray<TMdERelation> iRelationItemArray;

    };

#endif //__MDENOTIFIERAOAO_H__