/*
* 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 "emailtrace.h"
#include "ipsplgheaders.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()
    {
    // <qmail>
    TRequestStatus* status = &iObserverRequestStatus;
    if ( status && status->Int() == KRequestPending )
        {
        if (&iFSOperationObserver)
            {
            iFSProgress.iProgressStatus = TFSProgress::EFSStatus_RequestCancelled;
            iFSProgress.iError = KErrCancel;
            iFSProgress.iParam = NULL;

            TRAP_IGNORE( iFSOperationObserver.RequestResponseL( iFSProgress, iFSRequestId ) );
            }
        User::RequestComplete( status, iStatus.Int() );
        }
    // </qmail>
    FUNC_LOG;
    }

// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
const TDesC8& CIpsPlgMailStorerOperation::ProgressL()
    {
    return KNullDesC8;
    }

// <qmail>
// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
//   
const TDesC8& CIpsPlgMailStorerOperation::GetErrorProgressL( TInt /*aError*/ )
    {
    FUNC_LOG;
    
    return KNullDesC8; // error progress info not supported
    }

// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
//   
TFSProgress CIpsPlgMailStorerOperation::GetFSProgressL() const
    {
    FUNC_LOG;
    
    return iFSProgress;
    }

// ----------------------------------------------------------------------------
// ----------------------------------------------------------------------------    
TIpsOpType CIpsPlgMailStorerOperation::IpsOpType() const
    {
    FUNC_LOG;
    return EIpsOpTypeMailStorerOp;
    }
// </qmail>

// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
CIpsPlgMailStorerOperation::CIpsPlgMailStorerOperation(
    CMsvSession& aMsvSession,
    TRequestStatus& aObserverRequestStatus,
    CFSMailPlugin& aPlugin,
    RPointerArray<CFSMailMessage> &aMessages,
    MFSMailRequestObserver& aFSOperationObserver,
    const TInt aRequestId):
// <qmail>
    CIpsPlgBaseOperation(aMsvSession, aObserverRequestStatus, aRequestId, TFSMailMsgId()), 
    iPlugin(aPlugin),
    iMessages(aMessages),
    iFSOperationObserver(aFSOperationObserver)
// </qmail>
    {
    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 )
            {
            // <qmail>
            iFSProgress.iProgressStatus = TFSProgress::EFSStatus_RequestComplete;
            iFSProgress.iError = KErrNone;
            iFSProgress.iParam = NULL;

            TRAP_IGNORE( iFSOperationObserver.RequestResponseL( iFSProgress, iFSRequestId ) );
            // </qmail>
            }

        TRequestStatus* status = &iObserverRequestStatus;
        User::RequestComplete( status, KErrNone );
        }
    }

// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
TInt CIpsPlgMailStorerOperation::RunError()
    {
    FUNC_LOG;
    return KErrNone;
    }