/** Runtime facade for fast abort handling used by reply dispatch. */

export { formatAbortReplyText, tryFastAbortFromMessage } from "./abort.js";

const DEFAULT_MAX_LABEL_LENGTH = 128;

const TIMEOUT_MS = 15_000;

/** Inputs for generating a short conversation label from the active model. */

export type ConversationLabelParams = {

userMessage: string;

prompt: string;

return result.errorMessage?.trim() || "unknown error";

}

/** Generates a bounded human-readable label for a session, or null on failure. */

export async function generateConversationLabel(

params: ConversationLabelParams,

): Promise<string | null> {

const controller = new AbortController();

const timeout = setTimeout(() => controller.abort(), TIMEOUT_MS);

try {

// Label generation should never block normal reply handling for long.

const result = await completeSimple(

completionModel,

{

/** Runtime facade for persisting inline directive state after parsing. */

export { persistInlineDirectives } from "./directive-handling.persist.js";

/** Runtime media-understanding dependencies used by ACP reply dispatch. */

export { applyMediaUnderstanding } from "../../media-understanding/apply.js";

export { MediaAttachmentCache } from "../../media-understanding/attachments.js";

export { normalizeAttachments } from "../../media-understanding/attachments.normalize.js";

/** Runtime facade for reading persisted ACP session metadata. */

export { readAcpSessionEntry } from "../../acp/runtime/session-meta.js";

import type { ReplyPayload } from "../reply-payload.js";

import type { MsgContext } from "../templating.js";

/** Reply resolver signature used by dispatchers and tests for dependency injection. */

export type GetReplyFromConfig = (

ctx: MsgContext,

opts?: GetReplyOptions,

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

/** Extracts a simple group/channel id from stable group-like source ids. */

export function extractSimpleExplicitGroupId(raw: string | undefined | null): string | undefined {

const trimmed = normalizeOptionalString(raw) ?? "";

if (!trimmed) {

normalizeOptionalString,

} from "@openclaw/normalization-core/string-coerce";

/** Parsed `/plugins` command variants accepted by auto-reply command handling. */

export type PluginsCommand =

| { action: "list" }

| { action: "inspect"; name?: string }

| { action: "disable"; name: string }

| { action: "error"; message: string };

/** Parses a `/plugin` or `/plugins` command into a closed command action. */

export function parsePluginsCommand(raw: string): PluginsCommand | null {

const match = raw.match(/^\/plugins?(?:\s+(.*))?$/i);

if (!match) {

type DispatchReplyContext = MsgContext | FinalizedMsgContext;

type DispatchReplyOptions = Omit<GetReplyOptions, "onBlockReply">;

/** Buffered block dispatcher entry point used by provider reply flows. */

export type DispatchReplyWithBufferedBlockDispatcher = (params: {

ctx: DispatchReplyContext;

cfg: OpenClawConfig;

replyResolver?: GetReplyFromConfig;

}) => Promise<DispatchFromConfigResult>;

/** Plain dispatcher entry point used when block buffering is not needed. */

export type DispatchReplyWithDispatcher = (params: {

ctx: DispatchReplyContext;

cfg: OpenClawConfig;

import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/string-coerce";

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

/** Provider request error classes that get a specialized user-facing reply. */

export type ProviderRequestErrorCode = "provider_conversation_state_error";

/** Structured provider error classification for reply failure handling. */

export type ProviderRequestErrorClassification = {

code: ProviderRequestErrorCode;

userMessage: string;

technicalMessage: string;

};

/** User-facing copy for provider-side broken conversation state. */

export const PROVIDER_CONVERSATION_STATE_ERROR_USER_MESSAGE =

"⚠️ The model provider rejected the conversation state. Please try again, or use /new to start a fresh session.";

/** Classifies provider request failures that are actionable for users. */

export function classifyProviderRequestError(

err: unknown,

): ProviderRequestErrorClassification | undefined {

return undefined;

}

/** Detects provider errors that indicate invalid conversation/tool turn state. */

export function isProviderConversationStateErrorMessage(message: string): boolean {

const lower = normalizeLowercaseStringOrEmpty(message);

return (