type SessionEntry,

updateSessionStore,

} from "../../config/sessions.js";

import { resolveSilentReplyPolicy } from "../../config/silent-reply.js";

import type { OpenClawConfig } from "../../config/types.openclaw.js";

import { logVerbose } from "../../globals.js";

import { emitAgentEvent, onAgentEvent, registerAgentRunContext } from "../../infra/agent-events.js";

import { formatErrorMessage } from "../../infra/errors.js";

text: string;

sessionCtx: TemplateContext;

isGenericRunnerFailure: boolean;

cfg?: OpenClawConfig;

}): string {

if (!isNonDirectConversationContext(params.sessionCtx)) {

return params.text;

}

if (!params.isGenericRunnerFailure && !params.text.includes(AGENT_FAILED_BEFORE_REPLY_TEXT)) {

return params.text;

}

// Honor the documented `agents.defaults.silentReply` /

// `surfaces.<id>.silentReply` policy here so failure-fallback respects the

// same operator-visible knob that `route-reply.ts` already uses for

// `NO_REPLY`-style silent payloads. Defaults preserve the existing

// "groups/channels stay quiet on generic runner failure" behavior; opting

// into `silentReply.group: "disallow"` (or the per-surface override) lets

// the operator surface the failure copy in the chat instead.

// See docs/concepts/messages.md ("Silent replies") for the policy contract.

const silentPolicy = resolveSilentReplyPolicy({

cfg: params.cfg,

sessionKey: params.sessionCtx.SessionKey,

surface: params.sessionCtx.Surface,

conversationType: "group",

});

if (silentPolicy === "disallow") {

return params.text;

}

return SILENT_REPLY_TOKEN;

}

err: unknown;

sessionCtx: TemplateContext;

resolvedVerboseLevel: VerboseLevel | undefined;

cfg?: OpenClawConfig;

}): ReplyPayload | undefined {

const message = formatErrorMessage(params.err);

const isFallbackSummary = isFallbackSummaryError(params.err);

text: BILLING_ERROR_USER_MESSAGE,

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: false,

cfg: params.cfg,

}),

});

}

text: buildRateLimitCooldownMessage(params.err),

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: false,

cfg: params.cfg,

}),

});

}

text: rateLimitOrOverloadedCopy,

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: false,

cfg: params.cfg,

}),

});

}

text: externalRunFailureReply.text,

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: false,

cfg: params.cfg,

}),

});

}

text: switchErrorText,

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: !shouldSurfaceToControlUi,

cfg: params.followupRun.run.config,

}),

}),

};

text: fallbackText,

sessionCtx: params.sessionCtx,

isGenericRunnerFailure: externalRunFailureReply?.isGenericRunnerFailure ?? false,

cfg: params.followupRun.run.config,

});

params.replyOperation?.fail("run_failed", err);