/*
* 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:
*
* This class implements general wait object for calling
* a callback function after subscribed P&S key value changes.
*
*/

#include "propertylistener.h"
#include "logger.h"

using namespace java::installer;

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

CPropertyListener* CPropertyListener::NewL(TUid aUid, TUint aKey)
{
    CPropertyListener* self = new(ELeave) CPropertyListener(aUid, aKey);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
}

CPropertyListener::CPropertyListener(TUid aUid, TUint aKey)
    : CActive(CActive::EPriorityStandard), iUid(aUid), iKey(aKey)
{
}

void CPropertyListener::ConstructL()
{
    User::LeaveIfError(iProperty.Attach(iUid, iKey));
    // PropertyListener is always created from a thread which does
    // not have ActiveScheduler, so create ActiveScheduler now.
    iActiveScheduler = new(ELeave) CActiveScheduler;
    CActiveScheduler::Install(iActiveScheduler);
    // Add this object to the ActiveScheduler.
    CActiveScheduler::Add(this);
}

CPropertyListener::~CPropertyListener()
{
    Cancel();
    iProperty.Close();
    if (iActiveScheduler)
    {
        delete iActiveScheduler;
        iActiveScheduler = 0;
    }
}

void CPropertyListener::ProcessEventsL(JNIEnv *aEnv, jobject aProvider)
{
    // Get the java side callback method.
    jclass clazz = aEnv->GetObjectClass(aProvider);
    jmethodID method = aEnv->GetMethodID(clazz, "valueChanged", "(I)V");

    iEnv = aEnv;
    iProvider = aProvider;
    iMethod = method;

    // Run propertyListener once so that the current property value
    // gets delivered and property value changes are subscribed.
    RunL();

    // Start ActiveScheduler.
    CActiveScheduler::Start();
}

void CPropertyListener::RunL()
{
    if (iCancelled)
    {
        CActiveScheduler::Stop();
        return;
    }

    // Resubscribe before handling the new value to prevent missing updates.
    iProperty.Subscribe(iStatus);
    SetActive();

    TInt value;
    TInt err = iProperty.Get(value);
    if (KErrNone == err)
    {
        //ILOG3(EJavaInstaller,
        //      "CPropertyListener::RunL: property value changed"
        //      ", uid: 0x%x, key: 0x%x, value: %d", iUid.iUid, iKey, value);
        // Use callback method to deliver the changed property value to
        // Java side object.
        iEnv->CallVoidMethod(iProvider, iMethod, value);
    }
    else if (KErrNotFound == err)
    {
        // Property deleted, no actions needed.
    }
    else
    {
        // Error while reading property value.
        ELOG3(EJavaInstaller,
              "CPropertyListener::RunL: getting property value failed"
              ", uid: 0x%x, key: 0x%x, err=%d", iUid.iUid, iKey, err);
    }
}

void CPropertyListener::DoCancel()
{
    iCancelled = ETrue;
    iProperty.Cancel();
}