Update process
This commit is contained in:
parent
d681f9bc7f
commit
a92ebfe68a
4 changed files with 16 additions and 33 deletions
|
|
@ -5,4 +5,5 @@
|
||||||
babashka.impl.File/gen-wrapper-fn-2 clojure.core/def
|
babashka.impl.File/gen-wrapper-fn-2 clojure.core/def
|
||||||
babashka.impl.Pattern/gen-wrapper-fn-2 clojure.core/def
|
babashka.impl.Pattern/gen-wrapper-fn-2 clojure.core/def
|
||||||
babashka.impl.Pattern/gen-constants clojure.core/declare}
|
babashka.impl.Pattern/gen-constants clojure.core/declare}
|
||||||
:linters {:unsorted-required-namespaces {:level :warning}}}
|
:linters {:unsorted-required-namespaces {:level :warning}}
|
||||||
|
:hooks {:analyze-call {clojure.core/requiring-resolve hooks.mine/req-resolve}}}
|
||||||
|
|
|
||||||
2
process
2
process
|
|
@ -1 +1 @@
|
||||||
Subproject commit be047624edac65c3c648adace291bba38cd1a933
|
Subproject commit 36b2295bc5cdf10e7f2a09c53916c22b91fc8521
|
||||||
|
|
@ -8,6 +8,10 @@
|
||||||
|
|
||||||
(def defaults (sci/copy-var process/*defaults* tns))
|
(def defaults (sci/copy-var process/*defaults* tns))
|
||||||
|
|
||||||
|
(defn process* [& args]
|
||||||
|
(binding [process/*defaults* @defaults]
|
||||||
|
(apply process/process* args)))
|
||||||
|
|
||||||
(defn process [& args]
|
(defn process [& args]
|
||||||
(binding [process/*defaults* @defaults]
|
(binding [process/*defaults* @defaults]
|
||||||
(apply process/process args)))
|
(apply process/process args)))
|
||||||
|
|
@ -17,7 +21,9 @@
|
||||||
(apply process/pb args)))
|
(apply process/pb args)))
|
||||||
|
|
||||||
(def process-namespace
|
(def process-namespace
|
||||||
{'process (copy-var process tns)
|
{'parse-args (copy-var process/parse-args tns)
|
||||||
|
'process* (copy-var process/process* tns)
|
||||||
|
'process (copy-var process tns)
|
||||||
'check (copy-var process/check tns)
|
'check (copy-var process/check tns)
|
||||||
'pb (copy-var pb tns)
|
'pb (copy-var pb tns)
|
||||||
'start (copy-var process/start tns)
|
'start (copy-var process/start tns)
|
||||||
|
|
|
||||||
|
|
@ -59,37 +59,13 @@
|
||||||
:err :inherit
|
:err :inherit
|
||||||
:shutdown p/destroy-tree})
|
:shutdown p/destroy-tree})
|
||||||
|
|
||||||
(defn shell [cmd & args]
|
(defn shell [& args]
|
||||||
(let [[prev cmd args]
|
(let [{:keys [prev cmd opts]} (p/parse-args args)
|
||||||
(if (and (map? cmd)
|
local-log-level (:log-level opts)
|
||||||
(:proc cmd))
|
opts (merge default-opts opts)]
|
||||||
[cmd (first args) (rest args)]
|
|
||||||
[nil cmd args])
|
|
||||||
[opts cmd args]
|
|
||||||
(if (map? cmd)
|
|
||||||
[cmd (first args) (rest args)]
|
|
||||||
[nil cmd args])
|
|
||||||
opts (if-let [o (:out opts)]
|
|
||||||
(if (string? o)
|
|
||||||
(update opts :out io/file)
|
|
||||||
opts)
|
|
||||||
opts)
|
|
||||||
opts (if-let [o (:err opts)]
|
|
||||||
(if (string? o)
|
|
||||||
(update opts :err io/file)
|
|
||||||
opts)
|
|
||||||
opts)
|
|
||||||
opts (if prev
|
|
||||||
(assoc opts :in nil)
|
|
||||||
opts)
|
|
||||||
cmd (if (.exists (io/file cmd))
|
|
||||||
[cmd]
|
|
||||||
(p/tokenize cmd))
|
|
||||||
cmd (into cmd args)
|
|
||||||
local-log-level (:log-level opts)]
|
|
||||||
(sci/binding [log-level (or local-log-level @log-level)]
|
(sci/binding [log-level (or local-log-level @log-level)]
|
||||||
(apply log-info cmd)
|
(apply log-info args)
|
||||||
(handle-non-zero (pp/process prev cmd (merge default-opts opts)) opts))))
|
(handle-non-zero (pp/process* {:opts opts :cmd cmd :prev prev}) opts))))
|
||||||
|
|
||||||
(defn clojure [cmd & args]
|
(defn clojure [cmd & args]
|
||||||
(let [[opts cmd args]
|
(let [[opts cmd args]
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue