openclaw/extensions/codex/src/app-server/delivery-no-reply-runtime-contract.test.ts

import fs from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { SessionManager } from "@mariozechner/pi-coding-agent";
import type { EmbeddedRunAttemptParams } from "openclaw/plugin-sdk/agent-harness";
import { afterEach, describe, expect, it } from "vitest";
import { isSilentReplyPayloadText } from "../../../../src/auto-reply/tokens.js";
import { DELIVERY_NO_REPLY_RUNTIME_CONTRACT } from "../../../../test/helpers/agents/delivery-no-reply-runtime-contract.js";
import { CodexAppServerEventProjector } from "./event-projector.js";
import { createCodexTestModel } from "./test-support.js";

const THREAD_ID = "thread-delivery-contract";
const TURN_ID = "turn-delivery-contract";
const tempDirs = new Set<string>();

type ProjectorNotification = Parameters<CodexAppServerEventProjector["handleNotification"]>[0];

async function createParams(): Promise<EmbeddedRunAttemptParams> {
  const tempDir = await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-codex-delivery-contract-"));
  tempDirs.add(tempDir);
  const sessionFile = path.join(tempDir, "session.jsonl");
  SessionManager.open(sessionFile);
  return {
    prompt: DELIVERY_NO_REPLY_RUNTIME_CONTRACT.prompt,
    sessionId: DELIVERY_NO_REPLY_RUNTIME_CONTRACT.sessionId,
    sessionKey: DELIVERY_NO_REPLY_RUNTIME_CONTRACT.sessionKey,
    sessionFile,
    workspaceDir: tempDir,
    runId: DELIVERY_NO_REPLY_RUNTIME_CONTRACT.runId,
    provider: "codex",
    modelId: "gpt-5.4-codex",
    model: createCodexTestModel("codex"),
    thinkLevel: "medium",
  } as EmbeddedRunAttemptParams;
}

function forCurrentTurn(
  method: ProjectorNotification["method"],
  params: Record<string, unknown>,
): ProjectorNotification {
  return {
    method,
    params: { threadId: THREAD_ID, turnId: TURN_ID, ...params },
  } as ProjectorNotification;
}

afterEach(async () => {
  for (const tempDir of tempDirs) {
    await fs.rm(tempDir, { recursive: true, force: true });
  }
  tempDirs.clear();
});

describe("Delivery/NO_REPLY runtime contract - Codex app-server adapter", () => {
  it.each([
    DELIVERY_NO_REPLY_RUNTIME_CONTRACT.silentText,
    `  ${DELIVERY_NO_REPLY_RUNTIME_CONTRACT.silentText}  `,
    DELIVERY_NO_REPLY_RUNTIME_CONTRACT.jsonSilentText,
  ])("preserves silent terminal text %s for shared delivery suppression", async (text) => {
    const projector = new CodexAppServerEventProjector(await createParams(), THREAD_ID, TURN_ID);
    await projector.handleNotification(
      forCurrentTurn("item/agentMessage/delta", {
        itemId: "msg-1",
        delta: text,
      }),
    );

    const result = projector.buildResult({
      didSendViaMessagingTool: false,
      messagingToolSentTexts: [],
      messagingToolSentMediaUrls: [],
      messagingToolSentTargets: [],
      toolMediaUrls: [],
      toolAudioAsVoice: false,
    });

    expect(result.assistantTexts).toEqual([text.trim()]);
    expect(isSilentReplyPayloadText(result.assistantTexts[0])).toBe(true);
  });
});