Dashboard › opencode-lore › Session 0qM9xijbOYuq
0qM9xijbOYuqOswuwIn /home/byk/Code/opencode-lore-responses-projection-fix, research-only, no edits/VCS/server/network/DB. Inspect current projection stack through ozrmvotw/583020fa plus empty child. Trace raw provider events from principal and continuation parse through validation, accumulation, deferred/transactional holding, remapping, client forwarding, and terminal reconstruction. Identify the smallest exact implementation and deterministic fail-first test matrix to fix: (1) unsupported indexed events or extra top-level/nested fields leaking through remapping, (2) no-index deferred principal extension frames leaking after recall, (3) high-cardinality quadratic scans in sparse candidate resolution and identity matching. Distinguish what the separate private-reference candidate already fixes and what belongs here without importing reference behavior. Return exact current file:line/symbol evidence, existing relevant tests/helpers, expected failing behavior, minimal safe allowlist/projection design, and operation-counter test design. Do not write code or run broad tests.
Skill "repo-setup" not found. Available skills: ast-grep, customize-opencode, jj-create-pr, jj-guide, jj-update-pr, jj-workflow
<path>/home/byk/Code/opencode-lore-responses-projection-fix</path> <type>directory</type> <entries> .craft.yml .git .github/ .gitignore .jj/ .lore.md .oxfmtrc.json .oxlintrc.json AGENTS.md CHANGELOG.md codecov.yml LICENSE node_modules/ package.json packages/ patches/ pnpm-lock.yaml pnpm-workspace.yaml quality/ README.md scripts/ stryker.config.mjs supabase/ tsconfig.base.json tsconfig.json vitest.config.ts vitest.evals.config.ts vitest.mutation.config.ts (28 entries) </entries>
No files found
<path>/home/byk/Code/opencode-lore-responses-projection-fix/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-responses-projection-fix/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. ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/package.json</path>
<type>file</type>
<content>
1: {
2: "name": "lore-monorepo",
3: "private": true,
4: "type": "module",
5: "license": "FSL-1.1-Apache-2.0",
6: "description": "Monorepo root for Lore — three-tier memory architecture",
7: "main": "./packages/opencode/src/index.ts",
8: "exports": {
9: ".": "./packages/opencode/src/index.ts"
10: },
11: "packageManager": "pnpm@10.28.0",
12: "volta": {
13: "node": "24.16.0",
14: "pnpm": "10.28.0"
15: },
16: "pnpm": {
17: "onlyBuiltDependencies": [
18: "esbuild",
19: "onnxruntime-node",
20: "sharp"
21: ],
22: "overrides": {
23: "basic-ftp": "5.3.1",
24: "ip-address": "10.2.0",
25: "fast-xml-parser": "5.7.3",
26: "@huggingface/hub": "2.11.0",
27: "onnxruntime-node": "1.27.0",
28: "yaml": ">=2.8.3",
29: "esbuild": ">=0.28.1",
30: "@opentelemetry/core": ">=2.8.0",
31: ...
Found 100 matches (more matches available) /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/worker-model.ts: Line 703: * True when a candidate worker model id is currently usable for selection: Line 734: * 3. Group candidates by family; judge each family's tier by its NEWEST Line 742: * session model has no family/namespace metadata OR the lineage candidate set Line 766: // Group cheaper same-lineage selectable candidates by family, tracking each Line 897: * A candidate qualifies when it: Line 938: // selection advances to the next candidate on re-resolution. Line 996: * no qualifying candidate. Line 1119: * candidate, `:free`/zero-output included) only when NO paid chat model Line 1125: * signal (skip the candidate; it'd 400 at the upstream). ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/cache-stability.e2e.test.ts:
Line 329: // Turn 1→2 legitimately introduces system[2] (context-bound LTM is deferred
Line 1685: // knowledge is deferred to the next cold boundary. This asserts a raw
Line 1695: "Updated context-bound knowledge that must stay deferred while the warm pin is active.",
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/foreground-body-limit.test.ts:
Line 157: test("buffered Codex accepts sparse events without output_index", async () => {
Line 331: type: "item_reference",
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/idle-work.test.ts:
Line 547: // D6′ deferred prefix work — drive the real handler and assert via the worker
Line 623: // Distillation gate: a sub-minMessages backlog is deferred on hold-warm but
Line 668: // ...
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/worker-copilot-responses.test.ts /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/responses-upstream-error-relay.test.ts /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/responses-compact-routing.test.ts /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses.test.ts /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-stream.test.ts /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path> <type>file</type> <content> 1: /** 2: * OpenAI Responses API SSE stream accumulator. 3: * 4: * Parses upstream Responses API streaming events and accumulates the full 5: * response into a `GatewayResponse`. The Responses API uses a different 6: * SSE event lifecycle than Anthropic: 7: * 8: * response.created → response.in_progress → 9: * response.output_item.added → response.output_text.delta (repeated) → 10: * response.output_item.done → response.function_call_arguments.delta → 11: * response.function_call_arguments.done → 12: * response.completed 13: * 14: * Reuses `parseSSEStream` from the Anthropic stream module since the 15: * underlying SSE wire format is the same. ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path>
<type>file</type>
<content>
250: if (typeof type !== "string" || typeof status !== "string") return false;
251: return OUTPUT_ITEM_STATUSES_BY_TYPE[type]?.[phase]?.has(status) ?? false;
252: }
253:
254: function recordExtends(
255: actual: Record<string, unknown>,
256: streamed: Record<string, unknown>,
257: ignored: ReadonlySet<string> = new Set(),
258: ): boolean {
259: return Object.entries(streamed).every(
260: ([field, value]) =>
261: ignored.has(field) || terminalValueExtends(actual[field], value),
262: );
263: }
264:
265: function terminalValueExtends(actual: unknown, streamed: unknown): boolean {
266: if (streamed === undefined) return true;
267: if (Array.isArray(streamed)) {
268: if (!Array.isArray(actual) || actual.length !== streamed.length) {
269: return false;
270: }
271: return streamed.every((value, index) ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path>
<type>file</type>
<content>
670:
671: case "response.output_text.done": {
672: const outputIndex = parsed.output_index as number;
673: const text = parsed.text as string | undefined;
674: if (typeof outputIndex !== "number") break;
675:
676: const item = state.items.get(outputIndex);
677: if (item?.type === "text" && typeof text === "string") {
678: // Replace accumulated text with the final version (more reliable)
679: item.text = text;
680: }
681: break;
682: }
683:
684: case "response.refusal.delta": {
685: const outputIndex = parsed.output_index as number;
686: const delta = parsed.delta as string | undefined;
687: const item = state.items.get(outputIndex);
688: if (item?.type === "text" && typeof delta === "string") {
689: item.refusal = (item.refusal ?? ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path>
<type>file</type>
<content>
1087: case "response.content_part.added":
1088: case "response.content_part.done":
1089: if (
1090: !validOutputIndex ||
1091: !state.rawItems.has(outputIndex as number) ||
1092: !Number.isSafeInteger(parsed.content_index) ||
1093: (parsed.content_index as number) < 0 ||
1094: (parsed.content_index as number) >= maxSparseIndex ||
1095: (parsed.item_id !== undefined &&
1096: parsed.item_id !== state.rawItems.get(outputIndex as number)?.id) ||
1097: !parsed.part ||
1098: typeof parsed.part !== "object" ||
1099: Array.isArray(parsed.part)
1100: ) {
1101: malformed();
1102: }
1103: break;
1104: case "response.output_text.delta":
1105: if (!validOutputIndex || typeof parsed.delta !== "string") malformed();
1106: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path>
<type>file</type>
<content>
1680: }
1681: if (state.id && response.id !== undefined && response.id !== state.id) {
1682: throw new Error("malformed Responses terminal event");
1683: }
1684: if (
1685: state.model &&
1686: response.model !== undefined &&
1687: response.model !== state.model
1688: ) {
1689: throw new Error("malformed Responses terminal event");
1690: }
1691: if (
1692: event === "response.created" &&
1693: response.status !== undefined &&
1694: response.status !== "in_progress" &&
1695: response.status !== "queued"
1696: ) {
1697: malformedResponsesEvent();
1698: }
1699: if (
1700: event === "response.in_progress" &&
1701: response.status !== undefined &&
1702: response.status !== "in_progress"
1703: ) {
1704: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts</path>
<type>file</type>
<content>
2334: if (opts.validation && activeContentParts.size > 0) {
2335: throw new Error("incomplete Responses output lifecycle");
2336: }
2337: if (opts.validation === "codex") {
2338: for (const item of state.items.values()) {
2339: if (item.type === "tool_use" && !(item.callId || item.id)) {
2340: throw new Error("malformed Responses stream event");
2341: }
2342: }
2343: }
2344: // The first semantic terminal is authoritative. Any bytes already
2345: // delivered after it are transport tail and are discarded on cancel.
2346: await opts.onValidatedEvent?.(event, data);
2347: if (opts.stopAtTerminal) break;
2348: continue;
2349: }
2350: if (event !== "message") await opts.onValidatedEvent?.(event, ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:
Line 364: } from "./recall-continuation-failure";
Line 1378: for (const [candidate, entry] of provisionalHeaderSessionIndex) {
Line 1380: provisionalHeaderSessionIndex.delete(candidate);
Line 4052: // agent will run, so watch BOTH candidates (AGENTS.md + CLAUDE.md); an
Line 5570: * candidate — requires evidence beyond the (fingerprint-implied) first message. */
Line 5578: * pin. Returns the adopted session (isNew=false) or null when no candidate is
Line 5584: * cross-restart match signal. Confidently bound candidates require overlap in
Line 5585: * the incoming project. A provisionally bound candidate instead checks its
Line 5589: * candidate's stored count.
Line 5663: const candidates = findSessionStatesByFingerprint(fingerprint, {
Line 5665: }).map((candidate) => ({ ...candidate, credentialBound: true ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
320: } from "./cch";
321: import { isClaudeCodeClient, isRotationEligible } from "./session";
322: import { isClaudeCodeSideChannel } from "./side-channel";
323: import {
324: analyzeCacheTurn,
325: categorizeBust,
326: type CacheBustCause,
327: } from "./cache-analytics";
328: import {
329: recordGap,
330: getSessionHistogram,
331: recordGlobalGap,
332: resolveProfile as resolveWarmingProfile,
333: clearWarmupAuthDisabled,
334: creditWarmupHit,
335: resetCircuitBreaker,
336: setWarmingEnabled,
337: } from "./cache-warmer";
338: import {
339: setSentryRequestContext,
340: setSentryCacheContext,
341: setSentryLightContext,
342: setGenAiUsageAttributes,
343: setCacheAnalyticsAttributes,
344: emitCostMetric,
345: emitCacheBustMetric,
346: emitWarmupHitMetric,
347: emitCurationMetrics,
348: spanStartupBackfill,
349: ...
Found 1 matches /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts: Line 218: } from "./stream/openai-responses";
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
180: buildAnthropicRequest,
181: buildAnthropicNonStreamResponse,
182: parseAnthropicResponseJSON,
183: type AnthropicCacheOptions,
184: } from "./translate/anthropic";
185: import {
186: bedrockMantleUrl,
187: isBedrockMantleDispatch,
188: toMantleModelId,
189: } from "./translate/bedrock";
190: import { buildVertexUpstream, vertexHost } from "./translate/vertex";
191: import { getVertexAccessToken, resolveVertexProject } from "./vertex-auth";
192: import {
193: buildOpenAIUpstreamRequest,
194: buildOpenAIResponse,
195: } from "./translate/openai";
196: import {
197: buildOpenAIResponsesUpstreamRequest,
198: buildOpenAIResponsesResponse,
199: parseOpenAIResponsesRequest,
200: } from "./translate/openai-responses";
201: import {
202: accumulateResponsesSSEStream,
203: streamResponsesPassthrough,
204: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path> <type>file</type> <content> 7770: * 7771: * Unlike the buffered `accumulateResponsesSSEStream` path (which withholds ALL 7772: * client bytes until the entire slow reasoning-heavy upstream completes — the 7773: * cause of opencode's 10s `ProviderHeaderTimeoutError`), this function forwards 7774: * every upstream SSE event to the client AS IT ARRIVES, while transparently 7775: * intercepting a `recall` `function_call` output item: 7776: * 7777: * - **No recall**: forwards everything unchanged (identical to 7778: * `streamResponsesPassthrough`). 7779: * - **Recall + other tools (mixed)**: suppresses the recall item and its 7780: * flow events, emits a synthetic marker text item, then rebuilds the 7781: * terminal `response.completed` reflecting only client-visible output. ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
8380: }
8381: const lifecycles = lifecyclesFor(state);
8382: const lifecycle = lifecycles.get(outputIndex);
8383: if (lifecycle?.outputDone && event !== "response.output_item.added") {
8384: throw new Error(
8385: `Responses event after output_item.done for index ${outputIndex}`,
8386: );
8387: }
8388: if (event === "response.output_item.added") {
8389: if (state.rawItems.has(outputIndex)) {
8390: throw new Error(`duplicate Responses output_index ${outputIndex}`);
8391: }
8392: const item = parsed.item as Record<string, unknown> | undefined;
8393: const sparseCodexFunction =
8394: opts.validation === "codex" && item?.type === "function_call";
8395: if (
8396: !item ||
8397: typeof item.type !== "string" ||
8398: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
9030: ) {
9031: throw new Error(
9032: `Responses reasoning summary ended before completion for index ${outputIndex}:${summaryIndex}`,
9033: );
9034: }
9035: continue;
9036: }
9037: if (
9038: finalPart.type !== "summary_text" ||
9039: typeof finalPart.text !== "string"
9040: ) {
9041: throw new Error("invalid Responses reasoning summary item");
9042: }
9043: if (
9044: (summaryState.deltaSeen && !summaryState.valueDone) ||
9045: (summaryState.partAdded && !summaryState.partDone)
9046: ) {
9047: throw new Error(
9048: `Responses reasoning summary ended before ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
9670: coverage: result.coverage,
9671: });
9672: if (stopReason)
9673: log.info(
9674: `recall final continuation: budget exhausted reason=${stopReason}`,
9675: );
9676: return result;
9677: };
9678: const settleFollowUp = async (
9679: input: Parameters<typeof opts.runFollowUp>[0],
9680: ): ReturnType<typeof opts.runFollowUp> => {
9681: const operation = opts.runFollowUp({
9682: ...input,
9683: resultText: recallBudgetGuidance(
9684: input.resultText,
9685: input.finalRecallRound ? recallBudget.stopReason() : undefined,
9686: ),
9687: });
9688: const cancelLateReader = async (): Promise<void> => {
9689: try {
9690: const late = await operation;
9691: cancelAndReleaseReader(late.reader, signal.reason);
9692: } catch {
9693: // The ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
10360: ) {
10361: unresolvedToolIndices.add(outputIndex);
10362: } else {
10363: resolvingVisibleTool = true;
10364: }
10365: }
10366: }
10367:
10368: // Always accumulate into the internal state for postResponse.
10369: applyResponsesEvent(state, event, parsed);
10370: if (
10371: event === "response.output_item.done" &&
10372: outputIndex !== undefined
10373: ) {
10374: preserveStreamedReasoning(state, outputIndex);
10375: }
10376: if (newlyPrivateRecallIndex && recallIndices.size > 1) {
10377: throw new RecallContinuationFailure("parallel_recall");
10378: }
10379: let resolvedVisibleTool = ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
11020: }
11021: if (
11022: resolvedVisibleTool &&
11023: contRecallIndices.size === 0 &&
11024: contUnresolvedToolIndices.size === 0
11025: ) {
11026: flushHeldContinuation();
11027: }
11028: const isContRecall =
11029: ci !== undefined && contRecallIndices.has(ci);
11030: const isContUnresolvedTool =
11031: ci !== undefined &&
11032: contUnresolvedToolIndices.has(ci);
11033: if (
11034: (isContRecall || isContUnresolvedTool) &&
11035: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
11710: state = makeResponsesAccState();
11711: syntheticIdentities.clear();
11712: referenceIdentities.clear();
11713: outputIdentities.clear();
11714: recallIndices.clear();
11715: unresolvedToolIndices.clear();
11716: referenceIndices.clear();
11717: forwardedVisibleOutputIndices.clear();
11718: recallDetected = false;
11719: principalFailureCategory = "principal_unexpected";
11720: retainedStateBytes = retainedStateBaseline;
11721: hiddenRecallBytes = hiddenRecallBaseline;
11722: continue;
11723: }
11724: }
11725: } catch (err) {
11726: rollbackTransaction();
11727: if (principalReader) {
11728: ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/content-passthrough.test.ts:
Line 560: // blocksToText projection
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/cli-admin-contract.test.ts:
Line 276: // The F-1 scanner-error exit-code remap from PR #1569 covers all
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/worker-recovery.test.ts:
Line 140: } else controller.error(new Error("private upstream read failure"));
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/claude-usage-provisional.test.ts:
Line 33: ? new Response("private upstream quota detail", {
Line 83: expect(body).not.toContain("private upstream quota detail");
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/compact-endpoint-tenant-isolation.e2e.test.ts:
Line 274: // Compaction is a ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 95: if (!Number.isSafeInteger(data.output_index)) continue;
Line 104: expect(terminalOutput?.output?.[data.output_index as number]?.id).toBe(
Line 120: output_index: outputIndex,
Line 129: output_index: outputIndex,
Line 134: output_index: outputIndex,
Line 145: const sparseVisibleFunctionCall = (
Line 148: itemId = `fc_sparse_${outputIndex}`,
Line 149: callId = `call_sparse_${outputIndex}`,
Line 152: output_index: outputIndex,
Line 162: output_index: outputIndex,
Line 167: output_index: outputIndex,
Line 224: output_index: outputIndex,
Line 228: output_index: outputIndex,
Line 234: output_index: outputIndex,
Line 240: output_index: outputIndex,
Line 454: // recall call at output_index 0
Line 456: // a ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
1: /**
2: * Unit tests for `streamResponsesRecallAware` — the true-streaming,
3: * recall-aware OpenAI Responses (codex/ChatGPT) streamer.
4: *
5: * Regression for the "Provider response headers timed out after 10000ms" issue:
6: * the buffered `accumulateResponsesSSEStream` path withholds ALL client bytes
7: * until the entire (slow, reasoning-heavy) upstream completes, so opencode's
8: * 10s `ProviderHeaderTimeoutError` fired on ChatGPT sessions. This streamer
9: * forwards events live while transparently intercepting a `recall`
10: * function_call (emit marker, run follow-up, rebuild the terminal
11: * `response.completed`).
12: */
13: import { log } from "@loreai/core";
14: import { afterEach, describe, test, expect } from "vitest";
15: import { streamResponsesRecallAware } from "../src/pipeline";
16: import ...
Found 34 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 666: test("bounds deferred principal output after recall detection", async () => {
Line 1179: test("rejects response.in_progress changing the created response identity", async () => {
Line 1467: test("rejects one content index changing type", async () => {
Line 1588: test("rejects terminal output changing streamed identity", async () => {
Line 2086: test("accepts reasoning summaries with summary_index", async () => {
Line 2191: test("supports done-only sparse Codex items on principal and continuation streams", async () => {
Line 2350: test("redacts a sparse principal recall when promotion exceeds the hidden budget", async () => {
Line 2673: test("allows a terminal-discovered recall that preserves sparse visible output positions", async () => {
Line 2756: test("redacts a sparse terminal-discovered ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
5630: };
5631: }
5632: return {
5633: reader: streamFrom([
5634: created(`resp_twelve_${recalls}`, "gpt-5.6-terra"),
5635: recallCall(
5636: 0,
5637: { query: `source ${recalls + 1}` },
5638: `fc_twelve_${recalls}`,
5639: `call_twelve_${recalls}`,
5640: ),
5641: completed(`resp_twelve_${recalls}`),
5642: ]).body!.getReader(),
5643: };
5644: },
5645: },
5646: );
5647:
5648: const out = await drain(client);
5649: expect([recalls, followUps]).toEqual([12, 12]);
5650: expect(out).toContain("twelfth source establishes the final fact");
5651: expect(out).not.toContain(PUBLIC_RECALL_ERROR);
5652: });
5653:
5654: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
6070: created("resp_bytes_second", "gpt-5.6-terra"),
6071: secondRecall,
6072: completed("resp_bytes_second"),
6073: ]);
6074: const oneRecallBytes = new TextEncoder().encode(firstRecall).byteLength;
6075: let recalls = 0;
6076: const client = streamResponsesRecallAware(
6077: streamFrom([
6078: created("resp_bytes_first", "gpt-5.6-terra"),
6079: firstRecall,
6080: completed("resp_bytes_first"),
6081: ]),
6082: {
6083: maxDeferredBytes: 1024 * 1024,
6084: maxHiddenRecallBytes: oneRecallBytes + 32,
6085: onComplete: () => {},
6086: onRecall: async ({ query }) => {
6087: recalls++;
6088: return {
6089: anchorText: buildAnchor(query),
6090: resultText: "results",
6091: ...
Found 7 matches /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/cli/setup.ts: Line 210: export function _setSetupExternalEffectHookForTest( /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/cli/lib/install-transaction.ts: Line 81: export function _setInstallPublicationHookForTest( /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/cli/json-config.ts: Line 121: export function _setTrustedFileCommitHookForTest( Line 128: export function _setTrustedFilePublishHookForTest( Line 135: export function _setTrustedFileRollbackHookForTest( Line 142: export function _setTrustedDirectoryFsyncHookForTest( Line 149: export function _setStagedTrustedFileCommitHookForTest(
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:
Line 7781: * terminal `response.completed` reflecting only client-visible output.
Line 7785: * terminal `response.completed` reflecting marker + continuation.
Line 8346: event === "response.output_item.done" &&
Line 8363: "response.output_item.added",
Line 8367: applyResponsesEvent(state, "response.output_item.added", {
Line 8383: if (lifecycle?.outputDone && event !== "response.output_item.added") {
Line 8388: if (event === "response.output_item.added") {
Line 8525: event === "response.output_item.done" &&
Line 8534: event === "response.output_item.done" &&
Line 8546: event === "response.output_item.done" &&
Line 8595: event !== "response.output_item.done" &&
Line 8603: (event.startsWith("response.output_text") ||
Line 8604: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
1370: created("resp_retry_limit_principal", "gpt-5.6-terra"),
1371: recallCall(0, { query: "retry byte budget" }),
1372: completed("resp_retry_limit_principal"),
1373: ];
1374: const dropped = created("resp_retry_limit_dropped", "gpt-5.6-terra");
1375: const recovered = [
1376: created("resp_retry_limit_recovered", "gpt-5.6-terra"),
1377: textItem(0, "recovered after budget", "msg_retry_limit"),
1378: completed("resp_retry_limit_recovered"),
1379: ];
1380: const droppedFollowUp = new Response(
1381: new ReadableStream<Uint8Array>({
1382: start(controller) {
1383: controller.enqueue(new TextEncoder().encode(dropped));
1384: controller.error(new Error("socket reset"));
1385: },
1386: }),
1387: { headers: { ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
6750: );
6751:
6752: const out = await drain(client);
6753: expect(out).toContain(PUBLIC_RECALL_ERROR);
6754: expect(out).not.toContain("lore-recall");
6755: expect(recalled).toBe(0);
6756: });
6757:
6758: test("rejects continuation output using the reserved principal anchor ID", async () => {
6759: const continuation = streamFrom([
6760: created("resp_continuation_collision", "gpt-5.6-terra"),
6761: textItem(0, "collision", "msg_resp_principal_collision_0"),
6762: completed("resp_continuation_collision"),
6763: ]);
6764: const client = streamResponsesRecallAware(
6765: streamFrom([
6766: created("resp_principal_collision", "gpt-5.6-terra"),
6767: recallCall(0, { query: "architecture" }),
6768: completed("resp_principal_collision"),
6769: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
8020: query: "",
8021: scope: undefined,
8022: id: "k:one",
8023: ids: undefined,
8024: detailOffset: 10,
8025: detailLimit: 20,
8026: },
8027: },
8028: {
8029: mode: "batch-id",
8030: args: {
8031: query: null,
8032: scope: null,
8033: id: null,
8034: ids: ["k:one", "k:two"],
8035: detailOffset: null,
8036: detailLimit: null,
8037: },
8038: expected: {
8039: query: "",
8040: scope: undefined,
8041: id: undefined,
8042: ids: ["k:one", "k:two"],
8043: detailOffset: undefined,
8044: detailLimit: undefined,
8045: },
8046: },
8047: ])(
8048: "accepts nullable strict $mode recall arguments",
8049: async ({ args, expected }) => ...
Found 24 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 1906: name: "message annotations",
Line 1918: content: [{ type: "output_text", text: "answer", annotations: [] }],
Line 3745: arguments: '{"path":"secret"}',
Line 3787: content: [{ type: "output_text", text: "secret" }],
Line 3829: part: { type: "output_text", text: "secret" },
Line 3883: delta: "secret",
Line 3889: text: "secret",
Line 4075: part: { type: "output_text", text: "secret" },
Line 4304: text: "secret",
Line 5076: annotations: [citation],
Line 7764: arguments: '{"query":"secret"}',
Line 7776: arguments: '{"query":"secret"}',
Line 7805: arguments: '{"query":"secret"}',
Line 7850: expect(out).not.toContain("secret");
Line 8112: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
4980:
4981: expect(await drain(client)).toContain(PUBLIC_RECALL_ERROR);
4982: expect(recalled).toBe(0);
4983: });
4984:
4985: test("rejects cache usage without input_tokens before recall", async () => {
4986: let recalled = 0;
4987: const client = streamResponsesRecallAware(
4988: streamFrom([
4989: created("resp_cache_without_input", "gpt-5.6-terra"),
4990: recallCall(0, { query: "usage" }),
4991: completed("resp_cache_without_input", {
4992: output_tokens: 1,
4993: input_tokens_details: {
4994: cached_tokens: Number.MAX_SAFE_INTEGER,
4995: },
4996: }),
4997: ]),
4998: {
4999: onComplete: () => {},
5000: onRecall: async () => {
5001: recalled++;
5002: return { anchorText: "", ...
Found 24 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/recall.ts:
Line 1752: { type: "output_text", text: replaced.get(callId)!, annotations: [] },
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:
Line 9761: part: { type: "output_text", text: "", annotations: [] },
Line 9791: part: { type: "output_text", text, annotations: [] },
Line 9804: content: [{ type: "output_text", text, annotations: [] }],
Line 9930: { type: "output_text", text: item.text, annotations: [] },
Line 14754: // Must include id, status, and annotations to match the
Line 14765: { type: "output_text", text: summary, annotations: [] },
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/translate/openai-responses.ts:
Line 1195: annotations: [],
Line 1325: part: { type: "output_text", text: "", ...
Found 5 matches /home/byk/Code/opencode-lore-responses-projection-fix/.lore.md: Line 101: * **OpenCode v2 durable settlement**: OpenCode v2 separates durable terminal outcomes from ephemeral progress. Chose exactly one durable settlement event over reconstructing state from deltas because replay must remain bounded and deterministic: a newer turn supersedes stale incomplete rows, and the system must never resume an older assistant projection. \`session.tool.success\`/\`failed\` and \`session.compaction.ended\` settle replayable state; reasoning and compaction deltas remain live-only progress. Line 134: * **Sync EventV2 authority and persistence requirements**: Sync events must flow exclusively through EventV2 publication and replay, not ad hoc Bus.publish calls or sync-owned database writes. EventV2 is the authoritative boundary for sequencing, ownership/claiming, persistence, replay, and projections. \`events.persist=false\` only mitigates event-log storage growth: live ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/.lore.md</path> <type>file</type> <content> 500: 501: <!-- lore:01a03dc8-cc84-7489-934d-1d99f458d67b --> 502: * **opencode.json model MCP schema**: OpenCode \`model\` values always include the provider prefix, such as \`anthropic/claude-sonnet-4-6\`. Every \`mcp\[name]\` requires \`type\`, and \`command\` is always an array of strings, never one shell string. Bare model names and string commands look ergonomic, but they violate the configuration contract and create ambiguous provider or argument parsing. 503: 504: <!-- lore:01a03e22-941c-7289-9c82-f097a391d7f5 --> 505: * **pnpm engine-strict workflow**: Use pnpm exclusively in BYK/loreai; \`.npmrc\` enforces \`engine-strict=true\`. Always use \`pnpm add\` for dependencies, never \`npm install\` or \`yarn add\`, because alternate package managers bypass the repository’s lockfile and engine guarantees. 506: 507: <!-- lore:019fe14a-f9d4-7f87-947e-3c9730d3faef --> 508: * ...
No files found
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
620: created("resp_parallel_mixed", "gpt-5.6-terra"),
621: recallCall(0, { query: "one" }),
622: recallCall(1, { query: "two" }),
623: sseEvent("response.output_item.added", {
624: output_index: 2,
625: item: {
626: type: "function_call",
627: id: "fc_read",
628: call_id: "call_read",
629: name: "read",
630: },
631: }),
632: sseEvent("response.function_call_arguments.done", {
633: output_index: 2,
634: item_id: "fc_read",
635: arguments: "{}",
636: }),
637: sseEvent("response.output_item.done", {
638: output_index: 2,
639: item: {
640: type: "function_call",
641: id: "fc_read",
642: call_id: ...
Found 52 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses.test.ts:
Line 57: { type: "reasoning", summary: [] },
Line 395: { type: "output_text", text: "chart summary" },
Line 413: { type: "text", text: "chart summary" },
Line 431: summary: [],
Line 468: test("binds unknown self-contained output items to provenance", () => {
Line 469: const unknown = {
Line 479: unknown,
Line 495: { type: "opaque", raw: unknown, responsesItem: true },
Line 508: test("round-trips refusal and unknown output as top-level Responses items", () => {
Line 515: const unknown = {
Line 526: unknown,
Line 534: ).body as { input: Array<Record<string, unknown>> };
Line 542: { type: "opaque", raw: unknown, responsesItem: true },
Line 545: expect(body.input).toContainEqual(unknown);
Line 569: ).body as { input: ...
Found 100 matches (more matches available)
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-stream.test.ts:
Line 32: events: Array<{ event: string; data: Record<string, unknown> }>,
Line 148: event: "response.function_call_arguments.delta",
Line 150: type: "response.function_call_arguments.delta",
Line 156: event: "response.function_call_arguments.delta",
Line 158: type: "response.function_call_arguments.delta",
Line 164: event: "response.function_call_arguments.done",
Line 166: type: "response.function_call_arguments.done",
Line 193: input: unknown;
Line 251: event: "response.function_call_arguments.done",
Line 253: type: "response.function_call_arguments.done",
Line 284: input: unknown;
Line 807: "unknown incomplete reason",
Line 938: "public validation rejects cross-namespace identity aliases (%s)",
Line ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-stream.test.ts</path>
<type>file</type>
<content>
2520: event: string;
2521: data: Record<string, unknown>;
2522: }> = Array.from({ length: count }, (_, outputIndex) => ({
2523: event: "response.output_item.added",
2524: data: {
2525: ...(validation === "public" ? { output_index: outputIndex } : {}),
2526: item: { type: "message", id: `msg_${validation}_${outputIndex}` },
2527: },
2528: }));
2529: if (validation === "public") {
2530: events.push(
2531: ...Array.from({ length: count }, (_, outputIndex) => ({
2532: event: "response.output_item.done",
2533: data: {
2534: output_index: outputIndex,
2535: item: {
2536: type: "message",
2537: id: `msg_${validation}_${outputIndex}`,
2538: content: ...
Found 3 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 5425: ...Array.from({ length: budget - 1 }, () => false),
Line 8299: usage: { input_tokens: 1_000, output_tokens: 100 },
Line 8335: inputTokens: 1_000,
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/codex-usage-metadata.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect, test } from "vitest";
2: import fc from "fast-check";
3: import {
4: accumulateResponsesSSEStream,
5: ResponsesTerminalError,
6: streamResponsesPassthrough,
7: } from "../src/stream/openai-responses";
8: import { buildOpenAIResponsesResponse } from "../src/translate/openai-responses";
9:
10: const limits = {
11: type: "codex.rate_limits",
12: plan_type: "pro",
13: rate_limits: {
14: primary: { used_percent: 12.5, window_minutes: 300, reset_at: 2000000000 },
15: secondary: {
16: used_percent: 75,
17: window_minutes: 10080,
18: reset_at: 2000100000,
19: },
20: },
21: credits: { has_credits: true, unlimited: false, balance: "12.34" },
22: };
23:
24: function upstream(
25: events: Record<string, unknown>[],
26: incomplete = false,
27: ): Response {
28: const ...
Found 2 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/translate/openai-responses.ts:
Line 1281: for (const quota of resp.codexRateLimits ?? []) {
Line 1282: emit("codex.rate_limits", quota);
Found 13 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/codex-usage-provisional.test.ts:
Line 23: rate_limits: {
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/codex-usage-metadata.test.ts:
Line 12: plan_type: "pro",
Line 13: rate_limits: {
Line 21: credits: { has_credits: true, unlimited: false, balance: "12.34" },
Line 64: const events = [limits, { ...limits, metered_limit_name: "codex_spark" }];
Line 160: metered_limit_name: fc.string({ maxLength: 30 }),
Line 168: ({ metered_limit_name, ...primary }) => ({
Line 170: metered_limit_name,
Line 171: rate_limits: { primary },
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/openai-responses.ts:
Line 597: "metered_limit_name",
Line 598: ...
No files found
No files found
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
2175: };
2176: },
2177: runFollowUp: async () => ({ reader: followUp.body!.getReader() }),
2178: },
2179: );
2180:
2181: expect(await drain(client)).not.toContain("response.failed");
2182: expect(continuationCiphertext).toBe("completed-ciphertext");
2183: expect(completedResponse?.rawOutputItems).toContainEqual(
2184: expect.objectContaining({
2185: id: "rs_reasoning_ciphertext",
2186: encrypted_content: "completed-ciphertext",
2187: }),
2188: );
2189: });
2190:
2191: test("supports done-only sparse Codex items on principal and continuation streams", async () => {
2192: const seenRecallCiphertexts: unknown[] = [];
2193: let completedResponse: GatewayResponse | undefined;
2194: const followUp = streamFrom([
2195: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
4130: throw new Error("should not run");
4131: },
4132: },
4133: );
4134:
4135: expect(await drain(client)).toContain("response.failed");
4136: });
4137:
4138: test("accepts reasoning summary prefixes extended by deltas", async () => {
4139: const client = streamResponsesRecallAware(
4140: streamFrom([
4141: created("resp_summary_prefix", "gpt-5.6-terra"),
4142: sseEvent("response.output_item.added", {
4143: output_index: 0,
4144: item: {
4145: type: "reasoning",
4146: id: "rs_summary_prefix",
4147: summary: [{ type: "summary_text", text: "pre" }],
4148: },
4149: }),
4150: sseEvent("response.reasoning_summary_part.added", {
4151: output_index: 0,
4152: item_id: ...
Found 2 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/ui.ts:
Line 209: case "reasoning": {
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:
Line 19260: case "reasoning":
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
4740: recallCall(
4741: 1,
4742: { query: "identity" },
4743: "fc_reference_identity",
4744: "call_shared_reference",
4745: ),
4746: completed("resp_reference_identity"),
4747: ]),
4748: {
4749: onComplete: () => {},
4750: onRecall: async () => {
4751: recalled++;
4752: return { anchorText: "", resultText: "" };
4753: },
4754: runFollowUp: async () => {
4755: throw new Error("should not run");
4756: },
4757: },
4758: );
4759:
4760: expect(await drain(client)).toContain(PUBLIC_RECALL_ERROR);
4761: expect(recalled).toBe(0);
4762: });
4763:
4764: test("rejects reference identities colliding with synthetic markers", async () => {
4765: let recalled = 0;
4766: ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts</path>
<type>file</type>
<content>
3870: sseEvent("response.output_item.added", {
3871: output_index: 0,
3872: item: { type: "reasoning", id: "rs_changed", summary: [] },
3873: }),
3874: sseEvent("response.reasoning_summary_part.added", {
3875: output_index: 0,
3876: item_id: "rs_changed",
3877: summary_index: 0,
3878: }),
3879: sseEvent("response.reasoning_summary_text.delta", {
3880: output_index: 0,
3881: item_id: "rs_changed",
3882: summary_index: 0,
3883: delta: "secret",
3884: }),
3885: sseEvent("response.reasoning_summary_text.done", {
3886: output_index: 0,
3887: item_id: "rs_changed",
3888: summary_index: 0,
3889: text: "secret",
3890: }),
3891: ...
Found 2 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:
Line 7794: export function streamResponsesRecallAware(
Line 18804: streamResponsesRecallAware(upstreamResponse, {
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
18740: sessionSignal.aborted
18741: ) {
18742: dropStreamingFinalizer();
18743: return;
18744: }
18745: accountUnsuccessfulResponse(
18746: resp,
18747: sessionState.sessionID,
18748: sessionState.resolvedConversationTTL,
18749: genAiSpan,
18750: endGenAiSpan,
18751: () => {
18752: sessionState._dirty = true;
18753: },
18754: );
18755: },
18756: dropStreamingFinalizer,
18757: true,
18758: requestCredentialFingerprint(req.rawHeaders, config) ?? ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
18945: };
18946: },
18947: runFollowUp: async ({
18948: finalRecallRound,
18949: acc,
18950: resultText,
18951: toolUseId,
18952: contentPosition,
18953: signal,
18954: }) => {
18955: // Reconstruct the recall tool_use block for the follow-up request.
18956: const recallBlock = acc.content[contentPosition];
18957: if (
18958: recallBlock?.type !== "tool_use" ||
18959: recallBlock.id !== toolUseId ||
18960: recallBlock.name !== RECALL_TOOL_NAME
18961: ) {
18962: throw new Error(
18963: "recall follow-up: recall block not found in accumulated ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/recall-budget.ts</path>
<type>file</type>
<content>
1: import type { RecallCoverage } from "@loreai/core";
2: import type { GatewayUsage } from "./translate/types";
3:
4: /** Finite backstop only; normal termination is time, tokens, bytes, items, or stall. */
5: export const MAX_RECALL_EXECUTIONS = 24;
6: export const MAX_RECALL_CHAIN_TOKENS = 128_000;
7: export const MAX_RECALL_CHAIN_RESULT_BYTES = 512 * 1024;
8: export const MAX_RECALL_CHAIN_ITEMS = 64;
9: /** The formatter's configured maximum for source previews in one search. ...
Found 3 matches /home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/stream/anthropic.ts: Line 58: export const DEFAULT_MAX_SSE_FRAMES = 100_000; Line 175: const maxFrames = opts.maxFrames ?? DEFAULT_MAX_SSE_FRAMES; Line 1993: ? (opts.maxFrames ?? DEFAULT_MAX_SSE_FRAMES)
<path>/home/byk/Code/opencode-lore-responses-projection-fix/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: ...
Found 28 matches
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/test/openai-responses-recall-aware-stream.test.ts:
Line 1834: type: "item_reference",
Line 2020: test("never forwards response-side item_reference lifecycle events", async () => {
Line 2028: type: "item_reference",
Line 2035: type: "item_reference",
Line 2044: output: [{ type: "item_reference", id: "msg_server_only" }],
Line 2059: expect(out).not.toContain("item_reference");
Line 2061: expect(JSON.stringify(completedResponse)).not.toContain("item_reference");
Line 2064: test("rejects an item_reference missing output_item.done", async () => {
Line 2070: item: { type: "item_reference", id: "msg_reference_incomplete" },
Line 2461: { type: "item_reference", id: "fc_data_only_followup" },
Line 2932: type: "item_reference",
Line 3918: test("rejects reuse of an ...
<path>/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/translate/openai-responses.ts</path>
<type>file</type>
<content>
1240:
1241: function incompleteDetails(stopReason: string): { reason: string } {
1242: return {
1243: reason:
1244: stopReason === "content_filter" ? "content_filter" : "max_output_tokens",
1245: };
1246: }
1247:
1248: function buildOpenAIResponsesStreamResponse(resp: GatewayResponse): Response {
1249: const usage = resp.usage ?? ZERO_USAGE;
1250: const encoder = new TextEncoder();
1251:
1252: const stream = new ReadableStream({
1253: start(controller) {
1254: const respId = resp.id.startsWith("resp_") ? resp.id : `resp_${resp.id}`;
1255: const created = Math.floor(Date.now() / 1000);
1256:
1257: function emit(eventType: string, data: Record<string, unknown>) {
1258: controller.enqueue(
1259: encoder.encode(
1260: `event: ${eventType}\ndata: ...
I inspected the current filesystem bytes under /home/byk/Code/opencode-lore-responses-projection-fix. I made no edits and used no VCS, server, network, database, or test commands. Because VCS was forbidden, I did not independently verify ozrmvotw / 583020fa or the empty-child claim.
The required repo-setup skill was unavailable. I read AGENTS.md, quality/REVIEW.md, and the package scripts directly instead.
/home/byk/Code/opencode-lore-responses-projection-fix/packages/gateway/src/pipeline.ts:10232-10243payload.type === event check:pipeline.ts:10250-10277pipeline.ts:10287-10293item_reference handling:pipeline.ts:10296-10298outputIndexForEvent, pipeline.ts:8324-9112pipeline.ts:10368-10374pipeline.ts:10412-10473pipeline.ts:10475-10550pipeline.ts:10573-10612.pipeline.ts:10642-10725.pipeline.ts:10881-10899pipeline.ts:10900-10928pipeline.ts:10929-10940pipeline.ts:10941-10950pipeline.ts:10951-10973pipeline.ts:11002-11007pipeline.ts:11028-11090Date: Sep 16, 2026 * 🟡 (19:47) User supplied a continuation of `packages/gateway/src/pipeline.ts` covering approximately lines 9030-9670 of the Responses stream lifecycle, terminal reconciliation, SSE parsing, and recall-diagnostics implementation. * 🟡 (19:47) Responses lifecycle validation rejects malformed reasoning-summary items with exact error `"invalid Responses reasoning summary item"` a…
Date: Sep 16, 2026 * 🟡 (19:46) User supplied a continuation of `packages/gateway/src/pipeline.ts` covering approximately lines 8391-9027 of the Responses stream lifecycle implementation. * 🟡 (19:46) The implementation rejects an invalid initial function-call status with exact error `"invalid initial Responses function status"`. * 🟡 (19:46) Responses output-item reconciliation derives identitie…
Date: Sep 16, 2026 * 🔴 (19:44) User stated that private source coverage in `streamResponsesRecallAware()` is “never emitted to the client” (`packages/gateway/src/pipeline.ts:7854`). * 🟡 (19:44) `packages/gateway/src/pipeline.ts:201-218` imports these exact artifacts from `./stream/openai-responses`: `accumulateResponsesSSEStream`, `streamResponsesPassthrough`, `translateAnthropicStreamToRespons…
Date: Sep 16, 2026 * 🔴 (19:41) User stated that sparse numeric identities “never need more address space than the” applicable bound in `packages/gateway/src/stream/openai-responses.ts`, and that `index + 1` always changes the value. * 🟡 (19:41) `accumulateResponsesSSEStream()` appears at `packages/gateway/src/stream/openai-responses.ts:1873`; nearby logic tracks active content indexes with `act…
Date: Sep 16, 2026 * 🔴 (19:38) User specified that accumulated text should be replaced with the final version because the final version is more reliable. * 🟡 (19:39) Inspection of `packages/gateway/src/stream/openai-responses.ts:676-683` confirmed that final output-text handling replaces previously accumulated delta text with the final text, documented by the comment `Replace accumulated text w…
Date: Sep 16, 2026 * 🔴 [requested-research-only] (19:33) User directed work in `/home/byk/Code/opencode-lore-responses-projection-fix` to be research-only, with no edits, VCS operations, server use, network access, or database access. * 🟡 (19:33) User asked to inspect the current Responses projection stack through `ozrmvotw/583020fa` plus its empty child, tracing raw provider events from princi…