Function proxyOpenRouterVideoRecordContent

src/openrouter-video.ts:810–1133

* Live-proxy a content download for a completed record job — reachable under * proxyOnly (forever) and during the eager-capture window: the stored * upstream `unsigned_urls[index || 0]` is fetched with the same same-origin * Bearer-forwarding gate as the eager-capture path (headers gated by * `u

(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  job: OpenRouterVideoRecordJob;
  key: string;
  indexParam: string | null;
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
})

 * working through a long download list must not lose the job mid-way.
 */
async function proxyOpenRouterVideoRecordContent(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  job: OpenRouterVideoRecordJob;
  key: string;
  indexParam: string | null;
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
}): Promise<void> {
  const { req, res, job, key, indexParam, journal, defaults, jobs, method, path } = args;
  const logger = defaults.logger;

  const proxyError = (msg: string): void => {
    logger.error(`OpenRouter video content 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;
    journal.add({
      method,
      path,
      headers: flattenHeaders(req.headers),
      body: null,
      response: {
        status: 502,
        fixture: null,
        source: "proxy",
        ...strictOverrideField(defaults.strict, req.headers),
      },
    });
    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 BEFORE contacting the upstream
  // (and before forwarding the client's Bearer anywhere), mirroring the
  // record-job poll gate. The snapshot below is used for every later read
  // (same discipline as the poll path): the gate and its consumers must see
  // ONE config object even if the defaults are swapped mid-relay.
  const record = defaults.record;
  if (!record) {
    proxyError("record mode is no longer configured for an in-flight record job");
    return;
  }

  const urls = job.upstreamUnsignedUrls ?? [];
  const parsedIndex = indexParam === null ? 0 : Number(indexParam);
  const index = Number.isInteger(parsedIndex) && parsedIndex >= 0 ? parsedIndex : 0;
  if (indexParam !== null && index !== parsedIndex) {
    // Mirror the replay path's warn convention: a coerced index silently