Dashboard › opencode › Session 0PLm3errNmQp
0PLm3errNmQp6148MRead-only investigation in /home/byk/Code/opencode-lore. Inspect packages/gateway/src/cli/start.ts and nearby code/tests. Determine the smallest correct shared, reference-counted in-process gateway lifecycle suitable for multiple V2 plugin locations, including resolve/probe order, ownership, cleanup, setup failure, concurrent setup, and hard shutdown invariants. Do not edit files. Return exact file:line evidence, likely reusable types/functions, and specific regression cases.
/home/byk/Code/opencode-lore/AGENTS.md
<path>/home/byk/Code/opencode-lore/AGENTS.md</path> <type>file</type> <content> 1: <!-- This section is maintained by the coding agent via lore (https://github.com/BYK/loreai) --> 2: ## Long-term Knowledge 3: 4: For long-term knowledge entries managed by [lore](https://github.com/BYK/loreai) (gotchas, patterns, decisions, architecture), see [`.lore.md`](.lore.md) in the project root. 5: <!-- End lore-managed section --> 6: 7: ## Review 8: 9: See [`quality/REVIEW.md`](quality/REVIEW.md) for the review heuristics and workflow — regression-test discipline, adversarial-order state setup, fan-out registry coverage, recurring bug-class batteries, and the two-reviewer rule. Every non-trivial PR requires an adversarial correctness review before merge. 10: 11: # Project Overview 12: 13: Lore is a **three-tier memory architecture** for AI coding agents. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
1: /**
2: * `lore start` — start the gateway server without auto-launching an agent.
3: *
4: * Extracted from the old top-level index.ts boot logic.
5: */
6: import { spawn } from "node:child_process";
7: import { randomBytes } from "node:crypto";
8: import { closeSync } from "node:fs";
9: import { join } from "node:path";
10: import {
11: assertGatewayAccessConfigured,
12: loadConfig,
13: DEFAULT_PORTS,
14: type GatewayConfig,
15: } from "../config";
16: import { startServer, bracketHost } from "../server";
17: import { resetPipelineState } from "../pipeline";
18: import { writePortFile, removePortFile } from "../portfile";
19: import {
20: writeGatewayProcessFile,
21: readGatewayProcessFile,
22: removeGatewayProcessFile,
23: type GatewayProcessRecord,
24: } from "../pidfile";
25: import {
26: dataDir,
27: embedding,
28: temporalEmbeddingQueue,
29: ...
/home/byk/Code/opencode-lore/packages/gateway/test/gateway-auth-config.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/shutdown-embed-drain.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/run-shutdown-race.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/sync-team-lifecycle.integration.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/lifecycle-wiring.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-quiet.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/lifecycle-lock.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/auto-detect-remote-gateway.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/upgrade-lifecycle.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/shutdown.test.ts /home/byk/Code/opencode-lore/packages/gateway/test/gateway-access-auth.e2e.test.ts /home/byk/Code/opencode-lore/packages/gateway/te...
/home/byk/Code/opencode-lore/packages/opencode/package.json /home/byk/Code/opencode-lore/packages/opencode/tsconfig.json /home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/routing.e2e.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/internal.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/subagent-detection.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/tui-silence.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/session-state.test.ts /home/byk/Code/opencode-lore/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore/packages/opencode/src/index.ts /home/byk/Code/opencode-lore/packages/opencode/scripts/list-sessions.ts /home/byk/Code/opencode-lore/packages/opencode/eval/session_eval.ts /home/byk/Code/opencode-lore/packages/opencode/eval/extract_session.ts /home/byk/Code/opencode-lore/packages/o...
/home/byk/Code/opencode-lore/packages/gateway/src/turn-temporal.ts /home/byk/Code/opencode-lore/packages/gateway/src/source-checkpoint.ts /home/byk/Code/opencode-lore/packages/gateway/src/server.ts /home/byk/Code/opencode-lore/packages/gateway/src/semantic-preparation.ts /home/byk/Code/opencode-lore/packages/gateway/src/pipeline.ts /home/byk/Code/opencode-lore/packages/gateway/src/idle.ts /home/byk/Code/opencode-lore/packages/gateway/src/http-body.ts /home/byk/Code/opencode-lore/packages/gateway/src/config.ts /home/byk/Code/opencode-lore/packages/gateway/src/background-limiter.ts /home/byk/Code/opencode-lore/packages/gateway/src/worker-health.ts /home/byk/Code/opencode-lore/packages/gateway/src/llm-adapter.ts /home/byk/Code/opencode-lore/packages/gateway/src/cache-warmer.ts /home/byk/Code/opencode-lore/packages/gateway/src/batch-queue.ts /home/byk/Code/opencode-lore/packages/gateway/src/temporal-adapter.ts /home/byk/Code/opencode-lore/packages/gateway/src/recall.ts /home/byk/Code/openc...
Found 26 matches
/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts:
Line 2: import { probeGateway } from "../src/internal";
Line 7: * These exercise startGateway from @loreai/gateway directly (which is what
Line 19: // Track shutdown handles to clean up after tests.
Line 20: const shutdowns: Array<() => Promise<void>> = [];
Line 23: for (const shutdown of shutdowns) {
Line 24: await shutdown();
Line 29: test("probeGateway returns false for a port with nothing listening", async () => {
Line 31: const result = await probeGateway("http://127.0.0.1:19876", 500);
Line 35: test("startGateway starts the gateway and responds to health checks", async () => {
Line 45: shutdowns.push(async () => server.stop());
Line 51: const healthy = await probeGateway(base, 2000);
Line 62: // Use startServer directly (lighter than startGateway — avoids
Line 93: shutdowns.push(async () => server.stop());
Line 99: ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path> <type>file</type> <content> 381: output.headers, 382: gatewayAccessHeadersForRemote(gatewayBase), 383: ); 384: // Inject stable session ID — OpenCode's DB session ID survives restarts, 385: // unlike x-session-affinity (nanoid regenerated per process). 386: output.headers["x-lore-session-id"] = input.sessionID; 387: output.headers["x-lore-agent"] = input.agent; 388: // Flag OpenCode Task sub-agents so the gateway sizes their LTM 389: // injection (see #1300). A sub-agent runs in a child session carrying a 390: // parentID; forward it as the `x-parent-session-id` signal the gateway 391: // already understands (Claude Code sends this natively). Resolution is 392: // cached and never blocks or throws on failure. 393: const parentSessionID = await resolveParentSession( 394: ctx.client, 395: ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts</path> <type>file</type> <content> 1: /** 2: * Internal helpers for the Lore OpenCode plugin. 3: * 4: * These functions are intentionally kept OUT of the plugin entry module 5: * (`./index.ts`). OpenCode's legacy plugin loader treats EVERY function 6: * exported from a plugin module as a plugin instance and invokes it (see 7: * `getServerPlugin`/`getLegacyPlugins` in opencode's plugin loader). Exporting 8: * these helpers from the entry module caused them to be invoked as plugins and 9: * their return values pushed into the host's hooks array: 10: * `applyLoreProviderConfig` returns `undefined`, so the host crashed on the 11: * first hook dispatch with `undefined is not an object (evaluating 'A.event')` 12: * (the `?.` guards the `.event` property, not the `undefined` hook element). ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
1: import { createServer as createHttpServer } from "node:http";
2: import { mkdtempSync, rmSync } from "node:fs";
3: import {
4: createServer as createNetServer,
5: type AddressInfo,
6: type Server as NetServer,
7: } from "node:net";
8: import { tmpdir } from "node:os";
9: import { join } from "node:path";
10: import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
11: import { readPortFile, removePortFile } from "../src/portfile";
12: import {
13: readGatewayProcessFile,
14: removePidFile,
15: writeGatewayProcessFile,
16: } from "../src/pidfile";
17:
18: describe("startGateway authenticated reuse", () => {
19: const teardowns: Array<() => void | Promise<void>> = [];
20: let base: string;
21: let previousXdg: string | undefined;
22:
23: beforeEach(() => {
24: previousXdg = process.env.XDG_DATA_HOME;
25: base = ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts</path>
<type>file</type>
<content>
1: import { createServer, type Server } from "node:http";
2: import { once } from "node:events";
3: import { createConnection, type AddressInfo } from "node:net";
4: import { afterEach, describe, expect, it, vi } from "vitest";
5: import { embedding, log } from "@loreai/core";
6: import type { GatewayProcessRecord } from "../src/pidfile";
7:
8: afterEach(() => {
9: vi.restoreAllMocks();
10: });
11:
12: describe("startGateway active-stream shutdown", () => {
13: it("bounds authenticated shutdown when a socket sends incomplete headers", async () => {
14: const core = await import("@loreai/core");
15: vi.spyOn(embedding, "settleDocumentEmbeds").mockResolvedValue(undefined);
16: vi.spyOn(embedding, "resetProvider").mockResolvedValue(undefined);
17: vi.spyOn(core, "shutdownVectorPoolAsync").mockResolvedValue(undefined);
18: vi.spyOn(core, ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-embed-drain.test.ts</path> <type>file</type> <content> 1: /** 2: * Regression test for issue #1331: on graceful gateway shutdown, in-flight 3: * fire-and-forget document embeds (esp. a distillation embed created this 4: * session) must be DRAINED before the embedding worker is torn down, or their 5: * `distillation_vec` rows are never written → silent recall degradation on 6: * short/fast sessions. 7: * 8: * The `shutdown` closure built in `startGateway()` must call 9: * `embedding.settleDocumentEmbeds(<bounded>)` BEFORE `embedding.resetProvider()` 10: * (which kills the worker), and the drain must be bounded so a stuck embed can 11: * never reintroduce the Ctrl+C hang. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-sqlite-readers.test.ts</path> <type>file</type> <content> 1: /** 2: * Regression test for issue #1599: gateway graceful shutdown must close the 3: * vector/read worker pool's SQLite readers BEFORE the writer close runs, and 4: * the writer close must run exactly once on the normal path. 5: * 6: * Why this matters: 7: * - SQLite WAL TRUNCATE requires ZERO concurrent readers — each vector 8: * worker holds a read-mark via its `reader.db` connection. Leaving 9: * readers up while the writer tries to close either busy-returns the 10: * checkpoint (and strands the `-wal`) or hangs on the writer's busy- 11: * timeout. Both force WAL recovery on next boot. 12: * - The pre-#1599 sync `shutdownVectorPool()` posted `shutdown` + 13: * `terminate()` in the same tick and never awaited, so a reader could 14: * outlive the writer close. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/shutdown.ts</path>
<type>file</type>
<content>
1: /**
2: * Graceful-but-bounded process shutdown helpers.
3: *
4: * The gateway exits normally only after the `shutdown()` closure resolves.
5: * Several shutdown steps (batch-queue drain,
6: * embedding-worker exit) can, in pathological cases, take a long time — which
7: * is why Ctrl+C used to appear to "hang for minutes" with no way to break out.
8: *
9: * These helpers guarantee that:
10: * 1. shutdown can never block the process longer than a hard deadline, and
11: * 2. a *second* child-owning SIGINT/SIGTERM immediately escalates the child
12: * while retaining the hard wrapper deadline.
13: */
14: import { forcedExit, safeExit } from "./exit";
15: import { SHUTDOWN_DEADLINE_MS } from "../shutdown-deadline";
16:
17: export {
18: parseShutdownDeadline,
19: SHUTDOWN_DEADLINE_MS,
20: } from "../shutdown-deadline";
21:
22: const SIGNAL_NUMBERS: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1: import { AsyncLocalStorage } from "node:async_hooks";
2: import { createHash, randomBytes } from "node:crypto";
3: import {
4: closeSync,
5: constants,
6: fchmodSync,
7: fstatSync,
8: fsyncSync,
9: lstatSync,
10: linkSync,
11: mkdirSync,
12: openSync,
13: readFileSync,
14: readdirSync,
15: realpathSync,
16: renameSync,
17: rmdirSync,
18: rmSync,
19: unlinkSync,
20: writeFileSync,
21: type Stats,
22: } from "node:fs";
23: import { homedir } from "node:os";
24: import {
25: basename,
26: dirname,
27: isAbsolute,
28: join,
29: relative,
30: resolve,
31: } from "node:path";
32:
33: const LOCK_VERSION = 1;
34: const DIRECTORY_MODE = 0o700;
35: const FILE_MODE = 0o600;
36: const OWNER_FILE = "owner.json";
37: const UNINSTALL_TOMBSTONE_FILE = "uninstalled.json";
38: const INITIALIZATION_CLAIM_MARKER = ".init.";
39: const ...
Found 6 matches
/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts:
Line 198: const lockContext = new AsyncLocalStorage<LifecycleLock>();
Line 201: export function withoutLifecycleLock<T>(action: () => T): T {
Line 202: return lockContext.exit(action);
Line 1841: export async function withLifecycleLock<T>(
Line 1846: const inherited = lockContext.getStore();
Line 1853: return lockContext.run(lock, async () => {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1790: );
1791: }
1792: throw error;
1793: }
1794: }
1795:
1796: try {
1797: const snapshot = inspectLockPath(options.lockPath);
1798: lastOwner = snapshot.owner;
1799: if (ownerIsDefinitivelyStale(snapshot.owner, options)) {
1800: if (quarantineStaleLock(snapshot, options)) continue;
1801: }
1802: } catch (error) {
1803: if (isMissing(error)) {
1804: try {
1805: // Missing canonical path is an acquisition race: retry immediately.
1806: // A present, empty directory is recovered only by createLockDirectory
1807: // when a dead init or matching release generation proves its origin.
1808: lstatSync(options.lockPath);
1809: } catch (pathError) {
1810: if (isMissing(pathError)) continue;
1811: ...
Found 6 matches
/home/byk/Code/opencode-lore/packages/gateway/src/server.ts:
Line 752: export async function startServer(
Line 757: onShutdown?: () => void | Promise<void>;
Line 761: shutdownDeadlineMs?: number;
Line 775: closeServer(server, options.shutdownDeadlineMs ?? SHUTDOWN_DEADLINE_MS));
Line 1024: (method === "POST" && !options.onShutdown)
Line 1041: void Promise.resolve(options.onShutdown?.()).catch((error) => {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
700: // Pipeline returns the response in the client's native wire format
701: // (OpenAI Responses API JSON or SSE), so no server-side translation
702: // is needed.
703: return withoutCors(await handleRequest(gatewayReq, config));
704: } catch (e) {
705: const msg = e instanceof Error ? e.message : "Pipeline error";
706: log.error(`pipeline error: ${msg}`);
707: return errorResponse(502, "api_error", `Gateway pipeline error: ${msg}`);
708: }
709: }
710:
711: /**
712: * Codex (ChatGPT) ingress — `POST /v1/codex/responses`. Pi's `openai-codex`
713: * provider appends `/codex/responses` to the registered gateway baseUrl. The
714: * wire format is the OpenAI Responses API; we flag the request as Codex so the
715: * upstream is routed to `/backend-api/codex/responses` and Codex control fields
716: * (`store: false`, `include`, …) are preserved. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
1490: socket.removeListener("error", onSocketError);
1491: },
1492: };
1493: }
1494:
1495: export function waitForNodeResponseDrain(
1496: nodeRes: ServerResponse,
1497: signal: AbortSignal,
1498: ): Promise<void> {
1499: signal.throwIfAborted();
1500: return new Promise<void>((resolve, reject) => {
1501: let settled = false;
1502: const cleanup = (): void => {
1503: nodeRes.removeListener("drain", onDrain);
1504: signal.removeEventListener("abort", onAbort);
1505: };
1506: const finish = (operation: () => void): void => {
1507: if (settled) return;
1508: settled = true;
1509: cleanup();
1510: operation();
1511: };
1512: const onDrain = (): void => finish(resolve);
1513: const onAbort = (): void => finish(() => reject(signal.reason));
1514: nodeRes.on("drain", onDrain);
1515: ...
Found 9 matches
/home/byk/Code/opencode-lore/packages/gateway/src/server.ts:
Line 769: /** Resolves when all bound servers are listening. */
Line 1134: const servers: Server[] = [];
Line 1274: servers.push(s);
Line 1279: // already bound — close the successfully-bound servers so we don't leak
Line 1281: await Promise.all(servers.map(closeBoundServer));
Line 1287: if (servers.length === 0) {
Line 1294: const readyPromises = servers
Line 1301: stopPromise ??= Promise.all(servers.map(closeBoundServer)).then(() => {});
Line 1351: function closeServer(server: Server, deadlineMs: number): Promise<void> {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
1120: );
1121: }
1122: return errorResponse(500, "api_error", msg);
1123: }
1124: };
1125:
1126: // Spawn one node:http server per host address. This allows binding to
1127: // specific interfaces (e.g. 127.0.0.1 + a Tailscale IP) without
1128: // opening to 0.0.0.0.
1129: //
1130: // Bind sequentially so the OS-assigned port (when config.port is 0)
1131: // is known before the second host binds — that way all hosts share
1132: // the same actual port. node:http's listen() is async, so we must
1133: // await each bind; Array#map can't await, hence the for-of loop.
1134: const servers: Server[] = [];
1135: const boundHosts: string[] = [];
1136: let resolvedPort = config.port;
1137: try {
1138: for (const host of config.hosts) {
1139: const s = createHttpServer((nodeReq, nodeRes) => {
1140: void handleNodeRequest(
1141: ...
<path>/home/byk/Code/opencode-lore/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: }
15: },
16: "scripts": {
17: "typecheck": "tsc --noEmit",
18: "build": "echo '@loreai/opencode ships raw TS — no build step needed'"
19: },
20: "peerDependencies": {
21: "@opencode-ai/plugin": ">=1.1.0"
22: },
23: "dependencies": {
24: "@loreai/core": "workspace:*",
25: "@loreai/gateway": "workspace:*"
26: },
27: "devDependencies": {
28: "@opencode-ai/plugin": "^1.1.39",
29: "@opencode-ai/sdk": "^1.1.39",
30: ...
Found 87 matches
/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts:
Line 50: cleanup: () => rmSync(tmpDir, { recursive: true, force: true }),
Line 56: const { hooks, cleanup } = await initPlugin();
Line 63: cleanup();
Line 68: const { hooks, cleanup } = await initPlugin();
Line 105: cleanup();
Line 110: const { hooks, cleanup } = await initPlugin();
Line 124: cleanup();
Line 132: // a 404 from the gateway. The plugin must pin EVERY provider's baseURL
Line 133: // to `${gatewayBase}/v1` because opencode's resolveSDK() bypasses the
Line 210: test("is a no-op when gatewayBase is empty (test env / startup failure)", () => {
Line 211: // In NODE_ENV=test the plugin's init skips gateway start, so
Line 212: // gatewayBase is "". ...
<path>/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts</path>
<type>file</type>
<content>
1: import { describe, test, expect, afterAll } from "vitest";
2: import { probeGateway } from "../src/internal";
3:
4: /**
5: * Smoke tests for the in-process gateway startup.
6: *
7: * These exercise startGateway from @loreai/gateway directly (which is what
8: * the plugin's startInProcess delegates to). Tests use ephemeral ports so
9: * they don't collide with a running gateway.
10: */
11:
12: // Minimal view of the @loreai/gateway module surface used by these tests.
13: type GatewayServer = { stop: () => void; port: number; hosts: string[] };
14: type GatewayModule = {
15: loadConfig: () => { port: number } & Record<string, unknown>;
16: startServer: (config: unknown) => Promise<GatewayServer>;
17: };
18:
19: // Track shutdown handles to clean up after tests. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts</path>
<type>file</type>
<content>
1: import { describe, test, expect } from "vitest";
2: import { fileURLToPath } from "node:url";
3: import { LorePlugin } from "../src/index";
4: import { applyLoreProviderConfig } from "../src/internal";
5: import type { Plugin } from "@opencode-ai/plugin";
6:
7: /**
8: * Minimal mock of the OpenCode client. Only stubs the methods the plugin
9: * actually calls during initialization.
10: */
11: function createMockClient() {
12: return {
13: tui: {
14: showToast: () => Promise.resolve(),
15: },
16: session: {
17: get: () => Promise.resolve({ data: {} }),
18: list: () => Promise.resolve({ data: [] }),
19: create: () => Promise.resolve({ data: { id: "worker_1" } }),
20: messages: () => Promise.resolve({ data: [] }),
21: message: () => Promise.resolve({ data: null }),
22: prompt: () => Promise.resolve({ data: {} }),
23: ...
Found 100 matches (more matches available)
/home/byk/Code/opencode/packages/codemode/src/interpreter/runtime.ts:
Line 1262: const finalizer = getOptionalNode(node, "finalizer")
Line 1284: if (!finalizer) return attempted
Line 1293: : Effect.flatMap(this.evaluateStatement(finalizer), (final) =>
Line 1297: Effect.flatMap(this.evaluateStatement(finalizer), (final) =>
/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts:
Line 5: readonly setup: (context: PluginContext) => Promise<void> | void
/home/byk/Code/opencode/packages/llm/src/provider.ts:
Line 18: export interface Definition<Factory extends AnyModelFactory = ModelFactory> {
/home/byk/Code/opencode/packages/opencode/test/preload.ts:
Line 29: // Windows can keep SQLite WAL handles alive until GC finalizers run, so we
/home/byk/Code/opencode/packages/opencode/test/control-plane/workspace.test.ts:
Line 1113: yield* Effect.addFinalizer(() =>
Line 1171: ...
/home/byk/Code/opencode/packages/plugin/src/v2/promise/skill.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/registration.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/reference.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/integration.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/index.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/context.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/command.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/catalog.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/aisdk.ts /home/byk/Code/opencode/packages/plugin/src/v2/promise/agent.ts /home/byk/Code/opencode/packages/plugin/src/v2/options.ts /home/byk/Code/opencode/packages/plugin/src/v2/effect/skill.ts /home/byk/Code/opencode/packages/plugin/src/v2/effect/registration.ts /home/byk/Code/opencode/packages/plugin/src/v2/effect/reference.ts /home/byk/Code...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/plugin.ts</path>
<type>file</type>
<content>
1: import type { Effect, Scope } from "effect"
2: import type { PluginContext } from "./context.js"
3:
4: export interface Plugin<R = Scope.Scope> {
5: readonly id: string
6: readonly effect: (context: PluginContext) => Effect.Effect<void, never, R>
7: }
8:
9: export function define<R = Scope.Scope>(plugin: Plugin<R>) {
10: return plugin
11: }
12:
13: export interface PluginDomain {
14: readonly add: (plugin: Plugin) => Effect.Effect<void>
15: readonly remove: (id: string) => Effect.Effect<void>
16: }
(End of file - total 16 lines)
</content>
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { PluginContext } from "./context.js"
2:
3: export interface Plugin {
4: readonly id: string
5: readonly setup: (context: PluginContext) => Promise<void> | void
6: }
7:
8: export function define(plugin: Plugin) {
9: return plugin
10: }
11:
12: export interface PluginDomain {
13: readonly add: (plugin: Plugin) => Promise<void>
14: readonly remove: (id: string) => Promise<void>
15: }
(End of file - total 15 lines)
</content>
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/context.ts</path>
<type>file</type>
<content>
1: import type { PluginOptions } from "../options.js"
2: import type { AgentHooks } from "./agent.js"
3: import type { AISDKHooks } from "./aisdk.js"
4: import type { CatalogHooks } from "./catalog.js"
5: import type { CommandHooks } from "./command.js"
6: import type { IntegrationHooks } from "./integration.js"
7: import type { PluginDomain } from "./plugin.js"
8: import type { ReferenceHooks } from "./reference.js"
9: import type { SkillHooks } from "./skill.js"
10: import type { Reload } from "./registration.js"
11:
12: export interface PluginContext {
13: readonly options: PluginOptions
14: readonly agent: AgentHooks & Reload
15: readonly aisdk: AISDKHooks
16: readonly catalog: CatalogHooks & Reload
17: readonly command: CommandHooks & Reload
18: readonly integration: IntegrationHooks & Reload
19: readonly plugin: PluginDomain
20: readonly reference: ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/registration.ts</path>
<type>file</type>
<content>
1: export interface Registration {
2: readonly dispose: () => Promise<void>
3: }
4:
5: export interface Reload {
6: readonly reload: () => Promise<void>
7: }
8:
9: export type Hooks<Spec> = {
10: readonly [Name in keyof Spec]: (callback: (input: Spec[Name]) => Promise<void> | void) => Promise<Registration>
11: }
(End of file - total 11 lines)
</content>
/home/byk/Code/opencode/packages/core/src/plugin/models-dev.ts /home/byk/Code/opencode/packages/core/src/plugin/internal.ts /home/byk/Code/opencode/packages/core/src/plugin/variant.ts /home/byk/Code/opencode/packages/core/src/plugin/skill.ts /home/byk/Code/opencode/packages/core/src/plugin/provider.ts /home/byk/Code/opencode/packages/core/src/plugin/promise.ts /home/byk/Code/opencode/packages/core/src/plugin/host.ts /home/byk/Code/opencode/packages/core/src/plugin/command.ts /home/byk/Code/opencode/packages/core/src/plugin/agent.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/github-copilot.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/zenmux.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/xai.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/vercel.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/venice.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/togetherai.ts /home/byk/Code/opencode/packages/core/src/plu...
Found 27 matches
/home/byk/Code/opencode/packages/core/src/plugin/models-dev.ts:
Line 180: Effect.forkScoped({ startImmediately: true }),
/home/byk/Code/opencode/packages/core/src/plugin/internal.ts:
Line 6: import { Effect, Layer, Scope } from "effect"
Line 56: readonly effect: (context: PluginContext) => Effect.Effect<void, never, R | Scope.Scope>
Line 86: .effect(context)
Line 123: ).pipe(Effect.withSpan("PluginInternal.boot"), Effect.forkScoped({ startImmediately: true }))
/home/byk/Code/opencode/packages/core/src/plugin/provider.ts:
Line 34: import type { Scope } from "effect"
Line 36: export const ProviderPlugins: PluginInternal.Plugin<PluginInternal.Requirements | Scope.Scope>[] = [
/home/byk/Code/opencode/packages/core/src/plugin/promise.ts:
Line 5: import { Effect, Scope } from "effect"
Line 9: type HostRegistration = { readonly dispose: Effect.Effect<void> }
Line 15: * Hook registrations created during the async ...
<path>/home/byk/Code/opencode/packages/core/src/plugin/promise.ts</path>
<type>file</type>
<content>
1: export * as PluginPromise from "./promise"
2:
3: import { define } from "@opencode-ai/plugin/v2/effect"
4: import type { Plugin, PluginContext, Registration } from "@opencode-ai/plugin/v2/promise"
5: import { Effect, Scope } from "effect"
6:
7: // The Effect host hands back this registration shape; mirror it structurally so
8: // we do not have to alias the Effect package's `Registration` against the Promise one.
9: type HostRegistration = { readonly dispose: Effect.Effect<void> }
10:
11: /**
12: * Adapts a Promise plugin into an Effect plugin so the existing Effect-only
13: * loader (`PluginV2` / `PluginInternal`) can run it unchanged.
14: *
15: * Hook registrations created during the async `setup` attach to the plugin's
16: * scope, so unloading the plugin disposes them. ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/options.ts</path> <type>file</type> <content> 1: export type PluginOptions = Readonly<Record<string, any>> (End of file - total 1 lines) </content>
<path>/home/byk/Code/opencode/packages/core/src/plugin/internal.ts</path>
<type>file</type>
<content>
1: export * as PluginInternal from "./internal"
2:
3: import { makeLocationNode } from "../effect/app-node"
4: import { httpClient } from "../effect/app-node-platform"
5: import type { PluginContext } from "@opencode-ai/plugin/v2/effect"
6: import { Effect, Layer, Scope } from "effect"
7: import { AgentV2 } from "../agent"
8: import { Catalog } from "../catalog"
9: import { CommandV2 } from "../command"
10: import { Config } from "../config"
11: import { ConfigAgentPlugin } from "../config/plugin/agent"
12: import { ConfigCommandPlugin } from "../config/plugin/command"
13: import { ConfigExternalPlugin } from "../config/plugin/external"
14: import { ConfigProviderPlugin } from "../config/plugin/provider"
15: import { ConfigReferencePlugin } from "../config/plugin/reference"
16: import { ConfigSkillPlugin } from "../config/plugin/skill"
17: import { EventV2 } from "../event"
18: ...
<path>/home/byk/Code/opencode/packages/core/src/plugin.ts</path>
<type>file</type>
<content>
1: export * as PluginV2 from "./plugin"
2:
3: import { makeLocationNode } from "./effect/app-node"
4: import { Context, Deferred, Effect, Exit, Layer, Scope } from "effect"
5: import type { Plugin as PluginRuntime } from "@opencode-ai/plugin/v2/effect"
6: import { Plugin } from "@opencode-ai/schema/plugin"
7: import { AgentV2 } from "./agent"
8: import { AISDK } from "./aisdk"
9: import { Catalog } from "./catalog"
10: import { CommandV2 } from "./command"
11: import { EventV2 } from "./event"
12: import { Integration } from "./integration"
13: import { KeyedMutex } from "./effect/keyed-mutex"
14: import { PluginHost } from "./plugin/host"
15: import { Reference } from "./reference"
16: import { SkillV2 } from "./skill"
17: import { State } from "./state"
18:
19: export const ID = Plugin.ID
20: export type ID = typeof ID.Type
21: export const Event = Plugin.Event
22:
23: export interface ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/aisdk.ts</path>
<type>file</type>
<content>
1: import type { LanguageModelV3 } from "@ai-sdk/provider"
2: import type { ModelV2Info } from "@opencode-ai/sdk/v2/types"
3: import type { Hooks } from "./registration.js"
4:
5: export type AISDKHooks = Hooks<{
6: sdk: {
7: readonly model: ModelV2Info
8: readonly package: string
9: readonly options: Record<string, any>
10: sdk?: any
11: }
12: language: {
13: readonly model: ModelV2Info
14: readonly sdk: any
15: readonly options: Record<string, any>
16: language?: LanguageModelV3
17: }
18: }>
(End of file - total 18 lines)
</content>
Found 2 matches
/home/byk/Code/opencode/packages/opencode/test/fixture/tui-plugin.ts:
Line 161: acquireResource(_key: symbol, setup: () => () => void) {
/home/byk/Code/opencode/packages/opencode/src/plugin/tui/runtime.ts:
Line 81: "acquireResource",
Found 16 matches
/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-sqlite-readers.test.ts:
Line 23: * - `close()` is idempotent and a no-op when the DB was never opened.
Line 175: // closeDb is idempotent; calling it again is a no-op.
Line 254: it("close() is idempotent when called a second time after shutdown", async () => {
/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts:
Line 34: removePort: () => {},
Line 38: removeProcess: () => {
Line 117: removePort: () => {},
Line 121: removeProcess: () => {
Line 125: resetPipelineState: reset,
Line 201: removePort: () => {},
Line 205: removeProcess: () => {
Line 300: removePort: () => {},
Line 304: removeProcess: () => {
Line 356: removePort: () => {},
Line 360: removeProcess: () => {
Line 370: throw new Error("injected listener close ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-quiet.test.ts</path>
<type>file</type>
<content>
1: /**
2: * Regression test for the `startGateway({ quiet })` flag.
3: *
4: * In-process callers (the OpenCode plugin and the Pi extension) start the
5: * gateway with `{ quiet: true, local: true }` because they run inside the host
6: * agent's full-screen TUI, where ANY stdout/stderr write corrupts the rendered
7: * screen. Before the fix, `startGateway()` ignored `quiet` entirely and printed
8: * its startup/shutdown notices via `console.error`, leaking into the TUI (part
9: * of the Pi breakage Daniel Griesser reported).
10: *
11: * These tests pin the contract:
12: * - quiet:true → no `[lore] Shutting down…` on stderr (routed to file log).
13: * - quiet:false → the message is still printed (preserves `lore start` CLI). ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/portfile.ts</path>
<type>file</type>
<content>
1: /**
2: * Port file management — allows plugins to discover the gateway's actual port.
3: *
4: * When the gateway starts (especially on a fallback or random port), it writes
5: * the actual port number to `~/.local/share/lore/gateway.port`. Plugins read
6: * this file to locate the gateway without hardcoding a specific port.
7: *
8: * The file is removed on clean shutdown. Stale files (from crashes) are
9: * harmless — plugins probe `/health` after reading the port and ignore
10: * unresponsive ports.
11: */
12: import { randomBytes } from "node:crypto";
13: import { join } from "node:path";
14: import { linkSync, renameSync, rmSync } from "node:fs";
15: import { dataDir } from "@loreai/core";
16: import { atomicWriteRuntimeFile, readRuntimeFile } from "./runtime-files";
17:
18: const PORTFILE_NAME = "gateway.port";
19:
20: export interface GatewayPortRecord {
21: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/pidfile.ts</path>
<type>file</type>
<content>
1: /**
2: * PID file management — lets `lore stop` find a gateway started in the
3: * background (`lore start --bg`) or foreground.
4: *
5: * New gateways write an owner-only control record containing the PID, bound
6: * address, and a random challenge token. `lore stop` must authenticate that
7: * token against the gateway before signalling the PID, preventing PID reuse or
8: * a spoofed public health response from causing an unrelated process to die.
9: *
10: * Mirrors `portfile.ts` semantics (write/read/remove-if-matches).
11: */
12: import { randomBytes } from "node:crypto";
13: import { basename, join } from "node:path";
14: import { linkSync, lstatSync, renameSync, rmSync } from "node:fs";
15: import { dataDir } from "@loreai/core";
16: import { atomicWriteRuntimeFile, readRuntimeFile } from "./runtime-files";
17:
18: const PIDFILE_NAME = "gateway.pid";
19:
20: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/pidfile.ts</path>
<type>file</type>
<content>
295: /**
296: * Remove only the exact authenticated process generation. A raced-in successor
297: * is restored with no-clobber semantics or retained as a recovery artifact.
298: */
299: export function removeGatewayProcessFile(
300: expected: Pick<GatewayProcessRecord, "pid" | "token" | "processIdentity">,
301: ): void {
302: const path = pidfilePath();
303: const claimPath = join(
304: dataDir(),
305: `.gateway.pid.cleanup-${process.pid}-${randomBytes(8).toString("hex")}`,
306: );
307: try {
308: renameSync(path, claimPath);
309: } catch (error) {
310: if ((error as NodeJS.ErrnoException).code === "ENOENT") return;
311: throw error;
312: }
313:
314: const claimed = inspectGatewayProcessFileAt(claimPath);
315: if (
316: claimed.state === "valid" &&
317: claimed.record.pid === expected.pid &&
318: claimed.record.token === ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-v2-pilot/packages/tui/test/prompt/draft-stash.test.ts:
Line 5: // The Prompt component stashes an unsent draft in onCleanup and takes it back
/home/byk/Code/opencode-v2-pilot/packages/tui/src/util/delayed-presence.ts:
Line 1: import { createEffect, createMemo, createSignal, onCleanup, type Accessor } from "solid-js"
Line 30: onCleanup(() => clearTimeout(timer))
/home/byk/Code/opencode-v2-pilot/packages/tui/src/util/signal.ts:
Line 1: import { createEffect, createSignal, on, onCleanup, type Accessor } from "solid-js"
Line 14: onCleanup(() => {
/home/byk/Code/opencode-v2-pilot/packages/latex/src/plugin.ts:
Line 6: setup(context) {
/home/byk/Code/opencode-v2-pilot/packages/tui/src/ui/animation.ts:
Line 1: import { createEffect, createSignal, onCleanup, type Accessor } from "solid-js"
Line 201: onCleanup(stop)
/home/byk/Code/opencode-v2-pilot/packages/tui/src/routes/session/rows.ts:
...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
550: ),
551: },
552: worktree: {
553: list: adaptApiMethod(WorktreeEndpoints["worktree.list"], host.worktree.list),
554: create: adaptApiMethod(WorktreeEndpoints["worktree.create"], host.worktree.create),
555: remove: adaptApiMethod(WorktreeEndpoints["worktree.remove"], host.worktree.remove),
556: refresh: adaptApiMethod(WorktreeEndpoints["worktree.refresh"], host.worktree.refresh),
557: reload: () => run(host.worktree.reload()),
558: transform: (callback) =>
559: register(
560: host.worktree.transform((editor) =>
561: callback({
562: add: (definition) =>
563: editor.add({
564: id: definition.id,
565: create: (input) => ...
Found 60 matches
/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-quiet.test.ts:
Line 2: * Regression test for the `startGateway({ quiet })` flag.
Line 7: * screen. Before the fix, `startGateway()` ignored `quiet` entirely and printed
Line 46: const handle = await startGateway({ port: 0, local: true, quiet });
/home/byk/Code/opencode-lore/packages/gateway/test/server.test.ts:
Line 584: // bind with EADDRNOTAVAIL, which startGateway() then misreported as a port
/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts:
Line 28: const handle = await startGateway(
Line 111: const handle = await startGateway(
Line 195: const handle = await startGateway(
Line 294: await startGateway(
Line 350: await startGateway(
/home/byk/Code/opencode-lore/packages/gateway/test/lifecycle-wiring.test.ts:
Line 21: const pending = startGateway({ port: 0, local: true, quiet: true });
Line 39: ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/internal.ts</path>
<type>file</type>
<content>
180: */
181: export async function resolveGatewayUrl(): Promise<string | null> {
182: // 0. Remote gateway — skip local discovery/startup entirely.
183: if (process.env.LORE_REMOTE_URL) {
184: const url = gatewayUrlForLog(
185: process.env.LORE_REMOTE_URL.replace(/\/$/, ""),
186: );
187: if (url !== "invalid" && (await probeGateway(url))) return url;
188: log.info(
189: `pi: remote gateway at ${url} not reachable, falling through to local discovery`,
190: );
191: }
192:
193: // 1. Explicit env var — probe it to verify it's actually reachable.
194: if (process.env.LORE_GATEWAY_URL) {
195: const url = gatewayUrlForLog(
196: process.env.LORE_GATEWAY_URL.replace(/\/$/, ""),
197: );
198: if (url !== "invalid" && (await probeGateway(url))) return url;
199: // env var set but gateway unreachable — fall through to discovery
200: ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/pi/test/real-runtime.e2e.test.ts:
Line 24: * a real in-process Lore gateway sits in the middle, exactly as in
Line 59: const originalEnv = { ...process.env };
Line 130: process.env.LORE_PI_FORCE_ACTIVE = "1";
Line 131: process.env.LORE_GATEWAY_URL = baseURL;
Line 132: delete process.env.LORE_DISABLED;
Line 133: delete process.env.LORE_REMOTE_URL;
Line 163: // reroutes console.* away from process.stdout.write, but in a real Pi TUI a
Line 170: .spyOn(process.stdout, "write")
Line 176: .spyOn(process.stderr, "write")
Line 234: process.env = { ...originalEnv };
Line 266: // anthropic-messages call through the in-process gateway.
Line 280: // because the in-process gateway — a separate process in production —
/home/byk/Code/opencode-lore/packages/pi/test/internal.test.ts:
Line 9: resolveGatewayUrl,
Line 31: ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/index.ts</path> <type>file</type> <content> 1: /** 2: * @loreai/pi — Lore memory engine as a Pi coding-agent extension. 3: * 4: * On startup, the extension probes for an existing Lore gateway server 5: * and, if none is found, starts one in-process by importing 6: * @loreai/gateway. It installs a fetch-level interceptor that 7: * transparently reroutes LLM API calls through the gateway (preserving 8: * original auth headers and URLs), registers known providers with Pi, 9: * and adds a Pi-specific compaction hook (session_before_compact). 10: * All other memory features (LTM injection, gradient transforms, 11: * temporal capture, recall, idle work) are handled by the gateway pipeline. 12: * 13: * If the gateway server cannot be reached, the extension logs an error 14: * and becomes inert — no hooks are registered and Pi runs without 15: * memory features. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/config.ts</path>
<type>file</type>
<content>
1: /**
2: * Gateway configuration — loaded from environment variables with sensible
3: * defaults. No Zod, no file-based config — minimal @loreai/core dependency
4: * (only `normalizeRemoteUrl` for git URL canonicalization).
5: */
6:
7: import {
8: normalizeRemoteUrl,
9: discoverWorkspaceRoot,
10: GATEWAY_AUTH_HEADER,
11: UNATTRIBUTED_PROJECT_PREFIX,
12: isUnattributedProjectPath,
13: log,
14: } from "@loreai/core";
15: import { hasConflictingAuthHeaders } from "./auth";
16:
17: // ---------------------------------------------------------------------------
18: // Port defaults
19: // ---------------------------------------------------------------------------
20:
21: /**
22: * Default port preference order when LORE_LISTEN_PORT is not set. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/lifecycle-wiring.test.ts</path>
<type>file</type>
<content>
1: import { dirname, join } from "node:path";
2: import { rmSync } from "node:fs";
3: import { afterEach, describe, expect, test, vi } from "vitest";
4: import { startGateway } from "../src/cli/start";
5: import {
6: acquireLifecycleLock,
7: createUninstallTombstone,
8: LifecycleLockBusyError,
9: } from "../src/lifecycle-lock";
10:
11: afterEach(() => {
12: vi.useRealTimers();
13: vi.restoreAllMocks();
14: });
15:
16: describe("gateway lifecycle production wiring", () => {
17: test("active uninstall blocks gateway start before listener creation", async () => {
18: const lock = await acquireLifecycleLock("uninstall");
19: vi.useFakeTimers();
20: try {
21: const pending = startGateway({ port: 0, local: true, quiet: true });
22: const rejection = expect(pending).rejects.toBeInstanceOf(
23: LifecycleLockBusyError,
24: ...
<path>/home/byk/Code/opencode-lore/quality/REVIEW.md</path> <type>file</type> <content> 1: # Review Heuristics — Lore 2: 3: This document codifies the review bar for pull requests. It exists because 4: adversarial review has repeatedly caught correctness bugs that a green test 5: suite missed — skip/early-return branches, lifecycle sequences, and fan-out 6: registry gaps. Institutionalizing these patterns so they compound. 7: 8: The review workflow (§6) is referenced from AGENTS.md. 9: 10: --- 11: 12: ## 1. Regression-test discipline 13: 14: Every adversarial-review finding that surfaces a defect **must** land a 15: deterministic regression test in the same PR. The test: 16: - fails on the base branch (proving it reproduces the bug), 17: - passes on the fix (proving the fix works), 18: - drives the *real* precondition, not an artificially-constructed state (e.g. ...
Found 1 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/source.ts:
Line 152: yield* Effect.logWarning("configured plugin path must be a directory", { target: operation.target })
/home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/worktree.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/location-watcher.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/command.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/agent.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/websearch.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/tool-output.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/source.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/snapshot.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/skill.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/skill-file.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/shell.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/reference.ts /home/byk/Code/opencode-v2-pilot/packages/core/src/config/plugin/provider...
Found 41 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/vcs/hg.ts:
Line 33: const adapter = make(processes, fs, {
Line 42: info: () => adapter.info(),
Line 43: branches: (input) => adapter.branches({ search: input.search, limit: input.limit }),
Line 44: status: () => adapter.status(),
Line 45: diff: (input) => adapter.diff(input.mode, { context: input.context, base: input.base }),
Line 52: * Mercurial adapter for the Vcs service. `hg diff --git` emits git-format
/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/vcs/git.ts:
Line 28: const adapter = make(processes, {
Line 37: info: () => adapter.info(),
Line 38: base: () => adapter.base(),
Line 39: branches: (input) => adapter.branches({ search: input.search, limit: input.limit }),
Line 40: status: () => adapter.status(),
Line 41: diff: (input) => adapter.diff(input.mode, { context: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts</path>
<type>file</type>
<content>
1: export * as PluginModule from "./module.js"
2:
3: import type { Plugin } from "@opencode/plugin/effect/plugin"
4: import { Host } from "@opencode/plugin/host"
5: import { createPluginSources } from "@opencode/plugin/source"
6: import { Npm } from "@opencode/util/npm"
7: import { Deferred, Effect, FiberSet, PubSub, Schema, Stream } from "effect"
8: import path from "path"
9: import { stat } from "node:fs/promises"
10: import { fileURLToPath, pathToFileURL } from "url"
11: import type { ConfigPluginSource } from "../config/plugin/source.js"
12: import type { Generation } from "../plugin.js"
13: import { PluginPromise } from "./promise.js"
14: import { Watcher } from "../filesystem/watcher.js"
15:
16: export const make = Effect.fn("PluginModule.make")(function* () {
17: const watcher = yield* Watcher.Service
18: const scope = yield* Effect.scope
19: const runPromise = ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
1: import { Tool } from "@opencode/schema/tool"
2: import type { Rpc } from "@opencode/schema/rpc"
3: import type { RpcCallOptions, RpcEventPayload } from "@opencode/client/promise/api"
4: import { Effect, Schema, SchemaAST, Stream } from "effect"
5: import type { Scope } from "effect"
6: import { HttpApiEndpoint, HttpApiSchema } from "effect/unstable/httpapi"
7: import { define } from "../effect/plugin.js"
8: import type { Plugin } from "./plugin.js"
9: import type { Info } from "./tool.js"
10: import type { RpcDomain, RpcHandlers } from "./rpc.js"
11:
12: type HostRegistration = { readonly dispose: Effect.Effect<void> }
13: type Registration = { readonly dispose: () => Promise<void> }
14: type PromiseContext = Parameters<Plugin["setup"]>[0]
15: type PromiseEvent = ReturnType<PromiseContext["event"]["subscribe"]> extends AsyncIterable<infer Event> ? ...
Found 1 matches
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.ts:
Line 8: export function createPluginSources(watch: (file: string) => Promise<void>) {
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.ts</path>
<type>file</type>
<content>
1: import { readFileSync, readdirSync } from "node:fs"
2: import { fileURLToPath, pathToFileURL } from "node:url"
3: import path from "node:path"
4: import { Hash } from "@opencode/util/hash"
5:
6: // Keep source fingerprints and import attempts together. Filesystem events
7: // should reload changed local graphs, not repeat unchanged evaluations.
8: export function createPluginSources(watch: (file: string) => Promise<void>) {
9: const sources = new Map<string, Source>()
10: const cleanups: Array<() => void> = []
11: const watching = new Set<Promise<void>>()
12: return {
13: read: async (entrypoint: string) => {
14: await Promise.all(watching)
15: const previous = sources.get(entrypoint)
16: if (previous && [...previous.files].every(([file, item]) => item.digest === digest(file, item.directory)))
17: return previous.loaded
18:
19: const ...
<path>/home/byk/Code/opencode-lore/packages/core/src/log.ts</path>
<type>file</type>
<content>
80: export function traceDbQuery<T>(sql: string, fn: () => T): T {
81: return sink?.withDbSpan ? sink.withDbSpan(sql, fn) : fn();
82: }
83:
84: // ---------------------------------------------------------------------------
85: // Helpers
86: // ---------------------------------------------------------------------------
87:
88: // Match the gateway config's `isTruthy` semantics: only "1" or "true" enable
89: // debug. The naive `!!process.env.LORE_DEBUG` treated `LORE_DEBUG=0` and
90: // `LORE_DEBUG=false` as ENABLED (non-empty strings are truthy), which meant a
91: // user who set `LORE_DEBUG=0` to silence Lore still got `[lore]` status lines
92: // printed to stderr — fatal inside a full-screen TUI (e.g. the Pi agent).
93: const isDebug =
94: process.env.LORE_DEBUG === "1" ||
95: process.env.LORE_DEBUG?.toLowerCase() === "true";
96:
97: // ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin.ts</path>
<type>file</type>
<content>
1: export * as Plugin from "./plugin.js"
2: export { Event, ID, Info, Source, State } from "@opencode/schema/plugin"
3:
4: import { Plugin } from "@opencode/schema/plugin"
5: import { Node } from "@opencode/util/effect/app-node"
6: import { LayerNode } from "@opencode/util/effect/layer-node"
7: import type { PersistentPty } from "./persistent-pty.js"
8: import { Cause, Context, Effect, Exit, Latch, Layer, Logger, Queue, References, Scope, Semaphore } from "effect"
9: import { Bus } from "./bus.js"
10: import { KV } from "./kv.js"
11: import { PluginHost } from "./plugin/host.js"
12: import { type Failure, type Generation, Service } from "./plugin/service.js"
13: import { State } from "./state.js"
14:
15: export { awaitActivation, type Generation, type Interface, Service } from "./plugin/service.js"
16:
17: const layer = Layer.effect(
18: Service,
19: Effect.gen(function* () ...
Found 4 matches
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.ts:
Line 29: const { prepareSource } = await import("#plugin-source")
Line 30: const prepared: { version: string; load: () => Promise<unknown>; dispose?: () => void } = await prepareSource(
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.node.ts:
Line 9: export async function prepareSource(entrypoint: string, track: (file: string, directory?: boolean) => void) {
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.bun.ts:
Line 10: export async function prepareSource(entrypoint: string, track: (file: string, directory?: boolean) => void) {
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.bun.ts</path>
<type>file</type>
<content>
1: import { createRequire } from "node:module"
2: import { readFileSync } from "node:fs"
3: import path from "node:path"
4: import { fileURLToPath, pathToFileURL } from "node:url"
5: import { Host } from "./host.js"
6: import { localSource } from "./source.js"
7:
8: let generation = Date.now()
9:
10: export async function prepareSource(entrypoint: string, track: (file: string, directory?: boolean) => void) {
11: const root = fileURLToPath(entrypoint)
12: const files = new Set<string>()
13: const visit = (file: string, search = "") => {
14: if (file !== root && file.split(path.sep).includes("node_modules")) return
15: if (search) delete require.cache[file + search]
16: if (files.has(file)) return
17: files.add(file)
18: // Bun exposes ESM here too. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.node.ts</path>
<type>file</type>
<content>
1: import { registerHooks } from "node:module"
2: import path from "node:path"
3: import { fileURLToPath } from "node:url"
4: import { localSource } from "./source.js"
5: import { Host } from "./host.js"
6:
7: let generation = Date.now()
8:
9: export async function prepareSource(entrypoint: string, track: (file: string, directory?: boolean) => void) {
10: const version = String(++generation)
11: const fresh = (specifier: string) => {
12: const url = new URL(specifier)
13: url.searchParams.set("__opencode_reload", version)
14: return url.href
15: }
16: const hook = registerHooks({
17: resolve(specifier, context, nextResolve) {
18: if (!context.parentURL || new URL(context.parentURL).searchParams.get("__opencode_reload") !== version)
19: return nextResolve(specifier, context)
20: const local =
21: specifier.startsWith("./") || ...
<path>/home/byk/Code/opencode-lore/packages/gateway/script/bundle.ts</path>
<type>file</type>
<content>
460: /** Whether to log requests. Default: false. Env: LORE_DEBUG */
461: debug: boolean;
462: }
463:
464: export interface StartOptions {
465: port?: number;
466: hosts?: string[];
467: debug?: boolean;
468: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
469: quiet?: boolean;
470: }
471:
472: export interface GatewayHandle {
473: config: GatewayConfig;
474: port: number;
475: /** Whether this process owns the server (started it). False when reusing an existing instance. */
476: owned: boolean;
477: /** Shut down the gateway. No-op when owned is false. */
478: shutdown: () => Promise<void>;
479: }
480:
481: /** Default port preference order when LORE_LISTEN_PORT is not set. */
482: export declare const DEFAULT_PORTS: readonly [3207, 5673];
483:
484: /** The primary default port (first in the fallback chain). ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
1: /**
2: * `lore start` — start the gateway server without auto-launching an agent.
3: *
4: * Extracted from the old top-level index.ts boot logic.
5: */
6: import { spawn } from "node:child_process";
7: import { randomBytes } from "node:crypto";
8: import { closeSync } from "node:fs";
9: import { join } from "node:path";
10: import {
11: assertGatewayAccessConfigured,
12: loadConfig,
13: DEFAULT_PORTS,
14: type GatewayConfig,
15: } from "../config";
16: import { startServer, bracketHost } from "../server";
17: import { resetPipelineState } from "../pipeline";
18: import { writePortFile, removePortFile } from "../portfile";
19: import {
20: writeGatewayProcessFile,
21: readGatewayProcessFile,
22: removeGatewayProcessFile,
23: type GatewayProcessRecord,
24: } from "../pidfile";
25: import {
26: dataDir,
27: embedding,
28: temporalEmbeddingQueue,
29: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
780: io.logInfo(`Dashboard: ${url}/ui`);
781: io.logInfo(`Logs: ${daemonLogPath()}`);
782: io.logInfo(`Stop it with: lore stop`);
783: return 0;
784: }
785: }
786:
787: const cleanup = await terminateTimedOutDaemon(
788: pid,
789: spawnedProcessIdentity,
790: io,
791: interval,
792: spawnedRecord,
793: );
794: if (cleanup.stopped && cleanup.signalled) {
795: io.logError(
796: `Gateway did not establish authenticated ownership within ${timeout}ms; terminated background pid ${pid}. Check the log: ${daemonLogPath()}`,
797: );
798: } else if (cleanup.stopped) {
799: io.logError(
800: `Gateway did not establish authenticated ownership within ${timeout}ms; background pid ${pid}'s spawned process generation is no longer running. Check the log: ${daemonLogPath()}`,
801: );
802: } else {
803: ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/gateway/test/auto-detect-remote-gateway.test.ts:
Line 36: !("LORE_REMOTE_GATEWAY" in process.env) &&
Line 37: !("LORE_HOSTED_MODE" in process.env)
Line 320: test("lore run (local: true) + non-loopback bind → remoteGateway=false (in-process callers always disable remote)", () => {
/home/byk/Code/opencode-lore/packages/website/src/content/docs/docs/environment.md:
Line 48: | `LORE_REMOTE_URL` | CLI remote helper — shared utilities for CLI commands that need to call the remote gateway REST API when `LORE_REMOTE_URL` is set. |
Line 98: | `LORE_DISABLE_VEC_WORKER` | Kill switch: force the in-process vector-search path, disabling the off-thread read-worker pool. Default-on escape hatch, not opt-in. |
/home/byk/Code/opencode-lore/packages/website/src/content/docs/docs/configuration.md:
Line 195: | `workerOffload` | boolean | `true` | | Run vector searches on a read-worker pool off ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
430: if (upstream && !output.headers["x-lore-upstream-url"]) {
431: output.headers["x-lore-upstream-url"] = upstream;
432: }
433: }
434: // Forward LORE_UPSTREAM_EXTRA_HEADERS values as literal headers so
435: // corporate proxies / LiteLLM / Cloudflare AI Gateway get the
436: // required auth/team-routing tokens on every call. The gateway
437: // applies the same env var on its side as a safety net (so the
438: // headers are present even when the plugin is bypassed).
439: const extrasRaw = process.env.LORE_UPSTREAM_EXTRA_HEADERS;
440: if (extrasRaw) {
441: for (const rawLine of extrasRaw.split(/\r?\n/)) {
442: const line = rawLine.trim();
443: if (!line) continue;
444: const colonIdx = line.indexOf(":");
445: if (colonIdx <= 0) ...
Found 12 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/commands/doctor.ts:
Line 6: * its own thin IO shell for `collectInventory()` / `probeGateway()` /
Line 132: ? await probeGateway(`http://127.0.0.1:${gatewayPort}`)
/home/byk/Code/opencode-lore/packages/gateway/src/cli/run.ts:
Line 454: const alive = await probeGateway(remoteUrl);
/home/byk/Code/opencode-lore/packages/gateway/src/cli/setup.ts:
Line 3460: return probeGateway(origin);
/home/byk/Code/opencode-lore/packages/gateway/src/cli/inventory.ts:
Line 592: ? await probeGateway(`http://127.0.0.1:${gatewayPort}`)
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 198: export async function probeGatewayIdentity(
Line 207: export async function probeGatewayIdentityDetailed(
Line 241: export async function probeGatewayProcessStatus(
Line 292: export async function probeGatewayStatus(
Line 314: export async function probeGateway(
Line 334: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
183: /**
184: * Fetch an internal gateway endpoint without WHATWG's browser forbidden-port
185: * list breaking valid loopback listeners. Non-loopback URLs retain the normal
186: * Fetch transport and semantics used for remote/LAN gateways.
187: */
188: export function internalProbeFetch(
189: url: string,
190: init?: RequestInit,
191: ): Promise<Response> {
192: return isLoopbackProbeUrl(url)
193: ? nodeHttpFetch(url, init)
194: : Promise.resolve(fetch(url, init));
195: }
196:
197: /** Probe the owner-only control endpoint and return its process identity. */
198: export async function probeGatewayIdentity(
199: baseURL: string,
200: token: string,
201: timeoutMs = 1500,
202: ): Promise<GatewayHealthIdentity | null> {
203: const result = await probeGatewayIdentityDetailed(baseURL, token, timeoutMs);
204: return result.kind === "authenticated" ? ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore/quality/benchmarks/source-frontier-1710.md: Line 92: pnpm exec vitest run packages/gateway/test/source-window-benchmark.test.ts Line 95: pnpm exec vitest run packages/gateway/test/source-window-benchmark.test.ts /home/byk/Code/opencode-lore/quality/benchmarks/semantic-token-cache-1710.md: Line 13: `gatewayMessagesToLore` tokenizes both full provenance and visible JSON for Line 32: LORE_TOKEN_BENCHMARK=1 pnpm exec vitest run packages/gateway/test/semantic-token-benchmark.test.ts Line 50: The final implementation, including lifecycle checks and nonblocking writes, Line 91: review-found lifecycle and contention regressions also failed before repair. /home/byk/Code/opencode-lore/README.md: Line 15: Published as [`@loreai/gateway`](https://www.npmjs.com/package/@loreai/gateway) (standalone proxy), [`@loreai/opencode`](https://www.npmjs.com/package/@loreai/opencode) (OpenCode plugin), ...
Found 5 matches /home/byk/Code/opencode-lore/quality/REQUIREMENTS.md: Line 135: **Use Cases:** UC-02 (long-running gateway lifecycle) /home/byk/Code/opencode-lore/quality/EXPLORATION.md: Line 249: 10. **>=2 multi-function pattern deep dives:** Fallback (4 cascades with `embed()`, `ftsQuery()`, `startGateway()`, `identifySession()`), Cross-Implementation (3 analyses with `buildAnthropicRequest`/`buildOpenAIMessages`/`translateStream`), Enumeration (`resolveUpstreamRoute`/`AGENTS`/`saveSessionTracking`/`forSession`), API Surface (`cmdList`/API/`listKnowledge`, `executeRecall`/`commandRecall`). All 4 deep dives trace multiple functions. PASS /home/byk/Code/opencode-lore/packages/website/src/content/docs/docs/environment.md: Line 105: The gateway reads env vars once at startup (`loadConfig()` in `packages/gateway/src/config.ts`) and once at the boundary of each subsystem (worker model, cache warmer, cost tracker, etc.). ...
/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { PluginContext } from "./context.js"
2:
3: export interface Plugin {
4: readonly id: string
5: readonly setup: (context: PluginContext) => Promise<void> | void
6: }
7:
8: export function define(plugin: Plugin) {
9: return plugin
10: }
11:
12: export interface PluginDomain {
13: readonly add: (plugin: Plugin) => Promise<void>
14: readonly remove: (id: string) => Promise<void>
15: }
(End of file - total 15 lines)
</content>
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/context.ts</path>
<type>file</type>
<content>
1: import type { PluginOptions } from "../options.js"
2: import type { AgentHooks } from "./agent.js"
3: import type { AISDKHooks } from "./aisdk.js"
4: import type { CatalogHooks } from "./catalog.js"
5: import type { CommandHooks } from "./command.js"
6: import type { IntegrationHooks } from "./integration.js"
7: import type { PluginDomain } from "./plugin.js"
8: import type { ReferenceHooks } from "./reference.js"
9: import type { SkillHooks } from "./skill.js"
10: import type { Reload } from "./registration.js"
11:
12: export interface PluginContext {
13: readonly options: PluginOptions
14: readonly agent: AgentHooks & Reload
15: readonly aisdk: AISDKHooks
16: readonly catalog: CatalogHooks & Reload
17: readonly command: CommandHooks & Reload
18: readonly integration: IntegrationHooks & Reload
19: readonly plugin: PluginDomain
20: readonly reference: ...
No files found
No files found
Found 18 matches
/home/byk/Code/opencode/packages/core/test/plugin/host.ts:
Line 41: add: () => Effect.die("unused plugin.add"),
/home/byk/Code/opencode/packages/core/src/config/plugin/external.ts:
Line 83: yield* ctx.plugin.add({
/home/byk/Code/opencode/packages/core/src/plugin/internal.ts:
Line 105: return plugin.add(PluginV2.ID.make(loaded.id), loaded.effect)
/home/byk/Code/opencode/packages/core/src/plugin/promise.ts:
Line 76: return run(host.plugin.add(child))
/home/byk/Code/opencode/packages/core/src/plugin/host.ts:
Line 194: add: (input) => plugin.add(PluginV2.ID.make(input.id), input.effect),
/home/byk/Code/opencode/packages/schema/src/plugin.ts:
Line 10: type: "plugin.added",
/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts:
Line 12: export interface PluginDomain {
Line 13: readonly add: (plugin: Plugin) => ...
<path>/home/byk/Code/opencode/packages/core/src/config/plugin/external.ts</path>
<type>file</type>
<content>
50: return path.resolve(directory, ref.package)
51: }
52: return ref.package
53: })()
54: configured.push({ package: packageName, options: ref.options })
55: }
56: }
57:
58: if (entry.type === "directory") {
59: const files = yield* fs
60: .glob("{plugin,plugins}/*.{ts,js}", {
61: cwd: entry.path,
62: absolute: true,
63: include: "file",
64: dot: true,
65: symlink: true,
66: })
67: .pipe(Effect.orElseSucceed(() => []))
68: files.sort()
69: for (const file of files) configured.push({ package: file })
70: }
71: }
72:
73: for (const ref of configured) {
74: yield* Effect.gen(function* () {
75: const entrypoint = ...
<path>/home/byk/Code/opencode/packages/core/src/plugin/promise.ts</path>
<type>file</type>
<content>
1: export * as PluginPromise from "./promise"
2:
3: import { define } from "@opencode-ai/plugin/v2/effect"
4: import type { Plugin, PluginContext, Registration } from "@opencode-ai/plugin/v2/promise"
5: import { Effect, Scope } from "effect"
6:
7: // The Effect host hands back this registration shape; mirror it structurally so
8: // we do not have to alias the Effect package's `Registration` against the Promise one.
9: type HostRegistration = { readonly dispose: Effect.Effect<void> }
10:
11: /**
12: * Adapts a Promise plugin into an Effect plugin so the existing Effect-only
13: * loader (`PluginV2` / `PluginInternal`) can run it unchanged.
14: *
15: * Hook registrations created during the async `setup` attach to the plugin's
16: * scope, so unloading the plugin disposes them. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
Found 8 matches
/home/byk/Code/opencode-lore/packages/gateway/script/bundle.ts:
Line 97: entryPoints: [join(packageDir, "src/index.ts")],
Line 133: entryPoints: [join(packageDir, "src/index.ts")],
Line 443: const typeDeclarations = `/** Gateway configuration — loaded from environment variables with sensible defaults. */
Line 464: export interface StartOptions {
Line 472: export interface GatewayHandle {
Line 509: export declare function startGateway(opts?: StartOptions): Promise<GatewayHandle>;
Line 527: writeFileSync(join(distDir, "index.d.cts"), typeDeclarations);
/home/byk/Code/opencode-lore/packages/gateway/script/build.ts:
Line 67: ["index.bun.js", 'export * from "../src/index.ts";\n'],
<path>/home/byk/Code/opencode-lore/packages/gateway/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/gateway",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Lore as a transparent LLM proxy — context management for any AI coding client",
7: "main": "./dist/index.cjs",
8: "types": "./dist/index.d.cts",
9: "exports": {
10: ".": {
11: "types": "./dist/index.d.cts",
12: "bun": "./dist/index.bun.js",
13: "require": "./dist/index.cjs",
14: "default": "./dist/index.cjs"
15: }
16: },
17: "bin": {
18: "lore": "./dist/bin.cjs",
19: "lore-gateway": "./dist/bin.cjs"
20: },
21: "scripts": {
22: "typecheck": "tsc --noEmit",
23: "build": "tsx script/build.ts",
24: "bundle": "tsx script/bundle.ts",
25: "build:binary": "tsx script/build.ts --binary",
26: "build:binary:sea": "tsx script/build-binary-sea.ts",
27: "start": "tsx ...
<path>/home/byk/Code/opencode-lore/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: }
15: },
16: "scripts": {
17: "typecheck": "tsc --noEmit",
18: "build": "echo '@loreai/opencode ships raw TS — no build step needed'"
19: },
20: "peerDependencies": {
21: "@opencode-ai/plugin": ">=1.1.0"
22: },
23: "dependencies": {
24: "@loreai/core": "workspace:*",
25: "@loreai/gateway": "workspace:*"
26: },
27: "devDependencies": {
28: "@opencode-ai/plugin": "^1.1.39",
29: "@opencode-ai/sdk": "^1.1.39",
30: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts</path>
<type>file</type>
<content>
80: const load = Effect.fn("PluginModule.load")(function* (
81: operation: Extract<ConfigPluginSource.Operation, { type: "add" }>,
82: sources: ReturnType<typeof createPluginSources>,
83: options?: { readonly install?: boolean },
84: ) {
85: const local = path.isAbsolute(operation.target)
86: const npm = yield* Npm.Service
87: const installed = local
88: ? undefined
89: : options?.install === false
90: ? yield* npm.resolve(operation.target)
91: : yield* npm.add(operation.target)
92: // Legacy auto-discovery still admits standalone server sources. Configured
93: // local plugins always arrive here as directories.
94: const entrypoints: Host.Entrypoints =
95: local && (yield* Effect.promise(() => stat(operation.target))).isFile()
96: ? { server: pathToFileURL(operation.target).href }
97: : yield* Effect.sync(() => ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1: import { AsyncLocalStorage } from "node:async_hooks";
2: import { createHash, randomBytes } from "node:crypto";
3: import {
4: closeSync,
5: constants,
6: fchmodSync,
7: fstatSync,
8: fsyncSync,
9: lstatSync,
10: linkSync,
11: mkdirSync,
12: openSync,
13: readFileSync,
14: readdirSync,
15: realpathSync,
16: renameSync,
17: rmdirSync,
18: rmSync,
19: unlinkSync,
20: writeFileSync,
21: type Stats,
22: } from "node:fs";
23: import { homedir } from "node:os";
24: import {
25: basename,
26: dirname,
27: isAbsolute,
28: join,
29: relative,
30: resolve,
31: } from "node:path";
32:
33: const LOCK_VERSION = 1;
34: const DIRECTORY_MODE = 0o700;
35: const FILE_MODE = 0o600;
36: const OWNER_FILE = "owner.json";
37: const UNINSTALL_TOMBSTONE_FILE = "uninstalled.json";
38: const INITIALIZATION_CLAIM_MARKER = ".init.";
39: const ...
Found 5 matches
/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts:
Line 198: const lockContext = new AsyncLocalStorage<LifecycleLock>();
Line 202: return lockContext.exit(action);
Line 1841: export async function withLifecycleLock<T>(
Line 1846: const inherited = lockContext.getStore();
Line 1853: return lockContext.run(lock, async () => {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1825: `Lore lifecycle is busy${detail}; retry after the operation completes`,
1826: );
1827: }
1828: await options.sleep(
1829: Math.min(options.retryDelayMs, Math.max(0, deadline - options.now())),
1830: );
1831: }
1832: } finally {
1833: if (!ownerStageRemoved) {
1834: removeExpectedOwnerRecord(ownerStage.initializationClaimPath, ownerStage);
1835: removeExpectedOwnerRecord(ownerStage.path, ownerStage);
1836: }
1837: }
1838: }
1839:
1840: /** Run a lifecycle transition under the lock, with async-context reentrancy. */
1841: export async function withLifecycleLock<T>(
1842: operation: LifecycleOperation,
1843: action: (lock: LifecycleLock) => Promise<T> | T,
1844: options: LifecycleLockOptions = {},
1845: ): Promise<T> {
1846: const inherited = lockContext.getStore();
1847: if (inherited) ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
1: import { createServer as createHttpServer } from "node:http";
2: import { mkdtempSync, rmSync } from "node:fs";
3: import {
4: createServer as createNetServer,
5: type AddressInfo,
6: type Server as NetServer,
7: } from "node:net";
8: import { tmpdir } from "node:os";
9: import { join } from "node:path";
10: import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
11: import { readPortFile, removePortFile } from "../src/portfile";
12: import {
13: readGatewayProcessFile,
14: removePidFile,
15: writeGatewayProcessFile,
16: } from "../src/pidfile";
17:
18: describe("startGateway authenticated reuse", () => {
19: const teardowns: Array<() => void | Promise<void>> = [];
20: let base: string;
21: let previousXdg: string | undefined;
22:
23: beforeEach(() => {
24: previousXdg = process.env.XDG_DATA_HOME;
25: base = ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts</path>
<type>file</type>
<content>
330: const core = await import("@loreai/core");
331: vi.spyOn(embedding, "settleDocumentEmbeds").mockResolvedValue(undefined);
332: vi.spyOn(embedding, "resetProvider").mockResolvedValue(undefined);
333: vi.spyOn(core, "shutdownVectorPoolAsync").mockResolvedValue(undefined);
334: vi.spyOn(core, "close").mockImplementation(() => {});
335: const { startGateway } = await import("../src/cli/start");
336: let processRecord: GatewayProcessRecord | null = null;
337: let requestRemoteShutdown: (() => void | Promise<void>) | undefined;
338: let markReported!: () => void;
339: const reported = new Promise<void>((resolve) => {
340: markReported = resolve;
341: });
342: const warnings: string[] = [];
343: vi.spyOn(log, "warn").mockImplementation((message) => {
344: warnings.push(String(message));
345: if ...
/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts
<path>/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts</path>
<type>file</type>
<content>
1: import { describe, test, expect, afterAll } from "vitest";
2: import { probeGateway } from "../src/internal";
3:
4: /**
5: * Smoke tests for the in-process gateway startup.
6: *
7: * These exercise startGateway from @loreai/gateway directly (which is what
8: * the plugin's startInProcess delegates to). Tests use ephemeral ports so
9: * they don't collide with a running gateway.
10: */
11:
12: // Minimal view of the @loreai/gateway module surface used by these tests.
13: type GatewayServer = { stop: () => void; port: number; hosts: string[] };
14: type GatewayModule = {
15: loadConfig: () => { port: number } & Record<string, unknown>;
16: startServer: (config: unknown) => Promise<GatewayServer>;
17: };
18:
19: // Track shutdown handles to clean up after tests. ...
Found 28 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 90: remoteUrl?: string;
Line 451: if (opts.remoteUrl) args.push("--remote", opts.remoteUrl);
/home/byk/Code/opencode-lore/packages/gateway/src/cli/main.ts:
Line 220: remoteUrl: values.remote ?? undefined,
/home/byk/Code/opencode-lore/packages/gateway/src/cli/commands/start.ts:
Line 11: * opts.remoteUrl — remote gateway URL (string, optional)
Line 107: remoteUrl: flags.remote,
/home/byk/Code/opencode-lore/packages/gateway/src/cli/run.ts:
Line 420: const isLocal = !(opts.remoteUrl || config.remoteUrl);
Line 445: if (opts.remoteUrl || config.remoteUrl) {
Line 449: const remoteUrl = opts.remoteUrl || config.remoteUrl;
Line 450: if (!remoteUrl) {
Line 454: const alive = await probeGateway(remoteUrl);
Line 456: console.error(`[lore] Remote gateway at ${remoteUrl} is not reachable.`);
Line 462: gatewayUrl = ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/plugin.ts</path>
<type>file</type>
<content>
1: import type { Effect, Scope } from "effect"
2: import type { PluginContext } from "./context.js"
3:
4: export interface Plugin<R = Scope.Scope> {
5: readonly id: string
6: readonly effect: (context: PluginContext) => Effect.Effect<void, never, R>
7: }
8:
9: export function define<R = Scope.Scope>(plugin: Plugin<R>) {
10: return plugin
11: }
12:
13: export interface PluginDomain {
14: readonly add: (plugin: Plugin) => Effect.Effect<void>
15: readonly remove: (id: string) => Effect.Effect<void>
16: }
(End of file - total 16 lines)
</content>
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/gateway/test/worker-health.test.ts:
Line 727: // Scoped per provider.
/home/byk/Code/opencode-lore/packages/gateway/test/sync-orgs.integration.test.ts:
Line 2: * Integration tests for migration 0023 — Org → Scope registry (E-1, #827) against a real
/home/byk/Code/opencode-lore/packages/gateway/test/recall.test.ts:
Line 42: labelToScope,
Line 371: describe("scopeToLabel / labelToScope", () => {
Line 385: expect(labelToScope("all archives")).toBe("all");
Line 386: expect(labelToScope("session history")).toBe("session");
Line 387: expect(labelToScope("project archives")).toBe("project");
Line 388: expect(labelToScope("knowledge base")).toBe("knowledge");
Line 392: expect(labelToScope("unknown label")).toBe("all");
/home/byk/Code/opencode-lore/packages/gateway/src/server.ts:
Line 58: createForegroundAbortScope,
Line 413: const abortScope = ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/internal.ts</path>
<type>file</type>
<content>
180: */
181: export async function resolveGatewayUrl(): Promise<string | null> {
182: // 0. Remote gateway — skip local discovery/startup entirely.
183: if (process.env.LORE_REMOTE_URL) {
184: const url = gatewayUrlForLog(
185: process.env.LORE_REMOTE_URL.replace(/\/$/, ""),
186: );
187: if (url !== "invalid" && (await probeGateway(url))) return url;
188: log.info(
189: `pi: remote gateway at ${url} not reachable, falling through to local discovery`,
190: );
191: }
192:
193: // 1. Explicit env var — probe it to verify it's actually reachable.
194: if (process.env.LORE_GATEWAY_URL) {
195: const url = gatewayUrlForLog(
196: process.env.LORE_GATEWAY_URL.replace(/\/$/, ""),
197: );
198: if (url !== "invalid" && (await probeGateway(url))) return url;
199: // env var set but gateway unreachable — fall through to discovery
200: ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/index.ts</path>
<type>file</type>
<content>
45: } from "./internal";
46:
47: /** Guard against double-installing the fetch interceptor if Pi re-initializes. */
48: let fetchInterceptorInstalled = false;
49:
50: /**
51: * Pi extension entry point.
52: *
53: * Pi calls this function when loading the extension — either via `pi -e`
54: * or after `pi install`. Detects the Lore gateway and, if available,
55: * redirects provider URLs and registers compaction override.
56: */
57: export default async function lorePiExtension(pi: ExtensionAPI): Promise<void> {
58: let gatewayBase = "";
59: let loreActive = false;
60: const loreDisabled =
61: process.env.LORE_DISABLED === "1" || process.env.LORE_DISABLED === "true";
62: // The extension is inert under `NODE_ENV=test` so unrelated package test
63: // suites don't accidentally probe/start a gateway. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts</path>
<type>file</type>
<content>
1: export * as PluginModule from "./module.js"
2:
3: import type { Plugin } from "@opencode/plugin/effect/plugin"
4: import { Host } from "@opencode/plugin/host"
5: import { createPluginSources } from "@opencode/plugin/source"
6: import { Npm } from "@opencode/util/npm"
7: import { Deferred, Effect, FiberSet, PubSub, Schema, Stream } from "effect"
8: import path from "path"
9: import { stat } from "node:fs/promises"
10: import { fileURLToPath, pathToFileURL } from "url"
11: import type { ConfigPluginSource } from "../config/plugin/source.js"
12: import type { Generation } from "../plugin.js"
13: import { PluginPromise } from "./promise.js"
14: import { Watcher } from "../filesystem/watcher.js"
15:
16: export const make = Effect.fn("PluginModule.make")(function* () {
17: const watcher = yield* Watcher.Service
18: const scope = yield* Effect.scope
19: const runPromise = ...
File not found: /home/byk/Code/opencode-v2-pilot/packages/plugin/src/v2/effect/context.ts
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/tui/context.ts
Found 5 matches /home/byk/Code/opencode-lore/packages/opencode/src/internal.ts: Line 141: export async function probeGateway( /home/byk/Code/opencode-lore/packages/opencode/src/index.ts: Line 16: probeGateway, Line 48: if (await probeGateway(url)) return url; Line 57: if (await probeGateway(url)) return url; Line 76: if (await probeGateway(url)) return url;
<path>/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts</path>
<type>file</type>
<content>
125: : {}),
126: },
127: };
128: }
129: if (!pinned.openai) {
130: pinned.openai = {
131: options: { baseURL: baseUrl, headerTimeout: false },
132: };
133: }
134: cfg.provider = { ...existingProvider, ...pinned };
135: }
136:
137: /**
138: * Check if the Lore gateway is reachable at the given base URL.
139: * Short timeout so this doesn't delay OpenCode startup noticeably.
140: */
141: export async function probeGateway(
142: baseURL: string,
143: timeoutMs = 1500,
144: ): Promise<boolean> {
145: const controller = new AbortController();
146: const timer = setTimeout(() => controller.abort(), timeoutMs);
147: try {
148: const url = `${baseURL}/health`;
149: if (isLoopbackUrl(url)) return await probeLoopback(url, controller.signal);
150: return (await fetch(url, { signal: controller.signal })).ok;
151: } catch ...
/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore/packages/opencode/src/index.ts
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "name": "@opencode/plugin",
4: "version": "1.18.15",
5: "type": "module",
6: "license": "MIT",
7: "scripts": {
8: "test": "bun test --only-failures",
9: "typecheck": "tsgo --noEmit",
10: "build": "tsc -p tsconfig.build.json"
11: },
12: "exports": {
13: ".": "./src/promise/index.ts",
14: "./effect": "./src/effect/index.ts",
15: "./host": "./src/host.ts",
16: "./tui": "./src/tui/index.ts",
17: "./*": "./src/*.ts"
18: },
19: "imports": {
20: "#plugin-source": {
21: "bun": "./src/source.bun.ts",
22: "node": "./src/source.node.ts",
23: "default": "./src/source.node.ts"
24: }
25: },
26: "files": [
27: "dist"
28: ],
29: "dependencies": {
30: "@ai-sdk/provider": "3.0.8",
31: "@opencode/ai": "workspace:*",
32: ...
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/worktree.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/websearch.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/vcs.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/tool.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/storage.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/skill.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/session.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/rpc.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/registration.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/reference.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/permission.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/mcp.ts /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/integrat...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/effect/plugin.ts</path>
<type>file</type>
<content>
1: import type { ExperimentalApi, GenerateApi, PluginApi } from "@opencode/client/effect/api"
2: import type { Location } from "@opencode/schema/location"
3: import type { Effect, Scope } from "effect"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
1: import { Tool } from "@opencode/schema/tool"
2: import type { Rpc } from "@opencode/schema/rpc"
3: import type { RpcCallOptions, RpcEventPayload } from "@opencode/client/promise/api"
4: import { Effect, Schema, SchemaAST, Stream } from "effect"
5: import type { Scope } from "effect"
6: import { HttpApiEndpoint, HttpApiSchema } from "effect/unstable/httpapi"
7: import { define } from "../effect/plugin.js"
8: import type { Plugin } from "./plugin.js"
9: import type { Info } from "./tool.js"
10: import type { RpcDomain, RpcHandlers } from "./rpc.js"
11:
12: type HostRegistration = { readonly dispose: Effect.Effect<void> }
13: type Registration = { readonly dispose: () => Promise<void> }
14: type PromiseContext = Parameters<Plugin["setup"]>[0]
15: type PromiseEvent = ReturnType<PromiseContext["event"]["subscribe"]> extends AsyncIterable<infer Event> ? ...
Found 3 matches /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts: Line 52: yield* Effect.addFinalizer(() => Effect.promise(() => Promise.all(Array.from(subscriptions, (close) => close())))) Line 599: Effect.promise(() => Promise.resolve(plugin.setup(context2))), Line 600: (cleanup) => (cleanup ? Effect.promise(() => Promise.resolve(cleanup())) : Effect.void),
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
560: host.worktree.transform((editor) =>
561: callback({
562: add: (definition) =>
563: editor.add({
564: id: definition.id,
565: create: (input) => attempt((signal) => definition.create(input, { signal })),
566: remove: (input) => attempt((signal) => definition.remove(input, { signal })),
567: list: (directory) => attempt((signal) => definition.list(directory, { signal })),
568: }),
569: }),
570: ),
571: ),
572: },
573: session: {
574: hook: (name, callback, options) =>
575: register(
576: host.session.hook(name, (event) => Effect.promise(() => ...
Found 1 matches /home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts: Line 421: export function installFetchInterceptor(
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
390: // `/chat/completions`, issue #1052) or uses a non-standard prefix work as a
391: // pure passthrough. Only set when it's a sane absolute path.
392: if (upstreamPath.startsWith("/")) {
393: headers.set("x-lore-upstream-path", upstreamPath);
394: }
395:
396: // Inject dynamic context headers (session ID, project, git remote, etc.).
397: // Only set if not already present — per-request hooks may have set them.
398: try {
399: for (const [k, v] of Object.entries(config.getHeaders())) {
400: if (!headers.has(k)) headers.set(k, v);
401: }
402: } catch (e) {
403: log.error("fetch-interceptor: getHeaders() failed:", e);
404: }
405:
406: return headers;
407: }
408:
409: function observeRequestHeaders(
410: headers: Headers,
411: config: FetchInterceptorConfig,
412: ): void {
413: if (!config.onRequestHeaders) return;
414: try ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
535: );
536: observeRequestHeaders(headers, config);
537: log.info(
538: `fetch-interceptor: ${upstream.host}${upstream.pathname} → gateway (body-detected ${detected})`,
539: );
540: return originalFetch(rewrite.gatewayUrl, { ...init, headers });
541: }
542:
543: // LLM-looking path we couldn't intercept (no body, or unrecognized
544: // shape) — warn once so the operator can extend the patterns.
545: const warnKey = `${upstream.host}${upstream.pathname}`;
546: if (!warnedPaths.has(warnKey)) {
547: warnedPaths.add(warnKey);
548: log.warn(
549: `fetch-interceptor: ${upstream.host}${upstream.pathname} matched no LLM API pattern — request bypassing Lore gateway. Add a pattern in fetch-interceptor.ts if this is an LLM endpoint.`,
550: );
551: }
552: }
553: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/portfile.ts</path>
<type>file</type>
<content>
1: /**
2: * Port file management — allows plugins to discover the gateway's actual port.
3: *
4: * When the gateway starts (especially on a fallback or random port), it writes
5: * the actual port number to `~/.local/share/lore/gateway.port`. Plugins read
6: * this file to locate the gateway without hardcoding a specific port.
7: *
8: * The file is removed on clean shutdown. Stale files (from crashes) are
9: * harmless — plugins probe `/health` after reading the port and ignore
10: * unresponsive ports.
11: */
12: import { randomBytes } from "node:crypto";
13: import { join } from "node:path";
14: import { linkSync, renameSync, rmSync } from "node:fs";
15: import { dataDir } from "@loreai/core";
16: import { atomicWriteRuntimeFile, readRuntimeFile } from "./runtime-files";
17:
18: const PORTFILE_NAME = "gateway.port";
19:
20: export interface GatewayPortRecord {
21: ...
Found 72 matches
/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-sqlite-readers.test.ts:
Line 7: * - SQLite WAL TRUNCATE requires ZERO concurrent readers — each vector
Line 19: * - The strict shutdown order: pipeline stop → embedding drain → embedding
Line 23: * - `close()` is idempotent and a no-op when the DB was never opened.
Line 33: close as closeDb,
Line 54: /** Install no-op spies on the embedding shutdown hooks and `shutdownVectorPoolAsync`
Line 61: vi.spyOn(core, "shutdownVectorPoolAsync").mockResolvedValue(undefined);
Line 66: vi.spyOn(embedding, "settleDocumentEmbeds").mockResolvedValue(undefined);
Line 67: vi.spyOn(embedding, "resetProvider").mockResolvedValue(undefined);
Line 80: closeDb();
Line 103: describe("startGateway shutdown — strict order (#1599)", () => {
Line 105: const order: string[] = [];
Line 111: order.push("scheduler-stop");
Line 117: order.push("scheduler-settle");
...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-active-stream.test.ts</path>
<type>file</type>
<content>
1: import { createServer, type Server } from "node:http";
2: import { once } from "node:events";
3: import { createConnection, type AddressInfo } from "node:net";
4: import { afterEach, describe, expect, it, vi } from "vitest";
5: import { embedding, log } from "@loreai/core";
6: import type { GatewayProcessRecord } from "../src/pidfile";
7:
8: afterEach(() => {
9: vi.restoreAllMocks();
10: });
11:
12: describe("startGateway active-stream shutdown", () => {
13: it("bounds authenticated shutdown when a socket sends incomplete headers", async () => {
14: const core = await import("@loreai/core");
15: vi.spyOn(embedding, "settleDocumentEmbeds").mockResolvedValue(undefined);
16: vi.spyOn(embedding, "resetProvider").mockResolvedValue(undefined);
17: vi.spyOn(core, "shutdownVectorPoolAsync").mockResolvedValue(undefined);
18: vi.spyOn(core, ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore/packages/gateway/test/server.test.ts: Line 584: // bind with EADDRNOTAVAIL, which startGateway() then misreported as a port /home/byk/Code/opencode-lore/packages/gateway/test/auto-detect-remote-gateway.test.ts: Line 22: * Replicate the remote-gateway override logic from startGateway() so we can /home/byk/Code/opencode-lore/packages/gateway/test/hosted-config.test.ts: Line 2: * Tests for hosted mode configuration defaults in startGateway(). Line 4: * The override logic in startGateway() follows three-tier precedence: Line 15: * Replicate the hosted mode override logic from startGateway() so we can /home/byk/Code/opencode-lore/packages/gateway/src/server.ts: Line 782: `Use loadConfig() or startGateway() for a fully-populated config.`, Line 1254: // error still propagate to startGateway()'s port-fallback/reuse logic. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/aisdk.ts</path>
<type>file</type>
<content>
1: import type { LanguageModelV3 } from "@ai-sdk/provider"
2: import type { Model } from "@opencode/schema/model"
3: import type { ModelHooks } from "./registration.js"
4:
5: export interface AISDKHooks {
6: sdk: {
7: readonly model: Model.Info
8: readonly package: string
9: readonly options: Record<string, any>
10: sdk?: any
11: }
12: language: {
13: readonly model: Model.Info
14: readonly sdk: any
15: readonly options: Record<string, any>
16: language?: LanguageModelV3
17: }
18: }
19:
20: export interface AISDKDomain {
21: readonly hook: ModelHooks<AISDKHooks>
22: }
(End of file - total 22 lines)
</content>
Found 12 matches
/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts:
Line 84: * and the fetch interceptor skips 127.0.0.1 to avoid loops, so the call
Line 150: return (await fetch(url, { signal: controller.signal })).ok;
/home/byk/Code/opencode-lore/packages/opencode/src/index.ts:
Line 25: * URL context), this plugin installs a fetch-level interceptor that
Line 131: // `currentProject` is a fallback for the fetch interceptor's `getHeaders()`
Line 224: * process-wide fetch interceptor). True under test runners — `NODE_ENV=test`
Line 226: * spin up a gateway or patch `globalThis.fetch`.
Line 333: // for fetches that arrive without a known session ID (e.g., direct
Line 334: // SDK fetches that skip the plugin's chat.headers hook).
Line 378: // fetch interceptor (installed once per process). ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
210: sessionParent.set(sessionID, { parentID, lastSeenAt: Date.now() });
211: reapStaleSessionParent();
212: return parentID;
213: } catch {
214: // Best-effort: never break or slow the request path on a lookup failure.
215: return null;
216: }
217: }
218:
219: /** Memoized lore init promise — ensures concurrent plugin calls don't race. */
220: let loreInitPromise: Promise<string | null> | null = null;
221:
222: /**
223: * Whether the plugin should stay inert (skip gateway probe/start and the
224: * process-wide fetch interceptor). True under test runners — `NODE_ENV=test`
225: * or a `.test.` argv entry — so unrelated package suites don't accidentally
226: * spin up a gateway or patch `globalThis.fetch`. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
70: * for the writer's checkpoint+close. Mirrors {@link EMBED_DRAIN_DEADLINE_MS}'s
71: * safety floor of 500ms so an aggressive `LORE_SHUTDOWN_TIMEOUT_MS` (e.g.
72: * 1000ms) doesn't shrink the pool budget into a guaranteed timeout.
73: */
74: const VECTOR_POOL_SHUTDOWN_DEADLINE_MS = Math.max(
75: Math.min(
76: DEFAULT_VECTOR_POOL_SHUTDOWN_DEADLINE_MS,
77: SHUTDOWN_DEADLINE_MS - 500,
78: ),
79: 500,
80: );
81:
82: export interface StartOptions {
83: port?: number;
84: hosts?: string[];
85: debug?: boolean;
86: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
87: quiet?: boolean;
88: /** Remote gateway URL. When set, `lore run` delegates to this gateway
89: * instead of starting a local one. Overrides LORE_REMOTE_URL env var. */
90: remoteUrl?: string;
91: /**
92: * When true, disables hosted mode even for `lore ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
800: `Gateway did not establish authenticated ownership within ${timeout}ms; background pid ${pid}'s spawned process generation is no longer running. Check the log: ${daemonLogPath()}`,
801: );
802: } else {
803: io.logError(
804: `Gateway startup failed with unknown child state: background pid ${pid} did not establish authenticated ownership and could not be confirmed stopped. Check the log and process before retrying: ${daemonLogPath()}`,
805: );
806: }
807: return 1;
808: }
809:
810: /** Spawn the detached child gateway with stdio redirected to the log file. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-lore/AGENTS.md</path> <type>file</type> <content> 1: <!-- This section is maintained by the coding agent via lore (https://github.com/BYK/loreai) --> 2: ## Long-term Knowledge 3: 4: For long-term knowledge entries managed by [lore](https://github.com/BYK/loreai) (gotchas, patterns, decisions, architecture), see [`.lore.md`](.lore.md) in the project root. 5: <!-- End lore-managed section --> 6: 7: ## Review 8: 9: See [`quality/REVIEW.md`](quality/REVIEW.md) for the review heuristics and workflow — regression-test discipline, adversarial-order state setup, fan-out registry coverage, recurring bug-class batteries, and the two-reviewer rule. Every non-trivial PR requires an adversarial correctness review before merge. 10: 11: # Project Overview 12: 13: Lore is a **three-tier memory architecture** for AI coding agents. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: }
15: },
16: "scripts": {
17: "typecheck": "tsc --noEmit",
18: "build": "echo '@loreai/opencode ships raw TS — no build step needed'"
19: },
20: "peerDependencies": {
21: "@opencode-ai/plugin": ">=1.1.0"
22: },
23: "dependencies": {
24: "@loreai/core": "workspace:*",
25: "@loreai/gateway": "workspace:*"
26: },
27: "devDependencies": {
28: "@opencode-ai/plugin": "^1.1.39",
29: "@opencode-ai/sdk": "^1.1.39",
30: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
Found 32 matches
/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts:
Line 3: import { LorePlugin } from "../src/index";
Line 37: type PluginInput = Parameters<typeof LorePlugin>[0];
Line 38: const hooks = await LorePlugin({
Line 54: describe("LorePlugin config hook", () => {
Line 252: describe("LorePlugin hooks", () => {
Line 287: // named `LorePlugin` and the same-reference `default`) — nothing else.
Line 288: test("exports only the plugin (LorePlugin + same-ref default)", async () => {
Line 291: // The default export must be the LorePlugin function reference.
Line 293: expect(mod.default).toBe(mod.LorePlugin);
Line 295: // The ONLY export keys allowed are `LorePlugin` and `default`. Any other
Line 300: expect(Object.keys(mod).sort()).toEqual(["LorePlugin", "default"]);
Line 308: expect(uniqueFns.has(mod.LorePlugin)).toBe(true);
/home/byk/Code/opencode-lore/packages/opencode/test/routing.e2e.test.ts:
...
<path>/home/byk/Code/opencode-lore/packages/opencode/test/session-state.test.ts</path> <type>file</type> <content> 1: /** 2: * Tests for per-project state in the OpenCode plugin (B2). 3: * 4: * The plugin function (`LorePlugin`) can be called multiple times in the 5: * same process — e.g., when the user has multiple OpenCode worktrees open 6: * in parallel, or when a sub-agent spawns a new project context. The 7: * per-project Map ensures that: 8: * - Each project gets its own registered project path + git remote 9: * - The `chat.headers` hook injects the right headers per request 10: * - Concurrent project registrations don't clobber each other 11: * 12: * Regression coverage for the "lore-config" bug variant where the module- 13: * level `currentProjectPath` global was overwritten by sibling project 14: * inits, causing requests to be misattributed. ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/context.ts</path>
<type>file</type>
<content>
1: import type { PluginOptions } from "../options.js"
2: import type { AgentHooks } from "./agent.js"
3: import type { AISDKHooks } from "./aisdk.js"
4: import type { CatalogHooks } from "./catalog.js"
5: import type { CommandHooks } from "./command.js"
6: import type { IntegrationHooks } from "./integration.js"
7: import type { PluginDomain } from "./plugin.js"
8: import type { ReferenceHooks } from "./reference.js"
9: import type { SkillHooks } from "./skill.js"
10: import type { Reload } from "./registration.js"
11:
12: export interface PluginContext {
13: readonly options: PluginOptions
14: readonly agent: AgentHooks & Reload
15: readonly aisdk: AISDKHooks
16: readonly catalog: CatalogHooks & Reload
17: readonly command: CommandHooks & Reload
18: readonly integration: IntegrationHooks & Reload
19: readonly plugin: PluginDomain
20: readonly reference: ...
<path>/home/byk/Code/opencode/packages/core/src/plugin.ts</path>
<type>file</type>
<content>
1: export * as PluginV2 from "./plugin"
2:
3: import { makeLocationNode } from "./effect/app-node"
4: import { Context, Deferred, Effect, Exit, Layer, Scope } from "effect"
5: import type { Plugin as PluginRuntime } from "@opencode-ai/plugin/v2/effect"
6: import { Plugin } from "@opencode-ai/schema/plugin"
7: import { AgentV2 } from "./agent"
8: import { AISDK } from "./aisdk"
9: import { Catalog } from "./catalog"
10: import { CommandV2 } from "./command"
11: import { EventV2 } from "./event"
12: import { Integration } from "./integration"
13: import { KeyedMutex } from "./effect/keyed-mutex"
14: import { PluginHost } from "./plugin/host"
15: import { Reference } from "./reference"
16: import { SkillV2 } from "./skill"
17: import { State } from "./state"
18:
19: export const ID = Plugin.ID
20: export type ID = typeof ID.Type
21: export const Event = Plugin.Event
22:
23: export interface ...
Found 100 matches (more matches available) /home/byk/Code/opencode/packages/sdk-next/test/embedded.test.ts: Line 127: Effect.forkScoped, Line 170: yield* first.events.subscribe().pipe(observe(firstReady, firstEvent), Effect.forkScoped) Line 171: yield* second.events.subscribe().pipe(observe(secondReady, secondEvent), Effect.forkScoped) /home/byk/Code/opencode/packages/opencode/test/control-plane/workspace.test.ts: Line 1113: yield* Effect.addFinalizer(() => Line 1171: yield* Effect.addFinalizer(() => Effect.sync(() => captured.dispose())) /home/byk/Code/opencode/packages/opencode/test/git/git.test.ts: Line 15: Effect.acquireRelease( /home/byk/Code/opencode/packages/opencode/test/filesystem/filesystem.test.ts: Line 16: const tmp = yield* fs.makeTempDirectoryScoped() Line 25: const tmp = yield* fs.makeTempDirectoryScoped() Line 46: const tmp = yield* fs.makeTempDirectoryScoped() Line 57: ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
1: /**
2: * Fetch-level interception for transparent LLM API proxy routing.
3: *
4: * Instead of overwriting provider baseURLs early (which loses original auth
5: * and URL context), this interceptor wraps `globalThis.fetch` to redirect
6: * outgoing LLM API calls through the Lore gateway at the HTTP level.
7: *
8: * The SDK builds requests normally (correct auth, correct URL for each
9: * provider), and the interceptor transparently reroutes them through the
10: * gateway while preserving all original headers.
11: */
12: import * as log from "./log";
13:
14: /** Configuration for the fetch interceptor. */
15: export type FetchInterceptorConfig = {
16: /** Base URL of the Lore gateway (e.g., "http://127.0.0.1:3207"). */
17: gatewayBase: string;
18: /**
19: * Dynamic headers to inject on every intercepted request. ...
Found 2 matches /home/byk/Code/opencode-lore/packages/opencode/README.md: Line 64: export LORE_REMOTE_URL=https://lore.example.com Line 68: The plugin injects the token as `x-lore-gateway-token` only for `LORE_REMOTE_URL`. It is never used as provider authentication or put in the URL.
<path>/home/byk/Code/opencode-lore/packages/opencode/README.md</path> <type>file</type> <content> 42: # or 43: export LORE_UPSTREAM_OLLAMA=http://localhost:11434 44: ``` 45: 46: The URL should be the **server root** — do not include `/v1` (the gateway appends API paths automatically). The naming convention is `LORE_UPSTREAM_<PROVIDER>` where `<PROVIDER>` is the uppercased provider name with hyphens replaced by underscores: 47: 48: | Provider | Env var | 49: |----------|---------| 50: | `vllm` | `LORE_UPSTREAM_VLLM` | 51: | `llamacpp` | `LORE_UPSTREAM_LLAMACPP` | 52: | `ollama` | `LORE_UPSTREAM_OLLAMA` | 53: | `lmstudio` | `LORE_UPSTREAM_LMSTUDIO` | 54: | `tgi` | `LORE_UPSTREAM_TGI` | 55: | `litellm` | `LORE_UPSTREAM_LITELLM` | 56: 57: Cloud providers (Anthropic, OpenAI, etc.) are routed automatically by model name and don't need this. ...
No files found
<path>/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-sqlite-readers.test.ts</path> <type>file</type> <content> 1: /** 2: * Regression test for issue #1599: gateway graceful shutdown must close the 3: * vector/read worker pool's SQLite readers BEFORE the writer close runs, and 4: * the writer close must run exactly once on the normal path. 5: * 6: * Why this matters: 7: * - SQLite WAL TRUNCATE requires ZERO concurrent readers — each vector 8: * worker holds a read-mark via its `reader.db` connection. Leaving 9: * readers up while the writer tries to close either busy-returns the 10: * checkpoint (and strands the `-wal`) or hangs on the writer's busy- 11: * timeout. Both force WAL recovery on next boot. 12: * - The pre-#1599 sync `shutdownVectorPool()` posted `shutdown` + 13: * `terminate()` in the same tick and never awaited, so a reader could 14: * outlive the writer close. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/lifecycle-lock.test.ts</path>
<type>file</type>
<content>
1: import {
2: chmodSync,
3: existsSync,
4: lstatSync,
5: mkdirSync,
6: mkdtempSync,
7: readFileSync,
8: readdirSync,
9: renameSync,
10: rmSync,
11: symlinkSync,
12: writeFileSync,
13: } from "node:fs";
14: import { spawnSync } from "node:child_process";
15: import { tmpdir } from "node:os";
16: import { dirname, join } from "node:path";
17: import { afterEach, describe, expect, test } from "vitest";
18: import {
19: acquireLifecycleLock,
20: clearUninstallTombstoneForVerifiedInstall,
21: createUninstallTombstone,
22: currentUninstallTombstoneToken,
23: isVerifiedPackageInvocation,
24: LifecycleLockBusyError,
25: LifecycleLockLostError,
26: stableUnixProcessIdentity,
27: withLifecycleLock,
28: type LifecycleLockOptions,
29: type LifecycleLockOwner,
30: } from "../src/lifecycle-lock";
31:
32: const roots: string[] = [];
33:
34: ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore/packages/gateway/test/forward-client-headers.test.ts: Line 6: * gateway decodes the client body and re-serializes (then re-compresses) it, so Line 8: * value would mislabel the re-serialized body. /home/byk/Code/opencode-lore/packages/gateway/test/data-show-metadata.test.ts: Line 73: // fetches the entry from the gateway API. The API serializes ltm.get()'s /home/byk/Code/opencode-lore/packages/gateway/test/source-checkpoint.test.ts: Line 33: serializeRecallStore, Line 34: deserializeRecallStore, Line 582: recallStore: serializeRecallStore(recalls), Line 611: expect(expandRecallMarkers(request, deserializeRecallStore(durable!))).toBe( /home/byk/Code/opencode-lore/packages/gateway/test/background-limiter.test.ts: Line 380: // Two concurrent slots should be available even with no sessions. /home/byk/Code/opencode-lore/packages/gateway/test/cch.test.ts: Line 109: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
1: import { createServer as createHttpServer } from "node:http";
2: import { mkdtempSync, rmSync } from "node:fs";
3: import {
4: createServer as createNetServer,
5: type AddressInfo,
6: type Server as NetServer,
7: } from "node:net";
8: import { tmpdir } from "node:os";
9: import { join } from "node:path";
10: import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
11: import { readPortFile, removePortFile } from "../src/portfile";
12: import {
13: readGatewayProcessFile,
14: removePidFile,
15: writeGatewayProcessFile,
16: } from "../src/pidfile";
17:
18: describe("startGateway authenticated reuse", () => {
19: const teardowns: Array<() => void | Promise<void>> = [];
20: let base: string;
21: let previousXdg: string | undefined;
22:
23: beforeEach(() => {
24: previousXdg = process.env.XDG_DATA_HOME;
25: base = ...
<skill_content name="effect">
# Skill: effect
# Effect
This codebase uses Effect for typed, composable TypeScript services, schemas, and workflows.
## Source Of Truth
Use the current Effect v4 / effect-smol source, not memory or older Effect v2/v3 examples.
1. If `.opencode/references/effect-smol` is missing, clone `https://github.com/Effect-TS/effect-smol` there. Do this in the project, not in the skill folder.
2. Search `.opencode/references/effect-smol` for exact APIs, examples, tests, and naming patterns before answering or implementing Effect-specific code.
3. Also inspect existing repo code for local house style before introducing new patterns.
4. Prefer answers and implementations backed by specific source files or nearby repo examples.
## Guidelines
- Prefer current Effect v4 APIs and project-local patterns over old blog posts, examples, or package-memory guesses.
- Use `Effect.gen(function* () { ... })` for multi-step workflows.
- Use `Effect.fn("Name")` or ...
No files found
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/plugin.ts</path>
<type>file</type>
<content>
1: import type { Effect, Scope } from "effect"
2: import type { PluginContext } from "./context.js"
3:
4: export interface Plugin<R = Scope.Scope> {
5: readonly id: string
6: readonly effect: (context: PluginContext) => Effect.Effect<void, never, R>
7: }
8:
9: export function define<R = Scope.Scope>(plugin: Plugin<R>) {
10: return plugin
11: }
12:
13: export interface PluginDomain {
14: readonly add: (plugin: Plugin) => Effect.Effect<void>
15: readonly remove: (id: string) => Effect.Effect<void>
16: }
(End of file - total 16 lines)
</content>
No files found
Found 7 matches
/home/byk/Code/opencode/packages/core/test/plugin/provider-openai-compatible.test.ts:
Line 71: yield* aisdk.hook.sdk((event) =>
Line 92: yield* aisdk.hook.sdk((event) => {
/home/byk/Code/opencode/packages/core/test/plugin/provider-mistral.test.ts:
Line 63: yield* aisdk.hook.sdk((event) =>
Line 87: yield* aisdk.hook.sdk((event) =>
/home/byk/Code/opencode/packages/core/test/plugin/provider-google-vertex.test.ts:
Line 324: yield* aisdk.hook.sdk((evt) =>
/home/byk/Code/opencode/packages/core/src/plugin/host.ts:
Line 46: aisdk.hook.sdk((event) => {
Line 59: aisdk.hook.language((event) => {
<path>/home/byk/Code/opencode/packages/core/test/plugin/provider-openai-compatible.test.ts</path>
<type>file</type>
<content>
50: const plugin = yield* PluginV2.Service
51: const aisdk = yield* AISDK.Service
52: yield* addPlugin()
53: const result = yield* aisdk.runSDK({
54: model: ModelV2.Info.make({
55: ...ModelV2.Info.empty(ProviderV2.ID.make("custom"), ModelV2.ID.make("model")),
56: api: { id: ModelV2.ID.make("model"), type: "aisdk", package: "test-provider" },
57: }),
58: package: "file:///tmp/@ai-sdk/openai-compatible-provider.js",
59: options: { name: "custom" },
60: })
61: expect(result.options.includeUsage).toBe(true)
62: }),
63: )
64:
65: it.effect("uses the provider ID as the OpenAI-compatible provider name", () =>
66: Effect.gen(function* () {
67: const plugin = yield* PluginV2.Service
68: const aisdk = yield* AISDK.Service
69: const observed: string[] = ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/options.ts</path> <type>file</type> <content> 1: export type PluginOptions = Readonly<Record<string, any>> (End of file - total 1 lines) </content>
Found 100 matches (more matches available)
/home/byk/Code/opencode/packages/schema/test/event.test.ts:
Line 8: Event.define({ type: "test.pure", schema: { value: Schema.String } })
Line 13: const historical = Event.define({
Line 18: const current = Event.define({
Line 29: const definition = Event.define({
/home/byk/Code/opencode/packages/schema/src/worktree-event.ts:
Line 7: export const Ready = Event.define({
Line 15: export const Failed = Event.define({
/home/byk/Code/opencode/packages/schema/src/workspace-event.ts:
Line 13: export const Ready = Event.define({
Line 20: export const Failed = Event.define({
Line 27: export const Status = Event.define({
/home/byk/Code/opencode/packages/schema/src/vcs-event.ts:
Line 7: export const BranchUpdated = Event.define({
/home/byk/Code/opencode/packages/schema/src/v1/session.ts:
Line 572: Created: define({
Line 580: Updated: define({
Line 588: Deleted: define({
Line 596: ...
/home/byk/Code/opencode/packages/core/src/plugin/models-dev.ts /home/byk/Code/opencode/packages/core/src/plugin/internal.ts /home/byk/Code/opencode/packages/core/src/plugin/variant.ts /home/byk/Code/opencode/packages/core/src/plugin/skill.ts /home/byk/Code/opencode/packages/core/src/plugin/provider.ts /home/byk/Code/opencode/packages/core/src/plugin/promise.ts /home/byk/Code/opencode/packages/core/src/plugin/host.ts /home/byk/Code/opencode/packages/core/src/plugin/command.ts /home/byk/Code/opencode/packages/core/src/plugin/agent.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/github-copilot.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/zenmux.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/xai.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/vercel.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/venice.ts /home/byk/Code/opencode/packages/core/src/plugin/provider/togetherai.ts /home/byk/Code/opencode/packages/core/src/plu...
<path>/home/byk/Code/opencode/packages/core/src/plugin/provider/openai-compatible.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import { define } from "../internal"
3:
4: export const OpenAICompatiblePlugin = define({
5: id: "openai-compatible",
6: effect: Effect.fn(function* (ctx) {
7: yield* ctx.aisdk.sdk(
8: Effect.fn(function* (evt) {
9: if (evt.sdk) return
10: if (!evt.package.includes("@ai-sdk/openai-compatible")) return
11: if (evt.options.includeUsage !== false) evt.options.includeUsage = true
12: const mod = yield* Effect.promise(() => import("@ai-sdk/openai-compatible"))
13: evt.sdk = mod.createOpenAICompatible(evt.options as any)
14: }),
15: )
16: }),
17: })
(End of file - total 17 lines)
</content>
<path>/home/byk/Code/opencode/packages/core/src/plugin/internal.ts</path>
<type>file</type>
<content>
1: export * as PluginInternal from "./internal"
2:
3: import { makeLocationNode } from "../effect/app-node"
4: import { httpClient } from "../effect/app-node-platform"
5: import type { PluginContext } from "@opencode-ai/plugin/v2/effect"
6: import { Effect, Layer, Scope } from "effect"
7: import { AgentV2 } from "../agent"
8: import { Catalog } from "../catalog"
9: import { CommandV2 } from "../command"
10: import { Config } from "../config"
11: import { ConfigAgentPlugin } from "../config/plugin/agent"
12: import { ConfigCommandPlugin } from "../config/plugin/command"
13: import { ConfigExternalPlugin } from "../config/plugin/external"
14: import { ConfigProviderPlugin } from "../config/plugin/provider"
15: import { ConfigReferencePlugin } from "../config/plugin/reference"
16: import { ConfigSkillPlugin } from "../config/plugin/skill"
17: import { EventV2 } from "../event"
18: ...
Found 14 matches
/home/byk/Code/opencode/.lore.md:
Line 243: * **PluginModule default definition**: Trap: exporting a legacy async plugin function looks compatible because older OpenCode loaders invoke function exports. Fix: V2 \`PluginModule.load()\` requires one default \`{ id, setup }\` or \`{ id, effect }\` definition; configured local targets must also be directories with discoverable \`server\` or \`index\` entrypoints, while standalone files work only through auto-discovery.
/home/byk/Code/opencode/specs/v2/config.md:
Line 176: | `disabled_providers` | Disable automatically loaded providers | redesign | Replace with `experimental.policies: [{ effect: "deny", action: "provider.use", resource: "..." }]`. |
/home/byk/Code/opencode/specs/v2/provider-policy.md:
Line 55: effect: "allow" | "deny"
/home/byk/Code/opencode/packages/plugin/src/v2/promise/README.md:
Line 3: The Promise plugin API is the async/await equivalent of ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/README.md</path>
<type>file</type>
<content>
1: # OpenCode V2 Effect Plugin API
2:
3: The Effect plugin API grants plugins two in-process capabilities:
4:
5: - `hook` installs behavior at an OpenCode extension point.
6: - `reload` reruns every transform hook for a stateful domain.
7:
8: The public server client will be exposed separately. It is intentionally not part of `PluginContext` yet.
9:
10: ## Defining A Plugin
11:
12: ```ts
13: import { define } from "@opencode-ai/plugin/v2/effect"
14: import { Effect } from "effect"
15:
16: export const Plugin = define({
17: id: "example",
18: effect: Effect.fn(function* (ctx) {
19: yield* ctx.catalog.transform((catalog) => {
20: catalog.provider.update("example", (provider) => {
21: provider.name = "Example"
22: })
23: })
24: }),
25: })
26: ```
27:
28: Plugin setup registers hooks imperatively. It does not return a hook object. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts</path> <type>file</type> <content> 1: /** 2: * Internal helpers for the Lore OpenCode plugin. 3: * 4: * These functions are intentionally kept OUT of the plugin entry module 5: * (`./index.ts`). OpenCode's legacy plugin loader treats EVERY function 6: * exported from a plugin module as a plugin instance and invokes it (see 7: * `getServerPlugin`/`getLegacyPlugins` in opencode's plugin loader). Exporting 8: * these helpers from the entry module caused them to be invoked as plugins and 9: * their return values pushed into the host's hooks array: 10: * `applyLoreProviderConfig` returns `undefined`, so the host crashed on the 11: * first hook dispatch with `undefined is not an object (evaluating 'A.event')` 12: * (the `?.` guards the `.event` property, not the `undefined` hook element). ...
Found 22 matches
/home/byk/Code/opencode/packages/plugin/src/v2/effect/skill.ts:
Line 2: import type { Hooks } from "./registration.js"
Line 9: export type SkillHooks = Hooks<{
/home/byk/Code/opencode/packages/plugin/src/v2/effect/registration.ts:
Line 11: export type Hooks<Spec> = {
/home/byk/Code/opencode/packages/plugin/src/v2/effect/reference.ts:
Line 2: import type { Hooks } from "./registration.js"
Line 10: export type ReferenceHooks = Hooks<{
/home/byk/Code/opencode/packages/plugin/src/v2/effect/integration.ts:
Line 13: import type { Hooks } from "./registration.js"
Line 58: export interface IntegrationHooks extends Hooks<{ transform: IntegrationDraft }> {
/home/byk/Code/opencode/packages/plugin/src/v2/effect/context.ts:
Line 2: import type { AgentHooks } from "./agent.js"
Line 3: import type { AISDKHooks } from "./aisdk.js"
Line 4: import type { CatalogHooks } from "./catalog.js"
Line 5: import type { CommandHooks } from "./command.js"
...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/aisdk.ts</path>
<type>file</type>
<content>
1: import type { LanguageModelV3 } from "@ai-sdk/provider"
2: import type { ModelV2Info } from "@opencode-ai/sdk/v2/types"
3: import type { Hooks } from "./registration.js"
4:
5: export type AISDKHooks = Hooks<{
6: sdk: {
7: readonly model: ModelV2Info
8: readonly package: string
9: readonly options: Record<string, any>
10: sdk?: any
11: }
12: language: {
13: readonly model: ModelV2Info
14: readonly sdk: any
15: readonly options: Record<string, any>
16: language?: LanguageModelV3
17: }
18: }>
(End of file - total 18 lines)
</content>
No files found
Found 12 matches
/home/byk/Code/opencode/packages/plugin/src/tui.ts:
Line 630: export type TuiPluginModule = {
/home/byk/Code/opencode/packages/plugin/src/index.ts:
Line 76: export type PluginModule = {
/home/byk/Code/opencode/packages/tui/src/feature-plugins/builtins.ts:
Line 1: import type { TuiPlugin, TuiPluginModule } from "@opencode-ai/plugin/tui"
Line 15: export type BuiltinTuiPlugin = Omit<TuiPluginModule, "id"> & {
/home/byk/Code/opencode/packages/opencode/src/plugin/index.ts:
Line 6: PluginModule,
Line 116: hooks.push(await (plugin as PluginModule).server(input, load.options))
/home/byk/Code/opencode/packages/opencode/src/plugin/tui/runtime.ts:
Line 8: type TuiPluginModule,
Line 56: module: TuiPluginModule
Line 124: const EMPTY_TUI: TuiPluginModule = {
Line 685: .then(() => readV1Plugin(loaded.mod as Record<string, unknown>, loaded.spec, "tui") as ...
<path>/home/byk/Code/opencode/packages/core/src/config/plugin/external.ts</path>
<type>file</type>
<content>
1: export * as ConfigExternalPlugin from "./external"
2:
3: import type { Plugin as EffectPlugin } from "@opencode-ai/plugin/v2/effect"
4: import type { Plugin as PromisePlugin } from "@opencode-ai/plugin/v2/promise"
5: import { Effect, Schema } from "effect"
6: import path from "path"
7: import { fileURLToPath, pathToFileURL } from "url"
8: import { Config } from "../../config"
9: import { FSUtil } from "../../fs-util"
10: import { Location } from "../../location"
11: import { Npm } from "../../npm"
12: import { define } from "../../plugin/internal"
13: import { PluginPromise } from "../../plugin/promise"
14:
15: const PluginModule = Schema.Struct({
16: default: Schema.Union([
17: Schema.Struct({
18: id: Schema.String,
19: effect: Schema.declare<EffectPlugin["effect"]>(
20: (input): input is EffectPlugin["effect"] => typeof input === "function",
21: ...
Found 22 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 18: import { writePortFile, removePortFile } from "../portfile";
Line 46: withoutLifecycleLock,
Line 105: processBoundary?: boolean;
Line 139: writePort: (port: number, token: string) => void;
Line 141: writeProcess: (record: GatewayProcessRecord) => void;
Line 151: writePort: writePortFile,
Line 153: writeProcess: writeGatewayProcessFile,
Line 571: return await withLifecycleLock("gateway-shutdown", (lock) => {
Line 675: await withLifecycleLock("gateway-start", async (lifecycleLock) => {
Line 741: const spawned = await withLifecycleLock("gateway-start", (lifecycleLock) => {
Line 868: export async function startGateway(
Line 872: return withLifecycleLock("gateway-start", (lifecycleLock) =>
Line 877: async function startGatewayLocked(
Line 1049: server = await withoutLifecycleLock(() =>
Line 1076: io.writePort(actualPort, ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
850: * `safeExit`.
851: */
852: async function startDaemon(opts: StartOptions): Promise<never> {
853: safeExit(await runDaemon(opts, realDaemonIO(opts)));
854: }
855:
856: /**
857: * Start the gateway server, returning the actual port and a shutdown function.
858: *
859: * Merges CLI options on top of env-var config (CLI takes precedence).
860: *
861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`),
862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port.
863: * At each step, if the port is occupied by an existing lore gateway
864: * (verified via its process record and owner-only control token), returns a
865: * handle with `owned: false`
866: * so the caller can reuse the existing instance. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
1230: if (candidatePort === 0) {
1231: notify(
1232: `Preferred ports (${DEFAULT_PORTS.join(", ")}) were unavailable; using port ${actualPort}`,
1233: );
1234: }
1235:
1236: return {
1237: config,
1238: port: actualPort,
1239: owned: true,
1240: managementToken: controlToken,
1241: shutdown,
1242: processShutdown,
1243: };
1244: } catch (e) {
1245: // Clean up any successfully-bound servers before retrying.
1246: // In multi-host configs, some hosts may have bound before another
1247: // failed with EADDRINUSE — stop them to avoid leaking FDs.
1248: // `server` is undefined when startServer() itself rejected (the common
1249: // EADDRINUSE case), in which case there is nothing to stop here.
1250: if (server) await server.stop();
1251:
1252: ...
Found 3 matches
/home/byk/Code/opencode-lore/packages/core/src/git.d.ts:
Line 46: export declare function getGitRemote(path: string): string | null;
/home/byk/Code/opencode-lore/packages/core/src/git.ts:
Line 101: export function getGitRemote(path: string): string | null {
/home/byk/Code/opencode-lore/packages/core/src/workspace.ts:
Line 116: export function discoverWorkspaceRoot(startDir: string): string {
<path>/home/byk/Code/opencode-lore/AGENTS.md</path> <type>file</type> <content> 1: <!-- This section is maintained by the coding agent via lore (https://github.com/BYK/loreai) --> 2: ## Long-term Knowledge 3: 4: For long-term knowledge entries managed by [lore](https://github.com/BYK/loreai) (gotchas, patterns, decisions, architecture), see [`.lore.md`](.lore.md) in the project root. 5: <!-- End lore-managed section --> 6: 7: ## Review 8: 9: See [`quality/REVIEW.md`](quality/REVIEW.md) for the review heuristics and workflow — regression-test discipline, adversarial-order state setup, fan-out registry coverage, recurring bug-class batteries, and the two-reviewer rule. Every non-trivial PR requires an adversarial correctness review before merge. 10: 11: # Project Overview 12: 13: Lore is a **three-tier memory architecture** for AI coding agents. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
374: // Inject per-request identifiers so the gateway can distinguish meta
375: // requests (title generation, summary agents, etc.) from real
376: // conversation turns and route by provider.
377: // Project path, git remote, and upstream URL are injected by the
378: // fetch interceptor (installed once per process).
379: "chat.headers": async (input, output) => {
380: Object.assign(
381: output.headers,
382: gatewayAccessHeadersForRemote(gatewayBase),
383: );
384: // Inject stable session ID — OpenCode's DB session ID survives restarts,
385: // unlike x-session-affinity (nanoid regenerated per process).
386: output.headers["x-lore-session-id"] = input.sessionID;
387: output.headers["x-lore-agent"] = input.agent;
388: // Flag OpenCode Task sub-agents so the gateway sizes ...
<path>/home/byk/Code/opencode-lore/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: }
15: },
16: "scripts": {
17: "typecheck": "tsc --noEmit",
18: "build": "echo '@loreai/opencode ships raw TS — no build step needed'"
19: },
20: "peerDependencies": {
21: "@opencode-ai/plugin": ">=1.1.0"
22: },
23: "dependencies": {
24: "@loreai/core": "workspace:*",
25: "@loreai/gateway": "workspace:*"
26: },
27: "devDependencies": {
28: "@opencode-ai/plugin": "^1.1.39",
29: "@opencode-ai/sdk": "^1.1.39",
30: ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
430: return () => {};
431: }
432:
433: const originalFetch = globalThis.fetch;
434: writeOriginalFetchSlot(originalFetch);
435:
436: // Pre-parse the gateway URL once — avoids constructing a new URL object on
437: // every fetch call in the process (tool executions, file downloads, etc.).
438: const gateway = new URL(config.gatewayBase);
439: const gatewayBase = config.gatewayBase;
440:
441: const interceptor = async (
442: input: RequestInfo | URL,
443: init?: RequestInit,
444: ): Promise<Response> => {
445: const url =
446: typeof input === "string"
447: ? input
448: : input instanceof URL
449: ? input.toString()
450: : input.url;
451:
452: // Fast exit: skip URL parsing entirely for requests that can't possibly
453: // be LLM API calls. ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/gateway/instrument.ts:
Line 132: release: VERSION,
/home/byk/Code/opencode-lore/packages/gateway/test/session-retention.test.ts:
Line 134: it("gives a slow tool response a full grace period, releases snapshots, and resumes the durable session", async () => {
Line 243: const release = deferred();
Line 245: setPipelinePreUpstreamPauseForTest(release.promise, entered.resolve);
Line 257: release.resolve();
Line 322: const release = deferred();
Line 325: await release.promise;
Line 342: release.resolve();
Line 354: it("releases session ownership when a queued distillation is discarded", async () => {
Line 358: const release = deferred();
Line 361: await release.promise;
Line 374: release.resolve();
Line 383: release.resolve();
/home/byk/Code/opencode-lore/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 6131: ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
360: * Build the gateway-bound headers for an intercepted request: preserve all
361: * original headers (auth, content-type, etc.), set `X-Lore-Upstream-URL` to
362: * the resolved upstream base, `X-Lore-Upstream-Path` to the original endpoint
363: * pathname, and inject dynamic `X-Lore-*` context headers.
364: *
365: * Shared by both the URL-matched path (Path 1) and the body-detected path
366: * (Path 2) so header handling can never drift between them.
367: */
368: function buildGatewayHeaders(
369: input: RequestInfo | URL,
370: init: RequestInit | undefined,
371: upstreamBase: string,
372: upstreamPath: string,
373: config: FetchInterceptorConfig,
374: ): Headers {
375: // Handle both `fetch(url, {headers})` and `fetch(new Request(url, {headers}))`.
376: const existingHeaders =
377: init?.headers ??
378: (typeof input !== "string" && !(input ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
100: }
101:
102: /** True when the pathname looks like an LLM API endpoint (for warning/fallback). */
103: function pathLooksLLMLike(pathname: string): boolean {
104: return /\/(messages|chat\/completions|responses)(\/|$)/.test(pathname);
105: }
106:
107: /**
108: * Best-effort extraction of a request body as a JSON string for body-shape
109: * detection. Only handles bodies we can read *synchronously without
110: * consuming* them — strings, and ArrayBuffer/typed-array views (decoded as
111: * UTF-8). Streaming bodies (ReadableStream) and bodies that live only on a
112: * `Request` object can't be read here without consuming them (which would
113: * break the forwarded request), so we return undefined and let the request
114: * fall through to the warn-once path. Returns undefined on any failure. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/tsconfig.json</path>
<type>file</type>
<content>
1: {
2: "extends": "../../tsconfig.base.json",
3: "compilerOptions": {
4: "noEmit": true,
5: "types": ["bun"],
6: "paths": {
7: "@loreai/core": ["../core/src/index.ts"]
8: }
9: },
10: "include": ["src", "test", "script", "scripts", "eval"]
11: }
(End of file - total 11 lines)
</content>
Found 38 matches /home/byk/Code/opencode-lore/packages/core/src/embedding.ts: Line 1096: // `globalThis.__LORE_WORKER_SOURCE__`. We pass it to Line 1107: const workerSource = (globalThis as Record<string, unknown>) Line 1122: // Snapshot the host's silence state — the worker's own `globalThis` /home/byk/Code/opencode-lore/packages/core/src/db.ts: Line 5007: * (`/__lore_unattributed__/<sessionID>`) so unrelated sessions are never Line 5012: export const UNATTRIBUTED_PROJECT_PREFIX = "/__lore_unattributed__"; /home/byk/Code/opencode-lore/packages/core/src/embedding-vendor.d.ts: Line 9: * The binary's wrapper sets `globalThis.__LORE_VENDOR_MODEL__` to the Line 18: /** What the binary wrapper writes to globalThis after extracting model files. */ /home/byk/Code/opencode-lore/packages/core/src/log.ts: Line 116: // 🔴 The flag lives on `globalThis`, NOT a module-level `let`. ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path> <type>file</type> <content> 305: /** 306: * Install a fetch interceptor that transparently reroutes LLM API calls 307: * through the Lore gateway. 308: * 309: * The interceptor: 310: * 1. Checks if the outgoing URL matches a known LLM API path 311: * 2. Rewrites the URL to the gateway, preserving the path 312: * 3. Adds `X-Lore-Upstream-URL` (base) and `X-Lore-Upstream-Path` (original 313: * endpoint pathname, for verbatim forwarding) 314: * 4. Injects dynamic `X-Lore-*` context headers from `getHeaders()` 315: * 5. Preserves ALL original headers (auth, content-type, etc.) 316: * 317: * Returns a cleanup function that restores the original `globalThis.fetch`. 318: */ 319: /** 320: * Process-global slot holding the original `globalThis.fetch` captured before 321: * any interceptor was installed. ...
Found 13 matches /home/byk/Code/opencode-lore/.lore.md: Line 8: * **#1711 Responses ingress boundary**: Chose streaming only \`/v1/responses\` and \`/v1/codex/responses\` over converting every JSON ingress route, because their shared OpenAI item normalizer can process \`input\` incrementally. Anthropic, Chat, Gemini, and compaction routes require distinct full-protocol parsing or intentionally retain exact body text for fallback replay. This reduces compressed/decoded/raw-tree peak allocations, but deliberately does not solve #1710’s post-parse full-history semantic replay: normalized \`GatewayRequest.messages\` are still complete. Line 26: * **derivedMessageId temporal identity**: Chose tenant/project/session/source-derived \`temporal\_messages.id\` over treating caller \`source\_id\` as globally unique because sync, vector rows, distillation links, and multiple tenants require stable collision-free storage keys. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
Found 3 matches /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts: Line 598: yield* Effect.acquireRelease( Line 599: Effect.promise(() => Promise.resolve(plugin.setup(context2))), Line 600: (cleanup) => (cleanup ? Effect.promise(() => Promise.resolve(cleanup())) : Effect.void),
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
570: ),
571: ),
572: },
573: session: {
574: hook: (name, callback, options) =>
575: register(
576: host.session.hook(name, (event) => Effect.promise(() => Promise.resolve(callback(event))), options),
577: ),
578: create: adaptApiMethod(SessionEndpoints["session.create"], host.session.create),
579: get: adaptApiMethod(SessionEndpoints["session.get"], host.session.get),
580: switchAgent: adaptApiMethod(SessionEndpoints["session.switchAgent"], host.session.switchAgent),
581: switchModel: adaptApiMethod(SessionEndpoints["session.switchModel"], host.session.switchModel),
582: prompt: adaptApiMethod(SessionEndpoints["session.prompt"], host.session.prompt),
583: generate: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
80: );
81:
82: export interface StartOptions {
83: port?: number;
84: hosts?: string[];
85: debug?: boolean;
86: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
87: quiet?: boolean;
88: /** Remote gateway URL. When set, `lore run` delegates to this gateway
89: * instead of starting a local one. Overrides LORE_REMOTE_URL env var. */
90: remoteUrl?: string;
91: /**
92: * When true, disables hosted mode even for `lore start`.
93: * CLI: `--local` / `-l`.
94: */
95: local?: boolean;
96: /** Allow non-loopback peers to access the dashboard and management API. */
97: allowRemoteManagement?: boolean;
98: /**
99: * When true, `lore start` daemonizes: it re-spawns itself detached, polls
100: * the gateway until healthy, prints the address + PID + log path, and exits 0.
101: * CLI: `--bg` / `--daemon`. ...
Found 8 matches
/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts:
Line 47: export type LifecycleOperation =
Line 198: const lockContext = new AsyncLocalStorage<LifecycleLock>();
Line 201: export function withoutLifecycleLock<T>(action: () => T): T {
Line 202: return lockContext.exit(action);
Line 1686: export async function acquireLifecycleLock(
Line 1841: export async function withLifecycleLock<T>(
Line 1846: const inherited = lockContext.getStore();
Line 1853: return lockContext.run(lock, async () => {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path> <type>file</type> <content> 35: const FILE_MODE = 0o600; 36: const OWNER_FILE = "owner.json"; 37: const UNINSTALL_TOMBSTONE_FILE = "uninstalled.json"; 38: const INITIALIZATION_CLAIM_MARKER = ".init."; 39: const INITIALIZATION_QUARANTINE_MARKER = ".claim.init."; 40: const RELEASE_CLAIM_MARKER = ".release."; 41: const MAX_OWNER_BYTES = 16 * 1024; 42: const DEFAULT_TIMEOUT_MS = 5000; 43: const DEFAULT_RETRY_DELAY_MS = 50; 44: const NO_FOLLOW = process.platform === "win32" ? 0 : constants.O_NOFOLLOW; 45: 46: /** Lifecycle transitions serialized by the per-user lock. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1840: /** Run a lifecycle transition under the lock, with async-context reentrancy. */
1841: export async function withLifecycleLock<T>(
1842: operation: LifecycleOperation,
1843: action: (lock: LifecycleLock) => Promise<T> | T,
1844: options: LifecycleLockOptions = {},
1845: ): Promise<T> {
1846: const inherited = lockContext.getStore();
1847: if (inherited) {
1848: inherited.assertOwned();
1849: return action(inherited);
1850: }
1851:
1852: const lock = await acquireLifecycleLock(operation, options);
1853: return lockContext.run(lock, async () => {
1854: try {
1855: const result = await action(lock);
1856: if (
1857: operation === "hosted-install" &&
1858: readUninstallTombstone(lock.path) !== null
1859: ) {
1860: throw new Error(
1861: "Fresh install did not clear the uninstall marker after ...
File not found: /home/byk/Code/opencode-lore/packages/opencode/test/gateway-discovery.test.ts
/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/routing.e2e.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/internal.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/subagent-detection.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/tui-silence.test.ts /home/byk/Code/opencode-lore/packages/opencode/test/session-state.test.ts
<path>/home/byk/Code/opencode-lore/packages/opencode/test/routing.e2e.test.ts</path> <type>file</type> <content> 1: /** 2: * End-to-end test: the OpenCode plugin's REAL active path against a REAL 3: * in-process Lore gateway (upstream mocked — no real API call). 4: * 5: * Unlike the config-hook units (index.test.ts) and per-project header units 6: * (session-state.test.ts) — which run with the plugin inert under 7: * `NODE_ENV=test` — this test forces the plugin active via 8: * `LORE_OPENCODE_FORCE_ACTIVE=1` and points it at a controlled gateway via 9: * `LORE_GATEWAY_URL`, then proves the wiring the whole #1036/#1039 series 10: * exists to guard: 11: * 1. the plugin DISCOVERS the gateway (gatewayBase is resolved, not ""), 12: * so its `config` hook actually pins provider baseURLs to it, 13: * 2. the `chat.headers` hook injects the `x-lore-*` attribution headers, and 14: * 3. ...
No files found
<path>/home/byk/Code/opencode/packages/plugin/src/v2/effect/registration.ts</path>
<type>file</type>
<content>
1: import type { Effect, Scope } from "effect"
2:
3: export interface Registration {
4: readonly dispose: Effect.Effect<void>
5: }
6:
7: export interface Reload {
8: readonly reload: () => Effect.Effect<void>
9: }
10:
11: export type Hooks<Spec> = {
12: readonly [Name in keyof Spec]: (
13: callback: (input: Spec[Name]) => Effect.Effect<void> | void,
14: ) => Effect.Effect<Registration, never, Scope.Scope>
15: }
(End of file - total 15 lines)
</content>
<path>/home/byk/Code/opencode-v2-pilot/packages/schema/src/location.ts</path>
<type>file</type>
<content>
1: export * as Location from "./location.js"
2:
3: import { Schema } from "effect"
4: import { AbsolutePath, optional } from "./schema.js"
5: import { ProjectID } from "./project-id.js"
6: import { WorkspaceID } from "./workspace-id.js"
7:
8: export interface Ref extends Schema.Schema.Type<typeof Ref> {}
9: export const Ref = Schema.Struct({
10: directory: AbsolutePath,
11: workspaceID: optional(WorkspaceID),
12: }).annotate({ identifier: "Location.Ref" })
13:
14: export class Info extends Schema.Class<Info>("Location.Info")({
15: directory: AbsolutePath,
16: workspaceID: optional(WorkspaceID),
17: project: Schema.Struct({
18: id: ProjectID,
19: directory: AbsolutePath,
20: canonical: AbsolutePath,
21: }),
22: }) {}
23:
24: export function response<S extends Schema.Top>(data: S) {
25: return Schema.Struct({ location: Info, data })
26: }
(End of file ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/aisdk.ts</path>
<type>file</type>
<content>
1: import type { LanguageModelV3 } from "@ai-sdk/provider"
2: import type { Model } from "@opencode/schema/model"
3: import type { ModelHooks } from "./registration.js"
4:
5: export interface AISDKHooks {
6: sdk: {
7: readonly model: Model.Info
8: readonly package: string
9: readonly options: Record<string, any>
10: sdk?: any
11: }
12: language: {
13: readonly model: Model.Info
14: readonly sdk: any
15: readonly options: Record<string, any>
16: language?: LanguageModelV3
17: }
18: }
19:
20: export interface AISDKDomain {
21: readonly hook: ModelHooks<AISDKHooks>
22: }
(End of file - total 22 lines)
</content>
Found 93 matches
/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts:
Line 50: cleanup: () => rmSync(tmpDir, { recursive: true, force: true }),
Line 56: const { hooks, cleanup } = await initPlugin();
Line 63: cleanup();
Line 68: const { hooks, cleanup } = await initPlugin();
Line 105: cleanup();
Line 110: const { hooks, cleanup } = await initPlugin();
Line 124: cleanup();
Line 254: const { hooks, cleanup } = await initPlugin();
Line 258: cleanup();
Line 263: const { hooks, cleanup } = await initPlugin();
Line 273: cleanup();
/home/byk/Code/opencode-lore/packages/opencode/test/session-state.test.ts:
Line 105: // best-effort cleanup
/home/byk/Code/opencode-lore/packages/opencode/eval/session_eval.ts:
Line 371: function cleanupSeededData(): void {
Line 634: // Ensure cleanup happens even on error/interrupt
Line 636: cleanupSeededData();
Line 640: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts</path>
<type>file</type>
<content>
1: export * as PluginModule from "./module.js"
2:
3: import type { Plugin } from "@opencode/plugin/effect/plugin"
4: import { Host } from "@opencode/plugin/host"
5: import { createPluginSources } from "@opencode/plugin/source"
6: import { Npm } from "@opencode/util/npm"
7: import { Deferred, Effect, FiberSet, PubSub, Schema, Stream } from "effect"
8: import path from "path"
9: import { stat } from "node:fs/promises"
10: import { fileURLToPath, pathToFileURL } from "url"
11: import type { ConfigPluginSource } from "../config/plugin/source.js"
12: import type { Generation } from "../plugin.js"
13: import { PluginPromise } from "./promise.js"
14: import { Watcher } from "../filesystem/watcher.js"
15:
16: export const make = Effect.fn("PluginModule.make")(function* () {
17: const watcher = yield* Watcher.Service
18: const scope = yield* Effect.scope
19: const runPromise = ...
Found 4 matches
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/host.ts:
Line 11: export interface Entrypoints {
Line 12: readonly server?: string
Line 17: export function resolve(target: Target): Entrypoints {
Line 43: return { server: entry(["server", ""]), tui: entry(["tui"]), rpc: entry(["rpc"]) }
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/host.ts</path>
<type>file</type>
<content>
1: export * as Host from "./host.js"
2:
3: import path from "node:path"
4: import { importModule, resolveModule } from "@opencode/util/runtime-import"
5:
6: export interface Target {
7: readonly directory: string
8: readonly name?: string
9: }
10:
11: export interface Entrypoints {
12: readonly server?: string
13: readonly tui?: string
14: readonly rpc?: string
15: }
16:
17: export function resolve(target: Target): Entrypoints {
18: const entry = (subpaths: readonly string[]) => {
19: for (const subpath of subpaths) {
20: const specifier = target.name
21: ? [target.name, subpath].filter(Boolean).join("/")
22: : path.resolve(target.directory, subpath || "index")
23: try {
24: return resolveModule(specifier, target.directory)
25: } catch (error) {
26: if (
27: !(error instanceof Error) ||
28: ...
Found 33 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 18: import { writePortFile, removePortFile } from "../portfile";
Line 139: writePort: (port: number, token: string) => void;
Line 141: writeProcess: (record: GatewayProcessRecord) => void;
Line 151: writePort: writePortFile,
Line 153: writeProcess: writeGatewayProcessFile,
Line 219: if (!res.ok) return { kind: "rejected" };
Line 477: return { command: process.execPath, args: childArgs };
Line 480: return { command: process.execPath, args: [process.argv[1], ...childArgs] };
Line 538: return { state: "unknown" };
Line 624: return {
Line 639: return { stopped: false, signalled };
Line 660: return { stopped: false, signalled };
Line 691: return { stopped: exited, signalled };
Line 748: return {
Line 830: return {
Line 865: * handle with `owned: false`
Line 868: export async function startGateway(
Line 877: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
850: * `safeExit`.
851: */
852: async function startDaemon(opts: StartOptions): Promise<never> {
853: safeExit(await runDaemon(opts, realDaemonIO(opts)));
854: }
855:
856: /**
857: * Start the gateway server, returning the actual port and a shutdown function.
858: *
859: * Merges CLI options on top of env-var config (CLI takes precedence).
860: *
861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`),
862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port.
863: * At each step, if the port is occupied by an existing lore gateway
864: * (verified via its process record and owner-only control token), returns a
865: * handle with `owned: false`
866: * so the caller can reuse the existing instance. ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { PluginContext } from "./context.js"
2:
3: export interface Plugin {
4: readonly id: string
5: readonly setup: (context: PluginContext) => Promise<void> | void
6: }
7:
8: export function define(plugin: Plugin) {
9: return plugin
10: }
11:
12: export interface PluginDomain {
13: readonly add: (plugin: Plugin) => Promise<void>
14: readonly remove: (id: string) => Promise<void>
15: }
(End of file - total 15 lines)
</content>
Found 27 matches
/home/byk/Code/opencode-lore/packages/pi/test/internal.test.ts:
Line 9: resolveGatewayUrl,
Line 347: describe("resolveGatewayUrl diagnostics", () => {
Line 360: await expect(resolveGatewayUrl()).resolves.toBe(
Line 399: await resolveGatewayUrl();
/home/byk/Code/opencode-lore/packages/pi/test/gateway-discovery.test.ts:
Line 4: import { probeGateway, resolveGatewayUrl } from "../src/internal";
Line 8: * the env-var resolution order of `resolveGatewayUrl`. A real loopback HTTP
Line 63: describe("resolveGatewayUrl env-var order", () => {
Line 67: expect(await resolveGatewayUrl()).toBe(healthyUrl);
Line 73: expect(await resolveGatewayUrl()).toBe(healthyUrl);
/home/byk/Code/opencode-lore/packages/pi/src/internal.ts:
Line 181: export async function resolveGatewayUrl(): Promise<string | null> {
Line 233: export async function startInProcess(): Promise<string | null> ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
390: remove: editor.remove,
391: method: {
392: list: editor.method.list,
393: update: (input) => {
394: if (!("authorize" in input)) return editor.method.update(input)
395: const refresh = input.refresh
396: editor.method.update({
397: ...input,
398: authorize: (answer) =>
399: Effect.promise(() => input.authorize(answer)).pipe(
400: Effect.map((authorization) =>
401: authorization.mode === "auto"
402: ? {
403: ...authorization,
404: callback: Effect.promise(() => ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/internal.ts</path>
<type>file</type>
<content>
150: headers: Record<string, string>;
151: }
152:
153: /**
154: * Check if the Lore gateway is reachable at the given base URL.
155: * Short timeout so this doesn't delay Pi startup noticeably.
156: */
157: export async function probeGateway(
158: baseURL: string,
159: timeoutMs = 1500,
160: ): Promise<boolean> {
161: const controller = new AbortController();
162: const timer = setTimeout(() => controller.abort(), timeoutMs);
163: try {
164: const url = `${baseURL}/health`;
165: if (isLoopbackUrl(url)) return await probeLoopback(url, controller.signal);
166: return (await fetch(url, { signal: controller.signal })).ok;
167: } catch {
168: return false;
169: } finally {
170: clearTimeout(timer);
171: }
172: }
173:
174: /**
175: * Resolve the gateway URL by probing known ports and reading the port file. ...
<path>/home/byk/Code/opencode-lore/packages/pi/src/index.ts</path>
<type>file</type>
<content>
50: /**
51: * Pi extension entry point.
52: *
53: * Pi calls this function when loading the extension — either via `pi -e`
54: * or after `pi install`. Detects the Lore gateway and, if available,
55: * redirects provider URLs and registers compaction override.
56: */
57: export default async function lorePiExtension(pi: ExtensionAPI): Promise<void> {
58: let gatewayBase = "";
59: let loreActive = false;
60: const loreDisabled =
61: process.env.LORE_DISABLED === "1" || process.env.LORE_DISABLED === "true";
62: // The extension is inert under `NODE_ENV=test` so unrelated package test
63: // suites don't accidentally probe/start a gateway. Tests that need the
64: // extension active set `LORE_PI_FORCE_ACTIVE=1` and point it at a controlled
65: // in-process gateway via `LORE_GATEWAY_URL`. ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-quiet.test.ts</path>
<type>file</type>
<content>
1: /**
2: * Regression test for the `startGateway({ quiet })` flag.
3: *
4: * In-process callers (the OpenCode plugin and the Pi extension) start the
5: * gateway with `{ quiet: true, local: true }` because they run inside the host
6: * agent's full-screen TUI, where ANY stdout/stderr write corrupts the rendered
7: * screen. Before the fix, `startGateway()` ignored `quiet` entirely and printed
8: * its startup/shutdown notices via `console.error`, leaking into the TUI (part
9: * of the Pi breakage Daniel Griesser reported).
10: *
11: * These tests pin the contract:
12: * - quiet:true → no `[lore] Shutting down…` on stderr (routed to file log).
13: * - quiet:false → the message is still printed (preserves `lore start` CLI). ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore/packages/gateway/src/compaction.ts: Line 17: // Detection patterns — exported so tests can reference them Line 164: * Claude Code (the reference client for this anti-compaction feature) meters /home/byk/Code/opencode-lore/packages/gateway/src/team.ts: Line 354: * `hint` is a free-text label for the admin's own reference; it is NOT resolved/verified. /home/byk/Code/opencode-lore/packages/gateway/src/cache-analytics.ts: Line 501: // system[1] = stable LTM: preferences (pinned >=1h, cached with 1h TTL) Line 521: // (preference re-curation/consolidation add/remove/edit). This busts Line 526: return "stable LTM block content changed (preference re-curation/consolidation — prefix bust)"; Line 533: return "context-bound LTM changed (non-preference entries re-ranked)"; /home/byk/Code/opencode-lore/packages/gateway/src/api.ts: Line 127: // LLM client (lazy singleton — same ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
374: // Inject per-request identifiers so the gateway can distinguish meta
375: // requests (title generation, summary agents, etc.) from real
376: // conversation turns and route by provider.
377: // Project path, git remote, and upstream URL are injected by the
378: // fetch interceptor (installed once per process).
379: "chat.headers": async (input, output) => {
380: Object.assign(
381: output.headers,
382: gatewayAccessHeadersForRemote(gatewayBase),
383: );
384: // Inject stable session ID — OpenCode's DB session ID survives restarts,
385: // unlike x-session-affinity (nanoid regenerated per process).
386: output.headers["x-lore-session-id"] = input.sessionID;
387: output.headers["x-lore-agent"] = input.agent;
388: // Flag OpenCode Task sub-agents so the gateway sizes ...
Found 92 matches
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/index.ts:
Line 14: export { Provider } from "@opencode/schema/provider"
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/command.ts:
Line 3: import type { Session } from "@opencode/schema/session"
Line 4: import type { SessionInbox } from "@opencode/schema/session-inbox"
Line 8: readonly sessionID: Session.ID
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/catalog.ts:
Line 3: import type { Provider } from "@opencode/schema/provider"
Line 8: readonly provider: DeepMutable<Provider.Info>
Line 13: readonly provider: {
Line 15: get(providerID: string): CatalogProviderRecord | undefined
Line 16: update(providerID: string, update: (provider: DeepMutable<Provider.Info>) => void): void
Line 17: remove(providerID: string): void
Line 20: get(providerID: string, modelID: string): DeepMutable<Model.Info> | undefined
Line 21: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/session.ts</path>
<type>file</type>
<content>
1: import type { SessionApi } from "@opencode/client/promise/api"
2: import type { GenerationOptionsFields, Message, SystemPart } from "@opencode/ai"
3: import type { Agent } from "@opencode/schema/agent"
4: import type { Model } from "@opencode/schema/model"
5: import type { PromptInput } from "@opencode/schema/prompt-input"
6: import type { Session } from "@opencode/schema/session"
7: import type { SessionInbox } from "@opencode/schema/session-inbox"
8: import type { SessionError } from "@opencode/schema/session-error"
9: import type { SessionMessage } from "@opencode/schema/session-message"
10: import type { JsonSchema, Types } from "effect"
11: import type { ModelHooks } from "./registration.js"
12:
13: export interface SessionPrompt {
14: readonly sessionID: Session.ID
15: readonly messageID: SessionMessage.ID
16: prompt: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/registration.ts</path>
<type>file</type>
<content>
1: export interface Registration {
2: readonly dispose: () => Promise<void>
3: }
4:
5: export interface ModelHookOptions {
6: /** Limits the hook to one provider. Unscoped hooks apply to every provider. */
7: readonly providerID?: string
8: }
9:
10: export type Hooks<Spec> = <Name extends keyof Spec>(
11: name: Name,
12: callback: (input: Spec[Name]) => Promise<void> | void,
13: ) => Promise<Registration>
14:
15: export type ModelHooks<Spec> = <Name extends keyof Spec>(
16: name: Name,
17: callback: (input: Spec[Name]) => Promise<void> | void,
18: options?: Spec[Name] extends { readonly model: unknown } ? ModelHookOptions : never,
19: ) => Promise<Registration>
20:
21: export type Transform<Input> = (callback: (input: Input) => void) => Promise<Registration>
(End of file - total 21 lines)
</content>
Found 56 matches /home/byk/Code/opencode-v2-pilot/packages/core/src/instructions/builtins.ts: Line 20: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/formatter.ts: Line 30: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/filesystem.ts: Line 67: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/worktree/refresh.ts: Line 12: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/file-access.ts: Line 96: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/worktree.ts: Line 133: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/config.ts: Line 88: const location = yield* Location.Service /home/byk/Code/opencode-v2-pilot/packages/core/src/vcs.ts: Line 56: const location = yield* ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/host.ts</path>
<type>file</type>
<content>
48: plugin: Pick<Interface, "list">,
49: pluginID: string = "test",
50: ) {
51: const app = yield* App.Metadata
52: const agents = yield* Agent.Service
53: const aisdk = yield* AISDK.Service
54: const catalog = yield* Catalog.Service
55: const commands = yield* Command.Service
56: const bus = yield* Bus.Service
57: const integration = yield* Integration.Service
58: const kv = yield* KV.Service
59: const mcp = yield* Mcp.Service
60: const location = yield* Location.Service
61: const reference = yield* Reference.Service
62: const rpc = yield* Rpc.Service
63: const skill = yield* Skill.Service
64: const tools = yield* Tool.Service
65: const vcs = yield* Vcs.Service
66: const websearch = yield* WebSearch.Service
67: const generate = yield* Generate.Service
68: const permission = yield* Permission.Service
69: const hooks = yield* ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin.ts</path>
<type>file</type>
<content>
70: Context.make(Scope.Scope, activation.scope).pipe(
71: Context.add(Logger.CurrentLoggers, Context.get(context, Logger.CurrentLoggers)),
72: Context.add(References.MinimumLogLevel, Context.get(context, References.MinimumLogLevel)),
73: ),
74: ),
75: Effect.withSpan("Plugin.load", { attributes: { "plugin.id": plugin.id } }),
76: Effect.onExit((exit) =>
77: Exit.isFailure(exit) && !activation.failure ? Scope.close(activation.scope, exit) : Effect.void,
78: ),
79: Effect.exit,
80: )
81: if (activation.failure || Exit.isSuccess(exit)) return { activation } as const
82: yield* Effect.logWarning("failed to load plugin", {
83: "plugin.id": plugin.id,
84: cause: exit.cause,
85: })
86: return { error: Cause.pretty(exit.cause) } as const
87: })
88: ...
Found 3 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/host.ts:
Line 91: effect.pipe(Effect.map((data) => ({ location: locationInfo(), data })))
Line 127: const context: Plugin.Context = {
Line 129: location: locationInfo(),
No files found
Found 4 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/commands/start.ts:
Line 11: * opts.remoteUrl — remote gateway URL (string, optional)
Line 107: remoteUrl: flags.remote,
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 90: remoteUrl?: string;
Line 451: if (opts.remoteUrl) args.push("--remote", opts.remoteUrl);
<path>/home/byk/Code/opencode-lore/packages/gateway/script/bundle.ts</path> <type>file</type> <content> 300: }); 301: 302: // --------------------------------------------------------------------------- 303: // Ship onnxruntime-web WASM runtime next to the worker bundles 304: // --------------------------------------------------------------------------- 305: // The worker bundles redirect onnxruntime-node → onnxruntime-web (WASM). At 306: // runtime, embedding-worker.ts sets __LORE_NPM_WASM_PATHS__ to these sibling 307: // files so transformers.js loads the WASM locally instead of from the jsdelivr 308: // CDN (wrong variant + requires network). Must stay in sync with the `files` 309: // array in package.json and the runtime block in embedding-worker.ts. 310: // 311: // We ship the UNPATCHED ort-wasm-simd-threaded.mjs (unlike the SEA binary, 312: // which patches its pthread spawn to a no-op). This is safe ONLY because the 313: // worker forces numThreads=1 (embedding-worker.ts), so ...
<path>/home/byk/Code/opencode-lore/packages/gateway/script/bundle.ts</path>
<type>file</type>
<content>
440: // Type declarations — dist/index.d.cts
441: // ---------------------------------------------------------------------------
442:
443: const typeDeclarations = `/** Gateway configuration — loaded from environment variables with sensible defaults. */
444: export interface GatewayConfig {
445: /** Port to listen on. Default: 3207. Env: LORE_LISTEN_PORT */
446: port: number;
447: /** True when the port was explicitly set via LORE_LISTEN_PORT or --port. */
448: portExplicit: boolean;
449: /**
450: * Hosts to bind to. Default: ["127.0.0.1"].
451: * Env: LORE_LISTEN_HOST (comma-separated for multiple addresses).
452: */
453: hosts: string[];
454: /** Upstream Anthropic API URL. Default: "https://api.anthropic.com". Env: LORE_UPSTREAM_ANTHROPIC */
455: upstreamAnthropic: string;
456: /** Upstream OpenAI API URL. Default: "https://api.openai.com". ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
70: * for the writer's checkpoint+close. Mirrors {@link EMBED_DRAIN_DEADLINE_MS}'s
71: * safety floor of 500ms so an aggressive `LORE_SHUTDOWN_TIMEOUT_MS` (e.g.
72: * 1000ms) doesn't shrink the pool budget into a guaranteed timeout.
73: */
74: const VECTOR_POOL_SHUTDOWN_DEADLINE_MS = Math.max(
75: Math.min(
76: DEFAULT_VECTOR_POOL_SHUTDOWN_DEADLINE_MS,
77: SHUTDOWN_DEADLINE_MS - 500,
78: ),
79: 500,
80: );
81:
82: export interface StartOptions {
83: port?: number;
84: hosts?: string[];
85: debug?: boolean;
86: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
87: quiet?: boolean;
88: /** Remote gateway URL. When set, `lore run` delegates to this gateway
89: * instead of starting a local one. Overrides LORE_REMOTE_URL env var. */
90: remoteUrl?: string;
91: /**
92: * When true, disables hosted mode even for `lore ...
Found 24 matches
/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts:
Line 5: * and URL context), this interceptor wraps `globalThis.fetch` to redirect
Line 317: * Returns a cleanup function that restores the original `globalThis.fetch`.
Line 320: * Process-global slot holding the original `globalThis.fetch` captured before
Line 323: * module already patched `globalThis.fetch`, so later installs no-op instead
Line 326: * Keyed via `Symbol.for(...)` — a *process-global* registry — so that EVERY
Line 341: const ORIGINAL_FETCH_KEY = Symbol.for("lore.fetchInterceptor.originalFetch");
Line 344: function readOriginalFetchSlot(): typeof globalThis.fetch | null {
Line 346: (globalThis as Record<symbol, typeof globalThis.fetch | null | undefined>)[
Line 347: ORIGINAL_FETCH_KEY
Line 353: function writeOriginalFetchSlot(fn: typeof globalThis.fetch | null): void {
Line 354: (globalThis as Record<symbol, typeof globalThis.fetch | ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path> <type>file</type> <content> 310: * 1. Checks if the outgoing URL matches a known LLM API path 311: * 2. Rewrites the URL to the gateway, preserving the path 312: * 3. Adds `X-Lore-Upstream-URL` (base) and `X-Lore-Upstream-Path` (original 313: * endpoint pathname, for verbatim forwarding) 314: * 4. Injects dynamic `X-Lore-*` context headers from `getHeaders()` 315: * 5. Preserves ALL original headers (auth, content-type, etc.) 316: * 317: * Returns a cleanup function that restores the original `globalThis.fetch`. 318: */ 319: /** 320: * Process-global slot holding the original `globalThis.fetch` captured before 321: * any interceptor was installed. It backs the cross-copy double-install guard 322: * in `installFetchInterceptor()`: a non-null slot means some copy of this 323: * module already patched `globalThis.fetch`, so later installs no-op instead 324: * of stacking interceptors. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: }
15: },
16: "scripts": {
17: "typecheck": "tsc --noEmit",
18: "build": "echo '@loreai/opencode ships raw TS — no build step needed'"
19: },
20: "peerDependencies": {
21: "@opencode-ai/plugin": ">=1.1.0"
22: },
23: "dependencies": {
24: "@loreai/core": "workspace:*",
25: "@loreai/gateway": "workspace:*"
26: },
27: "devDependencies": {
28: "@opencode-ai/plugin": "^1.1.39",
29: "@opencode-ai/sdk": "^1.1.39",
30: ...
<path>/home/byk/Code/opencode-lore/AGENTS.md</path> <type>file</type> <content> 1: <!-- This section is maintained by the coding agent via lore (https://github.com/BYK/loreai) --> 2: ## Long-term Knowledge 3: 4: For long-term knowledge entries managed by [lore](https://github.com/BYK/loreai) (gotchas, patterns, decisions, architecture), see [`.lore.md`](.lore.md) in the project root. 5: <!-- End lore-managed section --> 6: 7: ## Review 8: 9: See [`quality/REVIEW.md`](quality/REVIEW.md) for the review heuristics and workflow — regression-test discipline, adversarial-order state setup, fan-out registry coverage, recurring bug-class batteries, and the two-reviewer rule. Every non-trivial PR requires an adversarial correctness review before merge. 10: 11: # Project Overview 12: 13: Lore is a **three-tier memory architecture** for AI coding agents. ...
Found 29 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 219: if (!res.ok) return { kind: "rejected" };
Line 477: return { command: process.execPath, args: childArgs };
Line 480: return { command: process.execPath, args: [process.argv[1], ...childArgs] };
Line 538: return { state: "unknown" };
Line 571: return await withLifecycleLock("gateway-shutdown", (lock) => {
Line 624: return {
Line 639: return { stopped: false, signalled };
Line 660: return { stopped: false, signalled };
Line 675: await withLifecycleLock("gateway-start", async (lifecycleLock) => {
Line 691: return { stopped: exited, signalled };
Line 741: const spawned = await withLifecycleLock("gateway-start", (lifecycleLock) => {
Line 748: return {
Line 830: return {
Line 865: * handle with `owned: false`
Line 868: export async function startGateway(
Line 872: return withLifecycleLock("gateway-start", ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
850: * `safeExit`.
851: */
852: async function startDaemon(opts: StartOptions): Promise<never> {
853: safeExit(await runDaemon(opts, realDaemonIO(opts)));
854: }
855:
856: /**
857: * Start the gateway server, returning the actual port and a shutdown function.
858: *
859: * Merges CLI options on top of env-var config (CLI takes precedence).
860: *
861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`),
862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port.
863: * At each step, if the port is occupied by an existing lore gateway
864: * (verified via its process record and owner-only control token), returns a
865: * handle with `owned: false`
866: * so the caller can reuse the existing instance. ...
Found 32 matches
/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts:
Line 8: * the plugin's startInProcess delegates to). Tests use ephemeral ports so
/home/byk/Code/opencode-lore/packages/opencode/src/index.ts:
Line 44: async function resolveGatewayUrl(): Promise<string | null> {
Line 89: async function startInProcess(): Promise<string | null> {
Line 265: const existingUrl = await resolveGatewayUrl();
Line 272: const startedUrl = await startInProcess();
/home/byk/Code/opencode-lore/packages/opencode/eval/data/sessions/cli-nightly.json:
Line 38: "content": "[reasoning] The user wants to implement a nightly/dev build distribution system for the Sentry CLI. Let me break down what they're asking for:\n\n1. A release channel concept (stable vs nightly)\n2. Automatic versioning for main branch builds (dev versions)\n3. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
548: })
549: }),
550: ),
551: },
552: worktree: {
553: list: adaptApiMethod(WorktreeEndpoints["worktree.list"], host.worktree.list),
554: create: adaptApiMethod(WorktreeEndpoints["worktree.create"], host.worktree.create),
555: remove: adaptApiMethod(WorktreeEndpoints["worktree.remove"], host.worktree.remove),
556: refresh: adaptApiMethod(WorktreeEndpoints["worktree.refresh"], host.worktree.refresh),
557: reload: () => run(host.worktree.reload()),
558: transform: (callback) =>
559: register(
560: host.worktree.transform((editor) =>
561: callback({
562: add: (definition) =>
563: editor.add({
564: id: definition.id,
565: ...
Found 34 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/tool/plugin/websearch.ts:
Line 183: yield* ctx.session.hook("context", (event) =>
/home/byk/Code/opencode-v2-pilot/packages/core/src/tool/plugin/subagent.ts:
Line 237: yield* ctx.session.hook("context", (event) =>
/home/byk/Code/opencode-v2-pilot/packages/core/src/tool/plugin/shell.ts:
Line 274: yield* ctx.session.hook("context", (event) =>
/home/byk/Code/opencode-v2-pilot/packages/core/src/tool/plugin/patch.ts:
Line 295: yield* ctx.session.hook("context", (event) =>
/home/byk/Code/opencode-v2-pilot/packages/core/src/tool/plugin/opencode.ts:
Line 28: yield* ctx.session.hook("context", (event) =>
/home/byk/Code/opencode-v2-pilot/packages/core/src/session/generate.ts:
Line 13: import { SessionModelRequest } from "./model-request.js"
/home/byk/Code/opencode-v2-pilot/packages/core/src/session/context.ts:
Line 24: import { SessionModelRequest } from "./model-request.js"
Line ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/session/model-request.ts</path>
<type>file</type>
<content>
205: }
206:
207: const sessionHeaders = (session: Pick<SessionSchema.Info, "id" | "parentID" | "projectID">, app: App.Info) => ({
208: "x-session-affinity": session.id,
209: "X-Session-Id": session.id,
210: ...(session.parentID ? { "x-parent-session-id": session.parentID } : {}),
211: "User-Agent": App.useragent(app),
212: "x-opencode-project": session.projectID,
213: "x-opencode-session": session.id,
214: "x-opencode-client": app.name,
215: })
216:
217: const promptCacheKey = (sessionID: SessionSchema.ID) =>
218: /^ses_[0-9a-f]{64}$/.test(sessionID) ? sessionID.slice(4) : sessionID
219:
220: // Lets session.model.request hooks rewrite the base URL and headers before dispatch.
221: const applyModelHooks = (hooks: PluginHooks.Interface, scope: HookScope, request: LLMRequest) =>
222: Effect.gen(function* () {
223: const currentBaseURL = ...
Found 84 matches
/home/byk/Code/opencode-lore/packages/opencode/test/index.test.ts:
Line 38: const hooks = await LorePlugin({
Line 50: cleanup: () => rmSync(tmpDir, { recursive: true, force: true }),
Line 56: const { hooks, cleanup } = await initPlugin();
Line 63: cleanup();
Line 68: const { hooks, cleanup } = await initPlugin();
Line 105: cleanup();
Line 110: const { hooks, cleanup } = await initPlugin();
Line 124: cleanup();
Line 132: // a 404 from the gateway. The plugin must pin EVERY provider's baseURL
Line 133: // to `${gatewayBase}/v1` because opencode's resolveSDK() bypasses the
Line 210: test("is a no-op when gatewayBase is empty (test env / startup failure)", () => {
Line 211: // In NODE_ENV=test the plugin's init skips gateway start, so
Line 212: // gatewayBase is "". ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/website/integrations/favicon-assets.ts:
Line 83: "cleanupIds",
/home/byk/Code/opencode-lore/packages/core/eval/inflate.ts:
Line 599: action: "compute" | "sync" | "cleanup";
Line 646: case "cleanup": {
Line 726: `Redis. Need processing, syncing, and cleanup job types with retry logic.`,
Line 733: `- Two job types: process (compute/sync/cleanup) and batch sync\n` +
Line 735: `- Auto-cleanup of completed (24h) and failed (7d) jobs\n` +
Line 897: const job = { data: { recordId: "rec-old", action: "cleanup", triggeredBy: "cron" }, attemptsMade: 0 };
Line 912: const job = { data: { recordId: "rec-recent", action: "cleanup", triggeredBy: "cron" }, attemptsMade: 0 };
Line 969: `Redis connections. Cover compute, cleanup (including the 30-day ` +
Line 1235: * Used by the cleanup worker to identify stale entries. ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { PluginContext } from "./context.js"
2:
3: export interface Plugin {
4: readonly id: string
5: readonly setup: (context: PluginContext) => Promise<void> | void
6: }
7:
8: export function define(plugin: Plugin) {
9: return plugin
10: }
11:
12: export interface PluginDomain {
13: readonly add: (plugin: Plugin) => Promise<void>
14: readonly remove: (id: string) => Promise<void>
15: }
(End of file - total 15 lines)
</content>
Found 5 matches
/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts:
Line 46: it("reuses an existing authenticated gateway instead of EADDRINUSE", async () => {
Line 219: it("removes port and PID state when process-record publication fails", async () => {
Line 236: it("retains discovery evidence if publication cleanup cannot close listener", async () => {
Line 277: it("serializes concurrent starts through process-record publication", async () => {
Line 322: it("makes a successor wait until shutdown removes predecessor records", async () => {
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
30: while (teardowns.length) {
31: try {
32: await teardowns.pop()?.();
33: } catch {
34: // Best-effort listener cleanup after an assertion failure.
35: }
36: }
37: const port = readPortFile();
38: if (port) removePortFile(port);
39: const record = readGatewayProcessFile();
40: if (record) removePidFile(record.pid);
41: if (previousXdg === undefined) delete process.env.XDG_DATA_HOME;
42: else process.env.XDG_DATA_HOME = previousXdg;
43: rmSync(base, { recursive: true, force: true });
44: });
45:
46: it("reuses an existing authenticated gateway instead of EADDRINUSE", async () => {
47: const { startGateway } = await import("../src/cli/start");
48: const existing = await startGateway({ port: 0, local: true, quiet: true });
49: teardowns.push(() => existing.shutdown());
50: const ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
210: * Adapts a Promise plugin into an Effect plugin so the existing Effect-only
211: * Core plugin runtime can run it unchanged.
212: *
213: * Hook registrations created during the async `setup` attach to the plugin's
214: * scope, so unloading the plugin disposes them. The captured fiber context
215: * preserves boot-time batching, so Promise-plugin transforms still coalesce
216: * into one reload per domain.
217: */
218: export function fromPromise(plugin: Plugin) {
219: return define({
220: id: plugin.id,
221: effect: (host) =>
222: Effect.gen(function* () {
223: const [{ ClientApi }, { OpenCodeEvent }] = yield* Effect.promise(() =>
224: Promise.all([import("@opencode/protocol/client"), import("@opencode/protocol/groups/event")]),
225: )
226: const AgentEndpoints = ClientApi.groups["server.agent"].endpoints
227: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
374: // Inject per-request identifiers so the gateway can distinguish meta
375: // requests (title generation, summary agents, etc.) from real
376: // conversation turns and route by provider.
377: // Project path, git remote, and upstream URL are injected by the
378: // fetch interceptor (installed once per process).
379: "chat.headers": async (input, output) => {
380: Object.assign(
381: output.headers,
382: gatewayAccessHeadersForRemote(gatewayBase),
383: );
384: // Inject stable session ID — OpenCode's DB session ID survives restarts,
385: // unlike x-session-affinity (nanoid regenerated per process).
386: output.headers["x-lore-session-id"] = input.sessionID;
387: output.headers["x-lore-agent"] = input.agent;
388: // Flag OpenCode Task sub-agents so the gateway sizes ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
1: /**
2: * `lore start` — start the gateway server without auto-launching an agent.
3: *
4: * Extracted from the old top-level index.ts boot logic.
5: */
6: import { spawn } from "node:child_process";
7: import { randomBytes } from "node:crypto";
8: import { closeSync } from "node:fs";
9: import { join } from "node:path";
10: import {
11: assertGatewayAccessConfigured,
12: loadConfig,
13: DEFAULT_PORTS,
14: type GatewayConfig,
15: } from "../config";
16: import { startServer, bracketHost } from "../server";
17: import { resetPipelineState } from "../pipeline";
18: import { writePortFile, removePortFile } from "../portfile";
19: import {
20: writeGatewayProcessFile,
21: readGatewayProcessFile,
22: removeGatewayProcessFile,
23: type GatewayProcessRecord,
24: } from "../pidfile";
25: import {
26: dataDir,
27: embedding,
28: temporalEmbeddingQueue,
29: ...
<path>/home/byk/Code/opencode/packages/plugin/src/v2/promise/context.ts</path>
<type>file</type>
<content>
1: import type { PluginOptions } from "../options.js"
2: import type { AgentHooks } from "./agent.js"
3: import type { AISDKHooks } from "./aisdk.js"
4: import type { CatalogHooks } from "./catalog.js"
5: import type { CommandHooks } from "./command.js"
6: import type { IntegrationHooks } from "./integration.js"
7: import type { PluginDomain } from "./plugin.js"
8: import type { ReferenceHooks } from "./reference.js"
9: import type { SkillHooks } from "./skill.js"
10: import type { Reload } from "./registration.js"
11:
12: export interface PluginContext {
13: readonly options: PluginOptions
14: readonly agent: AgentHooks & Reload
15: readonly aisdk: AISDKHooks
16: readonly catalog: CatalogHooks & Reload
17: readonly command: CommandHooks & Reload
18: readonly integration: IntegrationHooks & Reload
19: readonly plugin: PluginDomain
20: readonly reference: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/session.ts</path>
<type>file</type>
<content>
1: import type { SessionApi } from "@opencode/client/promise/api"
2: import type { GenerationOptionsFields, Message, SystemPart } from "@opencode/ai"
3: import type { Agent } from "@opencode/schema/agent"
4: import type { Model } from "@opencode/schema/model"
5: import type { PromptInput } from "@opencode/schema/prompt-input"
6: import type { Session } from "@opencode/schema/session"
7: import type { SessionInbox } from "@opencode/schema/session-inbox"
8: import type { SessionError } from "@opencode/schema/session-error"
9: import type { SessionMessage } from "@opencode/schema/session-message"
10: import type { JsonSchema, Types } from "effect"
11: import type { ModelHooks } from "./registration.js"
12:
13: export interface SessionPrompt {
14: readonly sessionID: Session.ID
15: readonly messageID: SessionMessage.ID
16: prompt: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/registration.ts</path>
<type>file</type>
<content>
1: export interface Registration {
2: readonly dispose: () => Promise<void>
3: }
4:
5: export interface ModelHookOptions {
6: /** Limits the hook to one provider. Unscoped hooks apply to every provider. */
7: readonly providerID?: string
8: }
9:
10: export type Hooks<Spec> = <Name extends keyof Spec>(
11: name: Name,
12: callback: (input: Spec[Name]) => Promise<void> | void,
13: ) => Promise<Registration>
14:
15: export type ModelHooks<Spec> = <Name extends keyof Spec>(
16: name: Name,
17: callback: (input: Spec[Name]) => Promise<void> | void,
18: options?: Spec[Name] extends { readonly model: unknown } ? ModelHookOptions : never,
19: ) => Promise<Registration>
20:
21: export type Transform<Input> = (callback: (input: Input) => void) => Promise<Registration>
(End of file - total 21 lines)
</content>
No files found
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
165:
166: function isLoopbackProbeUrl(value: string): boolean {
167: try {
168: const hostname = new URL(value).hostname
169: .replace(/^\[/, "")
170: .replace(/\]$/, "")
171: .toLowerCase();
172: return (
173: hostname === "localhost" ||
174: hostname === "localhost." ||
175: hostname === "::1" ||
176: /^127(?:\.\d{1,3}){3}$/.test(hostname)
177: );
178: } catch {
179: return false;
180: }
181: }
182:
183: /**
184: * Fetch an internal gateway endpoint without WHATWG's browser forbidden-port
185: * list breaking valid loopback listeners. Non-loopback URLs retain the normal
186: * Fetch transport and semantics used for remote/LAN gateways.
187: */
188: export function internalProbeFetch(
189: url: string,
190: init?: RequestInit,
191: ): Promise<Response> {
192: return isLoopbackProbeUrl(url)
193: ? ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
980:
981: function lockArtifactPrefix(lockPath: string, marker: string): string {
982: return `.${basename(lockPath)}${marker}`;
983: }
984:
985: function sameOwnerRecord(
986: left: OwnerRecordSnapshot,
987: right: OwnerRecordSnapshot,
988: ): boolean {
989: return sameFile(left.file, right.file) && left.content === right.content;
990: }
991:
992: function createOwnerStage(
993: lockPath: string,
994: owner: LifecycleLockOwner,
995: ): OwnerStage {
996: const parent = dirname(lockPath);
997: const path = join(
998: parent,
999: `${lockArtifactPrefix(lockPath, ".owner.")}${owner.token}.${randomBytes(8).toString("hex")}.tmp`,
1000: );
1001: const initializationClaimPath = join(
1002: parent,
1003: `${lockArtifactPrefix(lockPath, INITIALIZATION_CLAIM_MARKER)}${owner.token}`,
1004: );
1005: let fd: number | undefined;
1006: try {
1007: ...
Found 2 matches
/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts:
Line 201: export function withoutLifecycleLock<T>(action: () => T): T {
Line 1841: export async function withLifecycleLock<T>(
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
180: interface UninstallTombstoneSnapshot {
181: marker: UninstallTombstone;
182: file: Stats;
183: content: string;
184: }
185:
186: interface PackageInvocationEvidence {
187: entryPath: string;
188: entryIdentity: string;
189: manifestPath: string;
190: manifestIdentity: string;
191: }
192:
193: interface CapturedRegularFile {
194: content: Buffer;
195: identity: string;
196: }
197:
198: const lockContext = new AsyncLocalStorage<LifecycleLock>();
199:
200: /** Run work without propagating the current lifecycle lock to async resources. */
201: export function withoutLifecycleLock<T>(action: () => T): T {
202: return lockContext.exit(action);
203: }
204: const processEntryPath = (() => {
205: try {
206: return require.main?.filename;
207: } catch {
208: return undefined;
209: }
210: })();
211:
212: function errno(error: unknown): string | ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1825: `Lore lifecycle is busy${detail}; retry after the operation completes`,
1826: );
1827: }
1828: await options.sleep(
1829: Math.min(options.retryDelayMs, Math.max(0, deadline - options.now())),
1830: );
1831: }
1832: } finally {
1833: if (!ownerStageRemoved) {
1834: removeExpectedOwnerRecord(ownerStage.initializationClaimPath, ownerStage);
1835: removeExpectedOwnerRecord(ownerStage.path, ownerStage);
1836: }
1837: }
1838: }
1839:
1840: /** Run a lifecycle transition under the lock, with async-context reentrancy. */
1841: export async function withLifecycleLock<T>(
1842: operation: LifecycleOperation,
1843: action: (lock: LifecycleLock) => Promise<T> | T,
1844: options: LifecycleLockOptions = {},
1845: ): Promise<T> {
1846: const inherited = lockContext.getStore();
1847: if (inherited) ...
Found 4 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts:
Line 90: remoteUrl?: string;
Line 451: if (opts.remoteUrl) args.push("--remote", opts.remoteUrl);
/home/byk/Code/opencode-lore/packages/gateway/src/cli/commands/start.ts:
Line 11: * opts.remoteUrl — remote gateway URL (string, optional)
Line 107: remoteUrl: flags.remote,
Found 6 matches
/home/byk/Code/opencode-lore/packages/gateway/src/server.ts:
Line 761: shutdownDeadlineMs?: number;
Line 775: closeServer(server, options.shutdownDeadlineMs ?? SHUTDOWN_DEADLINE_MS));
Line 1298: let stopPromise: Promise<void> | undefined;
Line 1301: stopPromise ??= Promise.all(servers.map(closeBoundServer)).then(() => {});
Line 1302: return stopPromise;
Line 1351: function closeServer(server: Server, deadlineMs: number): Promise<void> {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
740: const msg = e instanceof Error ? e.message : "Pipeline error";
741: log.error(`pipeline error: ${msg}`);
742: return errorResponse(502, "api_error", `Gateway pipeline error: ${msg}`);
743: }
744: }
745:
746: // ---------------------------------------------------------------------------
747: // Server
748: // ---------------------------------------------------------------------------
749:
750: const responseCompletionCallbacks = new WeakMap<Response, () => void>();
751:
752: export async function startServer(
753: config: GatewayConfig,
754: options: {
755: controlToken?: string;
756: /** Invoked asynchronously after an authenticated shutdown response flushes. */
757: onShutdown?: () => void | Promise<void>;
758: /** Focused lifecycle seam for exercising listener-close failures. */
759: closeServer?: (server: Server) => Promise<void>;
760: ...
Found 7 matches
/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts:
Line 3: export interface Plugin {
Line 5: readonly setup: (context: PluginContext) => Promise<void> | void
Line 12: export interface PluginDomain {
/home/byk/Code/opencode/packages/plugin/src/v2/promise/context.ts:
Line 12: export interface PluginContext {
/home/byk/Code/opencode/packages/plugin/src/v2/effect/plugin.ts:
Line 4: export interface Plugin<R = Scope.Scope> {
Line 13: export interface PluginDomain {
/home/byk/Code/opencode/packages/plugin/src/v2/effect/context.ts:
Line 12: export interface PluginContext {
Found 12 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin.ts:
Line 24: // the prefix diff below stays index-aligned and a failed revision is not retried until it changes.
Line 25: const active = new Map<Plugin.ID, Slot>()
Line 65: plugin.effect({ ...host, storage: PluginHost.storage(kv, plugin.id) }),
Line 77: Exit.isFailure(exit) && !activation.failure ? Scope.close(activation.scope, exit) : Effect.void,
Line 89: const activate = Effect.fn("Plugin.activate")(function* (
Line 110: return entry?.plugin.id !== definition.id || entry.plugin.revision !== definition.revision
Line 135: yield* Scope.close(slot.activation.scope, Exit.void)
Line 141: // Reordering healthy registrations does not authorize retrying a failed revision.
Line 142: if (slot?.activation?.failure && slot.plugin.revision === definition.revision) {
Line 211: ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin.ts</path>
<type>file</type>
<content>
50: const grouped = State.group((failure, refresh) => {
51: activation.failure = {
52: error: `Plugin disabled after ${failure.state}.transform failed. Check server logs for details.`,
53: ref: `err_${crypto.randomUUID().slice(0, 8)}`,
54: }
55: Queue.offerUnsafe(pendingFailures, {
56: plugin,
57: scope: activation.scope,
58: failure,
59: refresh,
60: ref: activation.failure.ref,
61: release: holdUnsafe(),
62: })
63: })
64: const exit = yield* Effect.suspend(() =>
65: plugin.effect({ ...host, storage: PluginHost.storage(kv, plugin.id) }),
66: ).pipe(
67: grouped,
68: inherit,
69: Effect.updateContext((context: Context.Context<never>) =>
70: Context.make(Scope.Scope, activation.scope).pipe(
71: ...
Found 1 matches /home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts: Line 8: * the plugin's startInProcess delegates to). Tests use ephemeral ports so
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore/packages/pi/test/real-runtime.e2e.test.ts:
Line 131: process.env.LORE_GATEWAY_URL = baseURL;
/home/byk/Code/opencode-lore/packages/pi/test/internal.test.ts:
Line 9: resolveGatewayUrl,
Line 31: gatewayBase: GW,
Line 51: gatewayBase: GW,
Line 65: gatewayBase: GW,
Line 76: gatewayBase: GW,
Line 88: gatewayBase: GW,
Line 106: gatewayBase: "https://lore.example",
Line 126: gatewayBase: GW,
Line 154: gatewayBase: GW,
Line 347: describe("resolveGatewayUrl diagnostics", () => {
Line 350: const previousGateway = process.env.LORE_GATEWAY_URL;
Line 356: delete process.env.LORE_GATEWAY_URL;
Line 360: await expect(resolveGatewayUrl()).resolves.toBe(
Line 370: if (previousGateway === undefined) delete process.env.LORE_GATEWAY_URL;
Line 371: else process.env.LORE_GATEWAY_URL = previousGateway;
Line ...
/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore/packages/opencode/src/index.ts
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore/packages/opencode/src/index.ts
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/plugin.ts</path>
<type>file</type>
<content>
1: import type { OpenCodeClient } from "@opencode/client"
2: import type { GenerateApi, PluginApi } from "@opencode/client/promise/api"
3: import type { Location } from "@opencode/schema/location"
4: import type { PluginOptions } from "../options.js"
5: import type { App } from "../app.js"
6: import type { AgentDomain } from "./agent.js"
7: import type { AISDKDomain } from "./aisdk.js"
8: import type { CatalogDomain } from "./catalog.js"
9: import type { CommandDomain } from "./command.js"
10: import type { EventDomain } from "./event.js"
11: import type { IntegrationDomain } from "./integration.js"
12: import type { MCPDomain } from "./mcp.js"
13: import type { PermissionDomain } from "./permission.js"
14: import type { ReferenceDomain } from "./reference.js"
15: import type { RpcDomain } from "./rpc.js"
16: import type { SessionDomain } from "./session.js"
17: import type ...
/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore/packages/opencode/src/index.ts
Invalid ripgrep match output
Found 1 matches
/home/byk/Code/opencode-lore/packages/gateway/src/index.ts:
Line 22: export { startServer } from "./server";
Found 24 matches
/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts:
Line 317: * Returns a cleanup function that restores the original `globalThis.fetch`.
Line 322: * in `installFetchInterceptor()`: a non-null slot means some copy of this
Line 338: * The slot is unset until `installFetchInterceptor()` is called, and released
Line 339: * (set back to `null`) by its cleanup.
Line 341: const ORIGINAL_FETCH_KEY = Symbol.for("lore.fetchInterceptor.originalFetch");
Line 347: ORIGINAL_FETCH_KEY
Line 353: function writeOriginalFetchSlot(fn: typeof globalThis.fetch | null): void {
Line 355: ORIGINAL_FETCH_KEY
Line 421: export function installFetchInterceptor(
Line 428: // infinite-loop shape #1027 guards against). Return a no-op cleanup instead.
Line 433: const originalFetch = globalThis.fetch;
Line 434: writeOriginalFetchSlot(originalFetch);
Line 460: return originalFetch(input, init);
Line 468: return ...
<path>/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts</path> <type>file</type> <content> 309: * The interceptor: 310: * 1. Checks if the outgoing URL matches a known LLM API path 311: * 2. Rewrites the URL to the gateway, preserving the path 312: * 3. Adds `X-Lore-Upstream-URL` (base) and `X-Lore-Upstream-Path` (original 313: * endpoint pathname, for verbatim forwarding) 314: * 4. Injects dynamic `X-Lore-*` context headers from `getHeaders()` 315: * 5. Preserves ALL original headers (auth, content-type, etc.) 316: * 317: * Returns a cleanup function that restores the original `globalThis.fetch`. 318: */ 319: /** 320: * Process-global slot holding the original `globalThis.fetch` captured before 321: * any interceptor was installed. It backs the cross-copy double-install guard 322: * in `installFetchInterceptor()`: a non-null slot means some copy of this 323: * module already patched `globalThis.fetch`, so later installs no-op instead 324: * of ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
82: export interface StartOptions {
83: port?: number;
84: hosts?: string[];
85: debug?: boolean;
86: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
87: quiet?: boolean;
88: /** Remote gateway URL. When set, `lore run` delegates to this gateway
89: * instead of starting a local one. Overrides LORE_REMOTE_URL env var. */
90: remoteUrl?: string;
91: /**
92: * When true, disables hosted mode even for `lore start`.
93: * CLI: `--local` / `-l`.
94: */
95: local?: boolean;
96: /** Allow non-loopback peers to access the dashboard and management API. */
97: allowRemoteManagement?: boolean;
98: /**
99: * When true, `lore start` daemonizes: it re-spawns itself detached, polls
100: * the gateway until healthy, prints the address + PID + log path, and exits 0.
101: * CLI: `--bg` / `--daemon`.
102: */
103: bg?: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path> <type>file</type> <content> 860: * 861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`), 862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port. 863: * At each step, if the port is occupied by an existing lore gateway 864: * (verified via its process record and owner-only control token), returns a 865: * handle with `owned: false` 866: * so the caller can reuse the existing instance. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/internal.ts</path> <type>file</type> <content> 1: /** 2: * Internal helpers for the Lore OpenCode plugin. 3: * 4: * These functions are intentionally kept OUT of the plugin entry module 5: * (`./index.ts`). OpenCode's legacy plugin loader treats EVERY function 6: * exported from a plugin module as a plugin instance and invokes it (see 7: * `getServerPlugin`/`getLegacyPlugins` in opencode's plugin loader). Exporting 8: * these helpers from the entry module caused them to be invoked as plugins and 9: * their return values pushed into the host's hooks array: 10: * `applyLoreProviderConfig` returns `undefined`, so the host crashed on the 11: * first hook dispatch with `undefined is not an object (evaluating 'A.event')` 12: * (the `?.` guards the `.event` property, not the `undefined` hook element). ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/host.ts</path>
<type>file</type>
<content>
40: const mutable = <T>(value: T) => value as DeepMutable<T>
41: type RpcEvent = Event.Payload & {
42: readonly type: `rpc.${string}`
43: readonly location: Location.Ref
44: readonly data: Readonly<Record<string, unknown>>
45: }
46: const isRpcEvent = (event: Event.Payload): event is RpcEvent => event.type.startsWith("rpc.")
47: export const make = Effect.fn("PluginHost.make")(function* (
48: plugin: Pick<Interface, "list">,
49: pluginID: string = "test",
50: ) {
51: const app = yield* App.Metadata
52: const agents = yield* Agent.Service
53: const aisdk = yield* AISDK.Service
54: const catalog = yield* Catalog.Service
55: const commands = yield* Command.Service
56: const bus = yield* Bus.Service
57: const integration = yield* Integration.Service
58: const kv = yield* KV.Service
59: const mcp = yield* Mcp.Service
60: const location = yield* ...
Found 3 matches /home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts: Line 2: * Fetch-level interception for transparent LLM API proxy routing. Line 9: * provider), and the interceptor transparently reroutes them through the Line 306: * Install a fetch interceptor that transparently reroutes LLM API calls
No files found
/home/byk/Code/opencode-lore-v2/packages/opencode/src/server.ts /home/byk/Code/opencode-lore-v2/packages/opencode/src/server-runtime.ts /home/byk/Code/opencode-lore-v2/packages/opencode/src/internal.ts /home/byk/Code/opencode-lore-v2/packages/opencode/src/index.ts
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/server.ts</path>
<type>file</type>
<content>
1: import { rewriteRequest } from "@loreai/core";
2: import type { Plugin } from "@opencode/plugin";
3: import { acquireServerRuntime, buildServerHeaders } from "./server-runtime";
4:
5: const workers = [
6: ["lore-distill", "Lore memory distillation worker"],
7: ["lore-curator", "Lore knowledge curator worker"],
8: ["lore-query-expand", "Lore query expansion worker"],
9: ] as const;
10:
11: export default {
12: id: "lore",
13: setup: async (ctx) => {
14: const runtime = await acquireServerRuntime(ctx.location.project.directory);
15: if (!runtime) return;
16:
17: const registrations: Array<{ dispose: () => Promise<void> }> = [];
18: try {
19: registrations.push(
20: await ctx.agent.transform((editor) => {
21: for (const [id, description] of workers) {
22: editor.update(id, (agent) => {
23: ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/server-runtime.ts</path>
<type>file</type>
<content>
1: import { getGitRemote, log } from "@loreai/core";
2: import {
3: gatewayAccessHeadersForRemote,
4: parseUpstreamExtraHeaders,
5: probeGateway,
6: shouldForwardUpstreamExtraHeader,
7: } from "./internal";
8:
9: const gatewayPackage = "@loreai/gateway";
10: const knownGatewayPorts = [3207, 5673];
11:
12: export interface LoreServerRuntime {
13: gatewayBase: string;
14: projectPath: string;
15: gitRemote: string;
16: gatewayHeaders: Record<string, string>;
17: release: () => Promise<void>;
18: }
19:
20: export interface ServerRuntimeDependencies {
21: resolveGateway?: () => Promise<{
22: gatewayBase: string;
23: gatewayHeaders: Record<string, string>;
24: shutdown?: () => Promise<void>;
25: }>;
26: gitRemote?: (path: string) => string | null;
27: }
28:
29: interface GatewayHandle {
30: port: number;
31: owned: boolean;
32: ...
/home/byk/Code/opencode-lore-v2/packages/opencode/test/server.test.ts /home/byk/Code/opencode-lore-v2/packages/opencode/test/server-runtime.test.ts
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/test/server-runtime.test.ts</path>
<type>file</type>
<content>
1: import { afterEach, describe, expect, test, vi } from "vitest";
2: import {
3: acquireServerRuntime,
4: buildServerHeaders,
5: resetServerRuntimeForTest,
6: } from "../src/server-runtime";
7:
8: const savedEnv = { ...process.env };
9:
10: afterEach(async () => {
11: await resetServerRuntimeForTest();
12: process.env = { ...savedEnv };
13: });
14:
15: describe("V2 server runtime", () => {
16: test.each(["1", "true"])(
17: "stays inactive when LORE_DISABLED=%s",
18: async (value) => {
19: process.env.LORE_DISABLED = value;
20:
21: expect(
22: await acquireServerRuntime("/project", {
23: resolveGateway: vi.fn(),
24: gitRemote: vi.fn(),
25: }),
26: ).toBeUndefined();
27: },
28: );
29:
30: test("shares an owned gateway until every location releases it", async () => {
31: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
1: import { createServer as createHttpServer } from "node:http";
2: import { mkdtempSync, rmSync } from "node:fs";
3: import {
4: createServer as createNetServer,
5: type AddressInfo,
6: type Server as NetServer,
7: } from "node:net";
8: import { tmpdir } from "node:os";
9: import { join } from "node:path";
10: import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
11: import { readPortFile, removePortFile } from "../src/portfile";
12: import {
13: readGatewayProcessFile,
14: removePidFile,
15: writeGatewayProcessFile,
16: } from "../src/pidfile";
17:
18: describe("startGateway authenticated reuse", () => {
19: const teardowns: Array<() => void | Promise<void>> = [];
20: let base: string;
21: let previousXdg: string | undefined;
22:
23: beforeEach(() => {
24: previousXdg = process.env.XDG_DATA_HOME;
25: base = ...
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
322: it("makes a successor wait until shutdown removes predecessor records", async () => {
323: const { startGateway } = await import("../src/cli/start");
324: let processRecord: ReturnType<typeof readGatewayProcessFile> = null;
325: let recordsRemoved = false;
326: const sharedIO = {
327: readProcess: () => processRecord,
328: authenticate: async (record: NonNullable<typeof processRecord>) =>
329: record.hosts[0],
330: writePort: () => {},
331: removePort: () => {},
332: writeProcess: (record: NonNullable<typeof processRecord>) => {
333: processRecord = record;
334: },
335: removeProcess: (pid: number) => {
336: if (processRecord?.pid === pid) processRecord = null;
337: recordsRemoved = true;
338: },
339: };
340: const first = await startGateway(
341: { ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/test/server.test.ts</path>
<type>file</type>
<content>
1: import { afterEach, beforeEach, describe, expect, test, vi } from "vitest";
2:
3: const { release, acquireServerRuntime, buildServerHeaders, rewriteRequest } =
4: vi.hoisted(() => {
5: const release = vi.fn(async () => {});
6: return {
7: release,
8: acquireServerRuntime: vi.fn(async () => ({
9: gatewayBase: "http://127.0.0.1:3207",
10: projectPath: "/workspace/project",
11: gitRemote: "github.com/example/project",
12: gatewayHeaders: {},
13: release,
14: })),
15: buildServerHeaders: vi.fn(() => ({
16: "x-lore-session-id": "ses_1",
17: "x-lore-agent": "build",
18: "x-lore-provider": "openai",
19: "x-lore-upstream-url": "https://api.openai.com",
20: })),
21: rewriteRequest: vi.fn(
22: async (request: Request) =>
23: new ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: },
15: "./server": {
16: "types": "./src/server.ts",
17: "bun": "./dist/server.js",
18: "default": "./dist/server.js"
19: }
20: },
21: "scripts": {
22: "typecheck": "tsc --noEmit",
23: "build": "tsx script/build.ts"
24: },
25: "peerDependencies": {
26: "@opencode-ai/plugin": ">=1.1.0",
27: "@opencode/plugin": ">=0.0.0"
28: },
29: "peerDependenciesMeta": {
30: "@opencode/plugin": {
31: ...
Found 7 matches
/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts:
Line 198: const lockContext = new AsyncLocalStorage<LifecycleLock>();
Line 201: export function withoutLifecycleLock<T>(action: () => T): T {
Line 202: return lockContext.exit(action);
Line 1686: export async function acquireLifecycleLock(
Line 1841: export async function withLifecycleLock<T>(
Line 1846: const inherited = lockContext.getStore();
Line 1853: return lockContext.run(lock, async () => {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts</path>
<type>file</type>
<content>
1830: );
1831: }
1832: } finally {
1833: if (!ownerStageRemoved) {
1834: removeExpectedOwnerRecord(ownerStage.initializationClaimPath, ownerStage);
1835: removeExpectedOwnerRecord(ownerStage.path, ownerStage);
1836: }
1837: }
1838: }
1839:
1840: /** Run a lifecycle transition under the lock, with async-context reentrancy. */
1841: export async function withLifecycleLock<T>(
1842: operation: LifecycleOperation,
1843: action: (lock: LifecycleLock) => Promise<T> | T,
1844: options: LifecycleLockOptions = {},
1845: ): Promise<T> {
1846: const inherited = lockContext.getStore();
1847: if (inherited) {
1848: inherited.assertOwned();
1849: return action(inherited);
1850: }
1851:
1852: const lock = await acquireLifecycleLock(operation, options);
1853: return lockContext.run(lock, async () => {
1854: try {
1855: const ...
/home/byk/Code/opencode-lore-v2/packages/opencode/script/build.ts
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/script/build.ts</path>
<type>file</type>
<content>
1: import * as esbuild from "esbuild";
2: import { mkdirSync, rmSync } from "node:fs";
3: import { dirname, join } from "node:path";
4: import { fileURLToPath } from "node:url";
5:
6: const packageDir = dirname(dirname(fileURLToPath(import.meta.url)));
7: const dist = join(packageDir, "dist");
8:
9: rmSync(dist, { recursive: true, force: true });
10: mkdirSync(dist, { recursive: true });
11:
12: await esbuild.build({
13: entryPoints: [join(packageDir, "src/server.ts")],
14: outfile: join(dist, "server.js"),
15: bundle: true,
16: format: "esm",
17: platform: "node",
18: target: "esnext",
19: sourcemap: true,
20: external: ["@opencode/plugin", "@loreai/gateway"],
21: logLevel: "info",
22: });
(End of file - total 22 lines)
</content>
<path>/home/byk/Code/opencode-lore/packages/gateway/src/index.ts</path>
<type>file</type>
<content>
1: /**
2: * Lore Gateway — package entry point.
3: *
4: * Library exports for programmatic use, plus `runCli()` for the CLI binary.
5: *
6: * Library usage:
7: * import { startServer, loadConfig } from "@loreai/gateway";
8: *
9: * CLI usage (via bin wrapper):
10: * lore start
11: * lore run claude
12: */
13: import "../instrument";
14: import { fileURLToPath } from "node:url";
15:
16: // ---------------------------------------------------------------------------
17: // Library API
18: // ---------------------------------------------------------------------------
19:
20: export { loadConfig, DEFAULT_PORTS, DEFAULT_PORT } from "./config";
21: export type { GatewayConfig } from "./config";
22: export { startServer } from "./server";
23: export { handleRequest, resetPipelineState } from "./pipeline";
24: export { readPortFile } from "./portfile";
25: export { ...
Found 2 matches /home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts: Line 328: export async function rewriteRequest( Line 343: function rewriteRequestForProtocol(
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
280: * Only intercepts requests to known LLM API paths on remote hosts.
281: * Never intercepts:
282: * - Requests already going to the gateway
283: * - Local requests (localhost, 127.0.0.1, etc.) — these may be local LLM
284: * servers or the gateway itself (infinite loop risk)
285: * - Non-LLM API paths (arbitrary HTTP calls from plugins, health checks, etc.)
286: */
287: export function shouldIntercept(url: string, gatewayBase: string): boolean {
288: try {
289: const parsed = new URL(url);
290: // Never intercept requests already going to the gateway
291: if (url.startsWith(gatewayBase)) return false;
292: // Never intercept local requests (could be local LLM or gateway itself)
293: if (isLocalHost(parsed.hostname)) return false;
294: // Intercept known LLM API paths only
295: return matchesLLMApiPath(parsed.pathname);
296: } ...
Found 1 matches /home/byk/Code/opencode-lore-v2/packages/core/src/index.ts: Line 357: rewriteRequest,
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/internal.ts</path> <type>file</type> <content> 1: /** 2: * Internal helpers for the Lore OpenCode plugin. 3: * 4: * These functions are intentionally kept OUT of the plugin entry module 5: * (`./index.ts`). OpenCode's legacy plugin loader treats EVERY function 6: * exported from a plugin module as a plugin instance and invokes it (see 7: * `getServerPlugin`/`getLegacyPlugins` in opencode's plugin loader). Exporting 8: * these helpers from the entry module caused them to be invoked as plugins and 9: * their return values pushed into the host's hooks array: 10: * `applyLoreProviderConfig` returns `undefined`, so the host crashed on the 11: * first hook dispatch with `undefined is not an object (evaluating 'A.event')` 12: * (the `?.` guards the `.event` property, not the `undefined` hook element). ...
No files found
Found 16 matches /home/byk/Code/opencode-lore-v2/packages/core/src/log.ts: Line 8: * Set LORE_DEBUG=1 to see informational messages (useful when debugging Line 21: * at `~/.local/share/lore/lore.log` regardless of `LORE_DEBUG`. Line 89: // debug. The naive `!!process.env.LORE_DEBUG` treated `LORE_DEBUG=0` and Line 90: // `LORE_DEBUG=false` as ENABLED (non-empty strings are truthy), which meant a Line 91: // user who set `LORE_DEBUG=0` to silence Lore still got `[lore]` status lines Line 94: process.env.LORE_DEBUG === "1" || Line 95: process.env.LORE_DEBUG?.toLowerCase() === "true"; Line 111: // including `error`, and even when `LORE_DEBUG=1`. The TUI is sacrosanct; Line 133: * unconditionally — including when `LORE_DEBUG=1`. ...
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts</path>
<type>file</type>
<content>
128: return (globalThis as Record<string, unknown>)[STDERR_SILENCED_KEY] === true;
129: }
130:
131: /**
132: * Silence ALL stderr output from the logger (`info`/`warn`/`notice`/`error`),
133: * unconditionally — including when `LORE_DEBUG=1`. The file sink and the
134: * registered {@link LogSink} keep receiving everything, so nothing is lost.
135: *
136: * Call this from a host that runs the gateway in-process inside a full-screen
137: * TUI (the Pi extension, the OpenCode plugin). Process-global and idempotent,
138: * so it is honored even by a separately-bundled core instance.
139: */
140: export function silenceStderr(silenced = true): void {
141: (globalThis as Record<string, unknown>)[STDERR_SILENCED_KEY] = silenced;
142: }
143:
144: /** Whether stderr output is currently silenced (embedded/TUI mode). ...
Found 8 matches
/home/byk/Code/opencode-lore/packages/gateway/src/server.ts:
Line 761: shutdownDeadlineMs?: number;
Line 766: stop: () => Promise<void>;
Line 775: closeServer(server, options.shutdownDeadlineMs ?? SHUTDOWN_DEADLINE_MS));
Line 1298: let stopPromise: Promise<void> | undefined;
Line 1300: stop: (): Promise<void> => {
Line 1301: stopPromise ??= Promise.all(servers.map(closeBoundServer)).then(() => {});
Line 1302: return stopPromise;
Line 1351: function closeServer(server: Server, deadlineMs: number): Promise<void> {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
1284:
1285: // Every configured host was unavailable (nothing bound). That's a genuine
1286: // failure — surface it rather than returning a gateway that listens nowhere.
1287: if (servers.length === 0) {
1288: throw new Error(
1289: `Failed to bind: none of the configured hosts are available (${config.hosts.join(", ")}).`,
1290: );
1291: }
1292:
1293: // Collect all ready promises so startGateway() can await them.
1294: const readyPromises = servers
1295: .map((s) => serverReadyPromises.get(s))
1296: .filter((p): p is Promise<void> => p !== undefined);
1297:
1298: let stopPromise: Promise<void> | undefined;
1299: const result = {
1300: stop: (): Promise<void> => {
1301: stopPromise ??= Promise.all(servers.map(closeBoundServer)).then(() => {});
1302: return stopPromise;
1303: },
1304: port: resolvedPort,
1305: // ...
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
1: /**
2: * Fetch-level interception for transparent LLM API proxy routing.
3: *
4: * Instead of overwriting provider baseURLs early (which loses original auth
5: * and URL context), this interceptor wraps `globalThis.fetch` to redirect
6: * outgoing LLM API calls through the Lore gateway at the HTTP level.
7: *
8: * The SDK builds requests normally (correct auth, correct URL for each
9: * provider), and the interceptor transparently reroutes them through the
10: * gateway while preserving all original headers.
11: */
12: import * as log from "./log";
13:
14: /** Configuration for the fetch interceptor. */
15: export type FetchInterceptorConfig = {
16: /** Base URL of the Lore gateway (e.g., "http://127.0.0.1:3207"). */
17: gatewayBase: string;
18: /**
19: * Dynamic headers to inject on every intercepted request. ...
Found 17 matches /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/tool.ts: Line 33: update(id: string, update: (tool: Types.Mutable<Info>) => void): void /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/skill.ts: Line 10: update(id: string, update: (skill: DeepMutable<Skill.Info>) => void): void /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/catalog.ts: Line 16: update(providerID: string, update: (provider: DeepMutable<Provider.Info>) => void): void Line 21: update(providerID: string, modelID: string, update: (model: DeepMutable<Model.Info>) => void): void /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/agent.ts: Line 10: update(id: string, update: (agent: DeepMutable<Agent.Info>) => void): void /home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/mcp.ts: Line 10: update(name: string, update: (config: DeepMutable<Mcp.ServerConfig>) => void): ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/agent.ts</path>
<type>file</type>
<content>
1: import type { AgentApi } from "@opencode/client/promise/api"
2: import type { Agent } from "@opencode/schema/agent"
3: import type { Transform } from "./registration.js"
4: import type { DeepMutable } from "./types.js"
5:
6: export interface AgentEditor {
7: list(): readonly DeepMutable<Agent.Info>[]
8: get(id: string): DeepMutable<Agent.Info> | undefined
9: default(id: string | undefined): void
10: update(id: string, update: (agent: DeepMutable<Agent.Info>) => void): void
11: remove(id: string): void
12: }
13:
14: export interface AgentDomain extends AgentApi {
15: readonly transform: Transform<AgentEditor>
16: readonly reload: () => Promise<void>
17: }
(End of file - total 17 lines)
</content>
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/registration.ts</path>
<type>file</type>
<content>
1: export interface Registration {
2: readonly dispose: () => Promise<void>
3: }
4:
5: export interface ModelHookOptions {
6: /** Limits the hook to one provider. Unscoped hooks apply to every provider. */
7: readonly providerID?: string
8: }
9:
10: export type Hooks<Spec> = <Name extends keyof Spec>(
11: name: Name,
12: callback: (input: Spec[Name]) => Promise<void> | void,
13: ) => Promise<Registration>
14:
15: export type ModelHooks<Spec> = <Name extends keyof Spec>(
16: name: Name,
17: callback: (input: Spec[Name]) => Promise<void> | void,
18: options?: Spec[Name] extends { readonly model: unknown } ? ModelHookOptions : never,
19: ) => Promise<Registration>
20:
21: export type Transform<Input> = (callback: (input: Input) => void) => Promise<Registration>
(End of file - total 21 lines)
</content>
Found 4 matches /home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts: Line 200: export type DynamicRequestHeadersSource = Line 331: dynamicHeaders: DynamicRequestHeadersSource, Line 347: dynamicHeaders: DynamicRequestHeadersSource, Line 445: dynamicHeaders: DynamicRequestHeadersSource,
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts</path> <type>file</type> <content> 190: * full pathname (NOT the post-base suffix) so the gateway can reconstruct the 191: * original URL as `origin(base) + pathname` regardless of any base prefix — 192: * required for providers whose endpoint omits `/v1` (GitHub Copilot's 193: * `/chat/completions`, issue #1052) or uses a non-standard prefix. 194: */ 195: upstreamPath: string; 196: }; 197: 198: export type DynamicRequestHeaders = Readonly<Record<string, string>>; 199: 200: export type DynamicRequestHeadersSource = 201: | DynamicRequestHeaders 202: | (() => DynamicRequestHeaders); 203: 204: /** 205: * Rewrite an intercepted URL to the gateway, handling both standard /v1/... 206: * paths and non-standard paths (e.g. /codex/responses). Used by the 207: * URL-pattern-matched path (Path 1). ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/tsconfig.json</path>
<type>file</type>
<content>
1: {
2: "extends": "../../tsconfig.base.json",
3: "compilerOptions": {
4: "noEmit": true,
5: "types": ["bun"],
6: "paths": {
7: "@loreai/core": ["../core/src/index.ts"]
8: }
9: },
10: "include": ["src", "test", "script", "scripts", "eval"]
11: }
(End of file - total 11 lines)
</content>
Found 5 matches
/home/byk/Code/opencode-lore-v2/packages/opencode/src/server-runtime.ts:
Line 130: startGateway: (options: {
Line 135: const handle = await gateway.startGateway({ quiet: true, local: true });
/home/byk/Code/opencode-lore-v2/packages/opencode/src/index.ts:
Line 86: * Uses startGateway() which handles the full port fallback chain
Line 96: const { startGateway } = await import(/* webpackIgnore: true */ gw);
Line 97: const handle = await startGateway({ quiet: true, local: true });
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/server-runtime.ts</path>
<type>file</type>
<content>
1: import { getGitRemote, log } from "@loreai/core";
2: import {
3: gatewayAccessHeadersForRemote,
4: parseUpstreamExtraHeaders,
5: probeGateway,
6: shouldForwardUpstreamExtraHeader,
7: } from "./internal";
8:
9: const gatewayPackage = "@loreai/gateway";
10: const knownGatewayPorts = [3207, 5673];
11:
12: export interface LoreServerRuntime {
13: gatewayBase: string;
14: projectPath: string;
15: gitRemote: string;
16: gatewayHeaders: Record<string, string>;
17: release: () => Promise<void>;
18: }
19:
20: export interface ServerRuntimeDependencies {
21: resolveGateway?: () => Promise<{
22: gatewayBase: string;
23: gatewayHeaders: Record<string, string>;
24: shutdown?: () => Promise<void>;
25: }>;
26: gitRemote?: (path: string) => string | null;
27: }
28:
29: interface GatewayHandle {
30: port: number;
31: owned: boolean;
32: ...
/home/byk/Code/opencode-lore-v2/packages/opencode/test/server.test.ts /home/byk/Code/opencode-lore-v2/packages/opencode/test/server-runtime.test.ts
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/test/server-runtime.test.ts</path>
<type>file</type>
<content>
1: import { afterEach, describe, expect, test, vi } from "vitest";
2: import {
3: acquireServerRuntime,
4: buildServerHeaders,
5: resetServerRuntimeForTest,
6: } from "../src/server-runtime";
7:
8: const savedEnv = { ...process.env };
9:
10: afterEach(async () => {
11: await resetServerRuntimeForTest();
12: process.env = { ...savedEnv };
13: });
14:
15: describe("V2 server runtime", () => {
16: test.each(["1", "true"])(
17: "stays inactive when LORE_DISABLED=%s",
18: async (value) => {
19: process.env.LORE_DISABLED = value;
20:
21: expect(
22: await acquireServerRuntime("/project", {
23: resolveGateway: vi.fn(),
24: gitRemote: vi.fn(),
25: }),
26: ).toBeUndefined();
27: },
28: );
29:
30: test("shares an owned gateway until every location releases it", async () => {
31: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
74: const VECTOR_POOL_SHUTDOWN_DEADLINE_MS = Math.max(
75: Math.min(
76: DEFAULT_VECTOR_POOL_SHUTDOWN_DEADLINE_MS,
77: SHUTDOWN_DEADLINE_MS - 500,
78: ),
79: 500,
80: );
81:
82: export interface StartOptions {
83: port?: number;
84: hosts?: string[];
85: debug?: boolean;
86: /** Suppress verbose banner (env vars, export hints). Used in embedded mode. */
87: quiet?: boolean;
88: /** Remote gateway URL. When set, `lore run` delegates to this gateway
89: * instead of starting a local one. Overrides LORE_REMOTE_URL env var. */
90: remoteUrl?: string;
91: /**
92: * When true, disables hosted mode even for `lore start`.
93: * CLI: `--local` / `-l`.
94: */
95: local?: boolean;
96: /** Allow non-loopback peers to access the dashboard and management API. */
97: allowRemoteManagement?: boolean;
98: /**
99: * When true, `lore start` ...
Found 3 matches /home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts: Line 105: processBoundary?: boolean; Line 1214: const processShutdown = opts.processBoundary Line 1312: processBoundary: true,
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/server.ts</path>
<type>file</type>
<content>
1: import { rewriteRequest } from "@loreai/core";
2: import type { Plugin } from "@opencode/plugin";
3: import { acquireServerRuntime, buildServerHeaders } from "./server-runtime";
4:
5: const workers = [
6: ["lore-distill", "Lore memory distillation worker"],
7: ["lore-curator", "Lore knowledge curator worker"],
8: ["lore-query-expand", "Lore query expansion worker"],
9: ] as const;
10:
11: export default {
12: id: "lore",
13: setup: async (ctx) => {
14: const runtime = await acquireServerRuntime(ctx.location.project.directory);
15: if (!runtime) return;
16:
17: const registrations: Array<{ dispose: () => Promise<void> }> = [];
18: try {
19: registrations.push(
20: await ctx.agent.transform((editor) => {
21: for (const [id, description] of workers) {
22: editor.update(id, (agent) => {
23: ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore-v2/packages/website/src/content/docs/docs/setup.md: Line 46: | `opencode` | `~/.config/opencode/opencode.json` (with `provider.openai.options.baseURL` + `compaction.auto: false`) | Sets the built-in `openai` provider's `baseURL` and disables OpenCode's auto-compaction. Deep-merges with existing config (preserves custom providers, themes, keybinds). | Line 85: - **OpenCode** — `lore setup opencode` writes `provider.openai.options.baseURL` to `~/.config/opencode/opencode.json`. If you have a custom OpenAI provider configured (e.g. `provider.openrouter`), the helper only updates the built-in `openai` provider — your custom providers are preserved. The compaction setting is also disabled by default; you can re-enable it in the same file if you want. ...
Found 7 matches
/home/byk/Code/opencode-v2-pilot/packages/schema/src/config/agent.ts:
Line 6: import { ConfigModel } from "./model.js"
Line 12: model: ConfigModel.Selection.pipe(optional),
Line 16: mode: Schema.Literals(["subagent", "primary", "all"]).pipe(optional),
/home/byk/Code/opencode-v2-pilot/packages/schema/src/agent.ts:
Line 6: import { Model } from "./model.js"
Line 26: model: Model.Ref.pipe(optional),
Line 30: mode: Schema.Literals(["subagent", "primary", "all"]),
Line 44: mode: "primary",
<path>/home/byk/Code/opencode-v2-pilot/packages/schema/src/agent.ts</path>
<type>file</type>
<content>
18:
19: export const Color = Schema.String.annotate({ identifier: "Agent.Color" })
20: export type Color = typeof Color.Type
21:
22: export interface Info extends Schema.Schema.Type<typeof Info> {}
23: export const Info = Schema.Struct({
24: id: ID,
25: name: Name,
26: model: Model.Ref.pipe(optional),
27: request: Provider.Request,
28: system: Schema.String.pipe(optional),
29: description: Schema.String.pipe(optional),
30: mode: Schema.Literals(["subagent", "primary", "all"]),
31: hidden: Schema.Boolean,
32: color: Color.pipe(optional),
33: steps: PositiveInt.pipe(optional),
34: permissions: Permission.Ruleset,
35: })
36: .annotate({ identifier: "Agent.Info" })
37: .pipe(
38: statics(() => ({
39: default: (id: ID) =>
40: ({
41: id,
42: name: Name.make(id),
43: request: { settings: {}, headers: {}, body: {} ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
850: * `safeExit`.
851: */
852: async function startDaemon(opts: StartOptions): Promise<never> {
853: safeExit(await runDaemon(opts, realDaemonIO(opts)));
854: }
855:
856: /**
857: * Start the gateway server, returning the actual port and a shutdown function.
858: *
859: * Merges CLI options on top of env-var config (CLI takes precedence).
860: *
861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`),
862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port.
863: * At each step, if the port is occupied by an existing lore gateway
864: * (verified via its process record and owner-only control token), returns a
865: * handle with `owned: false`
866: * so the caller can reuse the existing instance. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/host.ts</path>
<type>file</type>
<content>
1: export * as Host from "./host.js"
2:
3: import path from "node:path"
4: import { importModule, resolveModule } from "@opencode/util/runtime-import"
5:
6: export interface Target {
7: readonly directory: string
8: readonly name?: string
9: }
10:
11: export interface Entrypoints {
12: readonly server?: string
13: readonly tui?: string
14: readonly rpc?: string
15: }
16:
17: export function resolve(target: Target): Entrypoints {
18: const entry = (subpaths: readonly string[]) => {
19: for (const subpath of subpaths) {
20: const specifier = target.name
21: ? [target.name, subpath].filter(Boolean).join("/")
22: : path.resolve(target.directory, subpath || "index")
23: try {
24: return resolveModule(specifier, target.directory)
25: } catch (error) {
26: if (
27: !(error instanceof Error) ||
28: ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
1: import type { Hooks, Plugin, PluginInput } from "@opencode-ai/plugin";
2: import {
3: log,
4: getGitRemote,
5: discoverWorkspaceRoot,
6: installFetchInterceptor,
7: } from "@loreai/core";
8: // Helpers live in a separate module so they are NOT re-exported from this
9: // plugin entry. OpenCode's legacy plugin loader invokes every function
10: // exported from the entry module as a plugin; leaking these helpers pushed
11: // `undefined` into the host hooks array and crashed it on event dispatch
12: // (`undefined is not an object (evaluating 'A.event')`). See ./internal.ts.
13: import {
14: applyLoreProviderConfig,
15: gatewayAccessHeadersForRemote,
16: probeGateway,
17: shouldForwardUpstreamExtraHeader,
18: surfaceGatewayUnavailable,
19: } from "./internal";
20:
21: /**
22: * Lore plugin for OpenCode — transparent LLM proxy routing. ...
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts</path>
<type>file</type>
<content>
72: ]),
73: })
74:
75: export class LoadError extends Schema.TaggedError<LoadError>()("PluginModule.LoadError", {
76: message: Schema.String,
77: cause: Schema.optional(Schema.Defect()),
78: }) {}
79:
80: const load = Effect.fn("PluginModule.load")(function* (
81: operation: Extract<ConfigPluginSource.Operation, { type: "add" }>,
82: sources: ReturnType<typeof createPluginSources>,
83: options?: { readonly install?: boolean },
84: ) {
85: const local = path.isAbsolute(operation.target)
86: const npm = yield* Npm.Service
87: const installed = local
88: ? undefined
89: : options?.install === false
90: ? yield* npm.resolve(operation.target)
91: : yield* npm.add(operation.target)
92: // Legacy auto-discovery still admits standalone server sources. Configured
93: // local plugins always arrive here as directories. ...
<path>/home/byk/Code/opencode-lore/packages/opencode/src/index.ts</path>
<type>file</type>
<content>
230: * in-process gateway via `LORE_GATEWAY_URL`. The force flag keeps
231: * `NODE_ENV=test` (so `log` stays file-suppressed and the DB isolated) while
232: * exercising the real wiring. Mirrors the Pi extension's `LORE_PI_FORCE_ACTIVE`.
233: */
234: function isInertTestEnv(): boolean {
235: if (process.env.LORE_OPENCODE_FORCE_ACTIVE === "1") return false;
236: return (
237: process.env.NODE_ENV === "test" ||
238: process.argv.some((a) => a.includes(".test."))
239: );
240: }
241:
242: export const LorePlugin: Plugin = async (ctx) => {
243: // Initialize lore — only probe/start once per process.
244: const loreDisabled =
245: process.env.LORE_DISABLED === "1" || process.env.LORE_DISABLED === "true";
246: let loreActive = processLoreActive;
247: let gatewayBase = processLoreBase;
248: if (!processInitDone) {
249: const inTestEnv = ...
I’ve traced the current V2 implementation and the authoritative OpenCode hooks. I’m checking the lifecycle edge cases and exact line references now, especially refcount races and whether the request hooks preserve original routing metadata.
Found 2 matches
/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts:
Line 68: const config = loadConfig();
Line 74: const existing = await startServer(config, { controlToken: token });
<path>/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-reuse.test.ts</path>
<type>file</type>
<content>
1: import { createServer as createHttpServer } from "node:http";
2: import { mkdtempSync, rmSync } from "node:fs";
3: import {
4: createServer as createNetServer,
5: type AddressInfo,
6: type Server as NetServer,
7: } from "node:net";
8: import { tmpdir } from "node:os";
9: import { join } from "node:path";
10: import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
11: import { readPortFile, removePortFile } from "../src/portfile";
12: import {
13: readGatewayProcessFile,
14: removePidFile,
15: writeGatewayProcessFile,
16: } from "../src/pidfile";
17:
18: describe("startGateway authenticated reuse", () => {
19: const teardowns: Array<() => void | Promise<void>> = [];
20: let base: string;
21: let previousXdg: string | undefined;
22:
23: beforeEach(() => {
24: previousXdg = process.env.XDG_DATA_HOME;
25: base = ...
Found 1 matches /home/byk/Code/opencode-lore/packages/gateway/src/server.ts: Line 752: export async function startServer(
<path>/home/byk/Code/opencode-lore/packages/gateway/src/server.ts</path>
<type>file</type>
<content>
740: const msg = e instanceof Error ? e.message : "Pipeline error";
741: log.error(`pipeline error: ${msg}`);
742: return errorResponse(502, "api_error", `Gateway pipeline error: ${msg}`);
743: }
744: }
745:
746: // ---------------------------------------------------------------------------
747: // Server
748: // ---------------------------------------------------------------------------
749:
750: const responseCompletionCallbacks = new WeakMap<Response, () => void>();
751:
752: export async function startServer(
753: config: GatewayConfig,
754: options: {
755: controlToken?: string;
756: /** Invoked asynchronously after an authenticated shutdown response flushes. */
757: onShutdown?: () => void | Promise<void>;
758: /** Focused lifecycle seam for exercising listener-close failures. */
759: closeServer?: (server: Server) => Promise<void>;
760: ...
Found 5 matches
/home/byk/Code/opencode-v2-pilot/packages/core/src/v1/config/agent.ts:
Line 28: description: "Hide this subagent from the @ autocomplete menu (default: false, only applies to mode: subagent)",
/home/byk/Code/opencode-v2-pilot/packages/core/src/agent.ts:
Line 40: default: (id: ID | undefined) => void
Line 41: update: (id: ID, fn: (agent: Types.DeepMutable<Info>) => void) => void
Line 71: default: (id) => {
Line 74: update: (id, fn) => {
<path>/home/byk/Code/opencode-v2-pilot/packages/core/src/agent.ts</path>
<type>file</type>
<content>
50: }
51:
52: export class Service extends Context.Service<Service, Interface>()("@opencode/Agent") {}
53:
54: const layer = Layer.effect(
55: Service,
56: Effect.gen(function* () {
57: const bus = yield* Bus.Service
58: const global = yield* Global.Service
59: const permissions: Info["permissions"] = [
60: { action: "external_directory", resource: SHELL_OUTPUT_GLOB(global.data), effect: "allow" },
61: { action: "external_directory", resource: TOOL_OUTPUT_GLOB(global.data), effect: "allow" },
62: { action: "external_directory", resource: path.join(global.tmp, "*"), effect: "allow" },
63: { action: "external_directory", resource: path.join(global.config, "*"), effect: "allow" },
64: ]
65: const state = State.create<Data, Editor>({
66: name: "agent",
67: initial: () => ({ agents: new Map() }),
68: editor: (editor) => ...
Found 5 matches /home/byk/Code/opencode-lore-v2/packages/core/src/index.ts: Line 357: rewriteRequest, /home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts: Line 328: export async function rewriteRequest( Line 334: return rewriteRequestForProtocol( Line 343: function rewriteRequestForProtocol( Line 558: const routed = rewriteRequestForProtocol(
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts</path>
<type>file</type>
<content>
310: host === "[::1]"
311: );
312: }
313:
314: /** True when a URL may need LLM routing or direct-gateway auth observation. */
315: function mayBeLLMRequest(url: string): boolean {
316: return (
317: url.includes("/messages") ||
318: url.includes("/completions") ||
319: url.includes("/responses")
320: );
321: }
322:
323: /**
324: * Return a gateway-routed copy of an LLM request, or the original Request when
325: * it must bypass Lore. This function never reads the request body: known paths
326: * can carry streaming bodies safely, while unknown paths always pass through.
327: */
328: export async function rewriteRequest(
329: request: Request,
330: gatewayBase: string,
331: dynamicHeaders: DynamicRequestHeadersSource,
332: onRequestHeaders?: (headers: Headers) => void,
333: ): Promise<Request> {
334: return ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/test/server.test.ts</path>
<type>file</type>
<content>
1: import { afterEach, beforeEach, describe, expect, test, vi } from "vitest";
2:
3: const { release, acquireServerRuntime, buildServerHeaders, rewriteRequest } =
4: vi.hoisted(() => {
5: const release = vi.fn(async () => {});
6: return {
7: release,
8: acquireServerRuntime: vi.fn(async () => ({
9: gatewayBase: "http://127.0.0.1:3207",
10: projectPath: "/workspace/project",
11: gitRemote: "github.com/example/project",
12: gatewayHeaders: {},
13: release,
14: })),
15: buildServerHeaders: vi.fn(() => ({
16: "x-lore-session-id": "ses_1",
17: "x-lore-agent": "build",
18: "x-lore-provider": "openai",
19: "x-lore-upstream-url": "https://api.openai.com",
20: })),
21: rewriteRequest: vi.fn(
22: async (request: Request) =>
23: new ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/opencode",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Three-tier memory architecture for OpenCode — distillation, not summarization",
7: "main": "./src/index.ts",
8: "types": "./src/index.ts",
9: "exports": {
10: ".": {
11: "types": "./src/index.ts",
12: "bun": "./src/index.ts",
13: "default": "./src/index.ts"
14: },
15: "./server": {
16: "types": "./src/server.ts",
17: "bun": "./dist/server.js",
18: "default": "./dist/server.js"
19: }
20: },
21: "scripts": {
22: "typecheck": "tsc --noEmit",
23: "build": "tsx script/build.ts"
24: },
25: "peerDependencies": {
26: "@opencode-ai/plugin": ">=1.1.0",
27: "@opencode/plugin": ">=0.0.0"
28: },
29: "peerDependenciesMeta": {
30: "@opencode/plugin": {
31: ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/script/build.ts</path>
<type>file</type>
<content>
1: import * as esbuild from "esbuild";
2: import { mkdirSync, rmSync } from "node:fs";
3: import { dirname, join } from "node:path";
4: import { fileURLToPath } from "node:url";
5:
6: const packageDir = dirname(dirname(fileURLToPath(import.meta.url)));
7: const dist = join(packageDir, "dist");
8:
9: rmSync(dist, { recursive: true, force: true });
10: mkdirSync(dist, { recursive: true });
11:
12: await esbuild.build({
13: entryPoints: [join(packageDir, "src/server.ts")],
14: outfile: join(dist, "server.js"),
15: bundle: true,
16: format: "esm",
17: platform: "node",
18: target: "esnext",
19: sourcemap: true,
20: alias: {
21: "@loreai/core": join(packageDir, "src/server-core.ts"),
22: },
23: external: ["@opencode/plugin", "@loreai/gateway"],
24: logLevel: "info",
25: });
(End of file - total 25 lines)
</content>
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/server-core.ts</path>
<type>file</type>
<content>
1: export { GATEWAY_AUTH_HEADER } from "../../core/src/credential-headers";
2: export { rewriteRequest } from "../../core/src/fetch-interceptor";
3: export { getGitRemote } from "../../core/src/git";
4: export * as log from "../../core/src/log";
(End of file - total 4 lines)
</content>
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/src/internal.ts</path> <type>file</type> <content> 1: /** 2: * Internal helpers for the Lore OpenCode plugin. 3: * 4: * These functions are intentionally kept OUT of the plugin entry module 5: * (`./index.ts`). OpenCode's legacy plugin loader treats EVERY function 6: * exported from a plugin module as a plugin instance and invokes it (see 7: * `getServerPlugin`/`getLegacyPlugins` in opencode's plugin loader). Exporting 8: * these helpers from the entry module caused them to be invoked as plugins and 9: * their return values pushed into the host's hooks array: 10: * `applyLoreProviderConfig` returns `undefined`, so the host crashed on the 11: * first hook dispatch with `undefined is not an object (evaluating 'A.event')` 12: * (the `?.` guards the `.event` property, not the `undefined` hook element). ...
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts</path>
<type>file</type>
<content>
1: /**
2: * Lightweight logger that suppresses informational messages by default.
3: *
4: * In TUI mode, all stderr output renders as red "error" text — confusing
5: * for routine status messages like "incremental distillation" or "pruned
6: * temporal messages". Only actual errors should be visible by default.
7: *
8: * Set LORE_DEBUG=1 to see informational messages (useful when debugging
9: * the plugin itself).
10: *
11: * ## Sink registration
12: *
13: * An optional {@link LogSink} can be registered via {@link registerSink}.
14: * When registered, every log call (regardless of `isDebug`) also forwards
15: * to the sink. This is used by the gateway to bridge logs → Sentry without
16: * adding a Sentry dependency to `@loreai/core`.
17: *
18: * ## File logging
19: *
20: * All log calls (info, warn, error) are written to a persistent log file
21: * at ...
No files found
M packages/core/src/fetch-interceptor.ts
M packages/core/src/index.ts
A packages/core/test/fetch-interceptor-request.test.ts
M packages/opencode/package.json
A packages/opencode/script/build.ts
M packages/opencode/src/index.ts
M packages/opencode/src/internal.ts
A packages/opencode/src/server-runtime.ts
A packages/opencode/src/server.ts
M packages/opencode/test/internal.test.ts
A packages/opencode/test/package.test.ts
A packages/opencode/test/server-runtime.test.ts
A packages/opencode/test/server.test.ts
M pnpm-lock.yaml
?? packages/opencode/src/server-core.ts
diff --git a/packages/opencode/package.json b/packages/opencode/package.json
index 2dc3111e..612407f5 100644
--- a/packages/opencode/package.json
+++ b/packages/opencode/package.json
@@ -11,14 +11,25 @@
"types": "./src/index.ts",
"bun": "./src/index.ts",
"default": "./src/index.ts"
+ },
+ "./server": {
+ "types": "./src/server.ts",
+ "bun": "./dist/server.js",
+ "default": ...
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts</path>
<type>file</type>
<content>
146: return readStderrSilenced();
147: }
148:
149: /** Format variadic args into a single string for the sink. */
150: function formatArgs(args: unknown[]): string {
151: return args
152: .map((a) =>
153: typeof a === "string" ? a : a instanceof Error ? a.message : String(a),
154: )
155: .join(" ");
156: }
157:
158: /** Extract the first Error instance from the args list, if any. */
159: function findError(args: unknown[]): Error | undefined {
160: for (const a of args) {
161: if (a instanceof Error) return a;
162: }
163: return undefined;
164: }
165:
166: const LOG_FILTERED = "[Filtered]";
167: const LOG_SENSITIVE_KEY = ...
Found 12 matches
/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts:
Line 14: * When registered, every log call (regardless of `isDebug`) also forwards
Line 93: const isDebug =
Line 127: function readStderrSilenced(): boolean {
Line 146: return readStderrSilenced();
Line 464: export function info(...args: unknown[]): void {
Line 466: if (isDebug && !readStderrSilenced())
Line 473: export function warn(...args: unknown[]): void {
Line 475: if (isDebug && !readStderrSilenced())
Line 489: export function notice(...args: unknown[]): void {
Line 491: if (!readStderrSilenced()) console.error("[lore]", ...safeArgs(args));
Line 497: export function error(...args: unknown[]): void {
Line 499: if (!readStderrSilenced()) console.error("[lore]", ...safeArgs(args));
<path>/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts</path>
<type>file</type>
<content>
450: fd = openLogFileForAppend(path);
451: writeFileSync(fd, line, "utf8");
452: } catch {
453: // Silently degrade — logging failure shouldn't crash the app
454: } finally {
455: if (fd !== undefined) closeSync(fd);
456: }
457: }
458:
459: // ---------------------------------------------------------------------------
460: // Public API
461: // ---------------------------------------------------------------------------
462:
463: /** Log an informational status message. Suppressed unless LORE_DEBUG=1. */
464: export function info(...args: unknown[]): void {
465: const msg = redactSensitiveLogText(formatArgs(args));
466: if (isDebug && !readStderrSilenced())
467: console.error("[lore]", ...safeArgs(args));
468: sink?.info(msg);
469: writeToFile("info", msg);
470: }
471:
472: /** Log a warning. Suppressed unless LORE_DEBUG=1. */
473: export function ...
<path>/home/byk/Code/opencode-lore-v2/packages/opencode/test/package.test.ts</path>
<type>file</type>
<content>
1: import { execFileSync } from "node:child_process";
2: import { mkdtempSync, readFileSync, rmSync } from "node:fs";
3: import { tmpdir } from "node:os";
4: import { join } from "node:path";
5: import { afterAll, beforeAll, describe, expect, test } from "vitest";
6:
7: const packageDir = join(import.meta.dirname, "..");
8: const temporary = mkdtempSync(join(tmpdir(), "lore-opencode-package-"));
9: const packageName = "loreai-opencode.tgz";
10:
11: beforeAll(() => {
12: execFileSync("pnpm", ["run", "build"], {
13: cwd: packageDir,
14: stdio: "pipe",
15: });
16: execFileSync("pnpm", ["pack", "--out", join(temporary, packageName)], {
17: cwd: packageDir,
18: stdio: "pipe",
19: });
20: execFileSync("tar", ["-xzf", join(temporary, packageName), "-C", temporary], {
21: stdio: "pipe",
22: });
23: });
24:
25: afterAll(() => {
26: ...
Found 2 matches
/home/byk/Code/opencode-lore/packages/gateway/src/cli/run.ts:
Line 408: // startGateway() re-runs loadConfig() AFTER upstream adoption has set
Line 485: const handle = await startGateway({
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/run.ts</path>
<type>file</type>
<content>
390:
391: export async function commandRun(
392: opts: StartOptions,
393: cmdArgs: string[],
394: extraArgs: string[] = [],
395: ): Promise<void> {
396: // 1. Resolve which agent will run BEFORE starting the gateway, so we can
397: // adopt the user's pre-existing upstream (which requires setting gateway
398: // env before loadConfig/startGateway — the config is captured once at
399: // startup and reused per request).
400: const selection = await resolveAgentSelection(cmdArgs);
401:
402: const config = loadConfig();
403: let gatewayUrl: string;
404: let owned: boolean;
405: let shutdown: () => Promise<void>;
406: let processShutdown: ProcessShutdownController | undefined;
407: // The config actually in effect for the running gateway. ...
Found 11 matches
/home/byk/Code/opencode-lore/packages/gateway/src/config.ts:
Line 104: hostedMode: boolean;
Line 179: export function loadConfig(): GatewayConfig {
Line 222: const hostedModeEnv = isTruthy(env.LORE_HOSTED_MODE);
Line 231: const hostedModeDefined = "LORE_HOSTED_MODE" in env;
Line 233: !remoteGatewayDefined && !hostedModeDefined && hasNonLoopbackHost(hosts);
Line 272: hostedMode: hostedModeEnv,
Line 296: remoteGateway: remoteGatewayEnv || hostedModeEnv || autoDetected,
Line 324: "remoteGateway" | "hostedMode" | "gatewayAuthToken"
Line 329: if ((config.remoteGateway || config.hostedMode) && !gatewayAuthToken) {
Line 540: config: Pick<GatewayConfig, "remoteGateway" | "hostedMode"> &
Line 544: if (!config.remoteGateway && !config.hostedMode) return true;
<path>/home/byk/Code/opencode-lore/packages/gateway/src/config.ts</path>
<type>file</type>
<content>
179: export function loadConfig(): GatewayConfig {
180: const env = process.env;
181: const hosts = parseHosts(env.LORE_LISTEN_HOST);
182: const upstreamAnthropic = trimTrailingSlash(
183: env.LORE_UPSTREAM_ANTHROPIC || "https://api.anthropic.com",
184: );
185: const upstreamOpenAI = trimTrailingSlash(
186: env.LORE_UPSTREAM_OPENAI || "https://api.openai.com",
187: );
188: const workerUpstream = env.LORE_WORKER_UPSTREAM
189: ? trimTrailingSlash(env.LORE_WORKER_UPSTREAM)
190: : undefined;
191: /**
192: * Comma-separated HTTPS origins that remote/hosted clients may select via
193: * `X-Lore-Upstream-URL`. Entries must be origins only (no credentials, paths,
194: * queries, fragments, or wildcards), and duplicates are rejected after URL
195: * normalization. Unset means deny every caller-selected origin. ...
Found 4 matches
/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts:
Line 218: export function fromPromise(plugin: Plugin) {
Line 598: yield* Effect.acquireRelease(
Line 599: Effect.promise(() => Promise.resolve(plugin.setup(context2))),
Line 600: (cleanup) => (cleanup ? Effect.promise(() => Promise.resolve(cleanup())) : Effect.void),
<path>/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/adapter.ts</path>
<type>file</type>
<content>
585: synthetic: adaptApiMethod(SessionEndpoints["session.synthetic"], host.session.synthetic),
586: interrupt: adaptApiMethod(SessionEndpoints["session.interrupt"], host.session.interrupt),
587: rename: adaptApiMethod(SessionEndpoints["session.rename"], host.session.rename),
588: move: adaptApiMethod(SessionEndpoints["session.move"], host.session.move),
589: wait: adaptApiMethod(SessionEndpoints["session.wait"], host.session.wait),
590: context: adaptApiMethod(SessionEndpoints["session.context"], host.session.context),
591: },
592: shell: {
593: hook: (name, callback) =>
594: register(host.shell.hook(name, (event) => Effect.promise(() => Promise.resolve(callback(event))))),
595: },
596: }
597:
598: yield* ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore/packages/core/src/log.ts: Line 116: // 🔴 The flag lives on `globalThis`, NOT a module-level `let`. The in-process Line 122: // the in-process gateway's own `[lore]` lines writing to the TUI. `globalThis` Line 128: return (globalThis as Record<string, unknown>)[STDERR_SILENCED_KEY] === true; Line 137: * TUI (the Pi extension, the OpenCode plugin). Process-global and idempotent, Line 141: (globalThis as Record<string, unknown>)[STDERR_SILENCED_KEY] = silenced; /home/byk/Code/opencode-lore/packages/core/src/prompt.ts: Line 497: "scope": "project" | "global", /home/byk/Code/opencode-lore/packages/core/src/curator.d.ts: Line 14: scope: "project" | "global"; /home/byk/Code/opencode-lore/packages/core/src/embedding-worker.ts: Line 353: const globals = globalThis as Record<string, unknown>; Line 364: !globals.__LORE_ORT_BINDING_PATH__ && Line 365: ...
<path>/home/byk/Code/opencode-lore/packages/core/src/index.ts</path>
<type>file</type>
<content>
195: dbFileSizeBytes,
196: freelistBytes,
197: autoVacuumMode,
198: incrementalVacuum,
199: } from "./db";
200: export {
201: normalizeRemoteUrl,
202: getGitRemote,
203: clearGitRemoteCache,
204: getGitUser,
205: clearGitUserCache,
206: } from "./git";
207: export {
208: GATEWAY_AUTH_HEADER,
209: KNOWN_SESSION_HEADERS,
210: CLAUDE_CODE_AGENT_ID_HEADER,
211: CLAUDE_CODE_PARENT_AGENT_ID_HEADER,
212: isCredentialHeaderName,
213: redactCredentialHeaderAssignments,
214: } from "./credential-headers";
215: export {
216: enableHostedMode,
217: isHostedMode,
218: _resetHostedModeForTest,
219: } from "./hosted";
220: export {
221: transform,
222: estimateMessages,
223: FullSourceRequired,
224: type SourceWindow,
225: prewarmDistillationSnapshot,
226: setModelLimits,
227: setMaxLayer0Tokens,
228: computeLayer0Cap,
229: setCachePricing,
(Showing ...
Found 13 matches
/home/byk/Code/opencode-lore/packages/gateway/src/pipeline.ts:
Line 100: isHostedMode,
Line 101: enableHostedMode,
Line 3971: if (isHostedMode()) return false;
Line 4018: if (isHostedMode()) return () => {};
Line 4166: enableHostedMode();
Line 5603: return isHostedMode() ? supplied : (getGitRemote(projectPath) ?? undefined);
Line 16064: `remoteGateway=${config.remoteGateway} hosted=${isHostedMode()} ` +
Line 18911: (isHostedMode() ||
/home/byk/Code/opencode-lore/packages/gateway/src/api.ts:
Line 25: isHostedMode,
Line 412: if (isHostedMode()) {
Line 610: if (isHostedMode()) {
Line 693: if (isHostedMode()) {
Line 767: if (isHostedMode()) {
<path>/home/byk/Code/opencode-lore/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
4145:
4146: /**
4147: * One-time init: load Lore config, ensure project exists in DB, start idle scheduler.
4148: * Safe to call multiple times — only the first call does work.
4149: */
4150: async function initIfNeeded(
4151: projectPath: string,
4152: config: GatewayConfig,
4153: gitRemote?: string,
4154: signal?: AbortSignal,
4155: requestGeneration?: number,
4156: ): Promise<void> {
4157: if (!pipelineResetInProgress) streamingPostResponsesAccepting = true;
4158: if (requestGeneration !== undefined) {
4159: assertCurrentPipelineGeneration(signal, requestGeneration);
4160: }
4161: if (initialized) return;
4162:
4163: // Enable hosted mode before any FS operations — once set, all core
4164: // functions that touch client-controlled paths become safe no-ops.
4165: if (config.hostedMode) {
4166: enableHostedMode();
4167: }
4168:
4169: await ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path>
<type>file</type>
<content>
1: /**
2: * `lore start` — start the gateway server without auto-launching an agent.
3: *
4: * Extracted from the old top-level index.ts boot logic.
5: */
6: import { spawn } from "node:child_process";
7: import { randomBytes } from "node:crypto";
8: import { closeSync } from "node:fs";
9: import { join } from "node:path";
10: import {
11: assertGatewayAccessConfigured,
12: loadConfig,
13: DEFAULT_PORTS,
14: type GatewayConfig,
15: } from "../config";
16: import { startServer, bracketHost } from "../server";
17: import { resetPipelineState } from "../pipeline";
18: import { writePortFile, removePortFile } from "../portfile";
19: import {
20: writeGatewayProcessFile,
21: readGatewayProcessFile,
22: removeGatewayProcessFile,
23: type GatewayProcessRecord,
24: } from "../pidfile";
25: import {
26: dataDir,
27: embedding,
28: temporalEmbeddingQueue,
29: ...
<path>/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts</path> <type>file</type> <content> 860: * 861: * When the port is not explicitly set (no `--port` / `LORE_LISTEN_PORT`), 862: * the server tries a fallback chain: 3207 → 5673 → OS-assigned random port. 863: * At each step, if the port is occupied by an existing lore gateway 864: * (verified via its process record and owner-only control token), returns a 865: * handle with `owned: false` 866: * so the caller can reuse the existing instance. ...
No files found
<path>/home/byk/Code/opencode-lore-v2/packages/gateway/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "@loreai/gateway",
3: "version": "0.40.0",
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Lore as a transparent LLM proxy — context management for any AI coding client",
7: "main": "./dist/index.cjs",
8: "types": "./dist/index.d.cts",
9: "exports": {
10: ".": {
11: "types": "./dist/index.d.cts",
12: "bun": "./dist/index.bun.js",
13: "require": "./dist/index.cjs",
14: "default": "./dist/index.cjs"
15: }
16: },
17: "bin": {
18: "lore": "./dist/bin.cjs",
19: "lore-gateway": "./dist/bin.cjs"
20: },
21: "scripts": {
22: "typecheck": "tsc --noEmit",
23: "build": "tsx script/build.ts",
24: "bundle": "tsx script/bundle.ts",
25: "build:binary": "tsx script/build.ts --binary",
26: "build:binary:sea": "tsx script/build-binary-sea.ts",
27: "start": "tsx ...
* 🔴 (15:16) User stated hosted mode is always a remote gateway because clients do not share a filesystem with it. * 🔴 (15:16) User showed `loadConfig()` in `/home/byk/Code/opencode-lore/packages/gateway/src/config.ts` computes `remoteGateway` as `remoteGatewayEnv || hostedModeEnv || autoDetected`; `LORE_REMOTE_GATEWAY=1` has highest priority, `LORE_HOSTED_MODE=1` implies remote-gateway mode, an…
* 🔴 (15:12) User stated `error()` messages are “Always visible — these indicate real failures.” * 🔴 (15:12) User showed `packages/core/src/log.ts` public logging behavior: `info()` and `warn()` write to stderr only when `isDebug` and stderr is not silenced; `notice()` and `error()` are not debug-gated but honor stderr silencing; every level forwards redacted text to the registered sink and pers…
* 🔴 (15:11) User showed a file-search tool result of `No files found`. * 🔴 (15:12) User showed 15 working-tree changes: modified `packages/core/src/fetch-interceptor.ts`, `packages/core/src/index.ts`, `packages/opencode/package.json`, `packages/opencode/src/index.ts`, `packages/opencode/src/internal.ts`, `packages/opencode/test/internal.test.ts`, and `pnpm-lock.yaml`; added `packages/core/test/…
* 🔴 (15:03) User showed exactly 5 references to `rewriteRequest` in `/home/byk/Code/opencode-lore-v2`: `/packages/core/src/index.ts` line 357 and `/packages/core/src/fetch-interceptor.ts` lines 328, 334, 343, and 558. * 🔴 (15:04) User showed `/home/byk/Code/opencode-lore-v2/packages/core/src/fetch-interceptor.ts` lines 315-320 define `mayBeLLMRequest(url)` by checking whether the URL includes `…
* 🔴 (14:53) User showed a search returning exactly 5 matches for `default`/related text: `/home/byk/Code/opencode-v2-pilot/packages/core/src/v1/config/agent.ts` line 28 and `/home/byk/Code/opencode-v2-pilot/packages/core/src/agent.ts` lines 40, 41, 71, and 74. * 🔴 (14:53) User showed `/home/byk/Code/opencode-v2-pilot/packages/core/src/v1/config/agent.ts` line 28 describes `hide` as: `"Hide this…
* 🔴 (14:52) User stated `loadConfig()` always provides the complete `GatewayConfig` values expected by `startServer()`; defensive defaults exist because `startServer` is a public export and callers may pass incomplete config. * 🔴 (14:52) User showed `/home/byk/Code/opencode-lore/packages/gateway/src/server.ts` defines `responseCompletionCallbacks` as `new WeakMap<Response, () => void>()`. * 🔴 …
* 🔴 (14:45) User showed `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts` documents `startGateway()`’s implicit-port fallback chain as `3207 → 5673 → 0` (OS-assigned random port); authenticated existing Lore gateways are reused with `owned: false`. * 🔴 (14:45) User showed `startGateway()` runs under `withLifecycleLock("gateway-start", ...)`, while the actual `io.startServer(...)`…
* 🔴 (14:38) User showed `/home/byk/Code/opencode-lore-v2/packages/core/src/log.ts` documents `silenceStderr(silenced = true)` as process-global and idempotent via `globalThis[STDERR_SILENCED_KEY]`; it silences logger `info`/`warn`/`notice`/`error` output unconditionally, including under `LORE_DEBUG=1`, while the file sink and registered `LogSink` continue receiving everything. `isStderrSilenced(…
* 🔴 (14:28) User showed `/home/byk/Code/opencode-lore-v2/packages/opencode/package.json` defines `@loreai/opencode` version `0.40.0`, ESM (`"type": "module"`), license `FSL-1.1-Apache-2.0`, description `"Three-tier memory architecture for OpenCode — distillation, not summarization"`, and author `BYK`. * 🔴 (14:28) User showed `@loreai/opencode` uses `./src/index.ts` for `main` and `types`; packa…
* 🔴 (14:27) User showed `/home/byk/Code/opencode-lore-v2/packages/opencode/test/server.test.ts` contains 6 Vitest tests for the V2 server plugin. * 🔴 (14:27) User showed the V2 export-compatibility test verifies `plugin.id === "lore"`, `plugin.setup` is a function, the legacy `../src/index` exports exactly `["LorePlugin", "default"]`, and `legacy.default === legacy.LorePlugin`. * 🔴 (14:27) Use…
* 🔴 (14:23) User showed `/home/byk/Code/opencode-lore-v2/packages/opencode/src/server.ts` defines the V2 Lore OpenCode server plugin as `id: "lore"` with 3 hidden `"subagent"` workers in exact order: 1. `lore-distill` — `"Lore memory distillation worker"`; 2. `lore-curator` — `"Lore knowledge curator worker"`; 3. `lore-query-expand` — `"Lore query expansion worker"`. * 🔴 (14:23) User showed the…
* 🔴 (14:19) User showed `/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts` documents interceptor processing in this order: 1. match outgoing URLs against known LLM API paths; 2. rewrite to the gateway while preserving the path; 3. add `X-Lore-Upstream-URL` for the base and `X-Lore-Upstream-Path` for the original endpoint pathname; 4. inject dynamic `X-Lore-*` context headers f…
* 🔴 (14:01) User showed `/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts` lines 1841-1868: `withLifecycleLock<T>(operation, action, options = {})` supports async-context reentrancy through `lockContext.getStore()`; an inherited lock is validated with `inherited.assertOwned()` and reused for `action(inherited)` instead of reacquiring. * 🔴 (14:01) User showed that when no life…
* 🔴 (13:51) User showed `/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/registration.ts`: `Registration` exposes readonly `dispose: () => Promise<void>`, and `ModelHookOptions` exposes optional readonly `providerID?: string`, limiting a hook to one provider while unscoped hooks apply to every provider. * 🔴 (13:51) User showed hook registration types in `/home/byk/Code/opencode-v2-…
* 🔴 (13:47) User showed `/home/byk/Code/opencode-lore/packages/opencode/src/index.ts` lines 374-456: the `"chat.headers"` hook merges `gatewayAccessHeadersForRemote(gatewayBase)`, sets stable `x-lore-session-id` from `input.sessionID`, sets `x-lore-agent` from `input.agent`, and conditionally sets `x-parent-session-id`, `x-lore-project`, `x-lore-git-remote`, `x-lore-provider`, and `x-lore-upstre…
* 🔴 (13:38) User stated the inert OpenCode Lore plugin never patched `fetch`; `/home/byk/Code/opencode-lore/packages/opencode/test/routing.e2e.test.ts` checks that active discovery resolves a non-empty `gatewayBase`, provider config is pinned to the gateway, and the installed interceptor rewrites `api.anthropic.com` through the in-process Lore gateway to a mocked upstream. * 🔴 (13:40) User show…
* 🔴 (13:38) User showed `/home/byk/Code/opencode-v2-pilot/packages/core/src/session/model-request.ts` lines 207-215: `sessionHeaders(...)` sets `"x-session-affinity"` and `"X-Session-Id"` to `session.id`, conditionally sets `"x-parent-session-id"` from `session.parentID`, sets `"User-Agent"` via `App.useragent(app)`, and includes `"x-opencode-project"`, `"x-opencode-session"`, and `"x-opencode-c…
* 🔴 (13:35) User’s search found 32 matches related to gateway startup in `/home/byk/Code/opencode-lore`: `/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts` line 8 says the plugin’s `startInProcess` delegates to gateway startup and tests use ephemeral ports; `/home/byk/Code/opencode-lore/packages/opencode/src/index.ts` contains `resolveGatewayUrl()` at line 44, `startInPr…
* 🔴 (13:32) User showed `/home/byk/Code/opencode-lore/packages/opencode/package.json`: package `@loreai/opencode` version `0.40.0`, ESM (`"type": "module"`), license `FSL-1.1-Apache-2.0`, description “Three-tier memory architecture for OpenCode — distillation, not summarization,” and raw TypeScript entry/types/exports at `./src/index.ts`. * 🔴 (13:32) User showed `@loreai/opencode` scripts: `"ty…
* 🔴 (13:31) User stated the URL-matched and body-detected interceptor paths must share `buildGatewayHeaders()` so header handling can “never drift between them.” * 🔴 (13:31) User stated: “Never intercept requests already going to the gateway.” In `/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts`, requests whose URL starts with `gatewayBase` are passed to `originalFetch`; the…
* 🔴 (13:25) User showed `/home/byk/Code/opencode-lore/packages/gateway/script/bundle.ts` lines 440–527 generate `dist/index.d.cts`; its generated `StartOptions` currently exposes only `port?: number`, `hosts?: string[]`, `debug?: boolean`, and `quiet?: boolean`, omitting source-level options including `remoteUrl`, `local`, `allowRemoteManagement`, `bg`, and `processBoundary`. * 🔴 (13:25) User s…
* 🔴 (13:21) User showed 4 `remoteUrl` matches in `/home/byk/Code/opencode-lore/packages/gateway`: `/home/byk/Code/opencode-lore/packages/gateway/src/cli/commands/start.ts` line 11 documents `opts.remoteUrl` as an optional remote gateway URL and line 107 sets `remoteUrl: flags.remote`; `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts` line 90 declares `remoteUrl?: string;` and line…
* 🟡 (13:18) Search found 3 `locationInfo()`/location-context matches in `/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/host.ts`: line 91 maps data to `{ location: locationInfo(), data }`; line 127 declares `const context: Plugin.Context = {`; line 129 sets `location: locationInfo(),`.
* 🔴 (13:16) User stated same-location plugin setup calls must never wait on themselves. * 🟡 (13:16) In `/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/host.ts`, `locationInfo()` constructs `Location.Info` from the active location’s `directory`, `workspaceID`, and `project`; `locationRef(input)` resolves an optional requested directory/workspace into `Location.Ref`, defaulting omitted…
* 🔴 (13:13) User stated tests that isolate gateway discovery files must never clobber a real running gateway’s `gateway.port` or `lore.pid` files. * 🟡 (13:13) `/home/byk/Code/opencode-lore/packages/gateway/test/start-gateway-quiet.test.ts` is an 82-line Vitest regression suite for `startGateway({ quiet })`, prompted by Pi TUI breakage reported by Daniel Griesser: embedded OpenCode/Pi callers us…
* 🔴 (13:13) User stated `X-Lore-Upstream-URL` must always be set from the original URL. * 🟡 (13:13) `/home/byk/Code/opencode-lore/packages/pi/src/index.ts` defines the default async entry point `lorePiExtension(pi: ExtensionAPI)`, which detects or starts the Lore gateway, redirects provider URLs, and registers a compaction override when loaded via `pi -e` or `pi install`. * 🟡 (13:13) `lorePiEx…
* 🟡 (13:08) Search found exactly 27 matches for `resolveGatewayUrl`, `startInProcess`, and `processBoundary` across `/home/byk/Code/opencode-lore`: `packages/pi/test/internal.test.ts` (lines 9, 347, 360, 399), `packages/pi/test/gateway-discovery.test.ts` (lines 4, 8, 63, 67, 73), `packages/pi/src/internal.ts` (lines 181, 233), `packages/pi/src/index.ts` (lines 40, 44, 83, 91), `packages/opencode…
* 🟡 (13:06) `/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts` defines `Plugin` with `readonly id: string` and `readonly setup: (context: PluginContext) => Promise<void> | void`; `PluginContext` is imported from `./context.js`. * 🟡 (13:06) `/home/byk/Code/opencode/packages/plugin/src/v2/promise/plugin.ts` exports `define(plugin: Plugin)`, which returns the supplied plugin unchan…
* 🔴 (13:05) User stated configured local plugins “always arrive here as directories” in `/home/byk/Code/opencode-v2-pilot/packages/core/src/plugin/module.ts`; standalone server-file sources are admitted only through legacy auto-discovery. * 🔴 (13:05) User stated the `--local` flag “always disables remote mode,” mirroring hosted mode; in `startGatewayLocked()` in `/home/byk/Code/opencode-lore/pa…
* 🔴 (13:04) User stated test environment teardown must “Always restore the previous value — never delete.” For `useTestConfigDir()`, `process.env[CONFIG_DIR_ENV_VAR]` should be restored to `savedConfigDir`; deleting `process.env.SENTRY_CONFIG_DIR` can break test files loaded after `afterEach` when module-level code or hooks read an undefined value. * 🔴 (13:04) User stated there should always be…
* 🔴 (13:04) `/home/byk/Code/opencode-lore/packages/gateway/src/index.ts` imports `../instrument` and `fileURLToPath` from `node:url`. * 🔴 (13:04) `/home/byk/Code/opencode-lore/packages/gateway/src/index.ts` exports `loadConfig`, `DEFAULT_PORTS`, `DEFAULT_PORT`, `GatewayConfig`, `startServer`, `handleRequest`, `resetPipelineState`, `readPortFile`, `readGatewayProcessFile`, `startGateway`, `probe…
* 🔴 (13:00) `withLifecycleLock<T>(operation, action, options = {})` in `/home/byk/Code/opencode-lore/packages/gateway/src/lifecycle-lock.ts` reuses an inherited `LifecycleLock` after `inherited.assertOwned()`; otherwise it calls `acquireLifecycleLock(operation, options)`, runs `action(lock)` inside `lockContext.run(...)`, and always calls `lock.release()` in `finally`. * 🔴 (13:00) After a `"hos…
* 🔴 (12:53) `packages/opencode/package.json` defines `@loreai/opencode` version `0.40.0`, ESM (`"type": "module"`), licensed `FSL-1.1-Apache-2.0`, with description `"Three-tier memory architecture for OpenCode — distillation, not summarization"`. * 🔴 (12:53) `@loreai/opencode` ships raw TypeScript from `./src/index.ts` for `main`, `types`, and the `"."` export’s `types`, `bun`, and `default` co…
* 🔴 (12:50) `packages/core/src/config/plugin/external.ts` defines `PluginModule` as a `Schema.Struct` whose `default` is a union of: an Effect plugin `{ id: Schema.String, effect: function }`, or a Promise plugin `{ id: Schema.String, setup: function }`. * 🔴 (12:50) External plugin discovery in `packages/core/src/config/plugin/external.ts` processes config document entries and directory entries…
Date: Sep 9, 2026 * 🔴 (12:50) Repository search found exactly 12 matches involving `TuiPluginModule` or `PluginModule`: `/home/byk/Code/opencode/packages/plugin/src/tui.ts:630` exports `TuiPluginModule`; `/home/byk/Code/opencode/packages/plugin/src/index.ts:76` exports `PluginModule`; `/home/byk/Code/opencode/packages/tui/src/feature-plugins/builtins.ts:1` imports `TuiPlugin` and `TuiPluginModul…
Date: Sep 9, 2026 * 🔴 (10:29) `/home/byk/Code/opencode/packages/plugin/src/v2/effect/README.md` states V2 plugin setup registers hooks imperatively and does not return a hook object; plugin configuration is available as `ctx.options`. * 🔴 (10:29) V2 Effect plugin registrations are owned by the plugin scope: closing the scope removes them automatically, and `dispose` can remove a registration ea…
Date: Sep 9, 2026 * 🔴 (10:26) `/home/byk/Code/opencode/packages/plugin/src/v2/options.ts` contains one line: `export type PluginOptions = Readonly<Record<string, any>>`. * 🔴 (10:27) A repository search for `define` found 100 displayed matches with more available. `Event.define(...)` is used throughout `/home/byk/Code/opencode/packages/schema`, including `test/event.test.ts`, `src/worktree-event…
Date: Sep 9, 2026 * 🔴 (10:24) `/home/byk/Code/opencode-lore/packages/gateway/test/shutdown-sqlite-readers.test.ts` is a 342-line regression suite for issue `#1599`: graceful gateway shutdown must close vector/read worker-pool SQLite readers before writer close, and `core close()` must run exactly once on the normal path. * 🔴 (10:24) Issue `#1599` root cause: SQLite WAL `TRUNCATE` requires zero …
Date: Sep 9, 2026 * 🔴 (10:18) Lore development, tests, and production require Node.js >= 22.5; the monorepo uses TypeScript with `pnpm workspaces`, and SQLite runs in WAL mode with FTS5 at `~/.local/share/lore/lore.db`. * 🔴 (10:18) Lore tests use a temporary SQLite database through `packages/core/test/setup.ts` and never the production database. * 🔴 (10:18) Project commands are: `pnpm install`…
* 🔴 (10:17) In `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts`, the `--local` flag always disables remote mode, mirroring hosted mode. * 🔴 (10:17) In `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts`, public health probing never establishes gateway identity. * 🔴 (10:17) The gateway port fallback order is exactly `3207 → 5673 → 0`, where `0` requests an OS-assign…
* 🔴 (10:15) `/home/byk/Code/opencode-v2-pilot/packages/plugin/src/promise/aisdk.ts` defines `AISDKHooks`: `sdk` contains readonly `model: Model.Info`, readonly `package: string`, readonly `options: Record<string, any>`, and optional `sdk?: any`; `language` contains readonly `model: Model.Info`, readonly `sdk: any`, readonly `options: Record<string, any>`, and optional `language?: LanguageModelV3…
Date: Sep 9, 2026 * 🔴 (10:10) User stated the fetch interceptor must never intercept requests already going to the gateway; `/home/byk/Code/opencode-lore/packages/core/src/fetch-interceptor.ts` lines 471-481 still pass their headers to `observeRequestHeaders()` so in-process extensions can scope side-channel requests, then call the original fetch. * 🔴 (10:10) User stated the fetch interceptor m…
* 🔴 (10:02) `/home/byk/Code/opencode-lore/packages/opencode/test/gateway-smoke.test.ts` contains 4 in-process gateway smoke tests: 1. `probeGateway("http://127.0.0.1:19876", 500)` returns `false` when nothing listens; 2. `startServer()` with `config.port=0`, `remoteGateway=false`, and `hostedMode=false` serves `/health` with HTTP success and `{ status: "ok" }`; 3. an explicit free port obtained …
* 🔴 (09:58) `/home/byk/Code/opencode-lore/packages/gateway/package.json` defines `@loreai/gateway` version `0.40.0`, ESM package type, Node engine `>=22.15`, main `./dist/index.cjs`, types `./dist/index.d.cts`, Bun export `./dist/index.bun.js`, and binaries `lore` / `lore-gateway` both mapped to `./dist/bin.cjs`. * 🔴 (09:58) `@loreai/gateway` scripts are `typecheck: tsc --noEmit`, `build: tsx s…
Date: September 9, 2026 * 🔴 (09:54) User established that OpenCode owns a full-screen TUI, so startup banners and other plugin output must NEVER use raw stderr writes; route them through `log` (file + sink, with stderr only when not silenced), making them visible via `lore logs`. * 🔴 (09:54) User established that OpenCode request headers must emit `x-lore-git-remote` only from the git remote pa…
* 🔴 (09:53) In `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts`, `opts.local === true` always disables remote mode by setting `config.remoteGateway = false` and `config.remoteGatewayAutoDetected = false`; this mirrors hosted-mode opt-out behavior. * 🔴 (09:53) In `/home/byk/Code/opencode-lore/packages/gateway/src/cli/start.ts`, when `opts.local === undefined` and neither `LORE_RE…
* 🔴 (09:53) `/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.node.ts` uses `registerHooks` from `node:module` and a monotonically incremented `generation` initialized with `Date.now()` to assign each prepared source a reload version. * 🔴 (09:53) `prepareSource(entrypoint, track)` in `/home/byk/Code/opencode-v2-pilot/packages/plugin/src/source.node.ts` defines `fresh(specifier)` by s…
Date: Sep 9, 2026 * 🔴 (09:45) `/home/byk/Code/opencode-lore/quality/REVIEW.md` codifies Lore’s pull-request review bar because adversarial review has repeatedly found correctness bugs missed by green test suites, especially skip/early-return branches, lifecycle sequences, and fan-out registry gaps. * 🔴 [enforced-regression-testing] (09:45) Every adversarial-review finding that exposes a defect …
Date: Sep 9, 2026 * 🔴 (09:43) In `/home/byk/Code/opencode-lore/packages/pi/src/index.ts`, Pi routine status and errors must go through the core file-based `log` module, NEVER through `console`, stdout, or stderr, because Pi runs a full-screen TUI that any raw terminal write would corrupt. * 🔴 (09:43) `lorePiExtension(pi)` calls `log.silenceStderr()` whenever it is not in inert test mode; the si…
* 🔴 (09:41) In `/home/byk/Code/opencode-lore/packages/gateway/src/pidfile.ts`, legacy numeric PID files cannot establish process ownership and must never be signalled; `readGatewayProcessFile()` therefore returns `null` for them. * 🔴 (09:41) `readGatewayProcessFile()` reads `gateway.pid` with `readRuntimeFile(PIDFILE_NAME, { ownerOnly: true })`, parses JSON, and returns a valid `GatewayProcessR…