/*

* Copyright (c) 2009 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 CCDSYController class

*

*/

// INCLUDE FILES 

#include "CDSYController.h"

#include "CDSYMessage.h"

#include "CDSYServiceLogic.h"

#include "CDSYMessagesServiceLogic.h"

#include "commondsy_debug.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

const TInt KServiceLogicArrayGranularity = 100;

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

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

// -----------------------------------------------------------------------------

// CCDSYController::CCDSYController

// -----------------------------------------------------------------------------

CCDSYController::CCDSYController()

: iCurrentTransactionID( 0 )

, iServiceLogics( KServiceLogicArrayGranularity )

    {

    COM_TRACE_( "CDSY - CCDSYController::CCDSYController()" );

    COM_TRACE_( "CDSY - CCDSYController::CCDSYController - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::~CCDSYController

// -----------------------------------------------------------------------------

CCDSYController::~CCDSYController()

    {

    COM_TRACE_( "CDSY - CCDSYController::~CCDSYController()" );

    iServiceLogics.ResetAndDestroy();

    COM_TRACE_( "CDSY - CCDSYController::~CCDSYController - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::NewL

// -----------------------------------------------------------------------------

CCDSYController* CCDSYController::NewL()

    {

    COM_TRACE_( "CDSY - CCDSYController::NewL()" );

    CCDSYController* controller = new ( ELeave ) CCDSYController();

    COM_TRACE_1( "CDSY - CCDSYController::NewL - return 0x%x", controller );

    return controller;

    }

// -----------------------------------------------------------------------------

// CCDSYController::ProcessMessageL

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::ProcessMessageL( TCDSYMessage& aCDSYMessage )

    {

    COM_TRACE_1( "CDSY - CCDSYController::ProcessMessageL(0x%x)", &aCDSYMessage );

    TUint count = 0;

    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )

        {

        if ( ( ( iServiceLogics[i] )->MessageGroup() == aCDSYMessage.Group() )

            && ( ( iServiceLogics[i] )->MessageID() == aCDSYMessage.ID() )

            && ( ( ( iServiceLogics[i] )->DynamicRegistration() == EFalse )

                || ( ( ( iServiceLogics[i] )->DynamicRegistration() )

                    && ( ( iServiceLogics[i] )->MessageTransactionID() == aCDSYMessage.TransactionID() ) ) ) )

            {

            count++;

            ( ( iServiceLogics[i] )->CDSYServiceLogic() )->ProcessMessageL( aCDSYMessage );

            }

        }

    TRACE_ASSERT( count > 0 );

    TRACE_ASSERT( count < 2 );

    COM_TRACE_( "CDSY - CCDSYController::ProcessMessageL - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::RegisterServiceLogicL

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::RegisterServiceLogicL( const TUint32 aMessageGroup, const TUint32 aMessageID, MCDSYServiceLogic* aCDSYServiceLogic )

    {

    COM_TRACE_3( "CDSY - CCDSYController::RegisterServiceLogicL(0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aCDSYServiceLogic );

#ifdef _DEBUG

    // Check that this hasn't been already registered

    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )

        {

        if ( ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )

            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )

            {

            TRACE_ASSERT_ALWAYS;

            }

        }

#endif //#ifdef _DEBUG

    CCDSYMessagesServiceLogic* serviceLogic = CCDSYMessagesServiceLogic::NewL( aMessageGroup, aMessageID, aCDSYServiceLogic );

    TInt err = iServiceLogics.Append( serviceLogic );

    if ( err != KErrNone )

        {

        TRACE_ASSERT_ALWAYS;

        delete serviceLogic;

        User::Leave( err );

        }

    COM_TRACE_( "CDSY - CCDSYController::RegisterServiceLogicL - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::RegisterServiceLogicL

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::RegisterServiceLogicL( const TUint32 aMessageGroup, const TUint32 aMessageID, const TUint32 aTransactionID, MCDSYServiceLogic* aCDSYServiceLogic )

    {

    COM_TRACE_4( "CDSY - CCDSYController::RegisterServiceLogicL(0x%x, 0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );

#ifdef _DEBUG

    // Check that this hasn't been already registered

    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )

        {

        if ( ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )

            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )

            {

            TRACE_ASSERT_ALWAYS;

            }

        }

#endif //#ifdef _DEBUG

    CCDSYMessagesServiceLogic* serviceLogic = CCDSYMessagesServiceLogic::NewL( aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );

    TInt err = iServiceLogics.Append( serviceLogic );

    if ( err != KErrNone )

        {

        TRACE_ASSERT_ALWAYS;

        delete serviceLogic;

        User::Leave( err );

        }

    COM_TRACE_( "CDSY - CCDSYController::RegisterServiceLogicL - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::UnregisterServiceLogic

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::UnregisterServiceLogic( const TUint32 aMessageGroup, const TUint32 aMessageID, const MCDSYServiceLogic* aCDSYServiceLogic )

    {

    COM_TRACE_3( "CDSY - CCDSYController::UnregisterServiceLogic(0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aCDSYServiceLogic );

    for ( TInt i = iServiceLogics.Count() - 1; i >= 0; i-- )

        {

        if ( ( ( iServiceLogics[i] )->CDSYServiceLogic() == aCDSYServiceLogic )

            && ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )

            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )

            {

            delete iServiceLogics[i];

            iServiceLogics.Remove( i );

            i = -1;

            }

        }

    COM_TRACE_( "CDSY - CCDSYController::UnregisterServiceLogic - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::UnregisterServiceLogic

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::UnregisterServiceLogic( const TUint32 aMessageGroup, const TUint32 aMessageID, const TUint32 aTransactionID, const MCDSYServiceLogic* aCDSYServiceLogic )

    {

    COM_TRACE_4( "CDSY - CCDSYController::UnregisterServiceLogic(0x%x, 0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );

    for ( TInt i = iServiceLogics.Count() - 1; i >= 0; i-- )

        {

        if ( ( ( iServiceLogics[i] )->CDSYServiceLogic() == aCDSYServiceLogic )

            && ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )

            && ( ( iServiceLogics[i] )->MessageID() == aMessageID )

            && ( ( iServiceLogics[i] )->MessageTransactionID() == aTransactionID ) )

            {

            delete iServiceLogics[i];

            iServiceLogics.Remove( i );

            i = -1;

            }

        }

    COM_TRACE_( "CDSY - CCDSYController::UnregisterServiceLogic - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::ExpireMessageL

// -----------------------------------------------------------------------------

EXPORT_C void CCDSYController::ExpireMessageL( TCDSYMessage& aCDSYMessage )

    {

    COM_TRACE_1( "CDSY - CCDSYController::ExpireMessageL(0x%x)", &aCDSYMessage );

    TUint count = 0;

    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )

        {

        if((((iServiceLogics[i])->MessageGroup() == aCDSYMessage.Group())

                && ((iServiceLogics[i])->MessageID() == aCDSYMessage.ID())

                && ((iServiceLogics[i])->DynamicRegistration() == EFalse))

            || (((iServiceLogics[i])->DynamicRegistration() != EFalse)

                && ((iServiceLogics[i])->MessageTransactionID() == aCDSYMessage.TransactionID())))

            {

            count++;

            ( ( iServiceLogics[i] )->CDSYServiceLogic() )->ExpireMessageL( aCDSYMessage );

            }

        if(((iServiceLogics[i])->DynamicRegistration() != EFalse)

            && ((iServiceLogics[i])->MessageTransactionID() == aCDSYMessage.TransactionID()))

            {

            delete iServiceLogics[i];

            iServiceLogics.Remove( i );

            i--;

            }

        }

    TRACE_ASSERT( count > 0 );

    TRACE_ASSERT( count < 2 );

    COM_TRACE_( "CDSY - CCDSYController::ExpireMessageL - return void" );

    }

// -----------------------------------------------------------------------------

// CCDSYController::GetNewTransactionID

// -----------------------------------------------------------------------------

EXPORT_C TUint8 CCDSYController::GetNewTransactionID()

    {

    COM_TRACE_( "CDSY - CCDSYController::GetNewTransactionID()" );

    iCurrentTransactionID++;

    COM_TRACE_1( "CDSY - CCDSYController::GetNewTransactionID - return 0x%x", iCurrentTransactionID );

    return iCurrentTransactionID;

    }