claude

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75// Best-effort reads of Claude's records through the scoped broker service.
// Missing and ungranted files retain the original null/empty semantics.
import * as Effect from "effect/Effect";
import * as wire from "./wire.ts";
import { Fs } from "convergence/effect";

const quiet = Effect.fnUntraced(function* <A, E extends { readonly _tag: string; readonly message: string }, R>(
  effect: Effect.Effect<A, E, R>,
) {
  return yield* effect.pipe(
    // Claude's own files are optional: unreadable history is absent history.
    Effect.catch((error) =>
      Effect.sync(() => {
        if (error._tag === "PermissionNotGranted") console.debug(`claude: ${error.message}`);
        return null;
      }),
    ),
  );
});
export function apiFiles() {
  return {
    text: Effect.fn("Claude.files.text")(function* (path: string) {
      return yield* quiet((yield* Fs).read(path));
    }),
    bytes: Effect.fn("Claude.files.bytes")(function* (path: string) {
      return yield* quiet((yield* Fs).read(path, { encoding: "binary" }));
    }),
    list: Effect.fn("Claude.files.list")(function* (path: string) {
      return yield* quiet((yield* Fs).list(path));
    }),
    stat: Effect.fn("Claude.files.stat")(function* (path: string) {
      return yield* quiet((yield* Fs).stat(path));
    }),
  };
}
export type Files = ReturnType<typeof apiFiles>;
export const readJson = Effect.fn("Claude.readJson")(function* (files: Files, path: string) {
  const text = yield* files.text(path);
  if (text === null) return null;
  try {
    const value: unknown = JSON.parse(text);
    return value;
  } catch {
    return null;
  }
});
export const readLines = Effect.fn("Claude.readLines")(function* (files: Files, path: string) {
  const text = yield* files.text(path);
  return text === null ? [] : parseLines(text);
});
export function parseLines(text: string): wire.Record[] {
  const out: wire.Record[] = [];
  for (const line of text.split("\n")) {
    if (!line.trim()) continue;
    try {
      out.push(wire.record.parse(JSON.parse(line)));
    } catch {
      /* A partially written or invalid record waits for a later read. */
    }
  }
  return out;
}
export function join(...parts: (string | null | undefined)[]) {
  return parts
    .filter((part) => part !== "" && part !== null && part !== undefined)
    .map((part, at) => (at === 0 ? String(part).replace(/\/+$/, "") : String(part).replace(/^\/+|\/+$/g, "")))
    .join("/");
}
export const mapLimit = Effect.fn("Claude.mapLimit")(function* <A, B, E, R>(
  items: A[],
  limit: number,
  work: (item: A, at: number) => Effect.Effect<B, E, R>,
) {
  return yield* Effect.forEach(items, work, { concurrency: limit });
});