/*
* 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:  Class for hiding differences between native and java listeners
*
*/

#include "logger.h"

#include "commsmessage.h"
#include "listeners.h"

namespace java
{
namespace comms
{

ListenerWrapper::ListenerWrapper(CommsListener* aListener) : mListener(aListener), mObject(0), mMethodID(0)
{
}

ListenerWrapper::ListenerWrapper(jobject aListener, JNIEnv* aEnv) : mListener(0), mObject(0), mMethodID(0)
{
    mObject = aEnv->NewGlobalRef(aListener);
    jclass cls = aEnv->GetObjectClass(aListener);
    if (cls != NULL)
    {
        mMethodID = aEnv->GetMethodID(cls, "processMessage", "(Lcom/nokia/mj/impl/comms/CommsMessage;)V");
    }

    if (mObject == NULL || mMethodID == NULL)
    {
        ELOG3(EJavaComms, "%s failed, mObject=%d - cls=%d", __PRETTY_FUNCTION__, mObject, mMethodID);
    }
}

ListenerWrapper::~ListenerWrapper()
{
}

void ListenerWrapper::processMessage(CommsMessage& aMessage, JNIEnv* aEnv)
{
    JELOG2(EJavaComms);
    if (mListener)
    {
        mListener->processMessage(aMessage);
        return;
    }

    char* buf = aMessage.toByteArray();
    int len = (reinterpret_cast<ipcMessage_t*>(buf))->ipcHeader.length;

    // create bytearray
    jbyteArray bytes = aEnv->NewByteArray(len);
    if (bytes!=NULL)
    {
        aEnv->SetByteArrayRegion(bytes, 0, len, (jbyte*)buf);
        // find CommsMessage java class
        jclass clazz = aEnv->FindClass("com/nokia/mj/impl/comms/CommsMessage");
        if (clazz!=NULL)
        {
            // find CommsMessage java class ctor
            jmethodID mid = aEnv->GetMethodID(clazz, "<init>", "([B)V");
            if (mid!=NULL)
            {
                // create CommsMessage java object
                jobject messageObj = aEnv->NewObject(clazz, mid, bytes);
                if (messageObj!=NULL)
                {
                    // make callback
                    callVoidJavaMethod(aEnv, mObject, mMethodID,
                                       "(Lcom/nokia/mj/impl/comms/CommsMessage;)V", messageObj);
                    // free local references manually as we run in dispatch loop that does not return to VM
                    aEnv->DeleteLocalRef(messageObj);
                }
                else
                {
                    ELOG(EJavaComms, "NewObject() failed");
                }
            }
            else
            {
                ELOG(EJavaComms, "GetMethodID() failed");
            }
            aEnv->DeleteLocalRef(clazz);
        }
        else
        {
            ELOG(EJavaComms, "FindClass() failed");
        }
        aEnv->DeleteLocalRef(bytes);
    }
    else
    {
        ELOG(EJavaComms, "NewByteArray() failed");
    }
}

void ListenerWrapper::callVoidJavaMethod(JNIEnv* aEnv, jobject aObject, jmethodID aMethodID, const char* aMethodSignature, ...)
{
    // make the callback
    va_list args;
    va_start(args, aMethodSignature);
    aEnv->CallVoidMethodV(aObject, aMethodID, args);
    va_end(args);

    // check for pending exception
    jboolean hasException = aEnv->ExceptionCheck();
    if (hasException == JNI_TRUE)
    {
        // Report any exceptions that were generated and
        // then clear them from the JNI environment
        aEnv->ExceptionDescribe();
        aEnv->ExceptionClear();
        WLOG(EJavaComms, "processMessage() threw exception (in CallVoidMethodV)");
    }
}

CommsListener* ListenerWrapper::getListener()
{
    return mListener;
}

void ListenerWrapper::release(JNIEnv* aEnv)
{
    // aEnv can be NULL if message loop thread has not attached to VM
    // (aka no messages have been received)
    if (aEnv)
    {
        aEnv->DeleteGlobalRef(mObject);
    }
}




} // namespace comms
} // namespace java