fix: CR R2 fixes — tool call IDs, journal gaps, MIME fallback, reset parity

- ws-gemini-live: pre-compute tool call IDs so wire message and
  conversation history use the same values (was generating twice)
- ws-gemini-live: push audio response to conversation history for
  multi-turn context continuity
- ws-gemini-live: add journal entry for strict-mode WS rejection
- recorder: change fallback MIME from "audio/mp3" to "audio/mpeg"
- recorder: remove stale cast and comment (types already widened)
- fal-audio: add journal entries for proxied requests
- fal-audio: remove unnecessary RecordProviderKey casts
- llmock: add falJobs.clear() to reset() for parity with HTTP reset

Author: jpr5

src/fal-audio.ts

@@ -1,12 +1,6 @@
 import type http from "node:http";
 import crypto from "node:crypto";
-import type {
-  AudioResponse,
-  ChatCompletionRequest,
-  Fixture,
-  HandlerDefaults,
-  RecordProviderKey,
-} from "./types.js";
+import type { AudioResponse, ChatCompletionRequest, Fixture, HandlerDefaults } from "./types.js";
 import { isAudioResponse, isErrorResponse, FORMAT_TO_CONTENT_TYPE, getTestId } from "./helpers.js";
 import { matchFixture } from "./router.js";
 import { proxyAndRecord } from "./recorder.js";
@@ -257,13 +251,22 @@ async function handleQueueSubmit(
         req,
         res,
         syntheticReq,
-        "fal" as RecordProviderKey,
+        "fal",
         pathname,
         fixtures,
         defaults,
         body,
       );
-      if (proxied) return;
+      if (proxied) {
+        journal.add({
+          method: req.method ?? "POST",
+          path: pathname,
+          headers: {},
+          body: syntheticReq,
+          response: { status: res.statusCode ?? 200, fixture: null },
+        });
+        return;
+      }
     }
 
     const strictStatus = defaults.strict ? 503 : 404;
@@ -529,13 +532,22 @@ async function handleSyncRun(
         req,
         res,
         syntheticReq,
-        "fal" as RecordProviderKey,
+        "fal",
         pathname,
         fixtures,
         defaults,
         body,
       );
-      if (proxied) return;
+      if (proxied) {
+        journal.add({
+          method: req.method ?? "POST",
+          path: pathname,
+          headers: {},
+          body: syntheticReq,
+          response: { status: res.statusCode ?? 200, fixture: null },
+        });
+        return;
+      }
     }
 
     const strictStatus = defaults.strict ? 503 : 404;

src/llmock.ts

@@ -27,6 +27,7 @@ import { Journal } from "./journal.js";
 import type { SearchFixture, SearchResult } from "./search.js";
 import type { RerankFixture, RerankResult } from "./rerank.js";
 import type { ModerationFixture, ModerationResult } from "./moderation.js";
+import { falJobs } from "./fal-audio.js";
 
 export class LLMock {
   private fixtures: Fixture[] = [];
@@ -307,6 +308,7 @@ export class LLMock {
     this.searchFixtures.length = 0;
     this.rerankFixtures.length = 0;
     this.moderationFixtures.length = 0;
+    falJobs.clear();
     if (this.serverInstance) {
       this.serverInstance.journal.clear();
       this.serverInstance.videoStates.clear();

src/recorder.ts

@@ -173,7 +173,7 @@ export async function proxyAndRecord(
       fixtureResponse = {
         audio: {
           b64Json: collapsed.audioB64,
-          contentType: collapsed.audioMimeType ?? "audio/mp3",
+          contentType: collapsed.audioMimeType ?? "audio/mpeg",
         },
       };
     } else if (
@@ -235,11 +235,8 @@ export async function proxyAndRecord(
   const fixtureMatch = buildFixtureMatch(matchRequest);
 
   // Build and save the fixture
-  // Cast: EndpointType here is broader than FixtureMatch.endpoint to cover
-  // audio-gen / fal-audio; the recorded JSON is correct, FixtureMatch will
-  // be widened in a follow-up types.ts change.
   const fixture: Fixture = {
-    match: fixtureMatch as Fixture["match"],
+    match: fixtureMatch,
     response: fixtureResponse,
   };
 

src/ws-gemini-live.ts

@@ -345,6 +345,13 @@ async function processMessage(
   if (!fixture) {
     if (defaults.strict) {
       defaults.logger.warn(`STRICT: No fixture matched for WebSocket message`);
+      journal.add({
+        method: "WS",
+        path,
+        headers: {},
+        body: completionReq,
+        response: { status: 404, fixture: null },
+      });
       ws.close(1008, "Strict mode: no fixture matched");
       return;
     }
@@ -420,6 +427,11 @@ async function processMessage(
         },
       }),
     );
+
+    session.conversationHistory.push({
+      role: "assistant",
+      content: "[audio]",
+    });
     return;
   }
 
@@ -488,6 +500,12 @@ async function processMessage(
       return;
     }
 
+    // Pre-compute tool calls with stable IDs so wire message and history match
+    const resolvedToolCalls = response.toolCalls.map((tc) => ({
+      ...tc,
+      resolvedId: tc.id ?? generateToolCallId(),
+    }));
+
     // Send tool calls
     if (!ws.isClosed) {
       if (latency > 0) await delay(latency, interruption?.signal);
@@ -499,7 +517,7 @@ async function processMessage(
         return;
       }
 
-      const functionCalls = response.toolCalls.map((tc) => {
+      const functionCalls = resolvedToolCalls.map((tc) => {
         let argsObj: Record<string, unknown>;
         try {
           argsObj = JSON.parse(tc.arguments || "{}") as Record<string, unknown>;
@@ -512,7 +530,7 @@ async function processMessage(
         return {
           name: tc.name,
           args: argsObj,
-          id: tc.id ?? generateToolCallId(),
+          id: tc.resolvedId,
         };
       });
 
@@ -539,12 +557,12 @@ async function processMessage(
       );
     }
 
-    // Add to conversation history
+    // Add to conversation history using the same resolved IDs from the wire message
     session.conversationHistory.push({
       role: "assistant",
       content: content || null,
-      tool_calls: response.toolCalls.map((tc) => ({
-        id: tc.id ?? generateToolCallId(),
+      tool_calls: resolvedToolCalls.map((tc) => ({
+        id: tc.resolvedId,
         type: "function" as const,
         function: {
           name: tc.name,