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



// INCLUDE FILES

#include <e32math.h>
#include "CbsServerConstants.h"
#include "CCbsRecEtel.h"
#include "CCbsRecEtelMonitor.h"
#include "CCbsRecMessage.h"
#include "CCbsRecWcdmaMessage.h"
#include "CCbsMessageFactory.h"
#include "CbsServerPanic.h"
#include "CCbsLivecastHandler.h"
#include <featmgr.h>
#include <bldvariant.hrh> // for feature definitions
#include "CbsLogger.h"

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

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::CCbsRecEtelMonitor
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CCbsRecEtelMonitor::CCbsRecEtelMonitor( 
    CCbsRecEtel& aEtel, 
    MCbsEtelMessaging& aMessaging,
    CCbsMessageFactory& aFactory,
    CCbsLivecastHandler& aLivecastHandler )
    : CActive( EPriorityStandard ),
    iEtel( aEtel ), 
    iSmsMessaging( aMessaging ),        
    iMsgAttributesPckg( iAttributes ),   // Message attributes
    iFactory( aFactory ),
    iLivecastHandler( aLivecastHandler ),
    iNewstickerSupported( EFalse )
    {
    }

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CCbsRecEtelMonitor::ConstructL()
    {
    CBSLOGSTRING("CBSSERVER: >>> CCbsRecEtelMonitor::ConstructL()");

    CActiveScheduler::Add( this );    

    // Sets up TLS, must be done before FeatureManager is used.
    FeatureManager::InitializeLibL();

    // Check if Newsticker feature is supported
    if ( FeatureManager::FeatureSupported( KFeatureIdNewsticker ) )
        {
        iNewstickerSupported = ETrue;
        CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::ConstructL(): Newsticker supported.");
        }
    else
        {
        CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::ConstructL(): Newsticker NOT supported.");
        }

    // Frees the TLS! Must be done after FeatureManager is used.
    FeatureManager::UnInitializeLib();
    
    CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::ConstructL()");
    }

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CCbsRecEtelMonitor* CCbsRecEtelMonitor::NewL( 
    CCbsRecEtel& aEtel, 
    MCbsEtelMessaging& aSmsMessaging,
    CCbsMessageFactory& aFactory,
    CCbsLivecastHandler& aLivecastHandler )
    {
    CBSLOGSTRING("CBSSERVER: >>> CCbsRecEtelMonitor::NewL()");

    CCbsRecEtelMonitor* self = 
        new ( ELeave ) CCbsRecEtelMonitor( aEtel, aSmsMessaging, aFactory, aLivecastHandler );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop();

    CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::NewL()");
    return self;
    }
    
// Destructor
CCbsRecEtelMonitor::~CCbsRecEtelMonitor()
    {
    CBSLOGSTRING("CBSSERVER: >>> CCbsRecEtelMonitor::~CCbsRecEtelMonitor()");
    Cancel();
    CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::~CCbsRecEtelMonitor()");
    }

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::IssueRequest
// Requests EPOC Telephony Server to forward next received CB message to this object.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CCbsRecEtelMonitor::IssueRequest() 
    {
    CBSLOGSTRING("CBSSERVER: >>> CCbsRecEtelMonitor::IssueRequest()");

    if ( !IsActive() )
        {
        iMsgData.FillZ();
        iSmsMessaging.ReceiveMessage( iStatus, iMsgData, iMsgAttributesPckg );
        SetActive(); 
        }
    CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::IssueRequest()");
    }

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::RunL
// Becomes active when EPOC Telephony Server has copied a CB message to 
// iMsgData. The message is then given to CCbsRecEtel for
// processing.
// Finally this function re-issues the ReceiveMessage request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CCbsRecEtelMonitor::RunL()
    {
    CBSLOGSTRING2("CBSSERVER: >>> CCbsRecEtelMonitor::RunL(), iStatus: %d", iStatus.Int() );

    if ( iStatus == KErrNone )
        {
        CCbsMessage* currentMessage = NULL;
        TCbsMessageType msgType( ECbsMessageTypeUnspecified );
		
        CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): Calling CreateMessageL()..." );
        currentMessage = iFactory.CreateMessageL( iMsgData, iAttributes, msgType );        
        CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): CreateMessageL() called OK." );

        if ( currentMessage )
            {            
            if ( msgType == ECbsMessageLivecast )
                {				
                CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): LC message" );

				if ( iNewstickerSupported )
					{
	                // Ownership of currentMessage transferred to iLivecastHandler
	                CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): Calling HandleLivecastMessageL()..." );
	                TInt lcResult( KErrNone );
	                TRAP( lcResult, iLivecastHandler.HandleLivecastMessageL( currentMessage ) );                
	                CBSLOGSTRING2("CBSSERVER: CCbsRecEtelMonitor::RunL(): HandleLivecastMessageL() finished, result: %d", lcResult );
					}
                else 
                	{
                	CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): NewsSticker is not supported" );
                	}
                }
            else
                {				
                CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): Normal message" );

                // Ownership of currentMessage transferred to iEtel
                CBSLOGSTRING("CBSSERVER: CCbsRecEtelMonitor::RunL(): Calling HandleMessageReceivedL()..." );
                TInt result( KErrNone );
                TRAP( result, iEtel.HandleMessageReceivedL( currentMessage ) );                
                CBSLOGSTRING2("CBSSERVER: CCbsRecEtelMonitor::RunL(): HandleMessageReceivedL() finished, result: %d", result );
                }            
            }

        // Renew the request
        IssueRequest();
        }
	CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::RunL()");
    }

// -----------------------------------------------------------------------------
// CCbsRecEtelMonitor::DoCancel
// Cancels an outstanding ReceiveMessage request.  
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CCbsRecEtelMonitor::DoCancel()
    {
    CBSLOGSTRING("CBSSERVER: >>> CCbsRecEtelMonitor::DoCancel()" );
    iSmsMessaging.ReceiveMessageCancel();
    CBSLOGSTRING("CBSSERVER: <<< CCbsRecEtelMonitor::DoCancel()" );
    }

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

//  End of File