/*

* Copyright (c) 2008 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:  Handles native landmark database events

 *

*/

// INTERNAL INCLUDES

#include    "clapilmdatabaseeventnotifier.h"

#include    "mlapilmdatabaseobserver.h"

#include    "lapipanics.h"

#include    "logger.h"

// EXTERNAL INCLUDES

#include    <EPos_CPosLandmarkDatabase.h>

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

// CLAPILmDatabaseEventNotifier::NewLC

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

//

CLAPILmDatabaseEventNotifier* CLAPILmDatabaseEventNotifier::NewLC(

    CPosLandmarkDatabase& aDatabase)

{

    JELOG2(EJavaLocation);

    CLAPILmDatabaseEventNotifier* self =

        new(ELeave) CLAPILmDatabaseEventNotifier(aDatabase);

    CleanupStack::PushL(self);

    return self;

}

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

// CLAPILmDatabaseEventNotifier::~CLAPILmDatabaseEventNotifier

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

//

CLAPILmDatabaseEventNotifier::~CLAPILmDatabaseEventNotifier()

{

    JELOG2(EJavaLocation);

    Cancel();

    iEventObservers.Close();

}

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

// CLAPILmDatabaseEventNotifier::AddObserverL

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

//

void CLAPILmDatabaseEventNotifier::AddObserverL(

    MLAPILmDatabaseObserver* aObserver)

{

    JELOG2(EJavaLocation);

    __ASSERT_DEBUG(aObserver, LAPIError::Panic(ELAPIPanicNullArgument));

    iEventObservers.AppendL(aObserver);

}

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

// CLAPILmDatabaseEventNotifier::RemoveObserver

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

//

void CLAPILmDatabaseEventNotifier::RemoveObserver(

    MLAPILmDatabaseObserver* aObserver)

{

    JELOG2(EJavaLocation);

    __ASSERT_DEBUG(aObserver, LAPIError::Panic(ELAPIPanicNullArgument));

    TInt index = iEventObservers.Find(aObserver);

    if (index != KErrNotFound)

    {

        iEventObservers.Remove(index);

    }

}

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

// CLAPILmDatabaseEventNotifier::IsEventListeningSupported

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

//

TBool CLAPILmDatabaseEventNotifier::IsEventListeningSupported()

{

    JELOG2(EJavaLocation);

    // Event listening is not supported if the first request has returned

    // with KErrNotSupported error code. If there are requests pending, it

    // means that the request is pending and event listening is supported

    return iStatus != KErrNotSupported;

}

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

// CLAPILmDatabaseEventNotifier::RunL

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

//

void CLAPILmDatabaseEventNotifier::RunL()

{

    JELOG2(EJavaLocation);

    LOG1(EJavaLocation, EInfo, "CLAPILmDatabaseEventNotifier::RunL - event %d",

         iEvent.iEventType);

    // Listening database events is not supported. Stop listening and return

    if (iStatus == KErrNotSupported)

    {

        return;

    }

    else

    {

        TPosLmEvent curEvent(iEvent);

        TRequestStatus curStatus(iStatus);

        // Request a new database event. The operation completes when a change

        // occurs in the native database so the callback does not occur immediately

        // Call this before notifying the observer because events may occur

        // very frequently so subsequent events will not be missed

        iDatabase.NotifyDatabaseEvent(iEvent, iStatus);

        SetActive();

        // Notify observers if the change occured without any errors. All events

        // are informed to the observers which are responsible for filtering

        // incorrect events

        if (curStatus == KErrNone)

        {

            TInt observerCount = iEventObservers.Count();

            for (TInt i = 0; i < observerCount; i++)

            {

                iEventObservers[i]->NotifyEvent(curEvent.iEventType,

                                                curEvent.iLandmarkItemId);

            }

        }

    }

}

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

// CLAPILmDatabaseEventNotifier::DoCancel

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

//

void CLAPILmDatabaseEventNotifier::DoCancel()

{

    JELOG2(EJavaLocation);

    // Cancel listening database events

    iDatabase.CancelNotifyDatabaseEvent();

}

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

// CLAPILmDatabaseEventNotifier::CLAPILmDatabaseEventNotifier

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

//

CLAPILmDatabaseEventNotifier::CLAPILmDatabaseEventNotifier(

    CPosLandmarkDatabase& aDatabase) :

        CActive(EPriorityStandard), iDatabase(aDatabase)

{

    JELOG2(EJavaLocation);

    CActiveScheduler::Add(this);

    // Issue database change request. Note that the request completes only

    // when a change occurs in the native database

    iDatabase.NotifyDatabaseEvent(iEvent, iStatus);

    SetActive();

}

// End of file