/*
* 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:  JNI implementation for SensorConnectionImpl.java
*
*/


#include "com_nokia_mj_impl_sensor_SensorConnectionImpl.h"
#include "sensorjniutils.h"
#include "sensornativeconstants.h"
#include "sensor.h"
#include "sensorconnection.h"
#include "sensorconnectionlist.h"
#include "logger.h"

void ConditionCallback(void* aJniEnv, void* aJavaPeer, void* aHandle, int aChannel,
                       double aValue, long aTimeStamp)
{
    JELOG2(ESensor);
    JNIEnv* jniEnv = (JNIEnv*)aJniEnv;
    jobject peer = (jobject) aJavaPeer;
    jclass cls = jniEnv->GetObjectClass(peer);
    jmethodID mid = jniEnv->GetMethodID(cls, "conditionMet", "(IIDJ)V");
    int condId = reinterpret_cast< int >(aHandle);
    jniEnv->CallVoidMethod(peer, mid, aChannel, condId, aValue, aTimeStamp);
    // Handle possible exception in callback
    HandleException(*jniEnv);
}

void FillData(DataFillerParams* aParams)
{
    JELOG2(ESensor);
    JNIEnv* jniEnv = (JNIEnv*)aParams->iJniEnv;
    jobjectArray destData = (jobjectArray)aParams->iDataObjects;

    // Assign data
    for (int i = 0; i < aParams->iDataCount; i++)
    {
        jobject data = jniEnv->GetObjectArrayElement(destData, i);
        jclass dataClass = jniEnv->GetObjectClass(data);

        if (aParams->iDatas[ i ]->iIntValues)
        {
            jfieldID field = jniEnv->GetFieldID(dataClass, "iIntValues", "[I");
            jintArray intValues = jniEnv->NewIntArray(aParams->iDatas[ i ]->iNumOfValues);
            jniEnv->SetIntArrayRegion(intValues, 0, aParams->iDatas[ i ]->iNumOfValues,
                                      aParams->iDatas[ i ]->iIntValues);
            jniEnv->SetObjectField(data, field, intValues);
            jniEnv->DeleteLocalRef(intValues);
            HandleException(*jniEnv);
        }
        else if (aParams->iDatas[ i ]->iDoubleValues)
        {
            jfieldID field = jniEnv->GetFieldID(dataClass, "iDoubleValues", "[D");
            jdoubleArray doubleValues = jniEnv->NewDoubleArray(aParams->iDatas[ i ]->iNumOfValues);
            jniEnv->SetDoubleArrayRegion(doubleValues, 0, aParams->iDatas[ i ]->iNumOfValues,
                                         aParams->iDatas[ i ]->iDoubleValues);
            jniEnv->SetObjectField(data, field, doubleValues);
            jniEnv->DeleteLocalRef(doubleValues);
            HandleException(*jniEnv);
        }
        if (aParams->iDatas[ i ]->iTimeStampsIncluded)
        {
            jfieldID field = jniEnv->GetFieldID(dataClass, "iTimestamps", "[J");
            jlongArray timestamps = jniEnv->NewLongArray(aParams->iDatas[ i ]->iNumOfValues);
            jniEnv->SetLongArrayRegion(timestamps, 0, aParams->iDatas[ i ]->iNumOfValues,
                                       reinterpret_cast<jlong*>(aParams->iDatas[ i ]->iTimeStamps));
            jniEnv->SetObjectField(data, field, timestamps);
            jniEnv->DeleteLocalRef(timestamps);
            HandleException(*jniEnv);
        }
        if (aParams->iDatas[ i ]->iValiditiesIncluded)
        {
            jfieldID field = jniEnv->GetFieldID(dataClass, "iValidities", "[Z");
            jbooleanArray validities = jniEnv->NewBooleanArray(aParams->iDatas[ i ]->iNumOfValues);
            jniEnv->SetBooleanArrayRegion(validities, 0, aParams->iDatas[ i ]->iNumOfValues,
                                          reinterpret_cast<jboolean*>(aParams->iDatas[ i ]->iValidities));
            jniEnv->SetObjectField(data, field, validities);
            jniEnv->DeleteLocalRef(validities);
            HandleException(*jniEnv);
        }
    }
    jobject peer = (jobject) aParams->iJavaPeer;
    jclass cls = jniEnv->GetObjectClass(peer);
    jmethodID mid = jniEnv->GetMethodID(cls, "dataReceived", "([Ljavax/microedition/sensor/Data;Z)V");
    jniEnv->CallVoidMethod(peer, mid, destData, aParams->iIsDataLost);
    // Handle possible exception in callback
    HandleException(*jniEnv);
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _createSensorConnection
 * Signature: (II)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1createSensorConnection
(JNIEnv* aJniEnv, jobject aJobj, jint aSensorList, jint aIndex)
{
    JELOG2(ESensor);
    SensorConnectionList* senList = reinterpret_cast< SensorConnectionList* >(aSensorList);
    SensorConnection* conn = senList->CreateSensorConnection(aIndex);
    if (!conn)
    {
        return ERROR_NOMEMORY;
    }
    int err = conn->GetSensor()->OpenChannel(conn);
    if (err)
    {
        return err;
    }
    conn->SetJavaPeer(aJniEnv->NewWeakGlobalRef(aJobj));
    conn->SetCallbacks(&FillData, &ConditionCallback);
    return reinterpret_cast< int >(conn);
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _startDataListening
 * Signature: ([Ljavax/microedition/sensor/Data;IJZZ)I
 */

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1startDataListening
(JNIEnv* aJniEnv, jobject /*aPeer*/, jint aSensorConnection, jobjectArray aData,
 jint aBufferSize, jlong aBufferingPeriod, jboolean aIsTimestampsIncluded,
 jboolean aIsValidityIncluded, jboolean aIsOneShot, jint aDataType)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aSensorConnection);
    void* oldData = 0;
    void* dataObjects = aJniEnv->NewGlobalRef(aData);
    int err = conn->PrepareDataListening(dataObjects,
                                         aJniEnv->GetArrayLength(aData),
                                         oldData,
                                         aDataType);
    // Remove possible old data objects
    if (oldData)
    {
        aJniEnv->DeleteGlobalRef((jobject)oldData);
    }

    if (!err)
    {
        err = conn->StartDataListening(aBufferSize, aBufferingPeriod,
                                       aIsTimestampsIncluded, aIsValidityIncluded,
                                       aIsOneShot);
    }
    return err;
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _cancelDataListening
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1cancelDataListening
(JNIEnv *, jobject, jint aSensorConnection)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aSensorConnection);
    Sensor* sensor = conn->GetSensor();
    return sensor->CancelDataListening();
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _removeConnection
 * Signature: (II)V
 */
JNIEXPORT void JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1removeConnection
(JNIEnv* aJniEnv, jobject, jint aSensorList, jint aSensorConnection)
{
    JELOG2(ESensor);
    SensorConnectionList* senList = reinterpret_cast< SensorConnectionList* >(aSensorList);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aSensorConnection);
    jobject dataObjects = (jobject)conn->DataObjects();
    if (dataObjects)
    {
        aJniEnv->DeleteGlobalRef(dataObjects);
    }
    aJniEnv->DeleteWeakGlobalRef((jweak)conn->GetJavaPeer());
    senList->RemoveConnection(conn);
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _startConditionListening
 * Signature: (II)V
 */
JNIEXPORT void JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1startConditionListening
(JNIEnv *, jobject, jint aConnectionHandle , jint aListeningType)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aConnectionHandle);
    Sensor* sensor = conn->GetSensor();
    sensor->StartConditionListening(aListeningType);
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _stopConditionListening
 * Signature: (I)V
 */
JNIEXPORT void JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1stopConditionListening
(JNIEnv *, jobject, jint aConnectionHandle)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aConnectionHandle);
    Sensor* sensor = conn->GetSensor();
    sensor->StopConditionListening();
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _startServer
 * Signature: (I)V
 */
JNIEXPORT void JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1startServer
(JNIEnv* aJniEnv, jobject, jint aConnectionHandle)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aConnectionHandle);
    Sensor* sensor = conn->GetSensor();
    // Store JNI env from this thread
    conn->SetJni(aJniEnv);
    sensor->StartServer();
}

/*
 * Class:     com_nokia_mj_impl_sensor_SensorConnectionImpl
 * Method:    _startServer
 * Signature: (I)V
 */
JNIEXPORT void JNICALL Java_com_nokia_mj_impl_sensor_SensorConnectionImpl__1stopServer
(JNIEnv *, jobject, jint aConnectionHandle)
{
    JELOG2(ESensor);
    SensorConnection* conn = reinterpret_cast< SensorConnection* >(aConnectionHandle);
    Sensor* sensor = conn->GetSensor();
    sensor->StopServer();
}