/*

* 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"

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

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

CIpsPlgPop3FetchOperation* CIpsPlgPop3FetchOperation::NewL(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TMsvId aService,

    CIpsPlgTimerOperation& aActivityTimer,

    const TImPop3GetMailInfo& aGetMailInfo,

    TFSMailMsgId aFSMailBoxId,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    {

    FUNC_LOG;

    CIpsPlgPop3FetchOperation* op = new(ELeave) CIpsPlgPop3FetchOperation(

    CleanupStack::PushL(op);

    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

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

    {

    FUNC_LOG;

    BaseConstructL( KUidMsgTypePOP3 );

    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();

        {

        delete iEntry;

        iEntry = NULL;

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

        TMsvEntry entry = iEntry->Entry();

        TBool complete = entry.Complete();

        if ( complete )

            {

            entry.SetComplete( EFalse );

            SetActive();

            iState = EStateClearCompleteFlag;

            }

        }

        {

        DoConnectL();

        }

    }

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

// DoConnectL

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

void CIpsPlgPop3FetchOperation::DoConnectL()

    {

    FUNC_LOG;

    iState = EStateConnecting;

    iStatus = KRequestPending;

    CIpsPlgPop3ConnectOp* connOp = CIpsPlgPop3ConnectOp::NewL(

    SetActive();

    }

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

// DoFetchL

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

void CIpsPlgPop3FetchOperation::DoFetchL()

    {

    FUNC_LOG;

    iState = EStateFetching;

    iStatus = KRequestPending;

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

    // getmail info instead

    TPckg<TImPop3GetMailInfo> param( iGetMailInfo );

    SetActive();

    if ( iEventHandler )

        {

        iEventHandler->SetNewPropertyEvent( 

            iService, KIpsSosEmailSyncStarted, KErrNone );

        } 

    }

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

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

CIpsPlgPop3FetchOperation::CIpsPlgPop3FetchOperation(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TMsvId aService,

    CIpsPlgTimerOperation& aActivityTimer,

    const TImPop3GetMailInfo& aGetMailInfo,

    TFSMailMsgId aFSMailBoxId,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    : 

    {

    FUNC_LOG;

    iService = aService;

    }

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

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

void CIpsPlgPop3FetchOperation::RunL()

    {

    FUNC_LOG;

    TRAP( iError, DoRunL() );

        {        

        // Notify observer we have finished.

        CompleteObserver();

        }    

    }

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

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

void CIpsPlgPop3FetchOperation::DoCancel()

    {

    FUNC_LOG;

    CIpsPlgOnlineOperation::DoCancel();

    if(iState == EStateFetching)

        {

        iMsvSession.StopService( iService );

        }

    if ( iEventHandler )

        {

        }

    }

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

// DoRunL

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

void CIpsPlgPop3FetchOperation::DoRunL()

    {

    FUNC_LOG;

    switch(iState)

        {

        case EStateClearCompleteFlag:

            {

            // First clean things

            delete iEntry;

            iEntry = NULL;

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

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

            TInt count = iSelection->Count();

                {

                delete iEntry;

                iEntry = NULL;

                iEntry = iMsvSession.GetEntryL(

                    iSelection->At( iEntryIndex ) );

                TMsvEntry entry = iEntry->Entry();

                TBool complete = entry.Complete();

                if ( complete )

                    {

                    entry.SetComplete( EFalse );

                    SetActive();

                    }

                }

                {

                DoConnectL();

                }

            break;

            }

        case EStateConnecting:

            {

            // Connect complete.

                {

                CompleteObserver( KErrCouldNotConnect );

                return;

                }

            DoFetchL();

            }

            break;

        case EStateFetching:         

            {

            TInt err = iStatus.Int();

                {

                TPckgBuf<TPop3Progress> paramPack;

                    {

                    }

                TPop3Progress& progress = paramPack();

                progress.iErrorCode = err;

                iFetchErrorProgress = paramPack.AllocL();

                }

            if ( iEventHandler )

                {

                }

            }

            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 };

    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;

    }

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

    {

    FUNC_LOG;

    }