/*
* Copyright (c) 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: Declaration of CMMCScBkupArchiveDataManager
*     
*
*/

#ifndef __CMMCSCBKUPARCHIVEDATAMANAGER_H__
#define __CMMCSCBKUPARCHIVEDATAMANAGER_H__

// System includes
#include <f32file.h>
#include <s32strm.h>

// User includes
#include "CMMCScBkupBufferManagers.h"
#include "MMMCScBkupArchiveDataInterface.h"
#include "TMMCScBkupArchiveVector.h"
#include "RMMCScBkupArchiveStreams.h"
#include "MMCScBkupOperations.h"
#include "MMCScBkupConfig.h"

// Classes referenced
class CEZCompressor;
class CEZDecompressor;
class RMMCScBkupArchiveBuf;
class MMMCScBkupProgressObserver;


/**
*
*
* @since 3.0
*/
NONSHARABLE_CLASS(CMMCScBkupArchiveDataManager) : public CActive, public MMMCScBkupArchiveDataInterface
    {
    public:

        /**
        * Static constructor
        */
        static CMMCScBkupArchiveDataManager* NewL( RFs& aFsSession, RFile64& aFile, MMMCScBkupProgressObserver& aProgressManager );

        /**
        * C++ destructor
        */
        ~CMMCScBkupArchiveDataManager();

    private:

        /**
        * C++ default constructor
        */
        CMMCScBkupArchiveDataManager( RFs& aFsSession, RFile64& aFile, MMMCScBkupProgressObserver& aProgressManager );

        /**
        *
        */
        void ConstructL();

    public: // API

        /**
        * Leaves on error, returns offset
        */
        TInt CurrentOffsetL() const;

        /**
        * Returns error or offset
        */
        TInt CurrentOffset() const;

    private: // For RMMCScBkupArchiveBuf only
   
        /**
        *
        */
        void SetCurrentVector(const TMMCScBkupArchiveVector& aInfo);


    private: // From MMMCScBkupArchiveDataInterface
        RFs& ADIFsSession() const;
        RFile64& ADIRawArchiveFile() const;
        //
        const TMMCScBkupArchiveVector& ADICurrentArchiveVectorInfo() const;
        const TMMCScBkupArchiveVector& ADIOverallArchiveVectorInfo() const;
        //
        RWriteStream& ADIWriteStreamUncompressedLC( TInt aPos );
        RReadStream& ADIReadStreamUncompressedLC( TInt aPos );
        //
        const TMMCScBkupArchiveVector& ADIWriteL( const TDesC8& aData );
        const TMMCScBkupArchiveVector& ADIReadL( TDes8& aSink, const TMMCScBkupArchiveVector& aInfo );
        //
        void ADIWriteFileL( const TDesC& aSourceFileName, TRequestStatus& aObserver );
        void ADIReadFileL( const TDesC& aDestinationFileName, const TMMCScBkupArchiveVector& aInfo, TRequestStatus& aStatus );
        //
        void ADIWriteCompressedL( const TDesC8& aData, TRequestStatus& aObserver );
        void ADIReadDecompressedL( TDes8& aSink, const TMMCScBkupArchiveVector& aInfo, TRequestStatus& aStatus ) ;
        //
        void ADIAsynchronousCancel();
        void ADIResetResources(TMMCScBkupOperationType aType);
#ifdef RD_FILE_MANAGER_BACKUP
        void ADIActivateCrcCalculation(TBool aType) { iCrcCalcActivated = aType; }
        TUint32 ADIArchiveCrc() { return iCrc; }
#endif


    private: // Internal enumerations

        /**
        *
        */
        enum TOperation
            {
            EOperationIdle = 0,
            EOperationCompressing,
            EOperationDecompressing
            };
    
    private: // Internal methods

        /**
        *
        */
        void EnsureCompressorExistsL(MEZBufferManager& aBufferManager);

        /**
        *
        */
        void EnsureDecompressorExistsL(MEZBufferManager& aBufferManager);

        /**
        *
        */
        void SetObserver(TRequestStatus& aStatus);

        /**
        *
        */
        void CompleteSelf(TInt aCompletionCode = KErrNone);

        /**
        *
        */
        void CompleteObserver(TInt aCompletionCode = KErrNone);

        /**
        *
        */
        void SetOperation(TOperation aOperation);
        
#ifdef RD_FILE_MANAGER_BACKUP
        /**
        *
        */
        void CalculateCrc( const TAny* aPtr,TInt aLength );
#endif


    private: // From CActive
        void RunL();
        void DoCancel();
        TInt RunError(TInt aError);

    private: // Member data

        // Owned externally:
        // 
        RFs& iFsSession;
        //
        RFile64& iFile;
        //
        MMMCScBkupProgressObserver& iProgressManager;
        //
        TRequestStatus* iObserverStatus;

        // Owned by this object
        //
        TOperation iOperation;
        //
        CMMCScBkupBufferManagerBase* iBufferManager;
        //
        CEZCompressor* iCompressor;
        //
        CEZDecompressor* iDecompressor;
        //
        TMMCScBkupArchiveVector iCurrentVectorInfo;
        //
        TMMCScBkupArchiveVector iOverallArchiveVectorInfo;
        //
        RMMCScBkupArchiveWriteStream iWriteStream;
        //
        RMMCScBkupArchiveReadStream iReadStream;
#ifdef RD_FILE_MANAGER_BACKUP
        //
        TBool iCrcCalcActivated;
        //
        TUint32 iCrc;
#if defined(__MMCSCBKUPLOGGING_ENABLED__)
        TUint32 iTotalTickCount;
#endif
#endif // RD_FILE_MANAGER_BACKUP

        friend class RMMCScBkupArchiveBuf;
    };




#endif // __CMMCSCBKUPARCHIVEDATAMANAGER_H__

//End of File