OmniRoute/tests/unit/codex-responses-passthrough-strip-3317.test.ts

import test from "node:test";
import assert from "node:assert/strict";
import fs from "node:fs";
import os from "node:os";
import path from "node:path";

const TEST_DATA_DIR = fs.mkdtempSync(path.join(os.tmpdir(), "omniroute-codex-3317-"));
process.env.DATA_DIR = TEST_DATA_DIR;

const core = await import("../../src/lib/db/core.ts");
const { CodexExecutor } = await import("../../open-sse/executors/codex.ts");

// #3317: a /v1/responses request against the built-in codex/ provider does an
// openai-responses -> openai-responses passthrough. The Codex upstream rejects
// client-only fields with 400 "Unsupported parameter": prompt_cache_retention,
// safety_identifier, user. The chat-completions path strips them, but the
// native passthrough (transformRequest returns body early) did not.
test("codex native responses passthrough strips client-only params (#3317)", async () => {
  const executor = new CodexExecutor();
  const body = {
    _nativeCodexPassthrough: true,
    model: "gpt-5.5",
    input: [{ role: "user", content: [{ type: "input_text", text: "reply ok" }] }],
    prompt_cache_retention: "24h",
    safety_identifier: "droid-user-123",
    user: "user-abc",
    max_output_tokens: 16,
  };

  const result = (await executor.transformRequest("gpt-5.5", body, false, {} as never)) as Record<
    string,
    unknown
  >;

  assert.equal(result.prompt_cache_retention, undefined, "prompt_cache_retention must be stripped");
  assert.equal(result.safety_identifier, undefined, "safety_identifier must be stripped");
  assert.equal(result.user, undefined, "user must be stripped");
  // The real request payload must survive the strip.
  assert.ok(Array.isArray(result.input), "input array preserved");
});

test("codex native responses passthrough normalizes additional_tools items", async () => {
  const executor = new CodexExecutor();
  const messageContent = [{ type: "input_text", text: "run the terminal tool" }];
  const tools = [{ type: "function", name: "terminal", parameters: { type: "object" } }];
  const body = {
    _nativeCodexPassthrough: true,
    model: "gpt-5.5",
    input: [
      {
        type: "additional_tools",
        role: "developer",
        content: [{ type: "input_text", text: "unsupported wrapper content" }],
        tools,
      },
      { type: "message", role: "user", content: messageContent },
    ],
  };

  const result = (await executor.transformRequest("gpt-5.5", body, true, {} as never)) as {
    input: Array<Record<string, unknown>>;
  };

  assert.deepEqual(result.input[0], { type: "additional_tools", role: "developer", tools });
  assert.deepEqual(result.input[1], { type: "message", role: "user", content: messageContent });
});

test.after(() => {
  try {
    core.resetDbInstance?.();
  } catch {
    /* ignore */
  }
  try {
    fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
  } catch {
    /* ignore */
  }
});