/*
* Copyright (c) 2003 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:  This module contains the implementation of RCbsTopicList class 
                 member functions.
*
*/



// INCLUDE FILES

#include "CbsServerConstants.h"
#include "RCbs.h"
#include "RCbsTopicList.h"

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

// -----------------------------------------------------------------------------
// RCbsTopicList::RCbsTopicList
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
RCbsTopicList::RCbsTopicList()
    : iNotifyEventPtr( NULL, 0, 0 ), 
    iNotifyHandlePtr( NULL, 0, 0 )
    {
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::Open
// Creates a subsession to the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::Open( 
    RCbs& aServer )
    {
    const TIpcArgs args( TIpcArgs::ENothing );
    return CreateSubSession( aServer, ECbsCreateTopicListSubsession, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::Close
// Closes the subsession and connection to the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
TInt RCbsTopicList::Close()
    {
    // Close the subsession.
    RSubSessionBase::CloseSubSession( ECbsCloseTopicListSubsession );
    return KErrNone;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetTopicCount
// Returns the total amount of topics the topic list contains.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsTopicList::GetTopicCount( 
    TInt& aCount )
    {
    // Send request to the server. Get the total amount of topics.
    aCount = 0;
    TPckgBuf< TInt > pckg( aCount );
    const TIpcArgs args( &pckg );

    TInt result = SendReceive( ECbsGetTopicCount, args );
    // In case everything went just fine update the parameter!
    if ( result == KErrNone )
        {
        aCount = pckg();
        }
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetTopic
// Returns information about a topic from the topic list.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::GetTopic( 
    const TInt aIndex, 
    TCbsTopic& aTopic )
    {
    TPckgBuf< TCbsTopic > pckgTopic;
    const TIpcArgs args( aIndex, &pckgTopic );

    TInt result = SendReceive( ECbsGetTopic, args );

    // Update if everything went just fine
    if ( result == KErrNone )
        {
        aTopic = pckgTopic();
        }

    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::FindTopicByNumber
// Finds the topic by given number.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
TInt RCbsTopicList::FindTopicByNumber( 
    TCbsTopicNumber aNumber, 
    TCbsTopic& aTopic )
    {
    TPckgBuf< TCbsTopic > pckgTopic;
    const TIpcArgs args( aNumber, &pckgTopic );

    TInt result = SendReceive( ECbsFindTopicByNumber, args );

    // Update aTopic if everything went just fine.
    if ( result == KErrNone )
        {
        aTopic = pckgTopic();
        }

    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::DeleteTopic
// Deletes an existing topic.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
TInt RCbsTopicList::DeleteTopic( 
    TCbsTopicNumber aNumber )
    {
    // Send request to the server to delete a topic by handle    
    const TIpcArgs args( aNumber );
    return SendReceive( ECbsDeleteTopic, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::DeleteAllTopics
// Delete all topics.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
TInt RCbsTopicList::DeleteAllTopics()
    {
    const TIpcArgs args( TIpcArgs::ENothing );
    return SendReceive( ECbsDeleteAll, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::AddTopic
// Adds a new topic.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::AddTopic( 
    TCbsTopic& aTopic )
    {
    // Send request to add a topic to the list.
    TPckgBuf< TCbsTopic > pckgTopic( aTopic );
    const TIpcArgs args( &pckgTopic );

    TInt result = SendReceive( ECbsAddTopic, args );

    if ( result == KErrNone )
        {
        // Update the topic information (only handle).
        aTopic = pckgTopic();    
        }

    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::ChangeTopicNameAndNumber
// Changes the name and number of the existing topic.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::ChangeTopicNameAndNumber( 
    TCbsTopicNumber aOldNumber, 
    TCbsTopicNumber aNewNumber, 
    const TCbsTopicName& aName )
    {
    // Send request to the server
    const TIpcArgs args( aOldNumber, aNewNumber, &aName );
    return SendReceive( ECbsChangeTopicNameAndNumber, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::ChangeTopicSubscriptionStatus
// Changes topic subscription status.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::ChangeTopicSubscriptionStatus( 
     TCbsTopicNumber aNumber, 
     TBool aNewStatus )
    {
    // Send request to the server
    TPckgBuf< TBool > pckgStatus( aNewStatus );
    const TIpcArgs args( aNumber, &pckgStatus );
    return SendReceive( ECbsChangeTopicSubscriptionStatus, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::ChangeTopicHotmarkStatus
// Changes topic hotmark status.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::ChangeTopicHotmarkStatus( 
     TCbsTopicNumber aNumber, 
     TBool aNewStatus )
    {
    // Send request to the server
    TPckgBuf< TBool > pckgStatus( aNewStatus );
    const TIpcArgs args( aNumber, &pckgStatus );
    return SendReceive( ECbsChangeTopicHotmarkStatus, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::NotifyOnEvent
// Requests the server to notify the client whenever an event occurs that 
// changes the information of the topics.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsTopicList::NotifyOnEvent( 
    TRequestStatus& aStatus, 
    const TInt aRequested, 
    TCbsTopicListEvent& aEvent, 
    TCbsTopicNumber& aHandle )
    {
    // Send request for the notify
    iNotifyEventPtr.Set( reinterpret_cast< TText8* >( &aEvent ), 
                         sizeof( TCbsTopicListEvent ),
                         sizeof( TCbsTopicListEvent ) );
    iNotifyHandlePtr.Set( reinterpret_cast< TText8* >( &aHandle ), 
                         sizeof( TCbsTopicNumber ),
                         sizeof( TCbsTopicNumber ) );

    const TIpcArgs args( aRequested, &iNotifyEventPtr, &iNotifyHandlePtr );
    SendReceive( ECbsNotifyOnEvent, args, aStatus );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::NotifyOnEventCancel
// Cancels the pending notify request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsTopicList::NotifyOnEventCancel()
    {
    const TIpcArgs args( TIpcArgs::ENothing );
    SendReceive( ECbsNotifyOnEventCancel, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetNewTopicsCount
// Returns the number of session-specific new topics and resets the counter.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::GetNewTopicsCount( 
    TInt& aCount )
    {
    // Send request to the server to get the total amount of new topics
    aCount = 0;
    TPckgBuf<TInt> pckg( aCount );
    const TIpcArgs args( &pckg );

    TInt result( SendReceive( ECbsGetNewTopicsCount, args ) );

    if ( result == KErrNone )
        {
        aCount = pckg();
        }

    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetLatestTopicNumber
// Returns the latest topic's number.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsTopicList::GetLatestTopicNumber( 
    TCbsTopicNumber& aNumber )
    {
    aNumber = 0;
    TPckgBuf<TCbsTopicNumber> pckg( aNumber );
    const TIpcArgs args( &pckg );

    TInt result( SendReceive( ECbsGetLatestTopicNumber, args ) );

    if ( result == KErrNone )
        {
        aNumber = pckg();
        }
    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetUnreadMessageCount
// Returns the total amount of unread messages.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsTopicList::GetUnreadMessageCount( 
    TInt& aCount )
    {
    // Send request to the server to get the total amount of unread messages
    TPckgBuf<TInt> pckg( aCount );
    const TIpcArgs args( &pckg );

    TInt result = SendReceive( ECbsGetUnreadMessageCount, args );

    // In case everything went just fine update the parameter
    if ( result == KErrNone )
        {
        aCount = pckg();
        }
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetHotmarkedMessageHandle
// Returns the handle to the latest hotmarked message that has been
// received after the system has started up.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
void RCbsTopicList::GetHotmarkedMessageHandle( 
    TCbsMessageHandle& aMessage )
    {
    // Send request to the server to get the handle to the hotmarked message
    TPckgBuf<TCbsMessageHandle> pckgMessageHandle( aMessage );
    const TIpcArgs args( &pckgMessageHandle );

    TInt result = SendReceive( ECbsGetHotmarkedMessageHandle, args );

    if ( result == KErrNone )
        {
        aMessage = pckgMessageHandle();
        }
    else
        {
        aMessage = 0;
        }
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::NumberOfUnreadHotmarkedMessages
// Returns the number of unread messages in hotmarked topics.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicList::NumberOfUnreadHotmarkedMessages() 
    {
    TInt hotMsgCount( 0 );
    TPckgBuf<TInt> pckgHotMsgCount;    
    const TIpcArgs args( &pckgHotMsgCount );

    if ( SendReceive( ECbsGetUnreadHotmarkedMessageCount, args ) == KErrNone )
        {
        hotMsgCount = pckgHotMsgCount();
        }

    return hotMsgCount;
    }

// -----------------------------------------------------------------------------
// RCbsTopicList::GetNextAndPrevTopicNumber
// Returns the numbers of topics that precede and succeed the given 
// topic in server-side topic list.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicList::GetNextAndPrevTopicNumber( 
	const TCbsTopicNumber& aCurrentTopicNumber,
	TCbsTopicNumber& aPrevTopicNumber,
	TCbsTopicNumber& aNextTopicNumber,
	TInt& aPosition )
    {
    TPckgBuf<TCbsTopicNumber> pckgCurrentTopic( aCurrentTopicNumber );
    TPckgBuf<TCbsNextPrevTopicAndPosition> pckgResults;

    const TIpcArgs args( &pckgCurrentTopic, &pckgResults );

    TInt result( SendReceive( ECbsGetNextAndPrevTopicNumber, args ) );
    if ( result == KErrNone )
        {
        aPrevTopicNumber = pckgResults().iPrevTopic;
        aNextTopicNumber = pckgResults().iNextTopic;
        aPosition = pckgResults().iPosition;
        }
    return result;
    }

// ================= OTHER EXPORTED FUNCTIONS ==============

//  End of File