/*

* 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 CNcdPurchaseHistoryProxy class

*

*/

#include <e32err.h>

#include <s32mem.h>

#include "catalogsinterfaceidentifier.h"

#include "catalogsclientserver.h"

#include "ncdpurchasehistoryproxy.h"

#include "ncdnodefunctionids.h"

#include "ncdpurchasedetails.h"

#include "ncdutils.h"

#include "ncdpurchasehistoryfilter.h"

#include "catalogsutils.h"

#include "catalogsconstants.h"

#include "catalogsdebug.h"

CNcdPurchaseHistoryProxy::CNcdPurchaseHistoryProxy(

    MCatalogsClientServer& aSession, 

    TInt aHandle,

    CCatalogsInterfaceBase* aParent,

    CNcdOperationManagerProxy& aOperationManager )

        : CNcdInterfaceBaseProxy( aSession, aHandle, aParent ),

        iOperationManager( aOperationManager )

    {

    }

void CNcdPurchaseHistoryProxy::ConstructL()

    {

    MNcdPurchaseHistory* history( this );

    AddInterfaceL( 

        CCatalogsInterfaceIdentifier::NewL(

            history,

            this,

            MNcdPurchaseHistory::KInterfaceUid ) );

    }

CNcdPurchaseHistoryProxy* CNcdPurchaseHistoryProxy::NewL(

    MCatalogsClientServer& aSession,

    TInt aHandle,

    CCatalogsInterfaceBase* aParent,

    CNcdOperationManagerProxy& aOperationManager )

    {

    CNcdPurchaseHistoryProxy* self = 

        CNcdPurchaseHistoryProxy::NewLC(

            aSession,

            aHandle,

            aParent,

            aOperationManager );

    CleanupStack::Pop( self );

    return self;        

    }

CNcdPurchaseHistoryProxy* CNcdPurchaseHistoryProxy::NewLC(

    MCatalogsClientServer& aSession,

    TInt aHandle,

    CCatalogsInterfaceBase* aParent,

    CNcdOperationManagerProxy& aOperationManager )

    {

    CNcdPurchaseHistoryProxy* self = 

        new( ELeave ) CNcdPurchaseHistoryProxy(

            aSession,

            aHandle,

            aParent,

            aOperationManager );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;        

    }

CNcdPurchaseHistoryProxy::~CNcdPurchaseHistoryProxy()

    {

    // Remove interfaces implemented by this class from the interface list.

    // So, the interface list is up to date when this class object is deleted.

    RemoveInterface( MNcdPurchaseHistory::KInterfaceUid );

    }

void CNcdPurchaseHistoryProxy::SavePurchaseL(

    const MNcdPurchaseDetails& aDetails,

    TBool aSaveIcon )

    {

    DLTRACEIN((""));

    DLINFO(("Save purchase details to purchase history"));

    CBufBase* buf = CBufFlat::NewL( KBufExpandSize );

    CleanupStack::PushL( buf );        

    RBufWriteStream stream( *buf );

    CleanupClosePushL( stream );

    static_cast<const CNcdPurchaseDetails*>(&aDetails)->ExternalizeL( stream );

    CleanupStack::PopAndDestroy( &stream );    

    TInt funcId( NcdNodeFunctionIds::ENcdPurchaseHistorySavePurchase );

    if ( !aSaveIcon )

        {

        funcId = 

            NcdNodeFunctionIds::ENcdPurchaseHistorySavePurchaseWithOldIcon;

        }

    HBufC8* dummyBuf = NULL;

    User::LeaveIfError( ClientServerSession().SendSyncAlloc(

        funcId,

        buf->Ptr( 0 ),

        dummyBuf,

        Handle(),

        0 ) );

    delete dummyBuf;

    CleanupStack::PopAndDestroy( buf );

    DLTRACEOUT((""));

    }

