/*
* Copyright (c) 2006-2008 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:   ?Description
*
*/


#ifndef C_NCDPURCHASEOPERATIONIMPL_H
#define C_NCDPURCHASEOPERATIONIMPL_H

#include <e32base.h>

#include "ncdbaseoperation.h"
#include "ncdparserobserver.h"
#include "catalogshttpobserver.h"
#include "catalogssmsobserver.h"

class MNcdParser;
class MNcdProtocol;
class CNcdNodeManager;
class CNcdPurchaseHistoryDb;
class MCatalogsSmsSession;
class CNcdNode;
class CNcdPreminetProtocolPurchaseInformationImpl;
class CNcdPreminetProtocolPurchaseProcessedImpl;
class MCatalogsAccessPointManager;

class CNcdPurchaseOptionImpl;

class MNcdPreminetProtocolPayment;
class MNcdOperationRemoveHandler;

class CNcdSubscriptionManager;
class CNcdDelay;
class MNcdConfigurationProtocolQuery;
class CNcdNodeIdentifier;
class CNcdDownloadInfo;
class CNcdPurchaseDetails;
class CNcdNodeMetaData;
class CNcdKeyValuePair;


/**
 *  Purchase operation implementation.
 *
 *  @lib ?library
 *  @since S60 ?S60_version *** for example, S60 v3.0
 */
