/*

* Copyright (c) 2006-2007 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:  Processor

 *

*/

#ifndef THUMBAGPROCESSOR_H

#define THUMBAGPROCESSOR_H

#include <thumbnailmanager.h>

#include <thumbnailmanagerobserver.h>

#include <thumbnaildata.h>

#include <mdesession.h>

#include <mdccommon.h>

#include <mdeobjectquery.h>

#include "thumbnaillog.h"

#include <harvesterclient.h>

#include <e32property.h>

#include <mpxcollectionobserver.h>

#include "tmactivitymanager.h"

#include "tmformatobserver.h"

#include "tmrpropertyobserver.h"

//FORWARD DECLARATIONS

class MMPXCollectionUtility;

/**

 *  Processor object for handling thumb generation

 *

 *  @since S60 v5.0

 */

class CThumbAGProcessor: public CActive,

                         public MThumbnailManagerObserver,

                         public MMdEQueryObserver,

                         public MHarvesterEventObserver,

                         public MMPXCollectionObserver,

                         public MTMActivityManagerObserver,

                         public MTMFormatObserver,

                         public MTMRPropertyObserver

    {

public:

    /**

     * Two-phased constructor.

     *

     * @since S60 v5.0

     * @return Instance of CThumbAGProcessor.

     */

    static CThumbAGProcessor* NewL();

    /**

     * Destructor

     *

     * @since S60 v5.0

     */

    virtual ~CThumbAGProcessor();

public:

    // From MMdEQueryObserver

    void HandleQueryNewResults( CMdEQuery& aQuery,

                                TInt aFirstNewItemIndex,

                                TInt aNewItemCount );

    void HandleQueryCompleted( CMdEQuery& aQuery, TInt aError );

    // from MThumbnailManagerObserver

    void ThumbnailPreviewReady( MThumbnailData& aThumbnail, TThumbnailRequestId aId );

    void ThumbnailReady( TInt aError, MThumbnailData& aThumbnail, TThumbnailRequestId aId );

    // from MHarvesterEventObserver

    void HarvestingUpdated( 

             HarvesterEventObserverType aHEObserverType, 

             HarvesterEventState aHarvesterEventState,

             TInt aItemsLeft );

    //From MTMFormatObserver

    void FormatNotification(TBool aFormat);

private: 

    // From MMPXCollectionObserver

    /// See @ref MMPXCollectionObserver::HandleCollectionMessageL

    void HandleCollectionMessage( CMPXMessage* aMessage,  TInt aError );

    /// See @ref MMPXCollectionObserver::HandleOpenL

    void HandleOpenL(const CMPXMedia& aEntries, TInt aIndex, TBool aComplete, TInt aError);

    /// See @ref MMPXCollectionObserver::HandleOpenL

    void HandleOpenL(const CMPXCollectionPlaylist& aPlaylist, TInt aError);  

    /// See @ref MMPXCollectionObserver::HandleCollectionMediaL

    void HandleCollectionMediaL( const CMPXMedia& aMedia, TInt aError );

private: //From MTMActivityManagerObserver

    void ActivityChanged(const TBool aActive);

private: //From MTMRPropertyObserver

    void RPropertyNotification(const TInt aError, const TUid aKeyCategory, const TUint aPropertyKey, const TInt aValue);

public:     

    /**

     * Sets MdE Session

     *

     * @since S60 v5.0

     * @param aMdESession MdE Session

     */

    void SetMdESession( CMdESession* aMdESession );    

    /**

     * Adds new IDs to queue

     *

     * @since S60 v5.0

     * @param aType TObserverNotificationType

     * @param aIDArray IDs for thumbnail creation

     * @param aForce pass ETrue if processor is forced to run without waiting harvesting complete

     */

    void AddToQueueL( TObserverNotificationType aType, const RArray<TItemId>& aIDArray, const RPointerArray<HBufC>& aObjectUriArray, TBool aPresent );

    /**

     * Calls Thumbnail Manager to create thumbnails

     *

     * @since S60 v5.0

     * @param aObject MdEObject

     */

    void CreateThumbnailsL( const CMdEObject* aObject ); 

    /**

     * Remove IDs from queue

     *

     * @since S60 v5.0

     * @param aIDArray IDs for thumbnail creation

     */

    void RemoveFromQueues( const RArray<TItemId>& aIDArray, const TBool aRemoveFromDelete = EFalse);

    void SetForceRun( const TBool aForceRun );

protected:

    void QueryAllItemsL();

    /**

     * QueryL

     *

     * @since S60 v5.0

     * @param aIDArray Item IDs to query

     */

    void QueryL( RArray<TItemId>& aIDArray );

    void QueryPlaceholdersL();

protected:

    /**

     * Handles an active object's request completion event.

     *

     * @since S60 v5.0

     */

    void RunL();

    /**

     * Implements cancellation of an outstanding request.

     *

     * @since S60 v5.0

     */

    void DoCancel();

    /**

     * Implements RunL error handling.

     *

     * @since S60 v5.0

     */

    TInt RunError(TInt aError);

private:

    /**

     * C++ default constructor

     *

     * @since S60 v5.0

     * @return Instance of CThumbAGProcessor.

     */

    CThumbAGProcessor();

    /**

     * Symbian 2nd phase constructor can leave.

     *

     * @since S60 v5.0

     */

    void ConstructL();

    /**

     * Activate AO

     *

     * @since S60 v5.0

     */

    void ActivateAO();

    /**

     * Callback for harvesting complete timer

     *

     * @since S60 v5.0

     */

    static TInt PeriodicTimerCallBack(TAny* aAny);

    /**

     * Check auto creation values from cenrep

     *

     * @since S60 v5.0

     */

    void CheckAutoCreateValuesL();

    /**

     * Start timeout timer

     *

     * @since S60 v5.0

     */

    void StartTimeout();

    /**

     * Cancel timeout timer

     *

     * @since S60 v5.0

     */

    void CancelTimeout();

    /**

     * Update KItemsLeft PS value

     * 

     * @since S60 v5.0

 	 * @param aDefine (re)define PS key before setting value

     */

    void UpdatePSValues(const TBool aDefine = EFalse);

    /**

     * Comparison function for logaritmic use of queue arrays

     * 

     * @since S60 v5.0

     */

    static TInt Compare(const TItemId& aLeft, const TItemId& aRight);

private:

    // not own

    CMdESession* iMdESession;

    CMdENamespaceDef* iDefNamespace;

    // own

    CThumbnailManager* iTMSession;

    CMdEObjectQuery* iQuery;

    CMdEObjectQuery* iQueryAllItems;

    CMdEObjectQuery* iQueryPlaceholders;

    RArray<TItemId> iAddQueue;

    RArray<TItemId> iModifyQueue;

    RPointerArray<HBufC> iRemoveQueue;

    RArray<TItemId> iQueryQueue;

    RArray<TItemId> iPlaceholderQueue;

    //not processing queue, used to keep KItemsLeft PS correct

    RArray<TItemId> i2ndRoundGenerateQueue;

	//reference to current processing queue

    RArray<TItemId>* iLastQueue;

    TBool i2ndRound;    

    TBool iQueryActive;

    TBool iQueryReady;

    TBool iModify;

    TInt iProcessingCount;

    TBool iHarvesting;

    TBool iHarvestingTemp;

    TBool iPHHarvesting;

    TBool iPHHarvestingTemp;

    CPeriodic* iPeriodicTimer;

	//MDS Harvester client

    RHarvesterClient iHarvesterClient;

    //Set when running RunL() first time

    TBool iInit;

    //2nd phase init after MDE session is open

    TBool iInit2;

    // auto create

    TBool iAutoImage;

    TBool iAutoVideo;

    TBool iAutoAudio;

    // in case of modified files force TN update

    TBool iForceRun; 

    // controlled by Photos application to run TN generation on foreground

    TBool iForegroundRun;

	//request pending in TNM side

    TBool iActive;

    CTMFormatObserver* iFormatObserver;

    TBool iFormatting;

    TBool iSessionDied;

    TInt iActiveCount;

    MMPXCollectionUtility* iCollectionUtility; // own

	//Flag is MPX harvesting or MTP synchronisation in progress

    TBool iMPXHarvesting;

    //inactivity polling timer

    CPeriodic* iInactivityTimer;

    //overall status of device

    TBool iIdle;

    CTMActivityManager* iActivityManager;

	//Observer foreground generation 

    CTMRPropertyObserver* iForegroundGenerationObserver;

	//Previously notified amount of items in processing queues (add/modify)

    TInt iPreviousItemsLeft;

    TBool iPreviousDaemonProcessing; 

	//set ETrue when QueryAllItems needs to be run after placeholder query

    TBool iDoQueryAllItems;

};

#endif // THUMBAGPROCESSOR_H