mirror of
https://github.com/openclaw/openclaw.git
synced 2026-06-26 22:29:35 +00:00
c67dc59b02
* fix(reply): deliver final reply when queued follow-up claims session; scope dedupe to routed thread Two core bugs caused composed replies to be silently dropped (no delivery, no error) when a second message arrived in the same thread mid-run: 1. dispatch-from-config: ensureDispatchReplyOperation only kept the dispatch-owned operation authoritative while it had no result. Once runReplyAgent completed the operation to drain queued follow-ups, a second same-thread inbound could claim the session and the first final reply would try to re-acquire the lane instead of finishing delivery, deadlocking behind the queued work. Keep the dispatch-owned operation authoritative through final delivery. 2. reply-payloads-dedupe: messaging-tool reply dedupe compared only the channel target, not the routed thread, so a send in one thread could suppress a later reply in a different thread. Thread the routed thread id through buildReplyPayloads + follow-up delivery and only fall back to channel-only matching for providers without a thread-aware suppression matcher when neither side carries thread evidence. Adds regression tests; existing Telegram topic-suppression behavior is preserved by gating the thread guard to providers lacking a plugin matcher. * fix(reply): preserve threaded message delivery evidence * fix(reply): dedupe final payloads by delivery route * fix(slack): preserve native send thread evidence * fix(reply): preserve explicit reply thread evidence * fix(reply): align explicit reply route dedupe * fix(reply): preserve delivery lane through final dispatch * fix(mattermost): preserve threaded tool send routes * chore(plugin-sdk): refresh API baseline * fix(reply): align final delivery route dedupe * fix(reply): gate followups on final delivery * fix(reply): keep send receipts private * fix(reply): infer implicit message provider * fix(reply): align routed threading policy * fix(reply): preserve queued delivery context * fix(reply): hydrate queued system event routes * fix(reply): hydrate queued execution routes * fix(reply): scope final delivery barriers * fix(slack): preserve DM target aliases * fix(reply): mirror resolved source thread routes * fix(mattermost): retain delayed delivery barrier * fix(codex): separate message routing from tool policy * fix(reply): consume normalized Slack DM targets once * fix(slack): remove stale target alias * style(reply): satisfy changed lint gates * fix(mattermost): preserve explicit reply targets * test: align Slack reply branch checks * fix(reply): persist overflow summaries to admitted session --------- Co-authored-by: Peter Steinberger <steipete@gmail.com>
68 lines
2.6 KiB
TypeScript
68 lines
2.6 KiB
TypeScript
// Shared agent/reply runtime helpers for channel plugins. Keep channel plugins
|
|
// off direct src/auto-reply imports by routing common reply primitives here.
|
|
|
|
export {
|
|
chunkMarkdownText,
|
|
chunkMarkdownTextWithMode,
|
|
chunkText,
|
|
chunkTextWithMode,
|
|
resolveChunkMode,
|
|
resolveTextChunkLimit,
|
|
} from "../auto-reply/chunk.js";
|
|
export type { ChunkMode } from "../auto-reply/chunk.js";
|
|
export {
|
|
dispatchInboundMessage,
|
|
dispatchInboundMessageWithBufferedDispatcher,
|
|
dispatchInboundMessageWithDispatcher,
|
|
settleReplyDispatcher,
|
|
} from "../auto-reply/dispatch.js";
|
|
export {
|
|
normalizeGroupActivation,
|
|
parseActivationCommand,
|
|
} from "../auto-reply/group-activation.js";
|
|
export {
|
|
HEARTBEAT_PROMPT,
|
|
DEFAULT_HEARTBEAT_ACK_MAX_CHARS,
|
|
resolveHeartbeatPrompt,
|
|
stripHeartbeatToken,
|
|
} from "../auto-reply/heartbeat.js";
|
|
export { resolveHeartbeatReplyPayload } from "../auto-reply/heartbeat-reply-payload.js";
|
|
export { getReplyFromConfig } from "../auto-reply/reply/get-reply.js";
|
|
export { HEARTBEAT_TOKEN, isSilentReplyText, SILENT_REPLY_TOKEN } from "../auto-reply/tokens.js";
|
|
export { isAbortRequestText } from "../auto-reply/reply/abort.js";
|
|
export { isBtwRequestText } from "../auto-reply/reply/btw-command.js";
|
|
export { resetInboundDedupe } from "../auto-reply/reply/inbound-dedupe.js";
|
|
export { finalizeInboundContext } from "../auto-reply/reply/inbound-context.js";
|
|
export {
|
|
createInboundDebouncer,
|
|
resolveInboundDebounceMs,
|
|
} from "../auto-reply/inbound-debounce.js";
|
|
export {
|
|
dispatchReplyWithBufferedBlockDispatcher,
|
|
dispatchReplyWithDispatcher,
|
|
} from "../auto-reply/reply/provider-dispatcher.js";
|
|
export {
|
|
createReplyDispatcher,
|
|
createReplyDispatcherWithTyping,
|
|
} from "../auto-reply/reply/reply-dispatcher.js";
|
|
export type {
|
|
ReplyDispatchKind,
|
|
ReplyDispatcher,
|
|
ReplyFollowupAdmissionBarrierTimeoutPolicy,
|
|
} from "../auto-reply/reply/reply-dispatcher.types.js";
|
|
export type {
|
|
ReplyDispatcherOptions,
|
|
ReplyDispatcherWithTypingOptions,
|
|
} from "../auto-reply/reply/reply-dispatcher.js";
|
|
export { createReplyReferencePlanner } from "../auto-reply/reply/reply-reference.js";
|
|
export type {
|
|
GetReplyOptions,
|
|
BlockReplyContext,
|
|
SourceReplyDeliveryMode,
|
|
} from "../auto-reply/get-reply-options.types.js";
|
|
export type { ReplyPayload } from "./reply-payload.js";
|
|
export type { FinalizedMsgContext, MsgContext } from "../auto-reply/templating.js";
|
|
export type { CommandTurnContext } from "../auto-reply/command-turn-context.js";
|
|
export { generateConversationLabel } from "../auto-reply/reply/conversation-label-generator.js";
|
|
export type { ConversationLabelParams } from "../auto-reply/reply/conversation-label-generator.js";
|