/*
* Copyright (c) 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:      Cds Sync Active Object header
*
*/






#ifndef CDSSYNCSQLAO_H
#define CDSSYNCSQLAO_H

// FORWARD DECLARATIONS
class MCmSqlMain;
class CCdsSyncImpl;
class CCmSqlBaseItem;
class CCmSqlGenericItem;

/**
 * CCdsSyncSqlAo class
 *
 * @lib cdssync.lib
 *
 * @since S60 v3.1
 */
class CCdsSyncSqlAo : public CActive 
    {         
public:
    // active object states
    enum TCdsSyncSqlAoState 
        {
        ECdsSyncSqlAoIdle = 0,
        ECdsSyncSqlAoAdding,
        ECdsSyncSqlAoDeleting,
        ECdsSyncSqlAoInitializing    
        };
        
    /**
     * Two-phased constructor.
     *
     * @param aSqlDb, Database handler instance
     * @param aSync, CdsSync implementation instance
     * @param aItemsToAdd, array of items to be added
     * @param aItemsToAdd, array of items to be deleted
     * @param aAddGranularity, count of items added at a time
     */
    static CCdsSyncSqlAo* NewL( MCmSqlMain& aSqlDb,
                                CCdsSyncImpl& aSync,
                                RPointerArray<CCmSqlGenericItem>& aItemsToAdd,
                                RPointerArray<CCmSqlBaseItem>& aItemsToDelete,
                                TInt aAddGranularity );

    /**
     * Two-phased constructor.
     *
     * @param aSqlDb, Database handler instance
     * @param aSync, CdsSync implementation instance
     * @param aItemsToAdd, array of items to be added
     * @param aItemsToAdd, array of items to be deleted
     * @param aAddGranularity, count of items added at a time     
     */
    static CCdsSyncSqlAo* NewLC( 
        MCmSqlMain& aSqlDb,
        CCdsSyncImpl& aSync,
        RPointerArray<CCmSqlGenericItem>& aItemsToAdd,
        RPointerArray<CCmSqlBaseItem>& aItemsToDelete,
        TInt aAddGranularity );

    /**
     * Destructor.
     */
    virtual ~CCdsSyncSqlAo();
 
    /**
     * NotifyItemsAddedL
     *
     * @since S60 v3.1
     * @param aSourceDataComplete, indicates if all source data is added     
     */
    void NotifyItemsAddedL( TBool aSourceDataComplete = EFalse );

    /**
     * Activate
     *
     * @since S60 v3.1
     */
    void Activate();
 
 protected:
 
// From base class CActive

    /**
     * From CActive
     * See base class definition
     */       
    void RunL();

    /**
     * From CActive
     * See base class definition
     */
    void DoCancel();
        
private:

    /**
     * Performs the first phase of two phase construction.
     *
     * @param aSqlDb, Database handler instance
     * @param aSync, CdsSync implementation instance
     * @param aItemsToAdd, array of items to be added
     * @param aItemsToAdd, array of items to be deleted
     * @param aAddGranularity, count of items added at a time     
     */   
    CCdsSyncSqlAo( MCmSqlMain& aSqlDb,
                   CCdsSyncImpl& aSync,
                   RPointerArray<CCmSqlGenericItem>& aItemsToAdd,
                   RPointerArray<CCmSqlBaseItem>& aItemsToDelete,
                   TInt aAddGranularity );

    /**
     * Performs the second phase construction.
     */  
    void ConstructL();    

    /**
     * Checks metadata amouts and removes overhead items
     *
     * @since S60 v5.1
     */        
    void IfOverLimitDeleteMediaItems();                  
        
public:

    /**
     * Active object state 
     */
    TCdsSyncSqlAoState                  iState;
  
private:

    /**
     * Database handler
     */  
    MCmSqlMain&                         iSqlDb;

    /**
     * Cds sync implementation reference
     */
    CCdsSyncImpl&                       iSync;
    
    /**
     * Array of items to be added
     */
    RPointerArray<CCmSqlGenericItem>&   iItemsToAdd;
    
    /**
     * Array of items to be deleted
     */
    RPointerArray<CCmSqlBaseItem>&      iItemsToDelete;

    /**
     * Amount of files to be added at a time
     */
    TInt                                iAddGranularity;
    /**
     * Flag for indicating that source data is ready
     */
    TBool                               iSourceDataComplete;

    /**
     * Count of items to be added
     */
    TInt                                iItemsInAddition;        

#ifdef _DEBUG
    /**
     * Time stamps for logging
     */
    TTime iOperationTime;
#endif // _DEBUG

};

#endif // CDSSYNCSQLAO_H