acp

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// ACP provider wiring: lazily share login environment and platform detection,
// then serve the registry in the plugin's resource scope.
import * as Effect from "effect/Effect";
import * as Scope from "effect/Scope";
import { Env, Process, runPlugin } from "convergence/effect";
import { RpcTransport } from "../sdk/effect.ts";
import { detectPlatform } from "./registry.ts";
import { AcpPlugin } from "./plugin.ts";
import type { AcpContext } from "./types.ts";
export { AcpPlugin } from "./plugin.ts";
export const ENV_VARS = ["XAI_API_KEY"];
const loginEnv = Effect.fn("Acp.loginEnv")(function* () {
  const env = yield* Env;
  const values: Record<string, string> = {};
  for (const name of ENV_VARS) {
    const value = yield* env.get(name).pipe(
      Effect.catchTag(["HostCallFailed", "PermissionNotGranted", "NeedsReview"], (error) =>
        Effect.sync(() => {
          console.warn(`acp: reading ${name} failed: ${error.message}`);
          return null;
        }),
      ),
    );
    if (typeof value === "string" && value) values[name] = value;
  }
  return values;
});
export const serve = Effect.fn("Acp.serve")(function* (observe?: (plugin: AcpPlugin) => void) {
  const scope = yield* Scope.Scope;
  const transport = yield* RpcTransport;
  const process = yield* Process;
  const platform = yield* Effect.cached(detectPlatform().pipe(Effect.scoped));
  const env = yield* Effect.cached(loginEnv());
  const context: AcpContext = {
    which: (program) =>
      process.which(program).pipe(
        Effect.map((result) => result.path ?? null),
        Effect.catchTag(["HostCallFailed", "PermissionNotGranted", "NeedsReview"], () => Effect.succeed(null)),
      ),
    platform: () => platform,
    loginEnv: () => env,
    icons: {},
  };
  const plugin = new AcpPlugin(scope, transport, context);
  observe?.(plugin);
  yield* plugin.start();
});
export const activate = runPlugin(RpcTransport.layer, serve());