/*
* Copyright (c) 2003 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:  
*     Changes message flag.
*
*/



// INCLUDE FILES
#include "MceChangeFlagOperation.h"   // header

#include <msvids.h>         // KMsvRootIndexEntryId

// CONSTANTS

_LIT8 ( KMceSpace8, " " ); // 8 bit space


// ================= MEMBER FUNCTIONS =======================

// ----------------------------------------------------
// CMceRemoveNewFlag::NewL
// Two-phased constructor.
// ----------------------------------------------------
CMceRemoveNewFlag* CMceRemoveNewFlag::NewL(
    TUint32 aRemoveFlags,
    CMsvSession& aMsvSession, 
    TRequestStatus& aObserverRequestStatus, 
    CMsvEntrySelection* aSelection )
    {
    CMceRemoveNewFlag* self=new (ELeave) CMceRemoveNewFlag(
        aRemoveFlags, aMsvSession, aObserverRequestStatus, KMsvRootIndexEntryId, aSelection );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::CMceRemoveNewFlag
// Constructor.
// ----------------------------------------------------
CMceRemoveNewFlag::CMceRemoveNewFlag(
    TUint32 aRemoveFlags,
    CMsvSession& aMsvSession, 
    TRequestStatus& aObserverRequestStatus, 
    TMsvId aFolderId,
    CMsvEntrySelection* aSelection )
    :
    CMsvOperation(aMsvSession, CActive::EPriorityStandard, aObserverRequestStatus), 
    iFolderId( aFolderId ),
    iEntrySelection( aSelection ),
    iBlank( KMceSpace8 )
    {
    CActiveScheduler::Add( this );
    iRemoveFlags.SetMceFlag( aRemoveFlags );
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::~CMceRemoveNewFlag
// Destructor.
// ----------------------------------------------------
CMceRemoveNewFlag::~CMceRemoveNewFlag()
    {
    Cancel();
    delete iOperation;    
    delete iEntry;
    delete iEntrySelection;
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::ConstructL
// Constructor..
// ----------------------------------------------------
void CMceRemoveNewFlag::ConstructL()
    {
    iCount = iEntrySelection->Count();
    iEntry = CMsvEntry::NewL( iMsvSession, iFolderId, TMsvSelectionOrdering() );
       
    if ( iEntrySelection->Count() == 0 )
        {
        iStatus=KRequestPending;
        SetActive();
        TRequestStatus* status = &iStatus;
        User::RequestComplete( status, KErrNone );
        }    
    else
        {
        TMsvId serviceId; // not used
        TMsvEntry entry;
        for ( TInt loop=iCount-1; loop>=0; loop-- )
            {            
            const TMsvId id = iEntrySelection->At( loop );
            User::LeaveIfError( iMsvSession.GetEntry( id, serviceId, entry ) );
            DeleteFromSelection( loop, entry.Unread() );
            }
         if ( iEntrySelection->Count() > 0 )
            {
            RemoveNextNewFlagL();
            }
         else
            {
            //all were read
            iStatus=KRequestPending;
            SetActive();
            TRequestStatus* status = &iStatus;
            User::RequestComplete( status, KErrNone );
            }
        }
    }

//
// ----------------------------------------------------------------------------
// CMceRemoveNewFlag::DeleteFromSelection()
// ----------------------------------------------------------------------------
//
void CMceRemoveNewFlag::DeleteFromSelection( TInt aIndex, TBool aUnread )
    {
    // Remove from selection, 
    // when read and setting to read or
    // when unread and setting to unread
    if ( iRemoveFlags.MceFlag( 
            EMceRemoveEntryFlagUnread ) && !aUnread || 
         iRemoveFlags.MceFlag( 
            EMceRemoveEntryFlagNew ) && aUnread ) //Changed from EMceRestoreEntryFlagRead
        {
        //remove read entries from selection
        iEntrySelection->Delete( aIndex );                
        }   
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::RemoveNextNewFlagL
// Starts handling next message to mark it read.
// ----------------------------------------------------
void CMceRemoveNewFlag::RemoveNextNewFlagL()
    {   
    delete iOperation;
    iOperation = NULL;      

    TMsvId serviceId; // not used
    TMsvEntry entry;
    const TMsvId id = iEntrySelection->At( 0 );   
    User::LeaveIfError( iMsvSession.GetEntry( id, serviceId, entry ) );
    
    TRAPD( err, MakeNextRemoveL() );

    // whether error or not, remove the data for this operation
    iEntrySelection->Delete( 0 );
    // and set active
    iStatus=KRequestPending;
    SetActive();
    // if error then complete this pass with the error code
    if ( err )
        {
        TRequestStatus* status = &iStatus;
        User::RequestComplete( status, err );
        }
    }


// ----------------------------------------------------
// CMceRemoveNewFlag::MakeNextRemoveL
// Marks message read.
// ----------------------------------------------------
void CMceRemoveNewFlag::MakeNextRemoveL()
    {
    iEntry->SetEntryL( (*iEntrySelection)[0] );
    iNewEntry = iEntry->Entry();
    
    // In no case that mce should set a message new
    // it used to be "!iRemoveFlags.MceFlag( EMceRemoveEntryFlagNew )" for some unknown reason
    iNewEntry.SetNew(  EFalse ); 
    iNewEntry.SetUnread( !iRemoveFlags.MceFlag( EMceRemoveEntryFlagUnread ) );        
    iOperation=iEntry->ChangeL( iNewEntry, iStatus );    
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::DoCancel
// Cancels active object.
// ----------------------------------------------------
void CMceRemoveNewFlag::DoCancel()
    {
    if ( iOperation )
        {
        iOperation->Cancel();
        }
    TRequestStatus* status = &iObserverRequestStatus;
    User::RequestComplete( status, iStatus.Int() );
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::RunL
// Runs active object.
// ----------------------------------------------------
void CMceRemoveNewFlag::RunL()
    {
    if ( iEntrySelection->Count()==0 )
        {
        // nothing left to process, so complete the observer
        TRequestStatus* status = &iObserverRequestStatus;
        User::RequestComplete( status, iStatus.Int() );
        }
    else 
        {
        // start the next pass
        RemoveNextNewFlagL();
        }   
    }

// ----------------------------------------------------
// CMceRemoveNewFlag::ProgressL
// Progressing of active object.
// ----------------------------------------------------
const TDesC8& CMceRemoveNewFlag::ProgressL()
    {
    if ( iOperation )
        {
        return iOperation->ProgressL();
        }
    return iBlank;
    }

// ---------------------------------------------------------
// CMceRemoveNewFlag::DecodeProgress
//
// ---------------------------------------------------------
//
TInt CMceRemoveNewFlag::DecodeProgress(
    const TDesC8& /*aProgress*/, 
    TBuf<CBaseMtmUi::EProgressStringMaxLen>& aReturnString, 
    TInt& aTotalEntryCount, 
    TInt& aEntriesDone,
    TInt& aCurrentEntrySize, 
    TInt& aCurrentBytesTrans, 
    TBool /*aInternal*/ )
    {
    aCurrentEntrySize = aTotalEntryCount = iCount;
    aCurrentBytesTrans = aEntriesDone = iCount - (iEntrySelection->Count());    
    aReturnString.Copy( _L("") );  
    return KErrNone;
    }

// End of file