/*
* 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 CNcdCreateAccessPointOperationProxy
*
*/


#include "ncdcreateaccesspointoperationproxy.h"

#include <s32strm.h>

#include "ncdcreateaccesspointoperationobserver.h"
#include "ncdoperationproxyremovehandler.h"
#include "catalogsclientserver.h"

#include "catalogsdebug.h"

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

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CNcdCreateAccessPointOperationProxy* CNcdCreateAccessPointOperationProxy::NewL( 
    MCatalogsClientServer& aSession,
    CNcdNodeManagerProxy* aNodeManager,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler& aRemoveHandler,
    MNcdCreateAccessPointOperationObserver& aObserver )
    {
    CNcdCreateAccessPointOperationProxy* self = 
        CNcdCreateAccessPointOperationProxy::NewLC( 
            aSession, aNodeManager, aHandle, aRemoveHandler, aObserver );
    CleanupStack::Pop( self );
    return self;
    }


// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CNcdCreateAccessPointOperationProxy* CNcdCreateAccessPointOperationProxy::NewLC( 
    MCatalogsClientServer& aSession,
    CNcdNodeManagerProxy* aNodeManager,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler& aRemoveHandler,
    MNcdCreateAccessPointOperationObserver& aObserver )
    {
    CNcdCreateAccessPointOperationProxy* self =
        new (ELeave) CNcdCreateAccessPointOperationProxy( aObserver );
    
    self->AddRef();
    CleanupReleasePushL( *self );    
    self->ConstructL( aSession, aNodeManager, aHandle, aRemoveHandler );
    return self;
    }

// ---------------------------------------------------------------------------
// From MNcdOperation
// Operation type getter
// ---------------------------------------------------------------------------
//
TNcdInterfaceId CNcdCreateAccessPointOperationProxy::OperationType() const
    {
    return static_cast< TNcdInterfaceId >( 
        MNcdCreateAccessPointOperation::KInterfaceUid );
    }


// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
CNcdCreateAccessPointOperationProxy::CNcdCreateAccessPointOperationProxy( 
    MNcdCreateAccessPointOperationObserver& aObserver )
    : CNcdOperation< MNcdCreateAccessPointOperation >( NULL ), 
      iObserver( aObserver )
    {
    }


// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CNcdCreateAccessPointOperationProxy::~CNcdCreateAccessPointOperationProxy()
    {
    DLTRACEIN( ( "" ) );         
    if ( iRemoveHandler )
        {
        iRemoveHandler->RemoveOperationProxy( *this );
        }
    }


// ---------------------------------------------------------------------------
// ConstructL
// ---------------------------------------------------------------------------
//
void CNcdCreateAccessPointOperationProxy::ConstructL(
    MCatalogsClientServer& aSession,
    CNcdNodeManagerProxy* aNodeManager,
    TInt aHandle,
    MNcdOperationProxyRemoveHandler& aRemoveHandler )
    {
    DLTRACEIN( ( "" ) );
    CNcdBaseOperationProxy::ConstructL( 
        aSession, 
        aHandle, 
        &aRemoveHandler,
        NULL, 
        aNodeManager );
    }


// ---------------------------------------------------------------------------
// Return the ap id
// ---------------------------------------------------------------------------
//
TUint32 CNcdCreateAccessPointOperationProxy::AccessPoint() const
    {
    return iAccessPoint;
    }


// ---------------------------------------------------------------------------
// Handle progress callback
// ---------------------------------------------------------------------------
//
void CNcdCreateAccessPointOperationProxy::ProgressCallback()
    {
    DLTRACEIN( ( "" ) );
    }
    
    
// ---------------------------------------------------------------------------
// Handle query received callback
// ---------------------------------------------------------------------------
//
void CNcdCreateAccessPointOperationProxy::QueryReceivedCallback( 
    CNcdQuery* /*aQuery*/ )
    {
    DLTRACEIN( ( "" ) );
    // Needed because this is abstract in baseoperation
    }
    
// ---------------------------------------------------------------------------
// Handle operation complete
// ---------------------------------------------------------------------------
//
void CNcdCreateAccessPointOperationProxy::CompleteCallback( TInt aError )
    {
    DLTRACEIN( ( "Error: %d", aError ) );
    
    AddRef();   // in case last reference would be released in OperationComplete callback.
    iObserver.OperationComplete( *this, aError );
    Release();
    }

// ---------------------------------------------------------------------------
// HandleCompletedMessage
// ---------------------------------------------------------------------------
//
void CNcdCreateAccessPointOperationProxy::HandleCompletedMessage(
    TNcdOperationMessageCompletionId aCompletionId,
    RReadStream& aReadStream,
    TInt aDataLength )
    {
    DLTRACEIN(( "aCompletionId =%d, aDataLength =%d", aCompletionId,
        aDataLength));
    switch ( aCompletionId )
        {
        // Handle operation completion
        case ENCDOperationMessageCompletionComplete:
            {
            DLTRACE( ( "ENCDOperationMessageCompletionComplete" ) );
                 // Read progress info
            TRAPD( err,
                {                
                TNcdSendableProgress progress; 
                progress.InternalizeL( aReadStream );
                iAccessPoint = progress.iProgress;
                }); //TRAPD
            aReadStream.Close();  
            
            SetState( MNcdOperation::EStateComplete );
            CompleteCallback( err );          
            break;
            }
                                
        default:
            {
            DLTRACE(("Calling base class"));
            // Call base class
            CNcdBaseOperationProxy::HandleCompletedMessage( aCompletionId,
                aReadStream,
                aDataLength );
            
            break;
            }
        }
    DLTRACEOUT((""));
    }