Function handleOpenRouterVideoCreate

src/openrouter-video.ts:1306–1668

(
  req: http.IncomingMessage,
  res: http.ServerResponse,
  raw: string,
  fixtures: Fixture[],
  journal: Journal,
  defaults: HandlerDefaults,
  setCorsHeaders: (res: http.ServerResponse) => void,
  jobs: OpenRouterVideoJobMap,
)

// ─── POST /api/v1/videos — submit ───────────────────────────────────────────

export async function handleOpenRouterVideoCreate(
  req: http.IncomingMessage,
  res: http.ServerResponse,
  raw: string,
  fixtures: Fixture[],
  journal: Journal,
  defaults: HandlerDefaults,
  setCorsHeaders: (res: http.ServerResponse) => void,
  jobs: OpenRouterVideoJobMap,
): Promise<void> {
  setCorsHeaders(res);
  const path = req.url ?? "/api/v1/videos";
  const method = req.method ?? "POST";

  let videoReq: OpenRouterVideoRequest;
  try {
    videoReq = JSON.parse(raw) as OpenRouterVideoRequest;
  } catch (parseErr) {
    const detail = parseErr instanceof Error ? parseErr.message : "unknown";
    journal.add({
      method,
      path,
      headers: flattenHeaders(req.headers),
      body: null,
      response: { status: 400, fixture: null },
    });
    writeErrorResponse(
      res,
      400,
      JSON.stringify({
        error: {
          message: `Malformed JSON: ${detail}`,
          type: "invalid_request_error",
          code: "invalid_json",
        },
      }),
    );
    return;
  }

  // Reject bodies that parsed but are not a JSON object (null, arrays,
  // numbers, strings) before touching any fields — mirrors fal's parseBody
  // guard so callers get a 400 instead of a raw TypeError 500.
  if (videoReq === null || typeof videoReq !== "object" || Array.isArray(videoReq)) {
    journal.add({
      method,
      path,
      headers: flattenHeaders(req.headers),
      body: null,
      response: { status: 400, fixture: null },
    });
    writeErrorResponse(
      res,
      400,
      JSON.stringify({
        error: {
          message: "Request body must be a JSON object",
          type: "invalid_request_error",