hive-system.events.system — io.github.hive-agi/hive-system 0.2.7

Event-driven system operations.

Registers event handlers for shell execution, tool checking, and process lifecycle. Each handler returns a Result in the effects map, which the journal interceptor persists.

Init: (init!) ;; default — no journal (init! {:journal-fn record!}) ;; with IJournal callback

Dispatch: (dispatch [:sys/exec "ls -la"]) (dispatch [:sys/exec ["rg" "pattern" "src/"]]) (dispatch [:sys/exec-ok "make test"]) (dispatch [:sys/which "rg"]) (dispatch [:sys/require-tool :ripgrep]) (dispatch [:sys/require-tools [:ripgrep :fd :jq]])

All handlers return {:result (ok ...) or (err ...)} in effects. The timing interceptor adds :_duration-ms. The journal interceptor persists to IJournal if configured.

dispatch-result clj

(dispatch-result event)

Dispatch synchronously and extract the :result from effects. Returns the Result (ok/err) directly.

init! clj

(init!)

(init! {:keys [journal-fn db]})

Initialize the event-driven system layer.

Opts: :journal-fn — (fn [op-map]) callback for IJournal recording. op-map: {:op-type :input :output :duration-ms :success?} :db — initial app-db atom (default: fresh atom)

shutdown! clj

(shutdown!)

Stop the event processing loop and reset state.