/*

* 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 connect operation

*

*/

#include "emailtrace.h"

#include "ipsplgheaders.h"

// Constants and defines

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

// CIpsPlgPop3ConnectOp::NewL()

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

CIpsPlgPop3ConnectOp* CIpsPlgPop3ConnectOp::NewL(

    CMsvSession& aMsvSession,                           

    TRequestStatus& aObserverRequestStatus,

    TMsvId aService,

    TBool aForcePopulate,

    CIpsPlgTimerOperation& aActivityTimer,

    TFSMailMsgId aFSMailBoxId,

    MFSMailRequestObserver* aFSOperationObserver,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    {

    FUNC_LOG;

    CleanupStack::PushL( op );

    op->ConstructL();

    CleanupStack::Pop( op );

    return op;

    }

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

// CIpsPlgPop3ConnectOp::~CIpsPlgPop3ConnectOp()

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

//

CIpsPlgPop3ConnectOp::~CIpsPlgPop3ConnectOp()

    {

    FUNC_LOG;

    }

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

// CIpsPlgPop3ConnectOp::ProgressL()

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

//

const TDesC8& CIpsPlgPop3ConnectOp::ProgressL()

    {

    FUNC_LOG;

    if( iError != KErrNone )

        {

        return GetErrorProgressL( iError );

        }

    else if( iSubOperation )

        {

        return iSubOperation->ProgressL();

        }

    iProgress().iErrorCode = KErrNone;

    return iProgress;    

    }   

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

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

//

void CIpsPlgPop3ConnectOp::DoCancel()

    {

    FUNC_LOG;

    if( iSubOperation )

        {

        iSubOperation->Cancel();

        }

    CompleteObserver( KErrCancel );

    }

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

// CIpsPlgPop3ConnectOp::DoRunL()

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

//

void CIpsPlgPop3ConnectOp::DoRunL()

    {

    FUNC_LOG;

    if ( iState == EStartConnect )

        {

        if ( iSubOperation )

            {

            // operation exist and it means 

            // disconnect operation was ongoing.

            delete iSubOperation;

            iSubOperation = NULL;

            }

        // Begin Connect.

        DoConnectL();

        iState = EConnected;

        }

    else if ( iState == EConnected )

        {

        // Connect completed

        if ( iForcePopulate && Connected() )

            {

            iState = EPopulate;

            DoPopulateL();

            }

        else

            {

            // <qmail>

            // start disconnecting

            iState = EDisconnecting;

            DoDisconnect();

            // </qmail>

            }

        }

    else if ( iState == EPopulate )

        {

        if ( iEventHandler )

            {

            }

        CIpsPlgSyncStateHandler::SaveSuccessfulSyncTimeL( iMsvSession, iService );

        // <qmail>

        // start disconnecting

        DoDisconnect();

        // </qmail>

        }

    // <qmail>

    else if ( iState == EDisconnecting )

        {

        // we're done here

        CompleteObserver( KErrNone );

        }

    // </qmail>

    else

        {

        User::Panic( KIpsPlgPopConnectPanic ,KErrNotFound);

        }

    }

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

// CIpsPlgPop3ConnectOp::GetErrorProgressL

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

//

const TDesC8& CIpsPlgPop3ConnectOp::GetErrorProgressL( TInt aError )

    {

    FUNC_LOG;

    iError = aError;

    if ( iSubOperation && iError == KErrNone )

        {

        return iSubOperation->ProgressL();

        }

    TPop3Progress& progress = iProgress();

    progress.iPop3Progress = TPop3Progress::EPopConnecting;

    progress.iTotalMsgs = 0;

    progress.iMsgsToProcess = 0;

    progress.iBytesDone = 0;

    progress.iTotalBytes = 0;

    progress.iErrorCode = iError;

    progress.iPop3SubStateProgress = TPop3Progress::EPopConnecting;

    progress.iServiceId = iService;

    return iProgress;

    }

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

// CIpsPlgPop3ConnectOp::GetFSProgressL()

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

//

TFSProgress CIpsPlgPop3ConnectOp::GetFSProgressL() const

    {

    FUNC_LOG;

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

    switch( iState )

        {

        case EStartConnect:

        case EConnected:

            result.iProgressStatus = TFSProgress::EFSStatus_Connecting;

            break;

        case EPopulate:

            // staus is used to inform fetching in base plugin

            result.iProgressStatus = TFSProgress::EFSStatus_Status;

            break;

        default:

            result.iProgressStatus = TFSProgress::EFSStatus_RequestComplete;

            break;

        }

    if ( iStatus.Int() == KErrCancel )

        {

        result.iProgressStatus = TFSProgress::EFSStatus_RequestCancelled;

        result.iError = KErrCancel;

        }

    return result;

    }

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

// CIpsPlgPop3ConnectOp::CIpsPlgPop3ConnectOp

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

//

// <qmail> priority parameter has been removed

CIpsPlgPop3ConnectOp::CIpsPlgPop3ConnectOp(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TMsvId aServiceId,

    TBool aForcePopulate,

    CIpsPlgTimerOperation& aActivityTimer,

    TFSMailMsgId aFSMailBoxId,

    MFSMailRequestObserver* aFSOperationObserver,

    TInt aFSRequestId,

    CIpsPlgEventHandler* aEventHandler )

    :

    CIpsPlgOnlineOperation(

        aMsvSession,

        aObserverRequestStatus, 

        aActivityTimer, 

        aFSMailBoxId,

        aFSOperationObserver, 

        aFSRequestId ),

    iState( EIdle ),

    iForcePopulate( aForcePopulate ),

    {

    iService = aServiceId; 

    }

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

// CIpsPlgPop3ConnectOp::ConstructL()

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

//

void CIpsPlgPop3ConnectOp::ConstructL()

    {

    FUNC_LOG;

    BaseConstructL( KUidMsgTypePOP3 );

    if ( tentry.iType.iUid != KUidMsvServiceEntryValue )

        {

        User::Leave( KErrNotSupported );

        }

        }

    else

        {

        }

    }

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

