/*
* 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:   Implements CNcdSubscriptionOperationProxy
*
*/


#include "ncdsubscriptionoperationproxy.h"
#include "ncdsubscriptionoperationobserver.h"
#include "ncdsubscriptionmanagerproxy.h"
#include "ncdqueryimpl.h"
#include "catalogsutils.h"
#include "ncdoperationproxyremovehandler.h"

CNcdSubscriptionOperationProxy* CNcdSubscriptionOperationProxy::NewL(
    MCatalogsClientServer& aSession,
    MNcdSubscriptionOperation::TType aSubscriptionType,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler* aRemoveHandler,
    MNcdSubscriptionOperationObserver& aObserver,
    CNcdSubscriptionManagerProxy* aSubscriptionManager,
    CNcdNodeManagerProxy* aNodeManager,
    MNcdClientLocalizer* aLocalizer )
    {
    CNcdSubscriptionOperationProxy* self =
        CNcdSubscriptionOperationProxy::NewLC(
            aSession,
            aSubscriptionType,
            aHandle,
            aRemoveHandler,
            aObserver,
            aSubscriptionManager,
            aNodeManager,
            aLocalizer );

    CleanupStack::Pop( self );

    return self;
    }

CNcdSubscriptionOperationProxy* CNcdSubscriptionOperationProxy::NewLC(
    MCatalogsClientServer& aSession,
    MNcdSubscriptionOperation::TType aSubscriptionType,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler* aRemoveHandler,
    MNcdSubscriptionOperationObserver& aObserver,
    CNcdSubscriptionManagerProxy* aSubscriptionManager,
    CNcdNodeManagerProxy* aNodeManager,
    MNcdClientLocalizer* aLocalizer )
    {
    CNcdSubscriptionOperationProxy* self =
        new( ELeave ) CNcdSubscriptionOperationProxy( aObserver, aLocalizer );
    
    self->AddRef();
    CleanupReleasePushL( *self );    
    self->ConstructL(
        aSession,
        aSubscriptionType,
        aHandle,
        aRemoveHandler,
        aSubscriptionManager,
        aNodeManager );

    return self;
    }

MNcdSubscriptionOperation::TType
    CNcdSubscriptionOperationProxy::SubscriptionOperationType() const
    {
    return iSubscriptionOperationType;
    }

TNcdInterfaceId CNcdSubscriptionOperationProxy::OperationType() const
    {
    return static_cast<TNcdInterfaceId>(MNcdSubscriptionOperation::KInterfaceUid);
    }

CNcdSubscriptionOperationProxy::CNcdSubscriptionOperationProxy(
    MNcdSubscriptionOperationObserver& aObserver,
    MNcdClientLocalizer* aClientLocalizer)
    : CNcdOperation< MNcdSubscriptionOperation >( aClientLocalizer ), 
      iObserver( aObserver )
    {
    }

CNcdSubscriptionOperationProxy::~CNcdSubscriptionOperationProxy()
    {
    DASSERT( iRemoveHandler );
    if ( iRemoveHandler )
        {        
        DLTRACE(("Removing proxy from remove handler"));
        iRemoveHandler->RemoveOperationProxy( *this );
        }
    }

void CNcdSubscriptionOperationProxy::ConstructL(
    MCatalogsClientServer& aSession,
    MNcdSubscriptionOperation::TType aSubscriptionType,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler* aRemoveHandler,
    CNcdSubscriptionManagerProxy* aSubscriptionManager,
    CNcdNodeManagerProxy* aNodeManager )
    {
    DLTRACEIN( ( "" ) );
    CNcdBaseOperationProxy::ConstructL(
        aSession,
        aHandle,
        aRemoveHandler,
        NULL,
        aNodeManager );
    
    iSubscriptionOperationType = aSubscriptionType;

    iSubscriptionManager = aSubscriptionManager;

    DLTRACEOUT( ( "" ) );    
    }


void CNcdSubscriptionOperationProxy::ProgressCallback()
    {
    DLTRACEIN( ( "" ) );

    TNcdSendableProgress& sendableProgress( SendableProgress() );
    TNcdProgress progress( sendableProgress.iProgress, 
                           sendableProgress.iMaxProgress );

    DLTRACE(("Progress: %d/%d", sendableProgress.iProgress,
        sendableProgress.iMaxProgress ));

    iObserver.SubscriptionProgress( *this, progress );

    DLTRACEOUT( ( "" ) );
    }

void CNcdSubscriptionOperationProxy::QueryReceivedCallback(
    CNcdQuery* aQuery )
    {
    DLTRACEIN( ( "" ) );

    aQuery->AddRef();
    iObserver.QueryReceived( *this, aQuery );

    DLTRACEOUT( ( "" ) );
    }

void CNcdSubscriptionOperationProxy::CompleteCallback( TInt aError )
    {
    DLTRACEIN( ( "Error: %d", aError ) );

    // Subscription manager on server side handles the informing
    // of all relevant proxies so no internalization here is needed
    // for the subscription manager proxy.
    
    iObserver.OperationComplete( *this, aError );

    DLTRACEOUT( ( "" ) );
    }