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

mount-state marker vs. session-id ts

Browse source
This commit is contained in:
anatoly 2015-10-27 22:02:34 -04:00
parent 880f23d431
commit c8b128e33c
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/mount/mount.clj
View file

@ -5,7 +5,8 @@
(disable-reload!) (disable-reload!)
(defonce ^:private session-id (System/currentTimeMillis)) ;; (defonce ^:private session-id (System/currentTimeMillis))
(defonce ^:private mount-state 42)
(defonce ^:private state-seq (atom 0)) (defonce ^:private state-seq (atom 0))
(defonce ^:private state-order (atom {})) (defonce ^:private state-order (atom {}))
@ -29,7 +30,7 @@
(defmacro defstate [state & body] (defmacro defstate [state & body]
(let [[state [c cf d df]] (macro/name-with-attributes state body) (let [[state [c cf d df]] (macro/name-with-attributes state body)
{:keys [start stop]} (validate {c cf d df})] {:keys [start stop]} (validate {c cf d df})]
(let [s-meta (-> {:session-id session-id (let [s-meta (-> {:mount-state mount-state
:order (make-state-seq state) :order (make-state-seq state)
:start `(fn [] (~@start)) :start `(fn [] (~@start))
:started? false} :started? false}
@ -56,11 +57,15 @@
(throw (RuntimeException. (str "could not stop [" name "] due to") t))))) (throw (RuntimeException. (str "could not stop [" name "] due to") t)))))
(alter-meta! var assoc :started? false))) (alter-meta! var assoc :started? false)))
(defn mount-state? [var]
(= (-> var meta :mount-state)
mount-state))
(defn find-all-states [] (defn find-all-states []
(->> (all-ns) (->> (all-ns)
(mapcat ns-interns) (mapcat ns-interns)
(map second) (map second)
(filter #(= (:session-id (meta %)) session-id)))) (filter mount-state?)))
;; TODO: narrow down by {:mount {:include-ns ;; TODO: narrow down by {:mount {:include-ns
;; {:starts-with ["app.foo" "bar.baz"] ;; {:starts-with ["app.foo" "bar.baz"]