/*

* Copyright (c) 2007-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:   Implements CNcdSendHttpRequestOperationProxy

*

*/

#include "ncdsendhttprequestoperationproxy.h"

#include <s32strm.h>

#include "ncdsendhttprequestoperationobserver.h"

#include "ncdoperationproxyremovehandler.h"

#include "catalogsclientserver.h"

#include "catalogsutils.h"

#include "catalogsdebug.h"

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

// ---------------------------------------------------------------------------

// 

// ---------------------------------------------------------------------------

//

CNcdSendHttpRequestOperationProxy* CNcdSendHttpRequestOperationProxy::NewLC( 

    MCatalogsClientServer& aSession,

    TInt aHandle,

    MNcdOperationProxyRemoveHandler& aRemoveHandler,

    CNcdNodeManagerProxy& aNodeManager,

    MNcdSendHttpRequestOperationObserver& aObserver )

    {

    CNcdSendHttpRequestOperationProxy* self =

        new( ELeave ) CNcdSendHttpRequestOperationProxy( aObserver );

    self->AddRef();

    CleanupReleasePushL( *self );    

    self->ConstructL( 

        aSession, 

        aHandle, 

        aRemoveHandler,         

        aNodeManager );

    return self;

    }

// ---------------------------------------------------------------------------

// 

// ---------------------------------------------------------------------------

//

HBufC8* CNcdSendHttpRequestOperationProxy::ResponseL() const

    {

    DLTRACEIN((""));    

    if ( OperationStateL() != MNcdOperation::EStateComplete ) 

        {

        DLERROR(("Operation has not completed yet, leaving with KErrNotReady"));

        User::Leave( KErrNotReady );

        }

    HBufC8* data = NULL;

    User::LeaveIfError( ClientServerSession().SendSyncAlloc( 

        ENCDOperationFunctionGetData,

        KNullDesC8(),

        data,

        Handle(),

        0 ) );

    if ( !data ) 

        {

        DLERROR(("No data, leaving with KErrCorrupt"));

        User::Leave( KErrCorrupt );

        }

    return data;

    }

// ---------------------------------------------------------------------------

// From MNcdOperation

// Operation type getter

// ---------------------------------------------------------------------------

//

TNcdInterfaceId CNcdSendHttpRequestOperationProxy::OperationType() const

    {

    return static_cast<TNcdInterfaceId>(

        MNcdSendHttpRequestOperation::KInterfaceUid );

    }

// ---------------------------------------------------------------------------

// Constructor

// ---------------------------------------------------------------------------

//

CNcdSendHttpRequestOperationProxy::CNcdSendHttpRequestOperationProxy(

    MNcdSendHttpRequestOperationObserver& aObserver )    

    : CNcdOperation< MNcdSendHttpRequestOperation >( NULL ), 

      iObserver( aObserver )      

    {

    }

// ---------------------------------------------------------------------------

// Destructor

// ---------------------------------------------------------------------------

//

CNcdSendHttpRequestOperationProxy::~CNcdSendHttpRequestOperationProxy()

    {

    DLTRACEIN(( "this: %X", this )); 

    if ( iRemoveHandler )

        {

        iRemoveHandler->RemoveOperationProxy( *this );

        }

    DLTRACEOUT(( "" ));    

    }

// ---------------------------------------------------------------------------

// ConstructL

// ---------------------------------------------------------------------------

//

void CNcdSendHttpRequestOperationProxy::ConstructL( 

    MCatalogsClientServer& aSession,

    TInt aHandle,

    MNcdOperationProxyRemoveHandler& aRemoveHandler,

    CNcdNodeManagerProxy& aNodeManager )

    {

    DLTRACEIN( ( "this: %X", this ) );

    CNcdBaseOperationProxy::ConstructL( 

        aSession, 

        aHandle, 

        &aRemoveHandler,

        NULL, 

        &aNodeManager );    

    }

// ---------------------------------------------------------------------------

// Handle progress callback

// ---------------------------------------------------------------------------

//

void CNcdSendHttpRequestOperationProxy::ProgressCallback()

    {

    DLTRACEIN( ( "this: %X", this ) );

    TNcdSendableProgress& sendableProgress( SendableProgress() );

    TNcdProgress progress( sendableProgress.iProgress, 

                           sendableProgress.iMaxProgress );

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

        sendableProgress.iMaxProgress ));

    AddRef();

    DLTRACE(("Calling observer"));            

    iObserver.Progress( *this, progress );

    Release();

    }

// ---------------------------------------------------------------------------

// Handle query received callback

// ---------------------------------------------------------------------------

//

void CNcdSendHttpRequestOperationProxy::QueryReceivedCallback( CNcdQuery* /*aQuery*/ )

    {

    DLTRACEIN( ( "" ) );

    }

// ---------------------------------------------------------------------------

// Handle operation complete

// ---------------------------------------------------------------------------

//

void CNcdSendHttpRequestOperationProxy::CompleteCallback( TInt aError )

    {

    DLTRACEIN( ( "Error: %d, this: %X", aError, this ) );

    AddRef();

    // Iterate backwards in case observers want to remove themselves

    iObserver.OperationComplete( *this, aError );

    DLTRACE(("Observers handled, this: %X", this));

    Release();    

    }