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

#include <s32mem.h>
#include <apmstd.h>

#include "catalogsbasemessage.h"
#include "catalogshttpincludes.h"

#include "catalogsutils.h"
#include "catalogscontext.h"
#include "ncdproviderdefines.h"
#include "ncddescriptordownloadsuboperation.h"
#include "ncdhttputils.h"
#include "ncdproviderutils.h"
#include "ncddeviceinteractionfactory.h"
#include "ncdinstallationservice.h"
#include "ncdgeneralmanager.h"

#include "catalogsdebug.h"

// ======== MEMBER FUNCTIONS ========

// ---------------------------------------------------------------------------
// NewL
// ---------------------------------------------------------------------------
//
CNcdRightsObjectOperation* CNcdRightsObjectOperation::NewL( 
    CNcdGeneralManager& aGeneralManager,
    const TDesC& aDownloadUri,
    const TDesC& aMimeType,
    const TNcdConnectionMethod& aMethod,
    MNcdOperationRemoveHandler& aRemoveHandler, 
    MCatalogsHttpSession& aHttpSession,
    MCatalogsSession& aSession )
    {
    CNcdRightsObjectOperation* self = new( ELeave ) CNcdRightsObjectOperation( 
        aGeneralManager, aRemoveHandler, aHttpSession, aSession );
    CleanupClosePushL( *self );
    self->ConstructL( aMethod, aDownloadUri, aMimeType );
    CleanupStack::Pop();
    return self;
    }


// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CNcdRightsObjectOperation::~CNcdRightsObjectOperation()
    {
    DLTRACEIN( ( "" ) );    
    if ( iDownloadOp ) 
        {
        iDownloadOp->Close();
        iDownloadOp = NULL;
        }
    delete iInstallationService;
    delete iMimeType;
    DLTRACEOUT((""));
    }


// ---------------------------------------------------------------------------
// Download config getter
// ---------------------------------------------------------------------------
//
MCatalogsHttpConfig& CNcdRightsObjectOperation::Config()
    {
    DASSERT( iDownloadOp );
    return iDownloadOp->Config();
    }


// ---------------------------------------------------------------------------
// Cancel
// ---------------------------------------------------------------------------
//
void CNcdRightsObjectOperation::Cancel() 
    {    
    DLTRACEIN(( "" ));
    if ( iDownloadOp ) 
        {
        iDownloadOp->Cancel();
        iDownloadOp->Close();
        iDownloadOp = NULL;
        }
    DLTRACEOUT(( "" ));
    }


// ---------------------------------------------------------------------------
// RunOperation
// ---------------------------------------------------------------------------
//
TInt CNcdRightsObjectOperation::RunOperation()
    {
    DLTRACEIN(( "Pending message: %X", iPendingMessage ));
    DASSERT( iDownloadOp );
    
    if ( !iPendingMessage ) 
        {      
        DLTRACE(("No pending message"));  
        return KErrNotReady;
        }
    
    // Start download.
    DLINFO(("Starting download op"));
    TInt err = iDownloadOp->Start();

    DLTRACEOUT(("err: %d", err));
    return err;
    }


// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
CNcdRightsObjectOperation::CNcdRightsObjectOperation(    
    CNcdGeneralManager& aGeneralManager,
    MNcdOperationRemoveHandler& aRemoveHandler,
    MCatalogsHttpSession& aHttpSession,
    MCatalogsSession& aSession )
    :
    CNcdBaseOperation( aGeneralManager, &aRemoveHandler, ERightsObjectOperation, aSession ), 
    iHttpSession( aHttpSession )        
    {
    }


// ---------------------------------------------------------------------------
// ConstructL
// ---------------------------------------------------------------------------
//
void CNcdRightsObjectOperation::ConstructL(
    const TNcdConnectionMethod& aMethod,
    const TDesC& aDownloadUri,
    const TDesC& aMimeType )
    {
    DLTRACEIN( ( "" ) );

    // Call ConstructL for the base class
    CNcdBaseOperation::ConstructL();

    iMimeType = ConvertUnicodeToUtf8L( aMimeType );

    iDownloadOp = CNcdDescriptorDownloadSubOperation::NewL( 
        iGeneralManager, iHttpSession, aDownloadUri, *this, iSession );
                
    iGeneralManager.HttpUtils().ConvertConnectionMethod( 
        aMethod, iConnectionMethod );  
    
    iDownloadOp->Config().SetConnectionMethod( iConnectionMethod );

    iInstallationService = 
        NcdDeviceInteractionFactory::CreateInstallationServiceL();

    DLTRACEOUT(( "" ));
    }
    
void CNcdRightsObjectOperation::Progress( CNcdBaseOperation& /*aOperation*/ )
    {
    DLTRACEIN((""));
    }

void CNcdRightsObjectOperation::QueryReceived(
    CNcdBaseOperation& /*aOperation*/, CNcdQuery* /*aQuery*/ )
    {
    DLTRACEIN((""));
    }

void CNcdRightsObjectOperation::OperationComplete( 
    CNcdBaseOperation* aOperation, TInt aError )
    {
    DLTRACEIN(("aOperation=%08x, aError=%d", aOperation, aError));
    (void) aOperation; // suppresses compiler warning

    if( aError == KErrNone )
        {
        // Install the DRM object.
        DLINFO(("Installing rights object (%d bytes data, mime type %S)", 
            iDownloadOp->Body().Size(), iMimeType ));
            
        TRAP( aError, iInstallationService->AppendRightsL( 
            iDownloadOp->Body(), 
            TDataType( *iMimeType ) ) );
        }

    DLINFO(("Completing rights object dl&install operation with %d", aError));
    CompleteMessage( iPendingMessage, 
        aError != KErrNone ? 
            ENCDOperationMessageCompletionError : 
            ENCDOperationMessageCompletionComplete, 
        aError );
    }