/*

 * 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: Class responsible for storing message part content asynchronously.

 * It can store text/plain and text/html body parts.

 *

 */

#include <e32std.h>

#include <e32base.h>

#include <msvapi.h>

#ifndef IPSPLGMESSAGEPARTSTOREOPERATION_H_

#define IPSPLGMESSAGEPARTSTOREOPERATION_H_

class CFSMailPlugin;

class CFSMailMessage;

class CFSMailMessagePart;

class MFSMailRequestObserver;

NONSHARABLE_CLASS( CIpsPlgMessagePartStorerOperation ) : public CMsvOperation

    {

public:

    /**

     * Symbian 2nd phase constructor

     * @param aMsvSession

     * @param aObserverRequestStatus

     * @param aPlugin

     * @param aMessageParts - ownership is taken from caller

     * @param aRequestId

     * @return CIpsPlgMessagePartStorerOperation*

     */

    static CIpsPlgMessagePartStorerOperation* NewL(CMsvSession& aMsvSession,

            TRequestStatus& aObserverRequestStatus, CFSMailPlugin& aPlugin,

            RPointerArray<CFSMailMessagePart> &aMessageParts,

            MFSMailRequestObserver& aFSOperationObserver,

            const TInt aRequestId);

    /**

     * Symbian 2nd phase constructor

     * @param aMsvSession

     * @param aObserverRequestStatus

     * @param aPlugin

     * @param aMessageParts - ownership is taken from caller

     * @param aRequestId

     * @return CIpsPlgMessagePartStorerOperation*

     */

    static CIpsPlgMessagePartStorerOperation* NewLC(CMsvSession& aMsvSession,

            TRequestStatus& aObserverRequestStatus, CFSMailPlugin& aPlugin,

            RPointerArray<CFSMailMessagePart> &aMessageParts,

            MFSMailRequestObserver& aFSOperationObserver,

            const TInt aRequestId);

    /**

     * Class destructor

     */

    virtual ~CIpsPlgMessagePartStorerOperation();

    /**

     * Implements cancellation of an outstanding request

     */

    void DoCancel();

    /**

     * From CMsvOperation

     */

    virtual const TDesC8& ProgressL();

protected:

    /**

     * Default constructor

     * @param aMsvSession

     * @param aObserverRequestStatus

     * @param aPlugin

     * @param aMessageParts - ownership is taken from caller

     * @param aRequestId

     */

    CIpsPlgMessagePartStorerOperation(CMsvSession& aMsvSession,

            TRequestStatus& aObserverRequestStatus, CFSMailPlugin& aPlugin,

            RPointerArray<CFSMailMessagePart> &aMessageParts,

            MFSMailRequestObserver& aFSOperationObserver,

            const TInt aRequestId);

private:

    /**

     * Initialization and construction of all leaving members

     */

    void ConstructL();

    /**

     * Handles an active object's request completion event

     */

    void RunL();

    /**

     * Handles a leave occurring in the request completion event handler

     */

    TInt RunError(TInt aError);

    /**

	 * Stores next part content in message store

	 * @return returns EFalse if there are none message parts

	 */

    TBool StoreNextPartL();

    /**

	 * Stores text plain content in message store

	 * @param CFSMailMessagePart* aPart to be stored

	 */

    void StoreTextPlainPartL(CFSMailMessagePart* aPart);

    /**

     * Stores text html content in message store

     * @param CFSMailMessagePart* aPart to be stored

     */

    void StoreTextHtmlPartL(CFSMailMessagePart* aPart);

private:

    //data

    CFSMailPlugin& iPlugin;

    // Array of message parts to be stored

    RPointerArray<CFSMailMessagePart> iMessageParts;

    MFSMailRequestObserver& iFSOperationObserver;

    const TInt iRequestId;

    // Execution index stores current progres

    TInt iExecutionIndex;

    // Data buffer for async operations

    HBufC8* iDataBuffer;

    };

#endif /* IPSPLGMESSAGEPARTSTOREOPERATION_H_ */