Feature: Datomic Client

client-test.clj

@@ -0,0 +1,62 @@
+(ns client-test
+  (:require [datomic.client.api :as d]))
+
+(System/setProperty
+  "java.home" 
+  (System/getenv "GRAALVM_HOME"))
+
+(def client
+  (d/client
+   {:server-type :peer-server
+    :endpoint "localhost:8080"
+    :secret "bar"
+    :access-key "foo"
+    :validate-hostnames false}))
+
+(def conn 
+  (d/connect client {:db-name "yellowdig"}))
+
+(def db 
+  (d/db conn))
+
+
+(println "- transact \n")
+(let [data [{:db/id "temp-foo" :test/name :foo}]
+      tx-res (d/transact conn {:tx-data data})]
+  (println (:tempids tx-res))
+  (d/pull
+    (:db-after tx-res)
+    {:eid (get (:tempids tx-res) "temp-foo")
+     :selector '[*]}))
+(println "\n")
+
+(println "- query \n")
+(println
+  (ffirst
+    (d/q
+      '[:find (pull ?e [:user/username :user/firstname]) 
+        :where [?e :user/username "bingo"]]
+      db)))
+(println "\n")
+
+
+(println "- tx-range \n")
+(println
+  (doseq [tx
+          (d/tx-range
+            conn
+            {:limit 10
+             :start nil
+             :end nil})]
+    (println (:id tx))))
+(println "\n")
+
+(println "- index range \n")
+(println 
+  (take 10
+        (d/index-range
+          (d/db conn)
+          {:attrid :network/name})))
+(println "\n")
+
+

deps.edn

@@ -21,7 +21,8 @@
         seancorfield/next.jdbc {:mvn/version "1.0.424"}
         org.postgresql/postgresql {:mvn/version "42.2.12"}
         org.hsqldb/hsqldb {:mvn/version "2.4.0"}
-        datascript {:mvn/version "0.18.11"}}
+        datascript {:mvn/version "0.18.11"}
+        com.datomic/client-pro {:mvn/version "0.9.57"}}
  :aliases {:main
            {:main-opts ["-m" "babashka.main"]}
            :profile

feature-datomic-client/babashka/impl/datomic_client.clj

@@ -0,0 +1,37 @@
+(ns babashka.impl.datomic-client
+  (:require [datomic.client.api :as d]
+            ;; these libs and others are dynamically 
+            ;; required by the client, depending on use
+            [datomic.client.api.sync]
+            [datomic.client.impl.pro]))
+
+(def client-vars
+  '#{administer-system
+     as-of
+     client
+     connect
+     create-database
+     datoms
+     db
+     db-stats
+     delete-database
+     history
+     index-pull
+     index-range
+     list-databases
+     pull
+     q
+     qseq
+     since
+     sync
+     transact
+     tx-range
+     with
+     with-db})
+
+(def client-namespace
+  (->> client-vars
+       (map (fn [v] [v (var-get (ns-resolve 'datomic.client.api v))]))
+       (into {})))
+
+

project.clj

@@ -8,7 +8,8 @@
   :license {:name "Eclipse Public License 1.0"
             :url "http://opensource.org/licenses/eclipse-1.0.php"}
   :source-paths ["src" "sci/src" "babashka.curl/src" "babashka.pods/src"
-                 "babashka.nrepl/src"]
+                 "babashka.nrepl/src"
+                 "feature-datomic-client"]
   ;; for debugging Reflector.java code:
   ;; :java-source-paths ["sci/reflector/src-java"]
   :java-source-paths ["src-java"]
@@ -21,7 +22,8 @@
                  [cheshire "5.10.0"]
                  [fipp "0.6.22"]
                  [nrepl/bencode "1.1.0"]
-                 [borkdude/sci.impl.reflector "0.0.1-java11"]]
+                 [borkdude/sci.impl.reflector "0.0.1-java11"]
+                 [com.datomic/client-pro "0.9.57"]]
   :profiles {:feature/xml  {:source-paths ["feature-xml"]
                             :dependencies [[org.clojure/data.xml "0.2.0-alpha6"]]}
              :feature/yaml {:source-paths ["feature-yaml"]

resources-config.json

@@ -0,0 +1,10 @@
+{
+  "resources": [
+    {
+      "pattern": ".*\\.pem$"
+    },
+    {
+      "pattern": ".*\\.json$"
+    }
+  ]
+}

script/compile

@@ -47,6 +47,7 @@ args=( "-jar" "$BABASHKA_JAR"
        "--initialize-at-build-time"
        "-H:Log=registerResource:"
        "-H:EnableURLProtocols=http,https"
+       "-H:ResourceConfigurationFiles=resources-config.json"
        "--enable-all-security-services"
        "-H:+JNI"
        "--verbose"
@@ -82,6 +83,7 @@ then
     export BABAHSKA_FEATURE_TRANSIT=false
     export BABASHKA_FEATURE_JAVA_TIME=false
     export BABASHKA_FEATURE_JAVA_NIO=false
+    export BABASHKA_FEATURE_DATOMIC_CLIENT=false
 fi
 
 "$GRAALVM_HOME/bin/native-image" "${args[@]}"

src/babashka/impl/classes.clj

@@ -140,6 +140,17 @@
           ;; java.net.URL, see below
           java.net.URLEncoder
           java.net.URLDecoder
+          ;;
+          java.nio.HeapByteBuffer
+          ~(symbol "[Ljava.nio.HeapByteBuffer;")
+          org.msgpack.template.builder.TemplateBuilderChain
+          org.msgpack.template.builder.FieldEntry
+          org.msgpack.template.builder.JavassistTemplateBuilder
+          org.msgpack.template.ListTemplate
+          org.msgpack.template.SetTemplate
+          org.msgpack.template.CollectionTemplate
+          org.msgpack.template.MapTemplate
+          ;;
           ~@(when features/java-nio?
               '[java.nio.file.OpenOption
                 java.nio.file.CopyOption

src/babashka/impl/features.clj

@@ -15,3 +15,4 @@
 (def postgresql? (= "true" (System/getenv "BABASHKA_FEATURE_POSTGRESQL")))
 (def hsqldb? (= "true" (System/getenv "BABASHKA_FEATURE_HSQLDB")))
 (def datascript? (= "true" (System/getenv "BABASHKA_FEATURE_DATASCRIPT")))
+(def datomic-client? (= "true" (System/getenv "BABASHKA_FEATURE_DATOMIC_CLIENT")))

src/babashka/main.clj

@@ -54,6 +54,7 @@
     (def pipe-signal-received? (constantly false))
     (def handle-sigint! (constantly nil))))
 
+
 (when features/xml?
   (require '[babashka.impl.xml]))
 
@@ -76,6 +77,12 @@
 (when features/datascript?
   (require '[babashka.impl.datascript]))
 
+(when features/datomic-client?
+  (require '[babashka.impl.datomic-client])
+  (System/setProperty 
+    "java.library.path"
+    (str (System/getenv "GRAALVM_HOME") "/lib")))
+
 (sci/alter-var-root sci/in (constantly *in*))
 (sci/alter-var-root sci/out (constantly *out*))
 (sci/alter-var-root sci/err (constantly *err*))
@@ -334,7 +341,8 @@ If neither -e, -f, or --socket-repl are specified, then the first argument that
     features/jdbc?       (assoc 'jdbc 'next.jdbc)
     features/core-async? (assoc 'async 'clojure.core.async)
     features/csv?        (assoc 'csv 'clojure.data.csv)
-    features/transit?    (assoc 'transit 'cognitect.transit)))
+    features/transit?    (assoc 'transit 'cognitect.transit)
+    features/datomic-client? (assoc 'datomic-client 'datomic.client.api)))
 
 (def cp-state (atom nil))
 
@@ -378,7 +386,8 @@ If neither -e, -f, or --socket-repl are specified, then the first argument that
                                 'clojure.core.async.impl.protocols @(resolve 'babashka.impl.async/async-protocols-namespace))
     features/csv?  (assoc 'clojure.data.csv @(resolve 'babashka.impl.csv/csv-namespace))
     features/transit? (assoc 'cognitect.transit @(resolve 'babashka.impl.transit/transit-namespace))
-    features/datascript? (assoc 'datascript.core @(resolve 'babashka.impl.datascript/datascript-namespace))))
+    features/datascript? (assoc 'datascript.core @(resolve 'babashka.impl.datascript/datascript-namespace))
+    features/datomic-client? (assoc 'datomic.client.api @(resolve 'babashka.impl.datomic-client/client-namespace))))
 
 (def bindings
   {'java.lang.System/exit exit ;; override exit, so we have more control