Rename op to load-ns
This commit is contained in:
parent
5b875ba457
commit
0142f418c2
4 changed files with 10 additions and 10 deletions
|
|
@ -241,8 +241,8 @@
|
||||||
(callback {:name name-sym :vars vars :done prom})))]
|
(callback {:name name-sym :vars vars :done prom})))]
|
||||||
(swap! callbacks assoc id callback)
|
(swap! callbacks assoc id callback)
|
||||||
(write (:stdin pod)
|
(write (:stdin pod)
|
||||||
{"op" "load"
|
{"op" "load-ns"
|
||||||
"path" (str namespace)
|
"ns" (str namespace)
|
||||||
"id" id})
|
"id" id})
|
||||||
@prom))
|
@prom))
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -45,7 +45,7 @@
|
||||||
(create-ns (symbol (namespace sym)))
|
(create-ns (symbol (namespace sym)))
|
||||||
(symbol (name sym)))))})
|
(symbol (name sym)))))})
|
||||||
namespaces (:namespaces pod)
|
namespaces (:namespaces pod)
|
||||||
load? (contains? (:ops pod) :load)]
|
load? (contains? (:ops pod) :load-ns)]
|
||||||
(when load?
|
(when load?
|
||||||
(swap! namespaces-to-load
|
(swap! namespaces-to-load
|
||||||
merge
|
merge
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,7 @@
|
||||||
(:require [babashka.pods.impl :as impl]
|
(:require [babashka.pods.impl :as impl]
|
||||||
[sci.core :as sci]))
|
[sci.core :as sci]))
|
||||||
|
|
||||||
(defn process-namespace [ctx {:keys [:name :vars :done]}]
|
(defn- process-namespace [ctx {:keys [:name :vars :done]}]
|
||||||
(let [env (:env ctx)
|
(let [env (:env ctx)
|
||||||
ns-name name
|
ns-name name
|
||||||
sci-ns (sci/create-ns ns-name)]
|
sci-ns (sci/create-ns ns-name)]
|
||||||
|
|
@ -44,7 +44,7 @@
|
||||||
v)
|
v)
|
||||||
v))))}))
|
v))))}))
|
||||||
namespaces (:namespaces pod)
|
namespaces (:namespaces pod)
|
||||||
load? (contains? (:ops pod) :load)
|
load? (contains? (:ops pod) :load-ns)
|
||||||
namespaces-to-load (when load?
|
namespaces-to-load (when load?
|
||||||
(set (keep (fn [[ns-name vars]]
|
(set (keep (fn [[ns-name vars]]
|
||||||
(when (empty? vars)
|
(when (empty? vars)
|
||||||
|
|
|
||||||
|
|
@ -83,7 +83,7 @@
|
||||||
dependents)}
|
dependents)}
|
||||||
{"name" "pod.test-pod.loaded"}]
|
{"name" "pod.test-pod.loaded"}]
|
||||||
"ops" {"shutdown" {}
|
"ops" {"shutdown" {}
|
||||||
"load" {}}})
|
"load-ns" {}}})
|
||||||
(recur))
|
(recur))
|
||||||
:invoke (let [var (-> (get message "var")
|
:invoke (let [var (-> (get message "var")
|
||||||
read-string
|
read-string
|
||||||
|
|
@ -159,12 +159,12 @@
|
||||||
"value" "#my/other-tag[1]"}))
|
"value" "#my/other-tag[1]"}))
|
||||||
(recur))
|
(recur))
|
||||||
:shutdown (System/exit 0)
|
:shutdown (System/exit 0)
|
||||||
:load (let [path (-> (get message "path")
|
:load-ns (let [ns (-> (get message "ns")
|
||||||
read-string
|
read-string
|
||||||
symbol)
|
symbol)
|
||||||
id (-> (get message "id")
|
id (-> (get message "id")
|
||||||
read-string)]
|
read-string)]
|
||||||
(case path
|
(case ns
|
||||||
pod.test-pod.loaded
|
pod.test-pod.loaded
|
||||||
(write
|
(write
|
||||||
{"status" ["done"]
|
{"status" ["done"]
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue