/*

* Copyright (c) 2007-2008 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:  POP3 fetch message operation class

*

*/

#include "emailtrace.h"

#include "ipsplgheaders.h"

// Constants and defines

const TInt KFetchOpPriority = CActive::EPriorityStandard;

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

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

CIpsPlgPop3FetchOperation* CIpsPlgPop3FetchOperation::NewL(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TInt aFunctionId,

    TMsvId aService,

    CIpsPlgTimerOperation& aActivityTimer,

    const TImPop3GetMailInfo& aGetMailInfo,

    const CMsvEntrySelection& aSel,

    TFSMailMsgId aFSMailBoxId,

    MFSMailRequestObserver& aFSOperationObserver,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    {

    FUNC_LOG;

    CIpsPlgPop3FetchOperation* op = new(ELeave) CIpsPlgPop3FetchOperation(

        aMsvSession, aObserverRequestStatus, aFunctionId, aService,

        aActivityTimer, aGetMailInfo, aFSMailBoxId, aFSOperationObserver,

        aFSRequestId, aEventHandler );

    CleanupStack::PushL(op);

    op->ConstructL(aSel);

    CleanupStack::Pop( op );

    return op;

    }

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

// ~CIpsPlgPop3FetchOperation

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

CIpsPlgPop3FetchOperation::~CIpsPlgPop3FetchOperation()

    {

    FUNC_LOG;

    delete iFetchErrorProgress;

    delete iSelection;

    delete iEntry;

    }

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

// ProgressL

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

const TDesC8& CIpsPlgPop3FetchOperation::ProgressL()

    {

    FUNC_LOG;

    if(iFetchErrorProgress && (iState == EStateIdle))

        {

        // Completed, but with an error during fetch.

        return *iFetchErrorProgress;

        }

    else

        {

        TPop3Progress progg;

        progg.iTotalSize = 0;

        progg.iErrorCode = KErrNone;

        TPckgBuf<TPop3Progress> param(progg);

        iProgressBuf.Copy(param);

        return iProgressBuf;   

        }

    }

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

// ConstructL

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

void CIpsPlgPop3FetchOperation::ConstructL(const CMsvEntrySelection& aSel)

    {

    FUNC_LOG;

    BaseConstructL( KUidMsgTypePOP3 );

    iSelection = aSel.CopyL();

    iSelection->InsertL( 0, iService );

    // For Get Mail API, first selection element must be service.

    // It is possible that the complete flag is on and we want to

    // download the attachment. In these cases we need to clear the

    // complete flag.

    TInt count = iSelection->Count();

    for ( ; iEntryIndex < count && !iOperation; iEntryIndex++ )

        {

        delete iEntry;

        iEntry = NULL;

        iEntry = iMsvSession.GetEntryL( iSelection->At( iEntryIndex ) );

        TMsvEntry entry = iEntry->Entry();

        TBool complete = entry.Complete();

        if ( complete )

            {

            entry.SetComplete( EFalse );

            iOperation = iEntry->ChangeL( entry, iStatus );

            SetActive();

            iState = EStateClearCompleteFlag;

            }

        }

    if ( !iOperation )

        {

        DoConnectL();

        }

    }

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

// DoConnectL

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

void CIpsPlgPop3FetchOperation::DoConnectL()

    {

    FUNC_LOG;

    iState = EStateConnecting;

    iStatus = KRequestPending;

    // when connecting for the fetch operation, don't let connect operation to do fetch,

    // because we do it by ourself. That's why give 0 to connect operation.    

    CIpsPlgPop3ConnectOp* connOp = CIpsPlgPop3ConnectOp::NewL(

        iMsvSession, iStatus, iService, EFalse, *iActivityTimer,

        iFSMailboxId, iFSOperationObserver, iFSRequestId, NULL,EFalse );

    delete iOperation;

    iOperation = connOp;

    SetActive();

    }

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

// DoFetchL

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

void CIpsPlgPop3FetchOperation::DoFetchL()

    {

    FUNC_LOG;

    iState = EStateFetching;

    // Switch operations.

    delete iOperation;

    iOperation = NULL;

    iStatus = KRequestPending;

    // Filters are not used when performing 'fetch' operation, use normal 

    // getmail info instead

    TPckg<TImPop3GetMailInfo> param( iGetMailInfo );

    InvokeClientMtmAsyncFunctionL( iFunctionId, *iSelection, iService, param );

    SetActive();

    if ( iEventHandler )

        {

        iEventHandler->SetNewPropertyEvent( 

            iService, KIpsSosEmailSyncStarted, KErrNone );

        } 

    }

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

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

CIpsPlgPop3FetchOperation::CIpsPlgPop3FetchOperation(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TInt aFunctionId,

    TMsvId aService,

    CIpsPlgTimerOperation& aActivityTimer,

    const TImPop3GetMailInfo& aGetMailInfo,

    TFSMailMsgId aFSMailBoxId,

    MFSMailRequestObserver& aFSOperationObserver,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    : 

    CIpsPlgOnlineOperation( aMsvSession, KFetchOpPriority,

        aObserverRequestStatus, aActivityTimer, aFSMailBoxId,

        aFSOperationObserver, aFSRequestId), iFunctionId( aFunctionId ),

        iGetMailInfo( aGetMailInfo ), iEventHandler( aEventHandler )

    {

    FUNC_LOG;

    iService = aService;

    }

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

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

void CIpsPlgPop3FetchOperation::RunL()

    {

    FUNC_LOG;

    TRAP( iError, DoRunL() );

    if(iError != KErrNone)

        {        

        // Notify observer we have finished.

        CompleteObserver();

        }    

    }

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

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

void CIpsPlgPop3FetchOperation::DoCancel()

    {

    FUNC_LOG;

    CIpsPlgOnlineOperation::DoCancel();

    if(iState == EStateFetching)

        {

        // Cancelled while fetching. Need to disconnect.

        iMsvSession.StopService( iService );

        // Ignore return value, nothing we can do.

        }

    if ( iEventHandler )

        {

        iEventHandler->SetNewPropertyEvent( 

            iService, KIpsSosEmailSyncCompleted, KErrCancel );

        }

    }

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

// DoRunL

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

void CIpsPlgPop3FetchOperation::DoRunL()

    {

    FUNC_LOG;

    switch(iState)

        {

        case EStateClearCompleteFlag:

            {

            // First clean things

            delete iOperation;

            iOperation = NULL;

            delete iEntry;

            iEntry = NULL;

            // Leave if setting the complete flag was a failure.

            User::LeaveIfError( iStatus.Int() );

            TInt count = iSelection->Count();

            for ( ; iEntryIndex < count && !iOperation; iEntryIndex++ )

                {

                delete iEntry;

                iEntry = NULL;

                iEntry = iMsvSession.GetEntryL(

                    iSelection->At( iEntryIndex ) );

                TMsvEntry entry = iEntry->Entry();

                TBool complete = entry.Complete();

                if ( complete )

                    {

                    entry.SetComplete( EFalse );

                    iOperation = iEntry->ChangeL( entry, iStatus );

                    SetActive();

                    }

                }

            if ( !iOperation )

                {

                DoConnectL();

                }

            break;

            }

        case EStateConnecting:

            {

            // Connect complete.

            TBool connected = 

                STATIC_CAST( CIpsPlgPop3ConnectOp*, iOperation )->Connected();

            if(!connected)

                {

                CompleteObserver( KErrCouldNotConnect );

                return;

                }

            DoFetchL();

            }

            break;

        case EStateFetching:         

            {

            TInt err = iStatus.Int();

            if( KErrNone != err )

                {

                TPckgBuf<TPop3Progress> paramPack;

                if ( iOperation )

                    {

                    paramPack.Copy( iOperation->ProgressL() );

                    }

                TPop3Progress& progress = paramPack();

                progress.iErrorCode = err;

                iFetchErrorProgress = paramPack.AllocL();

                }

            iState = EStateIdle;

            CompleteObserver( err );

            if ( iEventHandler )

                {

                iEventHandler->SetNewPropertyEvent( 

                    iService, KIpsSosEmailSyncCompleted, err );

                }

            }

            break;

        default:

            break;

        }        

    }

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

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

const TDesC8& CIpsPlgPop3FetchOperation::GetErrorProgressL( TInt /* aError */ )

    {

    FUNC_LOG;

    return *iFetchErrorProgress;

    }

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

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

TFSProgress CIpsPlgPop3FetchOperation::GetFSProgressL() const

    {

    FUNC_LOG;

    // might not never called, but gives something reasonable if called

    TFSProgress result = { TFSProgress::EFSStatus_Waiting, 0, 0, KErrNone };

    result.iError = KErrNone;

    switch( iState )

        {

        case EStateConnecting:

            result.iProgressStatus = TFSProgress::EFSStatus_Connecting;

            break;

        case EStateFetching:

            result.iProgressStatus = TFSProgress::EFSStatus_Connected;

            break;

        default:

            result.iProgressStatus = TFSProgress::EFSStatus_RequestComplete;

            break;

        }

    if ( iStatus.Int() == KErrCancel )

        {

        result.iProgressStatus = TFSProgress::EFSStatus_RequestCancelled;

        result.iError = KErrCancel;

        }

    return result;

    }

// EOF