/*
* 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:   Contains CNcdNodeSeenFolderProxy
*
*/


#include "ncdnodeseenfolderproxy.h"
#include "catalogsdebug.h"
#include "ncdnodefolderproxy.h"
#include "catalogsinterfaceidentifier.h"
#include "catalogsclientserver.h"
#include "ncdnodefunctionids.h"
#include "catalogsutils.h"
#include "ncdnodeidentifier.h"
#include "ncdnodemanagerproxy.h"

CNcdNodeSeenFolderProxy* CNcdNodeSeenFolderProxy::NewL(
    MCatalogsClientServer& aSession,
    TInt aHandle,
    CNcdNodeFolderProxy& aNode ) 
    {
    DLTRACEIN((""));
    CNcdNodeSeenFolderProxy* self = NewLC(
        aSession, aHandle, aNode );
    CleanupStack::Pop( self );
    return self;
    }
    

CNcdNodeSeenFolderProxy* CNcdNodeSeenFolderProxy::NewLC(
    MCatalogsClientServer& aSession,
    TInt aHandle,
    CNcdNodeFolderProxy& aNode ) 
    {
    DLTRACEIN((""));
    CNcdNodeSeenFolderProxy* self = 
        new( ELeave ) CNcdNodeSeenFolderProxy(
            aSession, aHandle, aNode );
    // Using PushL because the object does not have any references yet
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }
    
    
CNcdNodeSeenFolderProxy::CNcdNodeSeenFolderProxy(
    MCatalogsClientServer& aSession,
    TInt aHandle,
    CNcdNodeFolderProxy& aNode ) :
    CNcdInterfaceBaseProxy( aSession, aHandle, &aNode ),
    iFolder( aNode )
    {
    }


void CNcdNodeSeenFolderProxy::ConstructL() 
    {
    DLTRACEIN((""));
    
    // Register the interface.
    MNcdNodeSeenFolder* seen( this );
    DLINFO(("SeenFolder-ptr: %X, this: %X", seen, this ));
    AddInterfaceL(
        CCatalogsInterfaceIdentifier::NewL(
            seen, this, MNcdNodeSeenFolder::KInterfaceUid ) );
            
    InternalizeL();            
    }

CNcdNodeSeenFolderProxy::~CNcdNodeSeenFolderProxy() 
    {
    DLTRACEIN((""));

    // 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( MNcdNodeSeenFolder::KInterfaceUid );
    }
    
    
void CNcdNodeSeenFolderProxy::InternalizeL() 
    {
    // Nothing to internalize currently.
    }
    
void CNcdNodeSeenFolderProxy::SetContentsSeenL() 
    {
    DLTRACEIN((""));
    
    // Send the message to server side.
    TInt output;
    User::LeaveIfError(
        ClientServerSession().SendSync(
            NcdNodeFunctionIds::ENcdNodeSeenFolderSetContentsSeen,
            KNullDesC(),
            output,
            Handle() ) );
    }
    
    
TInt CNcdNodeSeenFolderProxy::NewCountL( TInt aLevels ) const
    {
    DLTRACEIN((""));
    
    if ( aLevels < 1 ) 
        {
        User::Leave( KErrArgument );
        }
    
    // Send the message to server side.
    RCatalogsBufferWriter writer;
    writer.OpenLC();
    writer().WriteInt32L( aLevels );
    
    TInt count( 0 );
    User::LeaveIfError(
        ClientServerSession().SendSync(
            NcdNodeFunctionIds::ENcdNodeSeenFolderNewCount,
            writer.PtrL(),
            count,
            Handle() ) );
            
    CleanupStack::PopAndDestroy( &writer );            
    
    DLINFO(( "count: %d", count ));        
    return count;
    }
    

RCatalogsArray<MNcdNode> CNcdNodeSeenFolderProxy::NewNodesL( TInt aLevels ) const 
    {
    DLTRACEIN(("levels: %d", aLevels));
    
    if ( aLevels < 1 ) 
        {
        User::Leave( KErrArgument );
        }
        
    // Send the message to server side.
    RCatalogsBufferWriter writer;
    writer.OpenLC();
    writer().WriteInt32L( aLevels );
    
    HBufC8* receiveData( NULL );
    User::LeaveIfError(
        ClientServerSession().SendSyncAlloc(
            NcdNodeFunctionIds::ENcdNodeSeenFolderNewNodes,
            writer.PtrL(),
            receiveData,
            Handle(),
            0 ) );

    CleanupStack::PopAndDestroy( &writer );
    
    RCatalogsArray<MNcdNode> array;
    CleanupResetAndDestroyPushL( array );

    DASSERT( receiveData );
    CleanupStack::PushL( receiveData );
        
    // Read the identifiers from receive data and add the nodes to the
    // array.
    RDesReadStream desReadStream( *receiveData );
    CleanupClosePushL( desReadStream );
    
    TInt identifierCount = desReadStream.ReadInt32L();
    
    for ( TInt i = 0; i < identifierCount; i++ ) 
        {
        CNcdNodeIdentifier* nodeId = CNcdNodeIdentifier::NewLC( desReadStream );
        MNcdNode* node = &iFolder.NodeManager().NodeL( *nodeId );
        CleanupStack::PopAndDestroy( nodeId );
        array.AppendL( node );
        
        // Add the reference count to make sure the nodes in the
        // array don't get deleted
        node->AddRef();
        }
        
    CleanupStack::PopAndDestroy( &desReadStream );
    CleanupStack::PopAndDestroy( receiveData );
    CleanupStack::Pop( &array );
    
    return array;
    }