Function callCodexImage

codex_image/codex_image.ts:141–331

(
  prompt: string,
  referenceImage?: { buffer: Buffer; mimeType: string },
  updateStatus?: StatusUpdater,
  deadlineAt: number = Date.now() + CODEX_MAX_WAIT_MS,
)

      `缺少鉴权，请先使用 ${mainPrefix}cximg token 你的codex access token（通常在 .codex/auth.json） 保存 Token`,
    );
  }

  const content = referenceImage
    ? [
        { type: "input_text", text: prompt },
        {
          type: "input_image",
          image_url: `data:${referenceImage.mimeType};base64,${referenceImage.buffer.toString("base64")}`,
        },
      ]
    : prompt;

  const payload = {
    model: CODEX_MODEL,
    instructions: "You are a helpful assistant. Use tools when available.",
    input: [
      {
        role: "user",
        content,
      },
    ],
    store: false,
    tools: [{ type: "image_generation" }],
    reasoning: { effort: "low" },
    include: [],
    tool_choice: "auto",
    parallel_tool_calls: true,
    prompt_cache_key: null,
    stream: true,
  };

  const headers = {
    Authorization: `Bearer ${token}`,
    "Content-Type": "application/json",
  };

  const readStreamResult = async (): Promise<CodexResponseResult> => {
    const response = await axios.post(CODEX_URL, payload, {
      responseType: "stream",
      timeout: Math.max(1000, deadlineAt - Date.now()),
      headers,
    });

    let buffer = "";
    let imageBase64: string | null = null;
    let revisedPrompt: string | null = null;
    let status: string | null = null;
    let responseId: string | null = null;

    for await (const chunk of response.data) {
      buffer += chunk.toString("utf8");

      let delimiterIndex = buffer.indexOf("\n\n");
      while (delimiterIndex !== -1) {
        const rawEvent = buffer.slice(0, delimiterIndex);
        buffer = buffer.slice(delimiterIndex + 2);

        const dataLines = rawEvent