/*

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

*     Populates imap4 folders using current populate settings.

*

*/

#include <impcmtm.h> // CImap4ClientMtm

#include <SenduiMtmUids.h>

#include "AlwaysOnlineEmailPluginLogging.h"

#include "AlwaysOnlineEmailLoggingTools.h"

#include "AlwaysOnlineImap4FolderPopulate.h"

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

// CAlwaysOnlineImap4Agent()

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

CAlwaysOnlineImap4FolderPopulate::CAlwaysOnlineImap4FolderPopulate(

    CMsvSession& aMsvSession, 

    CImap4ClientMtm& aImap4ClientMtm,

    TMsvId aServiceId,

    TMsvId aInboxId,

    TImImap4GetPartialMailInfo& aPartialInfo,

    TRequestStatus& aObserverRequestStatus )

    :

    CMsvOperation(

        aMsvSession, 

        CActive::EPriorityStandard, 

        aObserverRequestStatus), 

    iServiceId( aServiceId ),

    iPartialInfo( aPartialInfo),

    iImap4ClientMtm( aImap4ClientMtm ),

    iInboxId( aInboxId )

    {

    CActiveScheduler::Add(this);

    iMtm = KSenduiMtmImap4Uid;

    }

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

// NewL

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

CAlwaysOnlineImap4FolderPopulate* CAlwaysOnlineImap4FolderPopulate::NewL(

    CMsvSession& aMsvSession, 

    CImap4ClientMtm& aImap4ClientMtm,

    TMsvId aServiceId,

    TMsvId aInboxId,

    TImImap4GetPartialMailInfo& aPartialInfo,

    const CMsvEntrySelection* aSelection, // folder ids

    TRequestStatus& aObserverRequestStatus )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::NewL" );

    CAlwaysOnlineImap4FolderPopulate* self=new (ELeave) CAlwaysOnlineImap4FolderPopulate(

        aMsvSession, 

        aImap4ClientMtm,

        aServiceId,

        aInboxId,

        aPartialInfo,

        aObserverRequestStatus );

    CleanupStack::PushL(self);

    self->ConstructL(aSelection);

    CleanupStack::Pop(self);

    return self;

    }

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

// ConstructL()

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

void CAlwaysOnlineImap4FolderPopulate::ConstructL( const CMsvEntrySelection* aSelection)

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::ConstructL" );

    iFolderSelection = aSelection->CopyL();

    // if selection is empty, following just completes 

    StartNextFolderPopulateOperation();

    }

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

// ~CAlwaysOnlineImap4Agent()

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

CAlwaysOnlineImap4FolderPopulate::~CAlwaysOnlineImap4FolderPopulate()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::~CAlwaysOnlineImap4FolderPopulate" );

    Cancel();

    delete iOperation;

    delete iFolderSelection;

    }

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

// CAlwaysOnlineImap4FolderPopulate::StartNextFolderPopulateOperation

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

void CAlwaysOnlineImap4FolderPopulate::StartNextFolderPopulateOperation()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::StartNextFolderPopulateOperation" );

    delete iOperation;

    iOperation = NULL;

    TInt err = KErrNotFound; // if folder selection is empty, operation is completed with this error

    if ( iFolderSelection->Count() )

        {

        TRAP(err, DoNewFolderPopulateOperationL());

        // whether error or not, remove the data for this operation

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

        }

    }

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

// CAlwaysOnlineImap4FolderPopulate::DoNewFolderPopulateOperationL

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

void CAlwaysOnlineImap4FolderPopulate::DoNewFolderPopulateOperationL()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::DoNewFolderPopulateOperationL" );

    KAOEMAIL_LOGGER_FN1("CAlwaysOnlineImap4FolderPopulate::DoNewFolderPopulateOperationL");

    if ( HasFolderNewMailL( (*iFolderSelection)[0] ) )

        {

        // here do folder populate operation

        CMsvEntrySelection* selection=new(ELeave) CMsvEntrySelection;

        CleanupStack::PushL(selection);

        selection->AppendL( iServiceId );

        selection->AppendL( (*iFolderSelection)[0] );

        TPckg<TImImap4GetPartialMailInfo> param( iPartialInfo );

        iOperation = iImap4ClientMtm.InvokeAsyncFunctionL(

            KIMAP4MTMPopulateNewMailWhenAlreadyConnected,

            *selection, 

            param, 

            iStatus);

        KAOEMAIL_LOGGER_WRITE_FORMAT("Started populate folder 0x%x", (*selection)[1]); // CSI: 2 # 2 items added above

        CleanupStack::PopAndDestroy( selection );

        }

    else

        {

        // no new mail found, just complete

        KAOEMAIL_LOGGER_WRITE_FORMAT("No new mail found if folder 0x%x, just complete", (*iFolderSelection)[0]);

        iOperation = CMsvCompletedOperation::NewL(

            iMsvSession, 

            KSenduiMtmImap4Uid, 

            KNullDesC8, 

            KMsvLocalServiceIndexEntryId, 

            iStatus, 

            KErrCancel);

        }

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderPopulate::DoNewFolderPopulateOperationL");

    }

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

