/*
* 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:  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 "logger.h"

// -----------------------------------------------------------------------------
// CAOCenRepObserver::NewL
// -----------------------------------------------------------------------------
//
CAOCenRepObserver* CAOCenRepObserver::NewL( MAOCenRepObserver& aObserver )
    {
    CAOCenRepObserver* self = 
             CAOCenRepObserver::NewLC( aObserver );
    CleanupStack::Pop( self );
    return self;
    }

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

// -----------------------------------------------------------------------------
// CAOCenRepObserver::~CAOCenRepObserver
// -----------------------------------------------------------------------------
//
CAOCenRepObserver::~CAOCenRepObserver()
    {
    // Cancel outstanding request, if exists
    Cancel();
    delete iRepository;
    }

// -----------------------------------------------------------------------------
// CAOCenRepObserver::CAOCenRepObserver
// -----------------------------------------------------------------------------
//
CAOCenRepObserver::CAOCenRepObserver( MAOCenRepObserver& aObserver )
        :
        CActive( CActive::EPriorityStandard ),
        iObserver( aObserver )
    {
    }

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

// -----------------------------------------------------------------------------
// CAOCenRepObserver::RequestNotifications
// -----------------------------------------------------------------------------
//
void CAOCenRepObserver::RequestNotifications()
    {
    LOG_1( _L("CAOCenRepObserver::RequestNotifications") );

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

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

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

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

    if ( iStatus.Int() < KErrNone )
        {
        iErrorCounter++;
        if ( iErrorCounter > KCenRepErrorRetryCount )
            {
            LOG_2( _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 )
            {
            LOG_2( _L("KCurrentCellularDataUsage: %d"), value );
                   	
            TRAPD( leaveCode, iObserver.CurrentCellularDataUsageChangedL( value ) )
            
            if ( leaveCode )
                {
                LOG_2( _L("iObserver->CurrentCellularDataUsageChangedL FAILED: %d"), 
                       leaveCode );
                }
            }
        else
            {
            LOG_2( _L("ERROR, iRepository->Get(KCurrentCellularDataUsage) %d"), err );
            }
        }

    RequestNotifications();
    }

// End-of-file