/*

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

*       Operation to copy or move messages

*

*/

#include <eikenv.h>

#include <imum.rsg>

#include <MsvPrgReporter.h>

#include <ImumInMailboxUtilities.h>

#include "MsvConnectionValidation.h"

#include "MsvEmailConnectionProgressProvider.h"

#include "EmailUtils.H"

#include "ImumDisconnectOperation.h"

#include "MsvPop3CopyMoveOperation.h"

#include "MsvPop3FetchOperation.h"

#include "IMSSettingsNoteUi.h"

// Constants and defines

const TInt KCopyOrMoveOpPriority = CActive::EPriorityStandard;

// ----------------------------------------------------------------------------

// NewL

// ----------------------------------------------------------------------------

CMsvPop3CopyMoveOperation* CMsvPop3CopyMoveOperation::NewL(

    CImumInternalApi& aMailboxApi,

    TRequestStatus& aObserverRequestStatus,

    MMsvProgressReporter& aReporter,

    TMsvId aService, TMsvId aTarget,

    const CMsvEntrySelection& aSel,

    TBool aMoveMsgs)

    {

    IMUM_STATIC_CONTEXT( CMsvPop3CopyMoveOperation::NewL, 0, mtm, KImumMtmLog );

    IMUM_IN();

     // static

    CMsvPop3CopyMoveOperation* op = new(ELeave) CMsvPop3CopyMoveOperation(

        aMailboxApi,

        aObserverRequestStatus,

        aReporter,

        aService,

        aTarget,

        aMoveMsgs);

    CleanupStack::PushL(op);

    op->ConstructL(aSel);

    CleanupStack::Pop();

    IMUM_OUT();

    return op;

    }

// ----------------------------------------------------------------------------

// ~CMsvPop3CopyMoveOperation

// ----------------------------------------------------------------------------

CMsvPop3CopyMoveOperation::~CMsvPop3CopyMoveOperation()

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::~CMsvPop3CopyMoveOperation, 0, KImumMtmLog );

    IMUM_IN();

    delete iLocalSel;

    delete iRemoteSel;

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// DoRunL

// ----------------------------------------------------------------------------

void CMsvPop3CopyMoveOperation::DoRunL()

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::DoRunL, 0, KImumMtmLog );

    IMUM_IN();

    switch(iState)

        {

        case ELocalMsgs:

            if(GetOperationCompletionCodeL() != KErrNone)

                {

                // Failed to copy local messages.

                iState = EIdle;

                CompleteObserver();

                }

            else

                {

                DoRemoteFetchL();

                }

            break;

        case ERemoteMsgs:

            iState = EIdle;

            CompleteObserver();

            break;

        default:

            break;

        }

    if(iOperation)

        iMtm = iOperation->Mtm();

    else

        iMtm = KUidMsgTypePOP3;

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// GetErrorProgressL

// ----------------------------------------------------------------------------

const TDesC8& CMsvPop3CopyMoveOperation::GetErrorProgressL(TInt aError)

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::GetErrorProgressL, 0, KImumMtmLog );

    IMUM_IN();

    iError = aError;

    switch(iState)

        {

        case ERemoteMsgs:

            if(iOperation)

                {

                // iOperation is a CMsvPop3FetchOperation.

                return STATIC_CAST(CImumOnlineOperation*,iOperation)->

                    GetErrorProgressL(aError);

                }

            break;

        case ELocalMsgs:

        default:

            break;

        }

    TPop3Progress& progress = iErrorProgress();

    progress.iTotalMsgs = 0;

    progress.iMsgsToProcess = 0;

    progress.iBytesDone = 0;

    progress.iTotalBytes = 0;

    progress.iErrorCode = iError;

    progress.iPop3Progress = (iMoving) ?

        (TPop3Progress::EPopMoving) : (TPop3Progress::EPopCopying);

    progress.iPop3SubStateProgress = progress.iPop3Progress;

    IMUM_OUT();

    return iErrorProgress;

    }

// ----------------------------------------------------------------------------

// SortMessageSelectionL

// ----------------------------------------------------------------------------