// CAlwaysOnlineImap4FolderPopulate::DoCancel

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

void CAlwaysOnlineImap4FolderPopulate::DoCancel()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::DoCancel" );

    if (iOperation)

        {

        iOperation->Cancel();

        }

    TRequestStatus* status = &iObserverRequestStatus;

    User::RequestComplete(status, iStatus.Int());

    }

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

// CAlwaysOnlineImap4FolderPopulate::RunL

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

void CAlwaysOnlineImap4FolderPopulate::RunL()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::RunL" );

    KAOEMAIL_LOGGER_WRITE_FORMAT("CAlwaysOnlineImap4FolderPopulate::RunL iStatus %d", iStatus.Int() );

    if (iFolderSelection->Count()==0)

        {

        // nothing left to process, so complete the observer

        TRequestStatus* status = &iObserverRequestStatus;

        User::RequestComplete(status, iStatus.Int());

        }

    else

        {

        // start the next pass

        StartNextFolderPopulateOperation();

        }

    }

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

// CAlwaysOnlineImap4FolderPopulate::ProgressL

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

const TDesC8& CAlwaysOnlineImap4FolderPopulate::ProgressL()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::ProgressL" );

    if (iOperation)

        {

        return iOperation->ProgressL();

        }

    return KNullDesC8();

    }

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

// CAlwaysOnlineImap4FolderPopulate::SelectInbox

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

void CAlwaysOnlineImap4FolderPopulate::SelectInbox()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::SelectInbox" );

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderPopulate::SelectInbox");

    delete iOperation;

    iOperation = NULL;

    TRAPD(err, DoSelectInboxL());

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

        }

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderPopulate::SelectInbox");

    }

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

// CAlwaysOnlineImap4FolderPopulate::DoSelectInboxL

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

void CAlwaysOnlineImap4FolderPopulate::DoSelectInboxL()

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::DoSelectInboxL" );

    KAOEMAIL_LOGGER_FN1("CAlwaysOnlineImap4FolderPopulate::DoSelectInboxL");

    // here do folder populate operation

    CMsvEntrySelection* selection=new(ELeave) CMsvEntrySelection;

    CleanupStack::PushL(selection);

    selection->AppendL( iInboxId );

    TBuf8<1> dummyParams;

    dummyParams.Zero();

    iOperation = iImap4ClientMtm.InvokeAsyncFunctionL(

        //KIMAP4MTMPopulateAllMailWhenAlreadyConnected, 

        KIMAP4MTMInboxNewSync,

        //KIMAP4MTMSelect,

        *selection, 

        dummyParams, 

        iStatus);

    KAOEMAIL_LOGGER_WRITE_FORMAT("Started inbox select 0x%x", iInboxId);

    iInboxId = -1;

    CleanupStack::PopAndDestroy( selection );

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderPopulate::DoSelectInboxL");

    }

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

// CAlwaysOnlineImap4FolderPopulate::HasFolderNewMailL

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

TBool CAlwaysOnlineImap4FolderPopulate::HasFolderNewMailL( TMsvId aFolderId )

    {

    AOLOG_IN( "CAlwaysOnlineImap4FolderPopulate::HasFolderNewMailL" );

    KAOEMAIL_LOGGER_FN1("CAlwaysOnlineImap4FolderPopulate::HasFolderNewMailL");

    TInt count = 0; // number of NEW mails in this folder

    CMsvEntry* folderEntry = iMsvSession.GetEntryL( aFolderId );

    CleanupStack::PushL( folderEntry );

    const TInt entryCount = folderEntry->Count();

    TInt i=0;

    for (i=0; i < entryCount && count == 0 ; i++)

        {

        if ( (*folderEntry)[i].New() )

            {

            count++;

            }

        }

    CleanupStack::PopAndDestroy( folderEntry );

    KAOEMAIL_LOGGER_WRITE_FORMAT("New mail count %d", count);

    KAOEMAIL_LOGGER_FN2("CAlwaysOnlineImap4FolderPopulate::HasFolderNewMailL");

    return (count>0);

    }

//EOF