it("does not treat a user prompt containing the interrupted marker as terminal", async () => {

const harness = createStartedThreadHarness();

const run = runCodexAppServerAttempt(

createParams(path.join(tempDir, "session.jsonl"), path.join(tempDir, "workspace")),

{ turnTerminalIdleTimeoutMs: 60_000 },

const markerPrompt =

"<turn_aborted>\nThe user interrupted the previous turn on purpose. Any running unified exec processes may still be running in the background. If any tools/commands were aborted, they may have partially executed.\n</turn_aborted>";

const params = createParams(

path.join(tempDir, "session.jsonl"),

path.join(tempDir, "workspace"),

);

params.prompt = markerPrompt;

const run = runCodexAppServerAttempt(params, { turnTerminalIdleTimeoutMs: 60_000 });

let resolved = false;

void run.then(() => {

resolved = true;

content: [

{

type: "input_text",

text: "<turn_aborted>\nWhat does this marker mean?\n</turn_aborted>",

text: markerPrompt,

},

],

},

// See openclaw/openclaw#67996.

const isTurnCompletion = notification.method === "turn/completed" && isCurrentTurnNotification;

const isTurnAbortMarker =

isCurrentTurnNotification && isCodexTurnAbortMarkerNotification(notification);

isCurrentTurnNotification &&

isCodexTurnAbortMarkerNotification(notification, { currentPromptText: promptBuild.prompt });

const isTurnTerminal = isTurnCompletion || isTurnAbortMarker;

try {

await projector.handleNotification(notification);

const CODEX_INTERRUPTED_DEVELOPER_GUIDANCE =

"The previous turn was interrupted on purpose. Any running unified exec processes may still be running in the background. If any tools/commands were aborted, they may have partially executed.";

function isCodexTurnAbortMarkerNotification(notification: CodexServerNotification): boolean {

function isCodexTurnAbortMarkerNotification(

notification: CodexServerNotification,

options: { currentPromptText?: string } = {},

): boolean {

if (notification.method !== "rawResponseItem/completed" || !isJsonObject(notification.params)) {

return false;

}

return false;

}

const text = extractRawResponseItemText(item).trim();

if (role === "user" && text === options.currentPromptText?.trim()) {

return false;

}

const markerBody = readCodexTurnAbortMarkerBody(text);

return (

markerBody === CODEX_INTERRUPTED_USER_GUIDANCE ||