isTransientHttpError,

} from "../../agents/pi-embedded-helpers.js";

import { sanitizeUserFacingText } from "../../agents/pi-embedded-helpers/sanitize-user-facing-text.js";

import { isLikelyExecutionAckPrompt } from "../../agents/pi-embedded-runner/run/incomplete-turn.js";

import { runEmbeddedPiAgent } from "../../agents/pi-embedded.js";

import { buildAgentRuntimeOutcomePlan } from "../../agents/runtime-plan/build.js";

import {

// selection keeps conflicting with fallback model choices.

// See: https://github.com/openclaw/openclaw/issues/58348

export const MAX_LIVE_SWITCH_RETRIES = 2;

const GPT_CHAT_BREVITY_ACK_MAX_CHARS = 420;

const GPT_CHAT_BREVITY_ACK_MAX_SENTENCES = 3;

const GPT_CHAT_BREVITY_SOFT_MAX_CHARS = 900;

const GPT_CHAT_BREVITY_SOFT_MAX_SENTENCES = 6;

function readApprovalScopeValue(value: unknown): "turn" | "session" | undefined {

return value === "turn" || value === "session" ? value : undefined;

);

}

function shouldApplyOpenAIGptChatGuard(params: { provider?: string; model?: string }): boolean {

if (params.provider !== "openai" && params.provider !== "openai-codex") {

return false;

}

return /^gpt-5(?:[.-]|$)/i.test(params.model ?? "");

}

function countChatReplySentences(text: string): number {

return text

.trim()

.split(/(?<=[.!?])\s+/u)

.map((part) => part.trim())

.filter(Boolean).length;

}

function scoreChattyFinalReplyText(text: string): number {

const trimmed = text.trim();

if (!trimmed) {

return 0;

}

let score = 0;

const sentenceCount = countChatReplySentences(trimmed);

if (trimmed.length > 900) {

score += 1;

}

if (trimmed.length > 1_500) {

score += 1;

}

if (sentenceCount > 6) {

score += 1;

}

if (sentenceCount > 10) {

score += 1;

}

if (trimmed.split(/\n{2,}/u).filter(Boolean).length >= 3) {

score += 1;

}

if (

/\b(?:in summary|to summarize|here(?:'s| is) what|what changed|what I verified)\b/i.test(

trimmed,

)

) {

score += 1;

}

return score;

}

function shortenChattyFinalReplyText(

text: string,

params: { maxChars: number; maxSentences: number },

): string {

const trimmed = text.trim();

if (!trimmed) {

return trimmed;

}

const sentences = trimmed

.split(/(?<=[.!?])\s+/u)

.map((part) => part.trim())

.filter(Boolean);

let shortened = sentences.slice(0, params.maxSentences).join(" ");

if (!shortened) {

shortened = trimmed.slice(0, params.maxChars).trimEnd();

}

if (shortened.length > params.maxChars) {

shortened = shortened.slice(0, params.maxChars).trimEnd();

}

if (shortened.length >= trimmed.length) {

return trimmed;

}

return shortened.replace(/[.,;:!?-]*$/u, "").trimEnd() + "...";

}

function applyOpenAIGptChatReplyGuard(params: {

provider?: string;

model?: string;

commandBody: string;

isHeartbeat: boolean;

payloads?: ReplyPayload[];

}): void {

if (

params.isHeartbeat ||

!shouldApplyOpenAIGptChatGuard({

provider: params.provider,

model: params.model,

}) ||

!params.payloads?.length

) {

return;

}

const trimmedCommand = params.commandBody.trim();

const isAckTurn = isLikelyExecutionAckPrompt(trimmedCommand);

const allowSoftCap =

!isAckTurn &&

trimmedCommand.length > 0 &&

trimmedCommand.length <= 120 &&

!/\b(?:detail|detailed|depth|deep dive|explain|compare|walk me through|why|how)\b/i.test(

trimmedCommand,

);

for (const payload of params.payloads) {

const text = normalizeOptionalString(payload.text);

if (

!text ||

payload.isError ||

payload.isReasoning ||

payload.mediaUrl ||

(payload.mediaUrls?.length ?? 0) > 0 ||

payload.interactive ||

text.includes("```")

) {

continue;

}

if (isAckTurn) {

payload.text = shortenChattyFinalReplyText(text, {

maxChars: GPT_CHAT_BREVITY_ACK_MAX_CHARS,

maxSentences: GPT_CHAT_BREVITY_ACK_MAX_SENTENCES,

});

continue;

}

if (allowSoftCap && scoreChattyFinalReplyText(text) >= 4) {

payload.text = shortenChattyFinalReplyText(text, {

maxChars: GPT_CHAT_BREVITY_SOFT_MAX_CHARS,

maxSentences: GPT_CHAT_BREVITY_SOFT_MAX_SENTENCES,

});

}

}

}

function buildRestartLifecycleReplyText(): string {

return "⚠️ Gateway is restarting. Please wait a few seconds and try again.";

}

];

}

}

applyOpenAIGptChatReplyGuard({

provider: fallbackProvider,

model: fallbackModel,

commandBody: params.commandBody,

isHeartbeat: params.isHeartbeat,

payloads: runResult.payloads,

});

}

return {