/*
* 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:  Implementation of the class RCbsMcnSession.
*
*/


// INCLUDE FILES

#include "CbsServerConstants.h"
#include "CbsMcnPanic.h"
#include "CMcn.h"
#include "RCbsMcnSession.h"
#include "CCbsMcnListener.h"
#include "CMcnTopicArray.h"
#include "CbsLogger.h"

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

// -----------------------------------------------------------------------------
// RCbsMcnSession::RCbsMcnSession
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
RCbsMcnSession::RCbsMcnSession()
    : iConnected( EFalse )
    { //lint !e1928 !e1926
    }                               
    
// Destructor
RCbsMcnSession::~RCbsMcnSession()
    {
    Close();
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::GetCellInfo
// Retrieves the current MCN message from CBS server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsMcnSession::GetCellInfo( 
    TDes& aMcnMessage ) const
    {
    return GetInfoMessage( aMcnMessage, KCellInfoTopic );
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::GetInfoMessage
// Retrieves the current HomeZone message from CBS server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsMcnSession::GetInfoMessage( 
    TDes& aMessage, 
    const TInt aTopicNumber ) const
    {
    __ASSERT_DEBUG( iConnected, CbsMcnPanic( EMcnNotConnected ) );

    const TIpcArgs args( &aMessage, aTopicNumber );
    TInt result( SendReceive( EMcnGetInfoMessage, args ) );
    return result;
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::ReadMcnMessage
// Request next subscribed MCN message to be delivered to this session.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsMcnSession::ReadMcnMessage( 
    TRequestStatus& aStatus, 
    TPckg<TCbsMcnMessage>& aMcnPckg ) 
    {
    __ASSERT_DEBUG( iConnected, CbsMcnPanic( EMcnNotConnected ) );
    iSubSession.ReadMcnMessage( aStatus, aMcnPckg );
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::ReadMcnMessageCancel
// Cancels an outstanding request. Passed to the subsession object.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsMcnSession::ReadMcnMessageCancel() 
    {
    __ASSERT_DEBUG( iConnected, CbsMcnPanic( EMcnNotConnected ) );
    return iSubSession.ReadMcnMessageCancel();
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::RegisterL
// Subscribes topics given in aArray.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsMcnSession::RegisterL( 
    const CMcnTopicArray& aArray )
    {
    CBSLOGSTRING("CBSMCNCLIENT: >>> RCbsMcnSession::RegisterL()");

    __ASSERT_DEBUG( iConnected, CbsMcnPanic( EMcnNotConnected ) );
    iSubSession.RegisterL( aArray );
    
    CBSLOGSTRING("CBSMCNCLIENT: <<< RCbsMcnSession::RegisterL()");
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::ClearSubscriptionsL
// Clears all topic subscriptions of this session in CbsServer.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsMcnSession::ClearSubscriptionsL()
    {
    CBSLOGSTRING("CBSMCNCLIENT: >>> RCbsMcnSession::ClearSubscriptionsL()");

    __ASSERT_DEBUG( iConnected, CbsMcnPanic( EMcnNotConnected ) );
    iSubSession.ClearSubscriptionsL();

    CBSLOGSTRING("CBSMCNCLIENT: <<< RCbsMcnSession::ClearSubscriptionsL()");
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::Connect
// Establishes a connection with CbsServer.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TInt RCbsMcnSession::Connect()
    {
    CBSLOGSTRING("CBSMCNCLIENT: >>> RCbsMcnSession::Connect()");

    // Create a session to the server.
    TInt result = CreateSession( KCbsServerName,
       Version(), KCbsServerDefaultSlots );

    CBSLOGSTRING2("CBSMCNCLIENT: RCbsMcnSession::Connect(): CreateSession() result: %d", result );    

    if ( result == KErrNone )
        {
        TInt error = iSubSession.Open( *this );
        if ( !error )
            {
            iConnected = ETrue;
            CBSLOGSTRING("CBSMCNCLIENT: RCbsMcnSession::Connect(): Subsession opened.");            
            }        
        CBSLOGSTRING2("CBSMCNCLIENT: RCbsMcnSession::Connect(): Subsession opening failed, error: %d", error );        
        } 
    else
        {
        iConnected = EFalse;
        CBSLOGSTRING2("CBSMCNCLIENT: RCbsMcnSession::Connect(): CreateSession failed, errorCode: %d", result );
        }

    CBSLOGSTRING2("CBSMCNCLIENT: <<< RCbsMcnSession::Connect(), iConnected: %d", iConnected );    
    return result;
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::Close
// Closes the connection with CbsServer.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RCbsMcnSession::Close()
    {
    CBSLOGSTRING("CBSMCNCLIENT: >>> RCbsMcnSession::Close()");

    if ( iConnected ) 
        {
        iSubSession.Close();

        const TIpcArgs args( TIpcArgs::ENothing );
        SendReceive( EMcnCloseSession, args );
        RSessionBase::Close();
        iConnected = EFalse;

        CBSLOGSTRING("CBSMCNCLIENT: RCbsMcnSession::Close(): Connected -> subsession closed.");        
        }
    CBSLOGSTRING("CBSMCNCLIENT: <<< RCbsMcnSession::Close()");
    }

// -----------------------------------------------------------------------------
// RCbsMcnSession::Version
// Returns version information of this dll.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TVersion RCbsMcnSession::Version() const
    {
    // Create version and return it.
    return TVersion( KCbsServerVersionMajor,
                     KCbsServerVersionMinor,
                     KCbsServerVersionBuild );
    }
    
//  End of File