refactor: centralize inbound history shaping · openclaw/openclaw@a1a6cd6

Recent Commits to openclaw:main

steipete · 2026-05-15 · via Recent Commits to openclaw:main

File tree

extensions
- discord/src/monitor
- feishu/src
- imessage/src/monitor
- line/src
- matrix/src/matrix/monitor
- mattermost/src/mattermost
- msteams/src/monitor-handler
- signal/src/monitor
- slack/src/monitor/message-handler
- telegram/src
- whatsapp/src/auto-reply/monitor
- zalouser/src
src
- auto-reply
  - reply
- channels/turn
- plugin-sdk
- plugins/contracts

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,10 @@ import { resolveChannelContextVisibilityMode } from "openclaw/plugin-sdk/context`
`6`	`6`	`import { resolvePinnedMainDmOwnerFromAllowlist } from "openclaw/plugin-sdk/conversation-runtime";`
`7`	`7`	`import { isDangerousNameMatchingEnabled } from "openclaw/plugin-sdk/dangerous-name-runtime";`
`8`	`8`	`import { finalizeInboundContext } from "openclaw/plugin-sdk/reply-dispatch-runtime";`
`9`		`-import { buildPendingHistoryContextFromMap } from "openclaw/plugin-sdk/reply-history";`
	`9`	`+import {`
	`10`	`+buildInboundHistoryFromMap,`
	`11`	`+buildPendingHistoryContextFromMap,`
	`12`	`+} from "openclaw/plugin-sdk/reply-history";`
`10`	`13`	`import { buildAgentSessionKey, resolveThreadSessionKeys } from "openclaw/plugin-sdk/routing";`
`11`	`14`	`import { danger, logVerbose, shouldLogVerbose } from "openclaw/plugin-sdk/runtime-env";`
`12`	`15`	`import { evaluateSupplementalContextVisibility } from "openclaw/plugin-sdk/security-runtime";`
`@@ -287,14 +290,13 @@ export async function buildDiscordMessageProcessContext(params: {`
`287`	`290`	`return null;`
`288`	`291`	`}`
`289`	`292`	`const lastRouteTo = dmConversationTarget ?? effectiveTo;`
`290`		`-const inboundHistory =`
`291`		`-shouldIncludeChannelHistory && historyLimit > 0`
`292`		`- ? (guildHistories.get(messageChannelId) ?? []).map((entry) => ({`
`293`		`-sender: entry.sender,`
`294`		`-body: entry.body,`
`295`		`-timestamp: entry.timestamp,`
`296`		`-}))`
`297`		`- : undefined;`
	`293`	`+const inboundHistory = shouldIncludeChannelHistory`
	`294`	`+ ? buildInboundHistoryFromMap({`
	`295`	`+historyMap: guildHistories,`
	`296`	`+historyKey: messageChannelId,`
	`297`	`+limit: historyLimit,`
	`298`	`+})`
	`299`	`+ : undefined;`
