terminal

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
52
53
54
55// Register terminal views synchronously; expose them only after the kernel support probe succeeds.
// Both listeners and session work belong to the activation scope.
import * as Effect from "effect/Effect";
import * as Stream from "effect/Stream";
import { Commands, Events, Views, runPlugin } from "convergence/effect";
import { controller } from "./controller.ts";
import { TerminalState } from "./state.ts";
import { renderFlyOut, renderRail } from "./view.ts";

const program = Effect.gen(function* () {
  const terminal = yield* controller();
  const views = yield* Views;
  const events = yield* Events;
  terminal.state.rail = yield* views.slot("rail", (ctx) => renderRail(terminal, ctx), {
    on: ["app_state", "terminal"],
    order: 100,
  });
  terminal.state.flyOut = yield* views.slot(
    "right",
    (ctx) => {
      // The baseline requests a missing session when this view renders, after registrations are published.
      ctx.run(terminal.ensureVisible());
      return renderFlyOut(terminal, ctx);
    },
    {
      on: ["app_state", "terminal"],
      order: 100,
      title: "Terminal",
      flyout: { width: 1400, height: 820, align: "bottom" },
    },
  );
  yield* Effect.forkScoped(
    events
      .stream("terminal")
      .pipe(Stream.runForEach(() => Effect.forkIn(terminal.refresh(), terminal.scope, { startImmediately: true }))),
    { startImmediately: true },
  );
  const supported = yield* terminal.refresh().pipe(
    Effect.match({
      onSuccess: () => true,
      onFailure: (error) => {
        console.warn(`terminal: this build has no terminal support (${error.message})`);
        return false;
      },
    }),
  );
  if (!supported) return;
  const commands = yield* Commands;
  yield* commands.register("terminal.toggle", terminal.openInPane());
  yield* commands.register("terminal.new", terminal.openInPane(true));
  terminal.state.ready = true;
  terminal.update();
});

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