hive-vscode.bridge — io.github.hive-agi/hive-vscode 0.1.1

Loopback :json vessel bridge: hive pushes native payloads to every connected VS Code window as Server-Sent Events; windows acknowledge with POST. Wire-compatible copy of hive-deepseek.bridge (hive-81), pending its extraction into hive-vessel.

Routes (every request carries ?token=): GET /vessel/events SSE stream (event: vessel); replays retained panels POST /vessel/reply one JSON reply GET /vessel/health JSON status Requests carrying an Origin header are refused: the client is an extension host, never a web page.

broadcast! clj

(broadcast! {:keys [state]} message)

Send MESSAGE (JSON-able data) to every connected window and update retention. Returns {:delivered n :seq s}.

clients clj

(clients {:keys [state]})

inbox clj

(inbox {:keys [state]})

new-token clj

(new-token)

32 hex chars from a SecureRandom.

query-params clj

(query-params query)

retain clj

(retain retained message)

RETAINED (panel id -> message) after MESSAGE passes.

retained-panels clj

(retained-panels {:keys [state]})

sse-frame clj

(sse-frame seq message)

One SSE event carrying MESSAGE under sequence number SEQ.

start! clj

(start! {:keys [token port on-reply on-connect heartbeat-ms]
         :or {port 0 heartbeat-ms 15000}})

Start a bridge on loopback. opts: :token (required), :port (default 0), :on-reply (fn [reply-map]), :on-connect (fn [info]), :heartbeat-ms (default 15000).

stop! clj

(stop! {:keys [server state pool ticker]})

token-ok? clj

(token-ok? expected presented)

Constant-time comparison of the presented token.