// CIpsPlgPop3ConnectOp::DoConnectL()

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

//

void CIpsPlgPop3ConnectOp::DoConnectL()

    {

    FUNC_LOG;

    // <qmail> unnecessary: iStatus = KRequestPending;

    InvokeClientMtmAsyncFunctionL( KPOP3MTMConnect, iService ); // <qmail> 1 param removed

    SetActive();

    if ( iEventHandler )

        {

    }

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

// CIpsPlgPop3ConnectOp::DoPopulateL()

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

//

void CIpsPlgPop3ConnectOp::DoPopulateL()

    {

    FUNC_LOG;

    // <qmail> unnecessary: iStatus = KRequestPending;

    // Prepare parameters and include filtering

    TImPop3PopulateOptions pop3GetMailInfo;

    pop3GetMailInfo.SetMaxEmailSize( KMaxTInt32 );

    TPckgBuf<TImPop3PopulateOptions> params( pop3GetMailInfo );

    iBaseMtm->SwitchCurrentEntryL( iService );

    // Start the fetch operation

    SetActive();

    }

// <qmail> Connected() moved to baseclass

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

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

// <qmail> return type

TIpsOpType CIpsPlgPop3ConnectOp::IpsOpType() const

    {

    FUNC_LOG;

    return EIpsOpTypePop3SyncOp;

    }

// <qmail> removed QueryUsrPassL() from here as unneeded

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

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

void CIpsPlgPop3ConnectOp::DoDisconnect()

    {

    FUNC_LOG;

    // <qmail> unnecessary: iStatus = KRequestPending;

    InvokeClientMtmAsyncFunctionL( KPOP3MTMDisconnect, iService ); // <qmail> 1 param removed

    SetActive();

    }

//</qmail>