/*
* Copyright (c) 2004 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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 CActiveFavouritesDbNotifier.
*      
*
*/


// INCLUDE FILES

#include "ActiveFavouritesDbNotifier.h"
#include "FavouritesDbObserver.h"

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

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::CActiveFavouritesDbNotifier
// ---------------------------------------------------------
//
EXPORT_C CActiveFavouritesDbNotifier::CActiveFavouritesDbNotifier
( RFavouritesDb& aDb, MFavouritesDbObserver& aObserver )
: CActive( EPriorityStandard ), iDb( aDb ), iObserver( &aObserver )
    {
    CActiveScheduler::Add( this );
    }

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::~CActiveFavouritesDbNotifier
// ---------------------------------------------------------
//
EXPORT_C CActiveFavouritesDbNotifier::~CActiveFavouritesDbNotifier()
    {
    iNotifier.Close();
    Cancel();
    }

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::RunL
// ---------------------------------------------------------
//
EXPORT_C void CActiveFavouritesDbNotifier::RunL()
    {
    if ( iStatus == KErrCancel )
        {
        // Cancelled, do nothing.
        }
    else
        {
        // Otherwise, the event must be one of RDbNotifier::TEvent.
        RDbNotifier::TEvent event = 
            STATIC_CAST( RDbNotifier::TEvent, iStatus.Int() );
        if ( iStatus == RDbNotifier::EClose )
            {
            // Finish if the database is closed.
            iNotifier.Close();
            }
        else
            {
            // Reschedule automatically (as long as the database is open).
            NotifyChange();
            }
        // Call observer *after* the notifier is rescheduled: this way
        // the notifier stays alive even if observer leaves.
        iObserver->HandleFavouritesDbEventL( event );
        }
    }

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::DoCancel
// ---------------------------------------------------------
//
EXPORT_C void CActiveFavouritesDbNotifier::DoCancel()
    {
    iNotifier.Close();
    }

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::Start
// ---------------------------------------------------------
//
EXPORT_C TInt CActiveFavouritesDbNotifier::Start()
    {
    TInt err = iNotifier.Open( iDb );
    if ( !err )
        {
        NotifyChange();
        }
    return err;
    }

// ---------------------------------------------------------
// CActiveFavouritesDbNotifier::NotifyChange
// ---------------------------------------------------------
//
void CActiveFavouritesDbNotifier::NotifyChange()
    {
    if ( !IsActive() )
        {
        iNotifier.NotifyChange( iStatus );
        SetActive();
        }
    }

// End of File