/*

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

*

*/

#include "ipsplgmailstoreroperation.h"

#include "CFSMailPlugin.h"

#include "emailtrace.h"

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

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

CIpsPlgMailStorerOperation* CIpsPlgMailStorerOperation::NewL(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    CFSMailPlugin& aPlugin,

    RPointerArray<CFSMailMessage> &aMessages,

    MFSMailRequestObserver& aFSOperationObserver,

    const TInt aRequestId)

    {

    FUNC_LOG;

    CIpsPlgMailStorerOperation* self =

        new (ELeave)CIpsPlgMailStorerOperation(

                aMsvSession,

                aObserverRequestStatus,

                aPlugin,

                aMessages,

                aFSOperationObserver,

                aRequestId);

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

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

CIpsPlgMailStorerOperation* CIpsPlgMailStorerOperation::NewLC(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    CFSMailPlugin& aPlugin,

    RPointerArray<CFSMailMessage> &aMessages,

    MFSMailRequestObserver& aFSOperationObserver,

    const TInt aRequestId)

    {

    FUNC_LOG;

    CIpsPlgMailStorerOperation* self = CIpsPlgMailStorerOperation::NewL(

        aMsvSession,

        aObserverRequestStatus,

        aPlugin,

        aMessages,

        aFSOperationObserver,

        aRequestId);

    CleanupStack::PushL( self );

    return self;

    }

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

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

CIpsPlgMailStorerOperation::~CIpsPlgMailStorerOperation()

    {

    FUNC_LOG;

    Cancel();

    }

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

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

void CIpsPlgMailStorerOperation::DoCancel()

    {

    FUNC_LOG;

    }

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

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

const TDesC8& CIpsPlgMailStorerOperation::ProgressL()

    {

    return KNullDesC8;

    }

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

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

CIpsPlgMailStorerOperation::CIpsPlgMailStorerOperation(

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    CFSMailPlugin& aPlugin,

    RPointerArray<CFSMailMessage> &aMessages,

    MFSMailRequestObserver& aFSOperationObserver,

    const TInt aRequestId):

    CMsvOperation(aMsvSession, CActive::EPriorityStandard, aObserverRequestStatus),

    iPlugin(aPlugin),

    iMessages(aMessages),

    iFSOperationObserver(aFSOperationObserver),

    iRequestId(aRequestId)

    {

    FUNC_LOG;

    }

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

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

void CIpsPlgMailStorerOperation::ConstructL()

    {

    FUNC_LOG;

    iError = KErrNone;

    iExecutionIndex = 0;

    CActiveScheduler::Add(this);

    iStatus = KRequestPending;

    SetActive();

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrNone);

    }

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

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

void CIpsPlgMailStorerOperation::RunL()

    {

    FUNC_LOG;

    if( iMessages.Count() &&

        iExecutionIndex < iMessages.Count() )

        {

        TInt error=KErrNone;

        CFSMailMessage *message = iMessages[0];

        TRequestStatus* status;

        if(message)

            {

            TFSMailMsgId id = message->GetMessageId();

            iPlugin.StoreMessageL( id, *message );

            iExecutionIndex++;

            status = &iStatus;

            }

        else

            {

            error = KErrNotFound;

            status = &iObserverRequestStatus;

            }

        iStatus = KRequestPending;

        SetActive();

        User::RequestComplete(status, error);

        }

    else

        {

        if( &iFSOperationObserver )

            {

            TFSProgress prog = { TFSProgress::EFSStatus_RequestComplete, 0, 0, 0 };

            TRAP_IGNORE(

                    iFSOperationObserver.RequestResponseL(

                            prog,

                            iRequestId ) );

            }

        TRequestStatus* status = &iObserverRequestStatus;

        User::RequestComplete( status, KErrNone );

        }

    }

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

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

TInt CIpsPlgMailStorerOperation::RunError()

    {

    FUNC_LOG;

    return KErrNone;

    }