void CMsvPop3CopyMoveOperation::SortMessageSelectionL(

    const CMsvEntrySelection& aSel)

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::SortMessageSelectionL, 0, KImumMtmLog );

    IMUM_IN();

    // Sort messages into complete and incomplete selections.

    delete iLocalSel;

    iLocalSel = NULL;

    iLocalSel = new(ELeave) CMsvEntrySelection;

    delete iRemoteSel;

    iRemoteSel = NULL;

    iRemoteSel = new(ELeave) CMsvEntrySelection;

    TInt err;

    TMsvId id;

    TMsvId service;

    TMsvEntry tentry;

    for(TInt count=0; count<aSel.Count(); count++)

        {

        id = aSel[count];

        err = iMsvSession.GetEntry(id, service, tentry);

        if(KErrNone == err)

            {

            if(tentry.Complete())

                {

                iLocalSel->AppendL(id);

                }

            else

                {

                iRemoteSel->AppendL(id);

                }

            }

        }

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// DoLocalCopyMoveL

// ----------------------------------------------------------------------------

void CMsvPop3CopyMoveOperation::DoLocalCopyMoveL()

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::DoLocalCopyMoveL, 0, KImumMtmLog );

    IMUM_IN();

    if(iLocalSel->Count())

        {

        CMsvEntry* centry = iMsvSession.GetEntryL(iService);

        CleanupStack::PushL(centry);

        iStatus = KRequestPending;

        delete iOperation;

        iOperation = NULL;

        iOperation = MsvEmailMtmUiUtils::DoCEntryCopyMoveL(

            *centry,

            *iLocalSel,

            iTarget,

            iStatus,

            !iMoving);

        CleanupStack::PopAndDestroy(); // centry

        }

    else

        {

        CompleteThis();

        }

    iState = ELocalMsgs;

    SetActive();

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// DoRemoteFetchL

// ----------------------------------------------------------------------------

void CMsvPop3CopyMoveOperation::DoRemoteFetchL()

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::DoRemoteFetchL, 0, KImumMtmLog );

    IMUM_IN();

    TInt msgCount = iRemoteSel->Count();

    if(msgCount)

        {

        CMsvEntry* centry = iMsvSession.GetEntryL(iService);

        TBool doIt = centry->Entry().Connected();

        delete centry;

        if(!doIt)

            {

            // Prompt user before connecting.

            iReporter.MakeProgressVisibleL(EFalse);

            TInt queryResouce =  msgCount > 1 ?

                R_EMAIL_FETCH_MESSAGES_BEFORE_COPY_QUERY :

                R_EMAIL_FETCH_MESSAGE_BEFORE_COPY_QUERY;

            doIt = CIMSSettingsNoteUi::ShowQueryL(

                queryResouce, R_EMAIL_CONFIRMATION_QUERY );

            }

        if(doIt)

            {

            iReporter.MakeProgressVisibleL(ETrue);

            TImPop3GetMailInfo info;

            info.iMaxEmailSize = KMaxTInt32;

            info.iDestinationFolder = iTarget;

            TInt fnId = (iMoving) ? (KPOP3MTMMoveMailSelectionWhenAlreadyConnected) : (KPOP3MTMCopyMailSelectionWhenAlreadyConnected);

            iStatus = KRequestPending;

            delete iOperation;

            iOperation = NULL;

            iOperation = CMsvPop3FetchOperation::NewL(

                iMailboxApi,

                iStatus,

                iReporter,

                fnId,

                iService,

                info,

                *iRemoteSel);

            }

        }

    if(iStatus != KRequestPending)

        {

        CompleteThis();

        }

    iState = ERemoteMsgs;

    SetActive();

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// CMsvPop3CopyMoveOperation

// ----------------------------------------------------------------------------

CMsvPop3CopyMoveOperation::CMsvPop3CopyMoveOperation(

    CImumInternalApi& aMailboxApi,

    TRequestStatus& aObserverRequestStatus,

    MMsvProgressReporter& aReporter,

    TMsvId aService,

    TMsvId aTarget,

    TBool aMoveMsgs)

    :

    CImumDiskSpaceObserverOperation(

        aMailboxApi,

        KCopyOrMoveOpPriority,

        aObserverRequestStatus,

        aReporter),

    iMoving(aMoveMsgs),

    iTarget(aTarget)

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::CMsvPop3CopyMoveOperation, 0, KImumMtmLog );

    IMUM_IN();

    iService = aService;

    IMUM_OUT();

    }

// ----------------------------------------------------------------------------

// ConstructL

// ----------------------------------------------------------------------------

void CMsvPop3CopyMoveOperation::ConstructL(const CMsvEntrySelection& aSel)

    {

    IMUM_CONTEXT( CMsvPop3CopyMoveOperation::ConstructL, 0, KImumMtmLog );

    IMUM_IN();

    SortMessageSelectionL(aSel);

    BaseConstructL(KUidMsgTypePOP3);

    DoLocalCopyMoveL();

    IMUM_OUT();

    }