several improvements

- fix tests
- make code more consistent
- add owner concept

Author: mping

.gitignore

@@ -13,6 +13,7 @@ pom.xml.asc
 .hg/
 .clj-kondo
 test/*.db
+.lsp/
 
 .cpcache
 .shadow-cljs

DEVELOPMENT.md

@@ -50,3 +50,17 @@ Install earthly: https://earthly.dev
 ```
 earthly -P -i +test
 ```
+
+# Check FDB is working for your architecture
+
+```shell
+
+$ JAVA_OPTS="-DFDB_LIBRARY_PATH_FDB_C=/usr/local/lib/libfdb_c.dylib -DFDB_LIBRARY_PATH_FDB_JAVA=/usr/local/lib/libfdb_java.jnilib" clj -A:fdb:jdbc
+
+(import 'com.apple.foundationdb.JNIUtil)
+(let [method (.getDeclaredMethod com.apple.foundationdb.JNIUtil "loadLibrary" (into-array Class [String]))]
+  (.setAccessible method true)
+  (.invoke method com.apple.foundationdb.JNIUtil (object-array ["fdb_java"]))
+  (.invoke method com.apple.foundationdb.JNIUtil (object-array ["fdb_c"])))
+
+```

Earthfile

@@ -25,6 +25,8 @@ deps:
   CACHE ~/.m2
   RUN clj -Stree
   RUN npm install
+  #RUN wget https://github.com/apple/foundationdb/releases/download/7.3.63/foundationdb-clients_7.3.63-1_aarch64.deb
+  #RUN dpkg -i foundationdb-clients_7.3.63-1_aarch64.deb
   RUN wget https://github.com/apple/foundationdb/releases/download/7.1.31/foundationdb-clients_7.1.31-1_amd64.deb
   RUN dpkg -i foundationdb-clients_7.1.31-1_amd64.deb
   RUN echo "docker:docker@127.0.0.1:4500" > /etc/foundationdb/fdb.cluster

README.md

@@ -56,7 +56,7 @@ Examples:
           (foo pr :X))))
 
 (def mstore (store/make-memstore))
-(def worker (w/start-worker! mstore {`MyActivities (->MyActivitiesImpl)}))
+(def stop-worker (w/start-worker! mstore {`MyActivities (->MyActivitiesImpl)}))
 
 ;; note that in cljs, this returns a promise
 (def res (w/with-env {:store mstore}

bin/kaocha

@@ -2,8 +2,8 @@
 
 [ -d "node_modules/ws" ] || npm install ws
 
-#JAVA_OPTS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:5005 -Dio.netty.tryUnsafe=false"
-JAVA_OPTS="-Dio.netty.tryUnsafe=false"
+JAVA_OPTS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:5005 -Dio.netty.tryUnsafe=false"
+JAVA_OPTS="$JAVA_OPTS -Dio.netty.tryUnsafe=false"
 if [[ "$OSTYPE" == "darwin"* ]]; then
   JAVA_OPTS="-Dio.netty.tryUnsafe=false -DFDB_LIBRARY_PATH_FDB_C=/usr/local/lib/libfdb_c.dylib -DFDB_LIBRARY_PATH_FDB_JAVA=/usr/local/lib/libfdb_java.jnilib"
 fi

bin/run-coverage

@@ -20,4 +20,4 @@ lcov --add-tracefile target/coverage-clj/lcov.info  --add-tracefile target/cover
 genhtml coverage/lcov.merged.info -o coverage
 
 printf "${BLUE}done! opening report${NC}\n"
-xdg-open coverage/index.html || true
+xdg-open coverage/index.html || open coverage/index.html ||  true

dev/intemporal/demo_parallelism.clj

@@ -27,7 +27,7 @@
     @(p/all proms)))
 
 (def mstore (store/make-store))
-(def worker (w/start-worker! mstore {:protocols {`ThreadActivity (->ThreadActivityImpl)}}))
+(def stop-worker (w/start-worker! mstore {:protocols {`ThreadActivity (->ThreadActivityImpl)}}))
 
 ;; note that in cljs, this returns a promise
 (def res (w/with-env {:store mstore}

dev/intemporal/demo_recovery.clj

@@ -21,7 +21,7 @@
 ;; make a backup of the db to allow replay
 (io/copy (io/file "./dev/intemporal/recovery.edn") (io/file "/tmp/intemporal-recovery.edn"))
 (def mstore (store/make-store {:file "/tmp/intemporal-recovery.edn"}))
-(def worker (w/start-worker! mstore))
+(def stop-worker (w/start-worker! mstore))
 
 (defn pprint-table [table]
   (clojure.pprint/print-table table))

dev/intemporal/demo_saga.cljc

@@ -70,7 +70,7 @@
 
 
 (def mstore (s/make-store))
-(def worker (w/start-worker! mstore {:protocols {`TripBookingActivities example-impl}}))
+(def stop-worker (w/start-worker! mstore {:protocols {`TripBookingActivities example-impl}}))
 
 ;; note that in cljs, this returns a promise
 (def res (try

dev/intemporal/demo_vthread_recovery.clj

@@ -30,7 +30,7 @@
 ;; make a backup of the db to allow replay
 (io/copy (io/file "./dev/intemporal/vthread-recovery.edn") (io/file "/tmp/intemporal-vthread-recovery.edn"))
 (def mstore (store/make-store {:file "/tmp/intemporal-vthread-recovery.edn"}))
-(def worker (w/start-worker! mstore {:protocols {`intemporal.demo-vthread-recovery/ThreadActivity (->ThreadActivityImpl)}}))
+(def stop-worker (w/start-worker! mstore {:protocols {`intemporal.demo-vthread-recovery/ThreadActivity (->ThreadActivityImpl)}}))
 
 (defn pprint-table [table]
   (clojure.pprint/print-table table))