Revert unintentional changes

Author: simolus3

core/src/androidMain/kotlin/com/powersync/UpdateHookReceiver.kt

@@ -3,17 +3,20 @@
 #include <string>
 #include <cstring>
 
-extern "C" {
+typedef struct context {
+    JavaVM *javaVM;
+    jobject bindingsObj;
+    jclass bindingsClz;
+} Context;
+Context g_ctx;
 
-typedef struct hooks {
-    JavaVM *jvm;
-    jclass update_hook_receiver_class;
-    jobject update_hook_receiver_instance;
-} Hooks;
+extern "C" {
 
 JNIEXPORT
 jint JNICALL JNI_OnLoad(JavaVM *vm, void *reserved) {
     JNIEnv *env;
+    memset(&g_ctx, 0, sizeof(g_ctx));
+    g_ctx.javaVM = vm;
 
     if (vm->GetEnv((void **) &env, JNI_VERSION_1_6) != JNI_OK) {
         return JNI_ERR;  // JNI version not supported.
@@ -23,42 +26,66 @@ jint JNICALL JNI_OnLoad(JavaVM *vm, void *reserved) {
 }
 
 static void update_hook_callback(void *pData, int opCode, char const *pDbName, char const *pTableName, sqlite3_int64 iRow) {
+    // Get JNIEnv for the current thread
+    JNIEnv *env;
+    JavaVM *javaVM = g_ctx.javaVM;
+    javaVM->GetEnv((void **) &env, JNI_VERSION_1_6);
 
+    if (g_ctx.bindingsClz) {
+        jmethodID updateId = env->GetMethodID(
+                g_ctx.bindingsClz, "onTableUpdate", "(Ljava/lang/String;)V");
+
+        jstring tableString = env->NewStringUTF(std::string(pTableName).c_str());
+        env->CallVoidMethod(g_ctx.bindingsObj, updateId, tableString);
+    }
 }
 
 static int commit_hook(void *pool) {
+    // Get JNIEnv for the current thread
+    JNIEnv *env;
+    JavaVM *javaVM = g_ctx.javaVM;
+    javaVM->GetEnv((void **) &env, JNI_VERSION_1_6);
+
+    if (g_ctx.bindingsClz) {
+        jmethodID methodId = env->GetMethodID(
+                g_ctx.bindingsClz, "onTransactionCommit", "(Z)V");
+
+        env->CallVoidMethod(g_ctx.bindingsObj, methodId, JNI_TRUE);
+    }
+
     return 0;
 }
 
 static void rollback_hook(void *pool) {
+    // Get JNIEnv for the current thread
+    JNIEnv *env;
+    JavaVM *javaVM = g_ctx.javaVM;
+    javaVM->GetEnv((void **) &env, JNI_VERSION_1_6);
+
+    if (g_ctx.bindingsClz) {
+        jmethodID methodId = env->GetMethodID(
+                g_ctx.bindingsClz, "onTransactionCommit", "(Z)V");
 
+        env->CallVoidMethod(g_ctx.bindingsObj, methodId, JNI_FALSE);
+    }
 }
 
 JNIEXPORT
 int powersync_init(sqlite3 *db, char **pzErrMsg, const sqlite3_api_routines *pApi) {
     sqlite3_initialize();
 
-    return SQLITE_OK;
-}
+    sqlite3_update_hook(db, update_hook_callback, NULL);
+    sqlite3_commit_hook(db, commit_hook, NULL);
+    sqlite3_rollback_hook(db, rollback_hook, NULL);
 
-JNIEXPORT
-void JNICALL Java_com_powersync_DatabaseDriverFactory_registerUpdates(JNIEnv *env, jlong dbPtr, jobject receiver) {
-    jclass clz = env->GetObjectClass(receiver);
-
-    sqlite3 *db = (sqlite3*) dbPtr;
-    Hooks *hooks = static_cast<Hooks*>(calloc(1, sizeof(Hooks)));
-    env->GetJavaVM(&hooks->jvm);
-    hooks->update_hook_receiver_class = (jclass) env->NewGlobalRef(clz);
-    hooks->update_hook_receiver_instance = env->NewGlobalRef(receiver);
-
-    sqlite3_update_hook(db, update_hook_callback, hooks);
-    sqlite3_commit_hook(db, commit_hook, hooks);
-    sqlite3_rollback_hook(db, rollback_hook, hooks);
+    return SQLITE_OK;
 }
 
 JNIEXPORT
-void JNICALL Java_com_powersync_DatabaseDriverFactory_unregisterUpdates(JNIEnv *env, jlong dbPtr, jobject receiver) {
-
+void JNICALL Java_com_powersync_DatabaseDriverFactory_setupSqliteBinding(JNIEnv *env, jobject thiz) {
+    jclass clz = env->GetObjectClass(thiz);
+    g_ctx.bindingsClz = (jclass) env->NewGlobalRef(clz);
+    g_ctx.bindingsObj = env->NewGlobalRef(thiz);
 }
 
 }

core/src/jvmNative/cpp/sqlite_bindings.cpp

@@ -4,7 +4,7 @@ import com.powersync.DatabaseDriverFactory
 import java.io.File
 
 actual val factory: DatabaseDriverFactory
-    get() =   DatabaseDriverFactory()
+    get() = DatabaseDriverFactory()
 
 actual fun cleanup(path: String) {
     File(path).delete()

core/src/jvmTest/kotlin/com/powersync/testutils/TestUtils.jvm.kt

@@ -14,7 +14,7 @@ compose.kotlin.native.manageCacheKind=false
 # Development
 development=true
 # Release
-RELEASE_SIGNING_ENABLED=false
+RELEASE_SIGNING_ENABLED=true
 # Library config
 GROUP=com.powersync
 LIBRARY_VERSION=1.0.0-BETA25