/*
* Copyright (c) 2010 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:  Listens to changes in a Central Repository key 
*               KCurrentCellularDataUsage in Repository KCRUidCmManager.
*/

#include <commsdat.h>
#include <centralrepository.h>
#include <cmmanagerkeys.h>

#include "cenrepobserver.h"
#include "ai3.hrh"
using namespace AiXmlUiController;

#ifdef HS_NETWORK_MONITOR
#include <flogger.h>
_LIT( KLogFolder,"xnnetwork" );
_LIT( KLogDom, "networksettings.log" );

#define _LOG1( a ) RFileLogger::Write( \
    KLogFolder, KLogDom, EFileLoggingModeAppend, ( a ) );
#define _LOG2( a, b ) RFileLogger::WriteFormat( \
    KLogFolder, KLogDom, EFileLoggingModeAppend, ( a ), ( b ) )
#else
#define _LOG1
#define _LOG2
#endif

// -----------------------------------------------------------------------------
// CCenRepObserver::NewL
// -----------------------------------------------------------------------------
//
CCenRepObserver* CCenRepObserver::NewL( MCenRepObserver* aObserver )
    {
    CCenRepObserver* self = 
             CCenRepObserver::NewLC( aObserver );
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::NewLC
// -----------------------------------------------------------------------------
//
CCenRepObserver* CCenRepObserver::NewLC( MCenRepObserver* aObserver )
    {
    CCenRepObserver* self = 
             new( ELeave ) CCenRepObserver( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::~CCenRepObserver
// -----------------------------------------------------------------------------
//
CCenRepObserver::~CCenRepObserver()
    {
    // Cancel outstanding request, if exists
    Cancel();
    delete iRepository;
    iObserver = NULL;
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::CCenRepObserver
// -----------------------------------------------------------------------------
//
CCenRepObserver::CCenRepObserver( MCenRepObserver* aObserver )
        :
        CActive( CActive::EPriorityStandard ),
        iObserver( aObserver )
    {
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::ConstructL
// -----------------------------------------------------------------------------
//
void CCenRepObserver::ConstructL()
    {    
    TRAPD( err, iRepository = CRepository::NewL( KCRUidCmManager ) )
     
    if ( err == KErrNone )
        {
        CActiveScheduler::Add( this );
        RequestNotifications();
        }
    else
        {
        _LOG2( _L("FAILED to open KCRUidCmManager repository <%d>"), err ); 
        }
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::RequestNotifications
// -----------------------------------------------------------------------------
//
void CCenRepObserver::RequestNotifications()
    {
     _LOG1( _L("CCenRepObserver::RequestNotifications") );

    TInt err = iRepository->NotifyRequest( KCurrentCellularDataUsage, iStatus );

    if ( err == KErrNone )
        {
        SetActive();
        }
    else
        {
        _LOG2( _L("ERROR, iRepository->NotifyRequest() %d"), err ); 
        }
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::DoCancel
// -----------------------------------------------------------------------------
//
void CCenRepObserver::DoCancel()
    {
    iRepository->NotifyCancel( KCurrentCellularDataUsage );
    }

// -----------------------------------------------------------------------------
// CCenRepObserver::RunL
// -----------------------------------------------------------------------------
//
void CCenRepObserver::RunL()
    {
    _LOG2( _L("CCenRepObserver::RunL() %d"), iStatus.Int() );

    if ( iStatus.Int() < KErrNone )
        {
        iErrorCounter++;
        if ( iErrorCounter > KCenRepErrorRetryCount )
            {
            _LOG2( _L("Over %d consecutive errors, stopping notifications permanently"), 
                   KCenRepErrorRetryCount );    
            return;
            }
        }
    else
        {
        iErrorCounter = 0;
        
        TInt value( 0 );
        TInt err = iRepository->Get( KCurrentCellularDataUsage, value );
            
        if ( err == KErrNone )
            {
            _LOG2( _L("KCurrentCellularDataUsage: %d"), value );
             iObserver->CurrentCellularDataUsageChangedL( value );
            }
        else
            {
            _LOG2( _L("ERROR, iRepository->Get(KCurrentCellularDataUsage) %d"), err );
            }
        }

    RequestNotifications();
    }
// End-of-file