/*

 * 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 "nmframeworkadapterheaders.h"

/*!

    \class NmFwaMessageSendingOperation

    \brief NmFwaMessageSendingOperation is an async operation which creates a

           new message.

    NmFwaMessageSendingOperation is an async operation which creates a new

    message. \sa NmOperation

 */

/*!

    Constructor

    \param message pointer to the message under sent, ownership is transferred to operation

    \param mailClient Reference to mail client object.

 */

NmFwaMessageSendingOperation::NmFwaMessageSendingOperation(

    NmDataPluginInterface &pluginInterface,

    NmMessage *message,

    CFSMailClient &mailClient) :

        mPluginInterface(pluginInterface),

        mSaveOperation(NULL),

        mMessage(message),

        mMailClient(mailClient),

        mRequestId(NmNotFoundError),

        mSaved(false)

{

    mMailClient.IncReferenceCount();

}

/*!

    Destructor

 */

NmFwaMessageSendingOperation::~NmFwaMessageSendingOperation()

{

    if (mSaveOperation && mSaveOperation->isRunning()) {

        mSaveOperation->cancelOperation();

    }

    doCancelOperation();

    mMailClient.Close(); // decrease ref count

    delete mMessage;

}

/*!

    returns pointer to message, ownership is not transferred

 */

const NmMessage *NmFwaMessageSendingOperation::getMessage() const

{

    return mMessage;

}

/*!

    Called after base object construction via timer event, runs the

    async operation.

    \sa NmOperation

 */

void NmFwaMessageSendingOperation::doRunAsyncOperation()

{

    int err = NmNoError;

    if (mSaved) {

        TRAPD(trapped, err = sendMessageL());

        if (trapped == KErrNotFound) {

            err = NmNotFoundError;

        }

        else if (trapped != KErrNone) {

            err = NmGeneralError;

        }

    }

    else {

        err = saveMessageWithSubparts();

    }

    if (err != NmNoError) {

        completeOperation(err);

    }

    // err == NmNoError means everything went well and the operation is proceeding

}

/*!

 */

void NmFwaMessageSendingOperation::doCompleteOperation()

{

    mRequestId = NmNotFoundError;

}

/*!

 */

void NmFwaMessageSendingOperation::doCancelOperation()

{

    if (mRequestId >= 0) {

        TRAP_IGNORE(mMailClient.CancelL(mRequestId));

        mRequestId = NmNotFoundError;

    }

    if (mSaveOperation && mSaveOperation->isRunning()) {

        mSaveOperation->cancelOperation();

    }

}

/*!

    Asynchronous request response message.

    \param aEvent Plugin event description.

    \param aRequestId Request id of asyncronous operation.

 */

void NmFwaMessageSendingOperation::RequestResponseL(TFSProgress aEvent,

                                                    TInt aRequestId)

{

    TFSProgress::TFSProgressStatus status = aEvent.iProgressStatus;

    if (aRequestId == mRequestId) {

        if (status == TFSProgress::EFSStatus_RequestComplete) {

            completeOperation(NmNoError);

        }

        else if (status == TFSProgress::EFSStatus_RequestCancelled) {

            completeOperation(NmCancelError);

        }

        else {

            completeOperation(NmGeneralError);

        }

    }

}

/*!

    Handle completed store message operation

 */

void NmFwaMessageSendingOperation::handleCompletedSaveOperation(int error)

{

    if (error == NmNoError) {

        mSaved = true;

        doRunAsyncOperation();

    }

    else {

        completeOperation(NmGeneralError);

    }

}

/*!

    Saves a message with its subparts (into message store).

*/

int NmFwaMessageSendingOperation::saveMessageWithSubparts()

{

    int ret = NmNotFoundError;

    if (mMessage) {

        if (mSaveOperation && mSaveOperation->isRunning()) {

            mSaveOperation->cancelOperation();

        }

        mSaveOperation = mPluginInterface.saveMessageWithSubparts(*mMessage);

        if (mSaveOperation) {

            connect(mSaveOperation, SIGNAL(operationCompleted(int)), this,

                SLOT(handleCompletedSaveOperation(int)));

            ret = NmNoError;

        }

        else {

            ret = NmGeneralError;

        }

    }

    return ret;

}

/*!

    Sends the message.

 */

int NmFwaMessageSendingOperation::sendMessageL()

{

    int ret = NmNotFoundError;

    if (mMessage) {

        TFSMailMsgId mailboxId = NmConverter::nmIdToMailMsgId(mMessage->envelope().mailboxId());

        CFSMailBox *currentMailbox( NULL );

        currentMailbox = mMailClient.GetMailBoxByUidL(mailboxId);

        CleanupStack::PushL(currentMailbox);

        if (!currentMailbox) {

            User::Leave( KErrNotFound );

        }

        CFSMailMessage *msg = CFSMailMessage::NewL(*mMessage); // no leave -> msg != NULL

        CleanupStack::PushL(msg);

        mRequestId = currentMailbox->SendMessageL(*msg, *this);

        CleanupStack::PopAndDestroy(2); // msg, currentMailbox

        ret = NmNoError;

    }

    return ret;

}