function assertExpectedDiagnostics(surfaceMode, errorMessages) {

const expectedErrorMessages = new Set([

'channel "kitchen-sink-channel-probe" registration missing required config helpers',

"cli registration missing explicit commands metadata",

"only bundled plugins can register Codex app-server extension factories",

"only bundled plugins can register agent tool result middleware",

EOF

openclaw_live_codex_harness_append_build_extension codex

# The release package image intentionally excludes externalized plugins such as

# Codex. This lane must rebuild the live image so the plugin-owned harness is

# present under the bundled plugin runtime directory.

OPENCLAW_SKIP_DOCKER_BUILD=0

OPENCLAW_LIVE_DOCKER_REPO_ROOT="$ROOT_DIR" "$TRUSTED_HARNESS_DIR/scripts/test-live-build-docker.sh"

echo "==> Run Codex harness live test in Docker"

const controller = new AbortController();

const abortReason = new Error("live anthropic stream abort");

let requestBody = "";

let requestClosed = false;

let resolveRequestClosed: (() => void) | undefined;

const requestClosedPromise = new Promise<void>((resolve) => {

resolveRequestClosed = resolve;

});

const server = http.createServer((request, response) => {

request.on("close", () => {

requestClosed = true;

resolveRequestClosed?.();

});

void readRequestBody(request).then((body) => {

requestBody = body;

response.writeHead(200, {

if (result === timedOut) {

throw new Error("Anthropic live SSE stream did not abort within 1000ms");

}

await Promise.race([requestClosedPromise, delay(1_000, undefined)]);

expect(result.stopReason).toBe("aborted");

expect(result.errorMessage).toBe("live anthropic stream abort");

expect(requestClosed).toBe(true);

expect(JSON.parse(requestBody)).toMatchObject({

model: "claude-sonnet-4-6",

stream: true,