pEpJNIAdapter/src/foundation_pEp_jniadapter_AbstractEngine.cc

#include "foundation_pEp_jniadapter_AbstractEngine.h"

#ifndef NDEBUG
#include <iostream>
auto& debug_log = std::cerr;
#else
// the compiler should optimize this away
static struct _debug_log {
    _debug_log& operator<<(const char*) { return *this; }
    _debug_log& operator<<(int) { return *this; }
    _debug_log& operator<<(double) { return *this; }
} debug_log;
#endif

#include <stdexcept>
#include <unistd.h>
#include <assert.h>
#include <pthread.h>
#include <pEp/keymanagement.h>
#include <pEp/message_api.h>
#include <pEp/sync_api.h>
#include <pEp/Adapter.hh>

#include "throw_pEp_exception.hh"
#include "jniutils.hh"

namespace pEp {
    using namespace pEp::JNIAdapter;
    using namespace utility;

    bool first = true;

    JavaVM *jvm= nullptr;

    std::mutex mutex_obj;

    jfieldID field_value = nullptr;
    jmethodID messageConstructorMethodID = nullptr;
    jmethodID messageToSendMethodID = nullptr;
    jmethodID notifyHandShakeMethodID = nullptr;
    jmethodID needsFastPollMethodID = nullptr;
    jmethodID method_values = nullptr;

    jobject obj = nullptr;

    jclass messageClass = nullptr;
    jclass identityClass = nullptr;;
    jclass signalClass = nullptr;
    jclass engineClass = nullptr;

    class JNISync {
    public:
        JNIEnv * env()
        {
            JNIEnv *thread_env = nullptr;
            int status = jvm->GetEnv((void**)&thread_env, JNI_VERSION_1_6);
            if (status < 0) {
#ifdef ANDROID
                status = jvm->AttachCurrentThread(&thread_env, nullptr);
#else
                status = jvm->AttachCurrentThread((void **) &thread_env, nullptr);
#endif
            }
            assert(status >= 0);
            return thread_env;
        }

        void onSyncStartup()
        {
            env();
        }

        void onSyncShutdown()
        {
            jvm->DetachCurrentThread();
        }
    } o;

    void jni_init() {
        JNIEnv *_env = o.env();

        messageClass = reinterpret_cast<jclass>(
                _env->NewGlobalRef(findClass(_env, "foundation/pEp/jniadapter/Message")));
        identityClass = reinterpret_cast<jclass>(
            _env->NewGlobalRef(findClass(_env, "foundation/pEp/jniadapter/_Identity")));
        signalClass = reinterpret_cast<jclass>(
                _env->NewGlobalRef(findClass(_env, "foundation/pEp/jniadapter/SyncHandshakeSignal")));
        engineClass = reinterpret_cast<jclass>(_env->NewGlobalRef(findClass(_env, "foundation/pEp/jniadapter/Engine")));

        messageConstructorMethodID = _env->GetMethodID(messageClass, "<init>", "(J)V");
        messageToSendMethodID = _env->GetMethodID(
            engineClass,
            "messageToSendCallFromC",
            "(Lfoundation/pEp/jniadapter/Message;)I");
        needsFastPollMethodID = _env->GetMethodID(
            engineClass,
            "needsFastPollCallFromC",
            "(Z)I");
        notifyHandShakeMethodID = _env->GetMethodID(
            engineClass,
            "notifyHandshakeCallFromC",
            "(Lfoundation/pEp/jniadapter/_Identity;Lfoundation/pEp/jniadapter/_Identity;Lfoundation/pEp/jniadapter/SyncHandshakeSignal;)I");

        method_values = o.env()->GetStaticMethodID(signalClass, "values",
                    "()[Lfoundation/pEp/jniadapter/SyncHandshakeSignal;");
        field_value = o.env()->GetFieldID(signalClass, "value", "I");
    }

    PEP_STATUS messageToSend(message *msg)
    {
        std::lock_guard<std::mutex> l(mutex_obj);

        debug_log << "\n############### messageToSend() called\n";
        jobject msg_ = nullptr;

        assert(messageClass && messageConstructorMethodID && obj && messageToSendMethodID);

        msg_ = o.env()->NewObject(messageClass, messageConstructorMethodID, (jlong) msg);

        PEP_STATUS status = (PEP_STATUS) o.env()->CallIntMethod(obj, messageToSendMethodID, msg_);
        if (o.env()->ExceptionCheck()) {
            o.env()->ExceptionDescribe();
            status = PEP_UNKNOWN_ERROR;
            o.env()->ExceptionClear();
        }


        return status;
    }

    PEP_STATUS notifyHandshake(pEp_identity *me, pEp_identity *partner, sync_handshake_signal signal)
    {
        std::lock_guard<std::mutex> l(mutex_obj);

        debug_log << "\n############### notifyHandshake() called\n";
        jobject me_ = nullptr;
        jobject partner_ = nullptr;

        me_ = from_identity(o.env(), me, identityClass);
        partner_ = from_identity(o.env(), partner, identityClass);

        jobject signal_ = nullptr;
        {
            assert(signalClass);
            assert(method_values);
            assert(field_value);

            jobjectArray values = (jobjectArray) o.env()->CallStaticObjectMethod(signalClass,
                    method_values);
            if (o.env()->ExceptionCheck()) {
                o.env()->ExceptionClear();
                return PEP_UNKNOWN_ERROR;
            }

            jsize values_size = o.env()->GetArrayLength(values);
            for (jsize i = 0; i < values_size; i++) {
                jobject element = o.env()->GetObjectArrayElement(values, i);
                assert(element);
                jint value = o.env()->GetIntField(element, field_value);
                if (value == (jint) signal) {
                    signal_ = element;
                    break;
                }
                o.env() -> DeleteLocalRef(element);
            }
        }

        assert(obj && notifyHandShakeMethodID);

        PEP_STATUS status = (PEP_STATUS) o.env()->CallIntMethod(obj, notifyHandShakeMethodID, me_, partner_, signal_);
        if (o.env()->ExceptionCheck()) {
            o.env()->ExceptionClear();
            return PEP_UNKNOWN_ERROR;
        }

        return status;
    }
}

