/*
 * Copyright (c) 2010 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 "nmframeworkadapterheaders.h"

/*!

 */
NmFwaMessagePartsFetchingOperation::NmFwaMessagePartsFetchingOperation(
        const NmId &mailboxId,
        const NmId &folderId,
        const NmId &messageId,
        const QList<NmId> &messagePartIds,
        CFSMailClient &mailClient)
  : mMailboxId(mailboxId), 
    mFolderId(folderId), 
    mMessageId(messageId), 
    mMailClient(mailClient), 
    mLastProgressValue(0), 
    mRequestId(0)
{
    NM_FUNCTION;
    
    // Take own copy of the message part id list.
    mMessagePartIds.Reset();
    for (int i=0; i<messagePartIds.count(); ++i) {
        // let's ignore .Append return value here, the failing messages
        // just won't be handled at this time
        int ignore = mMessagePartIds.Append(
            NmConverter::nmIdToMailMsgId(
                messagePartIds.at(i)));
    }
}

/*!

 */
NmFwaMessagePartsFetchingOperation::~NmFwaMessagePartsFetchingOperation()
{
    NM_FUNCTION;
    
    doCancelOperation();
}

/*!

 */
void NmFwaMessagePartsFetchingOperation::RequestResponseL(TFSProgress aEvent, TInt aRequestId)
{
    NM_FUNCTION;
    
    if (aRequestId == mRequestId) {
        if (aEvent.iProgressStatus == TFSProgress::EFSStatus_RequestComplete ) {
            completeOperation(aEvent.iError);
        }
        else if (aEvent.iProgressStatus == TFSProgress::EFSStatus_RequestCancelled) {
            completeOperation(NmCancelError);
        }
        else if (aEvent.iProgressStatus == TFSProgress::EFSStatus_Status) {
            int progress = 0;
            if (aEvent.iMaxCount > 0) {
                // calculate progress per cents
                qreal counterValue = aEvent.iCounter;
                qreal maxCount = aEvent.iMaxCount;
                progress = (counterValue / maxCount)*100;
            }
            if (progress > mLastProgressValue) {
                // send only increasing values to prevent downward changing percentage
                mLastProgressValue = progress;
                updateOperationProgress(mLastProgressValue);
            }
        }
    }
}

/*!

 */
void NmFwaMessagePartsFetchingOperation::doRunAsyncOperation()
{
    NM_FUNCTION;
    
    TRAPD(err, doRunAsyncOperationL());
    if (err != KErrNone) {
        completeOperation(NmGeneralError);
    }
}

/*!
    Leaving version from doRunAsyncOperation
 */
void NmFwaMessagePartsFetchingOperation::doRunAsyncOperationL()
{
    NM_FUNCTION;
    
    if (mMessagePartIds.Count() > 0) {
        
        const TFSMailMsgId mailboxId(mMailboxId.pluginId32(), mMailboxId.id32());
        const TFSMailMsgId folderId(mFolderId.pluginId32(), mFolderId.id32());
        const TFSMailMsgId messageId(mMessageId.pluginId32(), mMessageId.id32());
        
        CFSMailMessage *message(NULL);
        message = mMailClient.GetMessageByUidL(mailboxId, folderId, messageId, EFSMsgDataEnvelope);
        CleanupStack::PushL(message);
       
        if (message) {
            CFSMailMessagePart* messagePart = message->ChildPartL( mMessagePartIds[0] );
            CleanupStack::PushL(messagePart);
            if (messagePart) {            
                mRequestId = messagePart->FetchMessagesPartsL(mMessagePartIds,*this,0);
            }
            else {
                completeOperation(NmNotFoundError);
            }
            CleanupStack::PopAndDestroy(messagePart);
        }
        else {
            completeOperation(NmNotFoundError);
        }
        CleanupStack::PopAndDestroy(message);
    }
    else {
        completeOperation(NmNotFoundError);
    }
}

/*!
 * Complete the operation
 */
void NmFwaMessagePartsFetchingOperation::doCompleteOperation()
{
    NM_FUNCTION;
    
    mRequestId = NmNotFoundError;
}

/*!
    Cancels the async operation. \sa NmOperation
 */
void NmFwaMessagePartsFetchingOperation::doCancelOperation()
{
    NM_FUNCTION;
    
    if (mRequestId >= 0) {
        TRAP_IGNORE(mMailClient.CancelL(mRequestId));
        mRequestId = NmNotFoundError;
    }
}