diff --git a/frontend/packages/swarm-ui/src/pages/agents/AgentTermPreview.tsx b/frontend/packages/swarm-ui/src/pages/agents/AgentTermPreview.tsx index 1275a9fd..2624bf06 100644 --- a/frontend/packages/swarm-ui/src/pages/agents/AgentTermPreview.tsx +++ b/frontend/packages/swarm-ui/src/pages/agents/AgentTermPreview.tsx @@ -9,7 +9,10 @@ import { useLayoutEffect, useRef, useState } from "preact/hooks"; import { Badge, type BadgeTone } from "@hive/shared/badge.js"; import { Row } from "@hive/shared/term-row.js"; -import { useSwarmTermStream, type ConnectionState } from "./useSwarmTermStream.js"; +import { + useSwarmTermStream, + type ConnectionState, +} from "./useSwarmTermStream.js"; import "./AgentTermPreview.css"; const NEAR_BOTTOM_PX = 48; diff --git a/frontend/packages/swarm-ui/src/pages/agents/useSwarmTermStream.ts b/frontend/packages/swarm-ui/src/pages/agents/useSwarmTermStream.ts index 3af22ad7..e5a56d7f 100644 --- a/frontend/packages/swarm-ui/src/pages/agents/useSwarmTermStream.ts +++ b/frontend/packages/swarm-ui/src/pages/agents/useSwarmTermStream.ts @@ -11,11 +11,7 @@ import { useEffect, useRef, useState } from "preact/hooks"; import type { TermMsg, TermRow } from "@hive/shared/term-msg.js"; -export type ConnectionState = - | "connecting" - | "open" - | "reconnecting" - | "closed"; +export type ConnectionState = "connecting" | "open" | "reconnecting" | "closed"; function appendRow(rows: TermRow[], row: TermRow): TermRow[] { const last = rows[rows.length - 1]; @@ -30,7 +26,9 @@ export interface UseSwarmTermStreamResult { connection: ConnectionState; } -export function useSwarmTermStream(streamUrl: string): UseSwarmTermStreamResult { +export function useSwarmTermStream( + streamUrl: string, +): UseSwarmTermStreamResult { const [rows, setRows] = useState([]); const [connection, setConnection] = useState("connecting"); const keySeqRef = useRef(0); @@ -61,7 +59,9 @@ export function useSwarmTermStream(streamUrl: string): UseSwarmTermStreamResult setRows((prev) => appendRow(prev, { ...msg, key, fromHistory: false })); }; es.onerror = () => { - setConnection(es.readyState === 0 /* CONNECTING */ ? "reconnecting" : "closed"); + setConnection( + es.readyState === 0 /* CONNECTING */ ? "reconnecting" : "closed", + ); }; return () => es.close(); }, [streamUrl]);