luciano/pods
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

tidied up naming

Browse source
This commit is contained in:
Jude Payne 2023-05-04 13:41:01 +01:00
parent d76f26f5f1
commit 8fc86b15a0
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/babashka/pods/impl.clj
View file

@ -90,14 +90,14 @@
(let [wh (transit/write-handler tag-fn val-fn)] (let [wh (transit/write-handler tag-fn val-fn)]
(swap! transit-default-write-handlers assoc *pod-id* wh))) (swap! transit-default-write-handlers assoc *pod-id* wh)))
(defonce vars-with-metadata-on-args (atom {})) (defonce vars-with-metadata (atom {}))
(defn transit-json-write (defn transit-json-write
([pod-id ^String s metadata-on-args?] ([pod-id ^String s metadata?]
(with-open [baos (java.io.ByteArrayOutputStream. 4096)] (with-open [baos (java.io.ByteArrayOutputStream. 4096)]
(let [w (transit/writer baos :json (merge {:handlers (get @transit-write-handler-maps pod-id) (let [w (transit/writer baos :json (merge {:handlers (get @transit-write-handler-maps pod-id)
:default-handler (get @transit-default-write-handlers pod-id)} :default-handler (get @transit-default-write-handlers pod-id)}
(when metadata-on-args? {:transform transit/write-meta})))] (when metadata? {:transform transit/write-meta})))]
(transit/write w s) (transit/write w s)
(str baos))))) (str baos)))))
@ -111,7 +111,7 @@
:json cheshire/generate-string :json cheshire/generate-string
:transit+json #(transit-json-write :transit+json #(transit-json-write
(:pod-id pod) % (:pod-id pod) %
(some #{pod-var} (get @vars-with-metadata-on-args (:pod-id pod))))) (some #{pod-var} (get @vars-with-metadata (:pod-id pod)))))
id (next-id) id (next-id)
chan (if handlers handlers chan (if handlers handlers
(promise)) (promise))
@ -142,9 +142,9 @@
name-sym (if vmeta name-sym (if vmeta
(with-meta name-sym vmeta) (with-meta name-sym vmeta)
name-sym) name-sym)
meta-args? (get-maybe-boolean var "read-metadata?")] metadata? (get-maybe-boolean var "read-metadata?")]
(when meta-args? (when metadata?
(swap! vars-with-metadata-on-args update (:pod-id pod) conj sym)) (swap! vars-with-metadata update (:pod-id pod) conj sym))
[name-sym [name-sym
(or code (or code
(fn [& args] (fn [& args]