RArray<TUint> CNcdPurchaseHistoryProxy::PurchaseIdsL(

    const MNcdPurchaseHistoryFilter& aFilter )

    {

    DLTRACEIN((""));

    DLINFO(("Get purchase IDs from purchase history"));

    CBufBase* filterBuf = CBufFlat::NewL( KBufExpandSize );

    CleanupStack::PushL( filterBuf );

    RBufWriteStream stream( *filterBuf );

    CleanupClosePushL( stream );

    TArray<TUid> clientUids = aFilter.ClientUids();

    TUint count = clientUids.Count();

    stream.WriteUint32L( count );

    for ( TInt i = 0; i < count; i++ )

        {

        stream.WriteInt32L( clientUids[i].iUid );

        }

    ExternalizeDesL( aFilter.Namespace(), stream );

    ExternalizeDesL( aFilter.EntityId(), stream );

    stream.WriteUint32L( aFilter.EventId() );

    CleanupStack::PopAndDestroy( &stream );

    HBufC8* idBuf = NULL;

    User::LeaveIfError( ClientServerSession().SendSyncAlloc(

        NcdNodeFunctionIds::ENcdPurchaseHistoryGetPurchaseIds,

        filterBuf->Ptr( 0 ),

        idBuf,

        Handle(),

        0 ) );

    CleanupStack::PopAndDestroy( filterBuf );

    CleanupStack::PushL( idBuf );

    TInt size = sizeof(TUint);

    count = Des8ToUint( idBuf->Mid( 0, size ) );

    RArray<TUint> purchaseIds;    

    CleanupClosePushL( purchaseIds );

    for ( TInt i = 0; i < count; i++ )

        {

        purchaseIds.Append(

            Des8ToUint( idBuf->Mid( ( i + 1 ) * size, size ) ) );

        }

    CleanupStack::Pop( &purchaseIds );

    CleanupStack::PopAndDestroy( idBuf );

    DLTRACEOUT((""));

    return purchaseIds;

    }

CNcdPurchaseDetails* CNcdPurchaseHistoryProxy::PurchaseDetailsL(

    TUint aPurchaseId,

    TBool aLoadIcon )

    {

    DLTRACEIN(("Load with icon: %d", aLoadIcon));

    DLINFO(("Get purchase details from purchase history"));

    HBufC8* id = UintToDes8LC( aPurchaseId );

    HBufC8* detailsBuf = NULL;

    if ( aLoadIcon ) 

        {        

        User::LeaveIfError( ClientServerSession().SendSyncAlloc(

            NcdNodeFunctionIds::ENcdPurchaseHistoryGetPurchase,

            *id,

            detailsBuf,

            Handle(),

            0 ) );

        }

    else

        {

        User::LeaveIfError( ClientServerSession().SendSyncAlloc(

            NcdNodeFunctionIds::ENcdPurchaseHistoryGetPurchaseNoIcon,

            *id,

            detailsBuf,

            Handle(),

            0 ) );

        }

    CleanupStack::PopAndDestroy( id );

    CleanupStack::PushL( detailsBuf );

    CNcdPurchaseDetails* details = CNcdPurchaseDetails::NewLC();

    RDesReadStream stream( *detailsBuf );

    CleanupClosePushL( stream );

    details->InternalizeL( stream );

    CleanupStack::PopAndDestroy( &stream );

    CleanupStack::Pop( details );

    CleanupStack::PopAndDestroy( detailsBuf );

    DLTRACEOUT((""));

    return details;

    }

void CNcdPurchaseHistoryProxy::RemovePurchaseL( TUint aPurchaseId )

    {

    DLTRACEIN((""));

    DLINFO(("Remove purchase from purchase history"));

    HBufC8* id = UintToDes8LC( aPurchaseId );

    HBufC8* dummyBuf = NULL;

    User::LeaveIfError( ClientServerSession().SendSyncAlloc(

        NcdNodeFunctionIds::ENcdPurchaseHistoryRemovePurchase,

        *id,

        dummyBuf,

        Handle(),

        0 ) );

    delete dummyBuf;

    CleanupStack::PopAndDestroy( id );

    DLTRACEOUT((""));

    }

TUint CNcdPurchaseHistoryProxy::EventCountL()

    {

    DLTRACEIN((""));

    DLINFO(("Get event count from purchase history"));

    HBufC8* countBuf = NULL;

    User::LeaveIfError( ClientServerSession().SendSyncAlloc(

        NcdNodeFunctionIds::ENcdPurchaseHistoryEventCount,

        KNullDesC8,

        countBuf,

        Handle(),

        0 ) );

    CleanupStack::PushL( countBuf );

    TUint count = Des8ToUint( *countBuf );

    CleanupStack::PopAndDestroy( countBuf );

    DLTRACEOUT((""));

    return count;

    }