/*
* 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 RCbsTopicMessages class 
                 member functions.
*
*/



// INCLUDE FILES

#include "CbsServerConstants.h"
#include "RCbs.h"
#include "RCbsTopicMessages.h"


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

// -----------------------------------------------------------------------------
// RCbsTopicMessages::RCbsTopicMessages
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
RCbsTopicMessages::RCbsTopicMessages()
    {
    }

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

// -----------------------------------------------------------------------------
// RCbsTopicMessages::Close
// Closes the subsession.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::Close()
    {
    // Release locked message, if any
    TCbsMessageHandle handle( 0 );
    LockMessage( handle );

    // Close the subsession.
    RSubSessionBase::CloseSubSession( ECbsCloseTopicMessagesSubsession );
    return KErrNone;
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::GetMessageCount
// Returns the total amount of messages the topic contains.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::GetMessageCount( 
    TCbsTopicNumber aNumber, 
    TInt& aCount )
    {
    // Send request to get the total amount of messages
    aCount = 0;
    TPckgBuf< TInt > pckgCount( aCount );    
    const TIpcArgs args( aNumber, &pckgCount );

    TInt result = SendReceive( ECbsGetMessageCount, args );
    
    // If everything went fine, give the result to the client.
    if ( result == KErrNone )
        {
        aCount = pckgCount();
        }
    return result;
    }
    
// -----------------------------------------------------------------------------
// RCbsTopicMessages::GetMessage
// Returns message information.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::GetMessage( 
    TCbsTopicNumber aNumber, 
    TInt aIndex, 
    TCbsMessage& aMessage )
    {
    // Send request to get the message from server
    TPckgBuf< TCbsMessage > pckgMessage;
    const TIpcArgs args( aNumber, aIndex, &pckgMessage );

    TInt result = SendReceive( ECbsGetMessage, args );

    if ( result == KErrNone )
        {
        aMessage = pckgMessage();
        }
    else
        {
        aMessage.iHandle = 0;
        }

    return result;

    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::FindMessageByHandle
// Finds a message by given handle.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::FindMessageByHandle( 
    const TCbsMessageHandle& aHandle, 
    TCbsMessage& aMessage )
    {
    // Send request to the server to find a message by handle
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    TPckgBuf< TCbsMessage > pckgMessage;
    const TIpcArgs args( &pckgHandle, &pckgMessage );

    TInt result = SendReceive( ECbsFindMessageByHandle, args );

    // If everything went fine, update the message
    if ( result == KErrNone )
        {
        aMessage = pckgMessage();
        }
    else
        {
        aMessage.iHandle = 0;
        }

    return result;

    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::GetMessageIndexByHandle
// Returns the index of a message with given handle in topic.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::GetMessageIndexByHandle( 
    const TCbsMessageHandle& aHandle, 
    TInt& aIndex )
    {
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    TPckgBuf< TInt > pckgIndex( 0 );
    const TIpcArgs args( &pckgHandle, &pckgIndex );

    TInt result( SendReceive( ECbsGetMessageIndexByHandle, args ) );

    if ( result == KErrNone )
        {
        aIndex = pckgIndex();
        }
    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::DeleteMessage
// Deletes an existing message.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::DeleteMessage( 
    const TCbsMessageHandle& aHandle )
    {
    // Send request to delete a message by handle
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    const TIpcArgs args( &pckgHandle );
    return SendReceive( ECbsDeleteMessage, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::SaveMessage
// Saves a message (i.e., the saved message won't be deleted to make 
// room for new messages).
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::SaveMessage( 
    const TCbsMessageHandle& aHandle )
    {
    // Send request to save a message by handle
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    const TIpcArgs args( &pckgHandle );
    return SendReceive( ECbsSaveMessage, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::LockMessage
// Locks the message.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::LockMessage( 
    const TCbsMessageHandle& aHandle )
    {
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    const TIpcArgs args( &pckgHandle );
    return SendReceive( ECbsLockMessage, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::ReadMessage
// Sets the message as read.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::ReadMessage( 
    const TCbsMessageHandle& aHandle )
    {
    // Send request to set message read by handle
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    const TIpcArgs args( &pckgHandle );
    return SendReceive( ECbsReadMessage, args );
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::GetMessageContents
// Returns the message contents.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::GetMessageContents( 
    const TCbsMessageHandle& aHandle, 
    TDes& aBuffer )
    {
    // Send request to get the message contents
    TPckgBuf< TCbsMessageHandle > pckgHandle( aHandle );
    TInt length = aBuffer.MaxLength();
    const TIpcArgs args( &pckgHandle, length, &aBuffer );

    TInt result( SendReceive( ECbsGetMessageContents, args ) );
    if ( result != KErrNone )
        {
        aBuffer.Zero();
        }
    return result;
    }

// -----------------------------------------------------------------------------
// RCbsTopicMessages::GetNextAndPrevMessageHandle
// Returns the handles of messages that precede and succeed the 
// given message in server-side list of topic messages.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
// 
TInt RCbsTopicMessages::GetNextAndPrevMessageHandle(
	const TCbsMessageHandle& aCurrentMsgHandle,
	TCbsMessageHandle& aPrevMsgHandle,
	TCbsMessageHandle& aNextMsgHandle,
	TInt& aPosition )
    {
    TPckgBuf< TCbsMessageHandle > pckgCurrentMsg( aCurrentMsgHandle );
    TPckgBuf< TCbsNextPrevMsgAndPosition > pckgResults;
    const TIpcArgs args( &pckgCurrentMsg, &pckgResults );

    TInt result( SendReceive( ECbsGetNextAndPrevMsgHandle, args ) );
    if ( result == KErrNone )
        {
        aPrevMsgHandle = pckgResults().iPrevMsg;
        aNextMsgHandle = pckgResults().iNextMsg;
        aPosition = pckgResults().iPosition;
        }
    return result;
    }

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

//  End of File