sidebar

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51// Register the sidebar synchronously, its commands, and the event
// subscriptions that keep its state current; the initial refresh runs in
// the plugin scope.
import * as Effect from "effect/Effect";
import * as Scope from "effect/Scope";
import * as Stream from "effect/Stream";
import { Commands, Events, Views, runPlugin } from "convergence/effect";
import { Sidebar } from "./controller.ts";
import { renderSidebar } from "./views.ts";

const program = Effect.gen(function* () {
  const sidebar = yield* Sidebar;
  const views = yield* Views;
  // Views register synchronously at the start of the program so reload
  // keeps the view's identity (same slot, same order).
  sidebar.views.push(
    yield* views.slot("left", (ctx) => renderSidebar(ctx, sidebar), {
      on: ["workspaces_changed", "chat_changed", "chat_removed", "agents_changed", "app_state"],
    }),
  );
  const commands = yield* Commands;
  yield* commands.register("sidebar.newChat", sidebar.newChatCommand());
  yield* commands.register("sidebar.toggleChatCompleted", sidebar.toggleCompletedCommand());
  yield* commands.register("sidebar.addWorkspace", sidebar.addWorkspace());
  for (let n = 1; n <= 9; n++) yield* commands.register(`sidebar.openChat${n}`, sidebar.selectListedCommand(n - 1));
  const events = yield* Events;
  // Event followers are fire-and-forget like the original's async handlers:
  // a failed refresh leaves the state for the next event, and the rest of
  // the plugin keeps working.
  const follow = <A, E>(
    stream: Stream.Stream<A, E>,
    handle: (event: A) => Effect.Effect<void, unknown>,
  ): Effect.Effect<void, never, Scope.Scope> =>
    stream.pipe(
      Stream.mapEffect((event) => handle(event).pipe(Effect.ignore), { concurrency: "unbounded" }),
      Stream.runDrain,
      Effect.forkScoped,
    );
  yield* follow(events.stream("workspaces_changed"), () => sidebar.refresh());
  yield* follow(events.stream("agents_changed"), () => sidebar.refresh());
  yield* follow(events.stream("chat_changed"), (event) => sidebar.chatChanged(event));
  yield* follow(events.stream("chat_removed"), (event) => sidebar.chatRemoved(event));
  yield* follow(events.stream("transcript_reset"), (event) => sidebar.transcriptReset(event));
  yield* follow(events.stream("agent"), (event) => sidebar.agentEvent(event));
  // The first load runs in the program fiber, like the original's refresh()
  // at the end of activate: its list calls leave before activate returns.
  // A failed load keeps the previous state, and the next event retries.
  yield* sidebar.refresh().pipe(Effect.ignore);
});

export const activate = runPlugin(Sidebar.layer, program);