`298`	`300`	`const originatingTo = autoThreadContext?.OriginatingTo ?? dmConversationTarget ?? replyTarget;`
`299`	`301`	`const effectiveSessionKey =`
`300`	`302`	`boundSessionKey ?? autoThreadContext?.SessionKey ?? threadKeys.sessionKey;`

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import {`
`7`	`7`	`} from "openclaw/plugin-sdk/conversation-runtime";`
`8`	`8`	`import { resolveAgentOutboundIdentity } from "openclaw/plugin-sdk/outbound-runtime";`
`9`	`9`	`import {`
	`10`	`+buildInboundHistoryFromMap,`
`10`	`11`	`buildPendingHistoryContextFromMap,`
`11`	`12`	`clearHistoryEntriesIfEnabled,`
`12`	`13`	`DEFAULT_GROUP_HISTORY_LIMIT,`
`@@ -1076,11 +1077,11 @@ export async function handleFeishuMessage(params: {`
`1076`	`1077`
`1077`	`1078`	`const inboundHistory =`
`1078`	`1079`	`isGroup && historyKey && historyLimit > 0 && chatHistories`
`1079`		`- ? (chatHistories.get(historyKey) ?? []).map((entry) => ({`
`1080`		`-sender: entry.sender,`
`1081`		`-body: entry.body,`
`1082`		`-timestamp: entry.timestamp,`
`1083`		`-}))`
	`1080`	`+ ? buildInboundHistoryFromMap({`
	`1081`	`+historyMap: chatHistories,`
	`1082`	`+historyKey,`
	`1083`	`+limit: historyLimit,`
	`1084`	`+})`
`1084`	`1085`	`: undefined;`
`1085`	`1086`
`1086`	`1087`	`const threadContextBySessionKey = new Map<`

Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,7 @@ import { hasControlCommand } from "openclaw/plugin-sdk/command-auth-native";`
`21`	`21`	`import type { DmPolicy, GroupPolicy, OpenClawConfig } from "openclaw/plugin-sdk/config-contracts";`
`22`	`22`	`import { resolveChannelContextVisibilityMode } from "openclaw/plugin-sdk/context-visibility-runtime";`
`23`	`23`	`import {`
	`24`	`+buildInboundHistoryFromMap,`
`24`	`25`	`buildPendingHistoryContextFromMap,`
`25`	`26`	`recordPendingHistoryEntryIfEnabled,`
`26`	`27`	`type HistoryEntry,`
`@@ -989,11 +990,11 @@ export function buildIMessageInboundContext(params: {`
`989`	`990`	const imessageTo = (decision.isGroup ? chatTarget : undefined) \|\| `imessage:${decision.sender}`;
`990`	`991`	`const inboundHistory =`
`991`	`992`	`decision.isGroup && decision.historyKey && params.historyLimit > 0`
`992`		`- ? (params.groupHistories.get(decision.historyKey) ?? []).map((entry) => ({`
`993`		`-sender: entry.sender,`
`994`		`-body: entry.body,`
`995`		`-timestamp: entry.timestamp,`
`996`		`-}))`
	`993`	`+ ? buildInboundHistoryFromMap({`
	`994`	`+historyMap: params.groupHistories,`
	`995`	`+historyKey: decision.historyKey,`
	`996`	`+limit: params.historyLimit,`
	`997`	`+})`
`997`	`998`	`: undefined;`
`998`	`999`
`999`	`1000`	`const ctxPayload = finalizeInboundContext({`

Original file line number	Diff line number	Diff line change
`@@ -54,6 +54,20 @@ vi.mock("openclaw/plugin-sdk/runtime-env", () => ({`
`54`	`54`	`}));`
`55`	`55`	`vi.mock("openclaw/plugin-sdk/reply-history", () => ({`
`56`	`56`	`DEFAULT_GROUP_HISTORY_LIMIT: 20,`
	`57`	`+buildInboundHistoryFromMap: ({`
	`58`	`+ historyMap,`
	`59`	`+ historyKey,`
	`60`	`+ limit,`
	`61`	`+}: {`
	`62`	`+historyMap: Map<string, HistoryEntry[]>;`
	`63`	`+historyKey: string;`
	`64`	`+limit: number;`
	`65`	`+}) => {`
	`66`	`+if (limit <= 0) {`
	`67`	`+return undefined;`
	`68`	`+}`
	`69`	`+return (historyMap.get(historyKey) ?? []).slice(-limit);`
	`70`	`+},`
`57`	`71`	`clearHistoryEntriesIfEnabled: ({`
`58`	`72`	`historyMap,`
`59`	`73`	`historyKey,`

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ import {`
`14`	`14`	`resolveRuntimeConversationBindingRoute,`
`15`	`15`	`} from "openclaw/plugin-sdk/conversation-runtime";`
`16`	`16`	`import { finalizeInboundContext } from "openclaw/plugin-sdk/reply-dispatch-runtime";`
`17`		`-import type { HistoryEntry } from "openclaw/plugin-sdk/reply-history";`
	`17`	`+import { buildInboundHistoryFromMap, type HistoryEntry } from "openclaw/plugin-sdk/reply-history";`
`18`	`18`	`import { resolveAgentRoute } from "openclaw/plugin-sdk/routing";`
`19`	`19`	`import { logVerbose, shouldLogVerbose } from "openclaw/plugin-sdk/runtime-env";`
`20`	`20`	`import { normalizeOptionalString } from "openclaw/plugin-sdk/string-coerce-runtime";`
`@@ -469,11 +469,11 @@ export async function buildLineMessageContext(params: BuildLineMessageContextPar`
`469`	`469`	`const historyKey = isGroup ? peerId : undefined;`
`470`	`470`	`const inboundHistory =`
`471`	`471`	`historyKey && groupHistories && (historyLimit ?? 0) > 0`
`472`		`- ? (groupHistories.get(historyKey) ?? []).map((entry) => ({`
`473`		`-sender: entry.sender,`
`474`		`-body: entry.body,`
`475`		`-timestamp: entry.timestamp,`
`476`		`-}))`
	`472`	`+ ? buildInboundHistoryFromMap({`
	`473`	`+historyMap: groupHistories,`
	`474`	`+historyKey,`
	`475`	`+limit: historyLimit ?? 0,`
	`476`	`+})`
`477`	`477`	`: undefined;`
`478`	`478`
`479`	`479`	`const finalized = await finalizeLineInboundContext({`

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@ import { isDangerousNameMatchingEnabled } from "openclaw/plugin-sdk/dangerous-na`
`24`	`24`	`import { hasFinalInboundReplyDispatch } from "openclaw/plugin-sdk/inbound-reply-dispatch";`
`25`	`25`	`import type { ChannelBotLoopProtectionFacts } from "openclaw/plugin-sdk/inbound-reply-dispatch";`
`26`	`26`	`import { mergePairLoopGuardConfig } from "openclaw/plugin-sdk/pair-loop-guard-runtime";`
	`27`	`+import { buildInboundHistoryFromEntries } from "openclaw/plugin-sdk/reply-history";`
`27`	`28`	`import type { GetReplyOptions } from "openclaw/plugin-sdk/reply-runtime";`
`28`	`29`	`import { resolvePinnedMainDmOwnerFromAllowlist } from "openclaw/plugin-sdk/security-runtime";`
`29`	`30`	`import {`
`@@ -1137,7 +1138,12 @@ export function createMatrixRoomMessageHandler(params: MatrixMonitorHandlerParam`
`1137`	`1138`	`messageId,`
`1138`	`1139`	`})`
`1139`	`1140`	`: undefined;`
`1140`		`-const inboundHistory = preparedTrigger?.history;`
	`1141`	`+const inboundHistory = preparedTrigger`
	`1142`	`+ ? buildInboundHistoryFromEntries({`
	`1143`	`+entries: preparedTrigger.history,`
	`1144`	`+limit: historyLimit,`
	`1145`	`+})`
	`1146`	`+ : undefined;`
`1141`	`1147`	`const triggerSnapshot = preparedTrigger;`
`1142`	`1148`
`1143`	`1149`	`return {`

Original file line number	Diff line number	Diff line change
`@@ -88,6 +88,7 @@ import type {`
`88`	`88`	`import {`
`89`	`89`	`buildAgentMediaPayload,`
`90`	`90`	`buildModelsProviderData,`
	`91`	`+buildInboundHistoryFromMap,`
`91`	`92`	`buildPendingHistoryContextFromMap,`
`92`	`93`	`createChannelPairingController,`
`93`	`94`	`createChannelMessageReplyPipeline,`
`@@ -1529,11 +1530,11 @@ export async function monitorMattermostProvider(opts: MonitorMattermostOpts = {}`
`1529`	`1530`	`const commandBody = rawText.trim();`
`1530`	`1531`	`const inboundHistory =`
`1531`	`1532`	`historyKey && historyLimit > 0`
`1532`		`- ? (channelHistories.get(historyKey) ?? []).map((entry) => ({`
`1533`		`-sender: entry.sender,`
`1534`		`-body: entry.body,`
`1535`		`-timestamp: entry.timestamp,`
`1536`		`-}))`
	`1533`	`+ ? buildInboundHistoryFromMap({`
	`1534`	`+historyMap: channelHistories,`
	`1535`	`+historyKey,`
	`1536`	`+limit: historyLimit,`
	`1537`	`+})`
`1537`	`1538`	`: undefined;`
`1538`	`1539`	`const ctxPayload = core.channel.reply.finalizeInboundContext({`
`1539`	`1540`	`Body: combinedBody,`

Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,7 @@ export { resolveChannelMediaMaxBytes } from "openclaw/plugin-sdk/media-runtime";`
`30`	`30`	`export { loadOutboundMediaFromUrl } from "openclaw/plugin-sdk/outbound-media";`
`31`	`31`	`export {`
`32`	`32`	`DEFAULT_GROUP_HISTORY_LIMIT,`
	`33`	`+buildInboundHistoryFromMap,`
`33`	`34`	`buildPendingHistoryContextFromMap,`
`34`	`35`	`recordPendingHistoryEntryIfEnabled,`
`35`	`36`	`} from "openclaw/plugin-sdk/reply-history";`

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,7 @@ import {`
`15`	`15`	`resolveInboundReplyDispatchCounts,`
`16`	`16`	`} from "openclaw/plugin-sdk/inbound-reply-dispatch";`
`17`	`17`	`import {`
	`18`	`+buildInboundHistoryFromMap,`
`18`	`19`	`buildPendingHistoryContextFromMap,`
`19`	`20`	`DEFAULT_GROUP_HISTORY_LIMIT,`
`20`	`21`	`recordPendingHistoryEntryIfEnabled,`
`@@ -729,11 +730,11 @@ export function createMSTeamsMessageHandler(deps: MSTeamsMessageHandlerDeps) {`
`729`	`730`
`730`	`731`	`const inboundHistory =`
`731`	`732`	`isRoomish && historyKey && historyLimit > 0`
`732`		`- ? (conversationHistories.get(historyKey) ?? []).map((entry) => ({`
`733`		`-sender: entry.sender,`
`734`		`-body: entry.body,`
`735`		`-timestamp: entry.timestamp,`
`736`		`-}))`
	`733`	`+ ? buildInboundHistoryFromMap({`
	`734`	`+historyMap: conversationHistories,`
	`735`	`+historyKey,`
	`736`	`+limit: historyLimit,`
	`737`	`+})`
`737`	`738`	`: undefined;`
`738`	`739`	`const commandBody = text.trim();`
`739`	`740`	`const quoteSenderAllowed =`

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ import {`
`27`	`27`	`import { runInboundReplyTurn } from "openclaw/plugin-sdk/inbound-reply-dispatch";`
`28`	`28`	`import { kindFromMime } from "openclaw/plugin-sdk/media-runtime";`
`29`	`29`	`import {`
	`30`	`+buildInboundHistoryFromMap,`
`30`	`31`	`buildPendingHistoryContextFromMap,`
`31`	`32`	`recordPendingHistoryEntryIfEnabled,`
`32`	`33`	`} from "openclaw/plugin-sdk/reply-history";`
`@@ -186,11 +187,11 @@ export function createSignalEventHandler(deps: SignalEventHandlerDeps) {`
`186`	`187`	`const signalTo = normalizeSignalMessagingTarget(signalToRaw) ?? signalToRaw;`
`187`	`188`	`const inboundHistory =`
`188`	`189`	`entry.isGroup && historyKey && deps.historyLimit > 0`
`189`		`- ? (deps.groupHistories.get(historyKey) ?? []).map((historyEntry) => ({`
`190`		`-sender: historyEntry.sender,`
`191`		`-body: historyEntry.body,`
`192`		`-timestamp: historyEntry.timestamp,`
`193`		`-}))`
	`190`	`+ ? buildInboundHistoryFromMap({`
	`191`	`+historyMap: deps.groupHistories,`
	`192`	`+historyKey,`
	`193`	`+limit: deps.historyLimit,`
	`194`	`+})`
`194`	`195`	`: undefined;`
`195`	`196`	`const ctxPayload = finalizeInboundContext({`
`196`	`197`	`Body: combinedBody,`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main

File tree