little thing.clj

(s/def ::edge-fn fn?)
(s/def ::input (s/coll-of keyword?))
(s/def ::output (s/coll-of keyword?))
(s/def ::edge (s/keys :req [::edge-fn ::input ::output]))
(s/def ::dynamic-edge-fn (s/fn :ret ::edge))
(s/def ::dynamic-edge (s/keys :req [::dynamic-edge-fn ::input]))
(s/def ::graph (s/coll-of (s/or ::edge ::dynamic-edge)))

(s/def ::state
  (s/and
   (s/map-of keyword? any?)
   #(s/valid? (eval `(s/keys :req [~@(keys %)]))
              %)))

(s/def ::outputs (s/coll-of keyword?))

(s/fdef run
  :args (s/cat :graph ::graph
               :state ::state
               :outputs ::outputs)
  :ret ::state
  :fn (every? (partial contains? (:ret %)) (-> % :args :outputs)))