output.cljs

(ns re-conf.resources.output
  (:require
   [cljs.core.match :refer-macros  [match]]
   [re-conf.resources.log :refer (info debug error)]
   [cljs.core.async :as async :refer [<! go]]))

(defn summary
  "Print result"
  ([c]
   (summary c "Pipeline ok"))
  ([c m]
   (go
     (let [r (<! c)]
       (match r
         {:error e} (error {:e e :m m} ::summary-fail)
         {:ok o} (info m ::summary-ok)
         :else (error r ::summary-error))
       (assoc r :context m)))))