extern "C" {
    using namespace pEp;

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_init(
            JNIEnv *env,
            jobject me
        )
    {
        if (first) {
            first = false;
            env->GetJavaVM(&jvm);
            jni_init();
            obj = env->NewGlobalRef(me);
            Adapter::_messageToSend = messageToSend;
        }
        Adapter::session();
    }

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_release(
            JNIEnv *env,
            jobject me
        )
    {
        Adapter::session(pEp::Adapter::release);
    }

    JNIEXPORT jstring JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_getVersion(JNIEnv *env, jobject)
    {
        return env->NewStringUTF(::get_engine_version());
    }

    JNIEXPORT jstring JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_getProtocolVersion(JNIEnv *env, jobject)
    {
        return env->NewStringUTF(::get_protocol_version());
    }

    int examine_identity(pEp_identity *ident, void *arg)
    {
        locked_queue< pEp_identity * > *queue = (locked_queue< pEp_identity * > *) arg;
        queue->push_back(identity_dup(ident));
        return 0;
    }

    pEp_identity *retrieve_next_identity(void *arg)
    {
        locked_queue< pEp_identity * > *queue = (locked_queue< pEp_identity * > *) arg;

        while (!queue->size())
            usleep(100000);

        pEp_identity *ident = queue->front();
        queue->pop_front();
        return ident;
    }

    static void *keyserver_thread_routine(void *arg)
    {
        PEP_STATUS status = do_keymanagement(retrieve_next_identity, arg);
        locked_queue< pEp_identity * > *queue = (locked_queue< pEp_identity * > *) arg;

        while (queue->size()) {
            pEp_identity *ident = queue->front();
            queue->pop_front();
            free_identity(ident);
        }

        delete queue;
        return (void *) status;
    }

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_startKeyserverLookup(
            JNIEnv *env,
            jobject obj
        )
    {
        pthread_t *thread = nullptr;
        locked_queue< pEp_identity * > *queue = nullptr;

        jfieldID thread_handle;
        jfieldID queue_handle;

        try {
            thread_handle = getFieldID(env, "foundation/pEp/jniadapter/Engine", "keyserverThread", "J");
            queue_handle = getFieldID(env, "foundation/pEp/jniadapter/Engine", "keyserverQueue", "J");
        }
        catch (std::exception& ex) {
            assert(0);
            return;
        }

        thread = (pthread_t *) env->GetLongField(obj, thread_handle);
        if (thread)
            return;

        thread = (pthread_t *) calloc(1, sizeof(pthread_t));
        assert(thread);
        env->SetLongField(obj, thread_handle, (jlong) thread);

        queue = new locked_queue< pEp_identity * >();
        env->SetLongField(obj, queue_handle, (jlong) queue);

        register_examine_function(Adapter::session(), examine_identity, (void *) queue);

        pthread_create(thread, nullptr, keyserver_thread_routine, (void *) queue);
    }

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_stopKeyserverLookup(
            JNIEnv *env,
            jobject obj
        )
    {
        pthread_t *thread = nullptr;
        locked_queue< pEp_identity * > *queue = nullptr;

        jfieldID thread_handle;
        jfieldID queue_handle;

        try {
            thread_handle = getFieldID(env, "foundation/pEp/jniadapter/Engine", "keyserverThread", "J");
            queue_handle = getFieldID(env, "foundation/pEp/jniadapter/Engine", "keyserverQueue", "J");
        }
        catch (std::exception& ex) {
            assert(0);
            return;
        }

        thread = (pthread_t *) env->GetLongField(obj, thread_handle);
        if (!thread)
            return;

        queue = (locked_queue< pEp_identity * > *) env->GetLongField(obj, queue_handle);

        env->SetLongField(obj, queue_handle, (jlong) 0);
        env->SetLongField(obj, thread_handle, (jlong) 0);

        register_examine_function(Adapter::session(), nullptr, nullptr);

        queue->push_front(nullptr);
        pthread_join(*thread, nullptr);
        free(thread);
    }

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_startSync(
            JNIEnv *env,
            jobject obj
        )
    {
        debug_log << "######## starting sync\n";
        try {
            Adapter::startup<JNISync>(messageToSend, notifyHandshake, &o, &JNISync::onSyncStartup, &JNISync::onSyncShutdown);
        }
        catch (RuntimeError& ex) {
            throw_pEp_Exception(env, ex.status);
            return;
        }
    }

    JNIEXPORT void JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_stopSync(
            JNIEnv *env,
            jobject obj
        )
    {
        Adapter::shutdown();
    }

    JNIEXPORT jboolean JNICALL Java_foundation_pEp_jniadapter_AbstractEngine_isSyncRunning
        (JNIEnv *, jobject)
    {
        return (jboolean) Adapter::is_sync_running();
    }

} // extern "C"