class CNcdPurchaseOperationImpl : public CNcdBaseOperation,
                                  public MNcdParserObserver,
                                  public MNcdParserPurchaseObserver,
                                  public MCatalogsHttpObserver,
                                  public MCatalogsSmsObserver
    {
    
public:

    /**
     *  Sub states of purchase operation 
     */
    enum TPurchaseOperationState
        {
        EBegin,
        EPurchaseRequestSent,
        EPurchaseInformationReceived,
        EPurchaseRequestResent,
        EDisclaimerQueried,
        EPaymentMethodsQueried,
        EPaymentInformationQueried,
        EPaymentProcessed,
        EPurchaseConfirmationSent,
        EDownloadDetailsReceived,
        EPurchaseComplete,
        EFailed
        };

    enum TPurchaseRequestType
        {
        EPurchaseRequest,
        EPurchaseConfirmation
        };
        

    static CNcdPurchaseOperationImpl* NewL( 
        const TDesC& aNameSpace,
        const TDesC& aNodeId,
        const TUid& aClientUid,
        const TDesC& aPurchaseOptionId,
        CNcdGeneralManager& aGeneralManager,        
        MCatalogsHttpSession& aHttpSession, 
        MCatalogsSmsSession& aSmsSession, 
        CNcdSubscriptionManager& aSubscriptionManager,
        MNcdOperationRemoveHandler* aRemoveHandler,
        MCatalogsSession& aSession );

    static CNcdPurchaseOperationImpl* NewLC( 
        const TDesC& aNameSpace,
        const TDesC& aNodeId,
        const TUid& aClientUid,
        const TDesC& aPurchaseOptionId,
        CNcdGeneralManager& aGeneralManager,
        MCatalogsHttpSession& aHttpSession,
        MCatalogsSmsSession& aSmsSession,
        CNcdSubscriptionManager& aSubscriptionManager,
        MNcdOperationRemoveHandler* aRemoveHandler,
        MCatalogsSession& aSession );
        
    virtual ~CNcdPurchaseOperationImpl();
    
public: // New functions

    /**
     * Call back function used in resend after case.
     *
     * @param aOperation The operation called in the function.
     */
    static TInt ResendAfterCallBack( TAny* aOperation );

    /**
     * Returns the identifier of the node that this operation relates to.
     *
     * @return Node identifier.
     */
    const CNcdNodeIdentifier& NodeIdentifier() const;
    
    
public: // from base class CNcdBaseOperation

    /**
     * @see CNcdBaseOperation::Cancel
     */
    virtual void Cancel();

    /**
     * @see CNcdBaseOperation::QueryCompletedL
     */
    virtual TBool QueryCompletedL( CNcdQuery* aQuery );

public: // from base class MCatalogsHttpObserver

    /**     
     * @see MCatalogsHttpObserver::HandleHttpEventL
     */

    virtual void HandleHttpEventL( 
        MCatalogsHttpOperation& aOperation, 
        TCatalogsHttpEvent aEvent );

    /**
     * @see MCatalogsHttpObserver::HandleHttpError()
     */
    virtual TBool HandleHttpError(
        MCatalogsHttpOperation& aOperation,
        TCatalogsHttpError aError );
        
public: // from base class MCatalogsSmsObserver

	/**
	 * @see MCatalogsSmsObserver::HandleSmsEvent()
	 */
	virtual TInt HandleSmsEvent( 
	    MCatalogsSmsOperation& aOperation, 
	    TCatalogsSmsEvent aEvent );

public: // from MNcdParserQueryObserver

    /**
     * @see MNcdParserQueryObserver
     */
    virtual void QueryL( MNcdConfigurationProtocolQuery* aData );



public: // from base class MNcdParserObserver

    /**
     * @see MNcdParserObserver
     */
    virtual void ParseError( TInt aErrorCode );

    /**
     * @see MNcdParserObserver
     */
    virtual void ParseCompleteL( TInt aError );

public: // from base class MNcdParserPurchaseObserver

    /**
     * @see MNcdParserPurchaseObserver::InformationL
     */
    virtual void InformationL( MNcdPreminetProtocolPurchaseInformation* aData );

    /**
     * @see MNcdParserPurchaseObserver::ProcessedL
     */
    virtual void ProcessedL( MNcdPreminetProtocolPurchaseProcessed* aData );
    
public: // from base class MNcdParserInformationObserver

    virtual void InformationL( 
        MNcdPreminetProtocolInformation* aData );
        
public: // from base class MNcdParserErrorObserver

    virtual void ErrorL( MNcdPreminetProtocolError* aData );
        

        
protected:

    CNcdPurchaseOperationImpl(
        CNcdGeneralManager& aGeneralManager,
        MCatalogsHttpSession& aHttpSession,
        MCatalogsSmsSession& aSmsSession,
        CNcdSubscriptionManager& aSubscriptionManager,
        MNcdOperationRemoveHandler* aRemoveHandler,
        MCatalogsSession& aSession );
        
    
    void ConstructL( 
        const TDesC& aNameSpace, 
        const TDesC& aNodeId,
        const TUid& aClientUid,
        const TDesC& aPurchaseOptionId );
        

public: // from base class CNcdBaseOperation

    /**
     * @see CNcdBaseOperation::RunOperation
     */
    virtual TInt RunOperation();
    
    void DoRunOperationL();
    
    /**
     * @see CNcdBaseOperation::RunOperation
     */
    virtual void ChangeToPreviousStateL();


private:

    HBufC8* CreatePurchaseRequestLC( TPurchaseRequestType aType, 
                                    const TDesC& aServerUri );

    void SendRequestL( const TDesC& aServerUri, const TDesC8& aData );

    void ProcessSmsPaymentL();

    void UpdatePurchaseHistoryL();
    
    // Copies relevant info from CNcdNodeContentInfo to given purchase details
    void SetContentInfoToPurchaseDetailsL( 
        CNcdPurchaseDetails& aDetails, 
        const CNcdNodeMetaData& aMetadata ) const;

    void HandleDependenciesL( CNcdPurchaseDetails& aDetails );   
    
    void AddDownloadInfosToDetailsL( CNcdPurchaseDetails& aDetails,
        const RPointerArray<CNcdDownloadInfo>& aInfos );
        
    TInt RemovePendingSmsOp( const TCatalogsTransportOperationId& aId );

    TInt StartResendAfterTimer();
    
private: // data
    
    /**
     * A sub-state of this operation's execution.
     */
    TPurchaseOperationState iPurchaseOperationState;
    
    /**
     * Reference to the access point manager.
     * Not owned by the purchase operation.
     */
    MCatalogsAccessPointManager& iAccessPointManager;
    
    /**
     * Not own.
     */
    CNcdPurchaseHistoryDb* iPurchaseHistory;

    /**
     * Http session for sending requests and receiving responses.
     * Not owned by the purchase operation.
     */
    MCatalogsHttpSession& iHttpSession;
    
    /**
     * Sms session for sending requests and receiving responses.
     * Not owned by the purchase operation.
     */
    MCatalogsSmsSession* iSmsSession;
    
    /**
     * Protocol.
     * Not owned by the purchase operation.
     */
    MNcdProtocol& iProtocol;    
    
    /**
     * Http operation for current transaction.
     * Not owned by the purchase operation.
     */
    MCatalogsHttpOperation* iHttpTransaction;

    /**
     * Subscription manager.
     * Not owned by the purchase operation.
     */
    CNcdSubscriptionManager& iSubscriptionManager;


    CNcdPurchaseOptionImpl* iSelectedPurchaseOption;
    const MNcdPreminetProtocolPayment* iSelectedPaymentMethod;
    
   
    /**
     * 
     * Not own.
     */
    CNcdNode* iNode;
    
    /**
     * Node identifier of the node to purchase.
     */
    CNcdNodeIdentifier* iNodeIdentifier;
    
    /**
     * Purchase option id. Used in subscription renew.
     */
    HBufC* iPurchaseOptionId;


    MNcdPreminetProtocolPurchaseInformation* iPurchaseInformationData;
    MNcdPreminetProtocolPurchaseProcessed* iPurchaseProcessedData;

	RPointerArray<MCatalogsSmsOperation> iPendingSmsOperations;

    /**
     * Purchase query.
     */
    CNcdQuery* iPurchaseQuery;
    
    TBool iLocked;
        
    CNcdDelay* iDelay;

    // Key() is address and Value() is message
    CNcdKeyValuePair* iSmsRegistrationRequest;
    
    HBufC* iRedirectUri;
    
    // Time after which the purchase request is resent
    TInt iResendAfter;
    };

#endif // C_NCDPURCHASEOPERATIONIMPL_H