Function proxyOpenRouterVideoRecordPoll

src/openrouter-video.ts:1943–2273

* Proxy a status poll for a record-mode job 1:1 to the upstream and relay * the result with mock-rewritten identifiers (rewriteRecordPollBody: id, * polling_url, unsigned_urls; everything else verbatim). When the upstream * reports `completed`, the rewritten body is relayed IMMEDIATELY and the *

(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  job: OpenRouterVideoRecordJob;
  key: string;
  testId: string;
  fixtures: Fixture[];
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
})

 * refreshes its TTL so a long generation cannot be evicted mid-recording.
 */
async function proxyOpenRouterVideoRecordPoll(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  job: OpenRouterVideoRecordJob;
  key: string;
  testId: string;
  fixtures: Fixture[];
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
}): Promise<void> {
  const { req, res, job, key, testId, fixtures, journal, defaults, jobs, method, path } = args;
  const logger = defaults.logger;

  const journalProxy = (status: number): void => {
    journal.add({
      method,
      path,
      headers: flattenHeaders(req.headers),
      body: null,
      response: {
        status,
        fixture: null,
        source: "proxy",
        ...strictOverrideField(defaults.strict, req.headers),
      },
    });
  };

  const proxyError = (msg: string): void => {
    logger.error(`OpenRouter video poll proxy failed: ${msg}`);
    // Guard BEFORE journaling (file convention): a disconnected client gets
    // neither a write nor a journal entry.
    if (res.destroyed || res.writableEnded) return;
    journalProxy(502);
    writeErrorResponse(
      res,
      502,
      JSON.stringify({
        error: { message: `Proxy to upstream failed: ${msg}`, type: "proxy_error" },
      }),
    );
  };

  // Recording can be disabled mid-flight (LLMock.disableRecording) — an
  // orphaned record job must fail loudly on ANY poll, before contacting the
  // upstream, rather than silently relaying non-terminal statuses and only
  // erroring at the terminal poll.
  const record = defaults.record;
  if (!record) {
    proxyError("record mode is no longer configured for an in-flight record job");
    return;
  }

  let fetched: { status: number; contentType: string | null; text: string };
  try {