/*
* Copyright (c) 2002-2007 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:  Notifies the changes in central repository values.
*
*/



// INCLUDE FILES
#include    <centralrepository.h>
#include    "CSatCenRepChangeNotifier.h"
#include    "MSatSystemStateObserver.h"
#include    "Panic.h"
#include    "SatLog.h"

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

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::CSatCenRepChangeNotifier
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CSatCenRepChangeNotifier::CSatCenRepChangeNotifier(
    const TUid& aCenRepCategory,
    TUint32 aCenRepId,
    MSatSystemStateObserver& aObserver,
    TInt aCenRepType ) :
    CActive( EPriorityStandard ),
    iObserver( aObserver ),
    iCenRepCategory( aCenRepCategory ),
    iCenRepId( aCenRepId ),
    iCenRepType( aCenRepType )
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        CSatCenRepChangeNotifier calling" )
    // Log parameters
    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        CSatCenRepChangeNotifier Category: %d", aCenRepCategory )
    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        CSatCenRepChangeNotifier ID: %d", aCenRepId )
    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        CSatCenRepChangeNotifier Type: %d ", aCenRepType )

    CActiveScheduler::Add( this );

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        CSatCenRepChangeNotifier exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CSatCenRepChangeNotifier* CSatCenRepChangeNotifier::NewL(
    const TUid& aCenRepCategory,
    TUint32 aCenRepId,
    MSatSystemStateObserver& aObserver,
    TInt aCenRepType )
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NewL calling" )

    CSatCenRepChangeNotifier* self =
        new( ELeave ) CSatCenRepChangeNotifier(
            aCenRepCategory, aCenRepId, aObserver, aCenRepType );

    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NewL exiting" )
    return self;
    }


// Destructor
CSatCenRepChangeNotifier::~CSatCenRepChangeNotifier()
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        ~CSatCenRepChangeNotifier calling" )

    Cancel();
    if ( iCenRepClient )
        {
        delete iCenRepClient;
        iCenRepClient = NULL;
        }

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
        ~CSatCenRepChangeNotifier exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::ConstructL
// Creates central repository object.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::ConstructL()
    {
    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ConstructL calling" )

    iCenRepClient = CRepository::NewL( iCenRepCategory );

    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ConstructL exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::NotifyChangeL
// Issues notification request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::NotifyChangeL()
    {
    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NotifyChangeL calling" )

    __ASSERT_ALWAYS( !IsActive(), Panic( ESatSystemStateAllReadyActive ) );
    ActivateL();

    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NotifyChangeL exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::CancelNotify
// Cancels outstanding request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::CancelNotify()
    {
    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::CancelNotify calling" )

    Cancel();

    LOG( SIMPLE,
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::CancelNotify exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::DoCancel
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::DoCancel()
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::DoCancel calling" )

    // Cancel all notifications. This causes notification mechanism to return
    // KInvalidNotificationId in the RunL function, so it must be handled there.
    iCenRepClient->NotifyCancelAll();

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::DoCancel exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::RunL
// Activates the request again and calls the observer.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::RunL()
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL calling" )

    // In CenRep CRepository returns the key for the changed value in iStatus.
    const TUint32 cenRepId( iStatus.Int() );
    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
    iStatus: %d", iStatus.Int() )
    // Makes sure that all the changes are notified.
    if ( KErrCancel != iStatus.Int() )
        {
        ActivateL();
        }
        
    // Check that notification came from that ID we are observing.
    if ( cenRepId == iCenRepId )
        {
        LOG( SIMPLE, 
        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL cenRepId == iCenRepId" )
        switch ( iCenRepType )
            {
            case ECRTypeInteger:
                {
                TInt value;
                iCenRepClient->Get( iCenRepId, value );
                LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
                    Notifying TInt value: %d", value )
                iObserver.StateChanged( value );
                break;
                }
            case ECRTypeReal:
                {
                TReal value;
                iCenRepClient->Get( iCenRepId, value );
                LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
                    Notifying TReal value: %d", value )
                iObserver.StateChanged( value );
                break;
                }
            case ECRTypeDesC8:
                {
                TBuf8<NCentralRepositoryConstants::KMaxBinaryLength> value;
                iCenRepClient->Get( iCenRepId, value );
                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
                    Notifying string value" )
                iObserver.StateChanged( value );
                break;
                }
            case ECRTypeDesC16:
                {
                TBuf16<NCentralRepositoryConstants::KMaxUnicodeStringLength> value;
                iCenRepClient->Get( iCenRepId, value );
                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
                    Notifying Unicode value" )
                iObserver.StateChanged( value );
                break;
                }
            case ECRTypeUnknown:
            default:
                {
                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
                    Notifying without value" )
                // If type is not defined, call StateChanged without parameters
                iObserver.StateChanged();
                break;
                }
            }
        }

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL exiting" )
    }

// -----------------------------------------------------------------------------
// CSatCenRepChangeNotifier::ActivateL
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CSatCenRepChangeNotifier::ActivateL()
    {
    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ActivateL calling" )

    // This request notifies all changes in this category, not just the one we
    // are observing. Thus we have to read the value from CenRep before
    // notification.
    User::LeaveIfError( iCenRepClient->NotifyRequest( iCenRepId, iStatus ) );
    SetActive();

    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ActivateL exiting" )
    }

//  End of File