Function proxyOpenRouterVideoSubmit

src/openrouter-video.ts:1684–1902

* Proxy an unmatched video submit to the configured OpenRouter upstream and * answer the client with a mock-rewritten envelope: a fresh aimock jobId and * a polling_url pointing back at the mock (testId embedded). The upstream * lifecycle is then driven interactively by the client's own polls — u

(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  raw: string;
  syntheticReq: ChatCompletionRequest;
  record: RecordConfig;
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
})

 * the caller falls through to its 404 branch (fal convention).
 */
async function proxyOpenRouterVideoSubmit(args: {
  req: http.IncomingMessage;
  res: http.ServerResponse;
  raw: string;
  syntheticReq: ChatCompletionRequest;
  record: RecordConfig;
  journal: Journal;
  defaults: HandlerDefaults;
  jobs: OpenRouterVideoJobMap;
  method: string;
  path: string;
}): Promise<"handled" | "no_upstream"> {
  const { req, res, raw, syntheticReq, record, journal, defaults, jobs, method, path } = args;

  const upstreamBase = record.providers.openrouter;
  if (!upstreamBase) {
    defaults.logger.warn(`No upstream URL configured for provider "openrouter" — cannot proxy`);
    return "no_upstream";
  }

  const proxyError = (msg: string): "handled" => {
    defaults.logger.error(`OpenRouter video submit 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 "handled";
    journal.add({
      method,
      path,
      headers: flattenHeaders(req.headers),
      body: syntheticReq,
      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" },
      }),
    );
    return "handled";
  };

  let submitUrl: URL;
  let upstreamOrigin: string;
  try {
    submitUrl = resolveUpstreamUrl(upstreamBase, OPENROUTER_VIDEOS_PATH);
    upstreamOrigin = new URL(upstreamBase).origin;
  } catch (err) {
    const msg = err instanceof Error ? err.message : String(err);
    return proxyError(`Invalid upstream URL: ${upstreamBase} (${msg})`);
  }

  defaults.logger.warn(