// Stateful progress-draft compositor for channel streaming previews.

// It merges tool, reasoning, and commentary updates until the final reply replaces them.

import { formatReasoningMessage } from "../agents/embedded-agent-utils.js";

import { findCodeRegions, isInsideCode } from "../shared/text/code-regions.js";

import { stripInlineDirectiveTagsForDelivery } from "../utils/directive-tags.js";

// Small progress-draft line helpers shared by streaming renderers.

import type { ChannelProgressDraftLine } from "./streaming.js";

/** Progress draft state can mix legacy plain text lines with keyed structured lines. */

// Read-only channel account inspection facade for setup and status diagnostics.

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

import { getBundledChannelAccountInspector } from "./plugins/bundled.js";

import { getLoadedChannelPlugin } from "./plugins/registry.js";

// Cached lookup view for active channel plugin registry entries and aliases.

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

import type {

ActivePluginChannelRegistration,

ActivePluginChannelRegistry,

} from "../plugins/channel-registry-state.types.js";

import { getActivePluginChannelRegistrySnapshotFromState } from "../plugins/runtime-channel-state.js";

// Cached lookup view for the active channel plugin registry. The cache is keyed

// by registry object/version so request-time callers avoid rebuilding alias maps.

export type RegisteredChannelPluginEntry = ActivePluginChannelRegistration & {

plugin: ActivePluginChannelRegistration["plugin"] & {

id?: string | null;

key: string | undefined,

entry: RegisteredChannelPluginEntry,

): void {

// First writer wins so canonical ids keep priority over later aliases.

if (key && !map.has(key)) {

map.set(key, entry);

}

// Channel id normalization through the active plugin registry.

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

import type { ChannelId } from "./plugins/channel-id.types.js";

import { findRegisteredChannelPluginEntry } from "./registry-lookup.js";

// Normalizes user/config channel identifiers through the active plugin registry

// so aliases resolve to canonical channel ids.

/** Normalizes user/config channel identifiers so aliases resolve to canonical channel ids. */

export function normalizeAnyChannelId(raw?: string | null): ChannelId | null {

const key = normalizeOptionalLowercaseString(raw);

if (!key) {

// Public channel registry facade for channel ids, metadata, and setup copy.

import {

normalizeOptionalLowercaseString,

normalizeOptionalString,

// Reply-prefix context helpers shared by channel reply dispatchers.

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

import { resolveAgentIdentity, resolveEffectiveMessagesConfig } from "../agents/identity.js";

import type { GetReplyOptions } from "../auto-reply/get-reply-options.types.js";

// Route projection helpers between sessions, delivery context, and channel routes.

import type { SessionEntry } from "../config/sessions/types.js";

import type {

ConversationRef,

// Channel run-state tracker used to publish busy/activity status.

type RunStateStatusPatch = {

busy?: boolean;

activeRuns?: number;

// Sender display-label helpers shared by channel ingress and audit surfaces.

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

// Sender display helpers shared by channel ingress and audit surfaces. The

// resolved label keeps a human-readable name plus stable id when both differ.

export type SenderLabelParams = {

name?: string;

username?: string;