files

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// Register file views before starting app and agent subscriptions.
// Background reads start from app changes, never from rendering.
import * as Effect from "effect/Effect";
import * as Stream from "effect/Stream";
import { App, Events, Views, runPlugin } from "convergence/effect";
import { Files } from "./controller.ts";
import { runFinished } from "./panel.ts";
import { renderRail, renderPanel } from "./views.ts";

const program = Effect.gen(function* () {
  const files = yield* Files;
  const views = yield* Views;
  files.views.push(yield* views.slot("rail", (ctx) => renderRail(ctx, files), { on: ["app_state"], order: 10 }));
  files.views.push(
    yield* views.slot("right", (ctx) => renderPanel(ctx, files), { on: ["app_state"], order: 10, title: "Files" }),
  );
  const app = yield* App;
  const events = yield* Events;
  yield* app.changes.pipe(
    Stream.runForEach((next) => Effect.forkScoped(files.followApp(next), { startImmediately: true })),
    Effect.forkScoped({ startImmediately: true }),
  );
  yield* events.stream("agent").pipe(
    Stream.runForEach((event) =>
      Effect.forkScoped(
        runFinished(event.kind) && files.state.workspaceId ? files.refresh(files.state.workspaceId) : Effect.void,
        { startImmediately: true },
      ),
    ),
    Effect.forkScoped({ startImmediately: true }),
  );
  yield* files.followApp(yield* app.state);
});

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