惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

J
Java Code Geeks
月光博客
月光博客
D
DataBreaches.Net
云风的 BLOG
云风的 BLOG
F
Fortinet All Blogs
T
The Blog of Author Tim Ferriss
Stack Overflow Blog
Stack Overflow Blog
Blog — PlanetScale
Blog — PlanetScale
aimingoo的专栏
aimingoo的专栏
U
Unit 42
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
MyScale Blog
MyScale Blog
T
Tailwind CSS Blog
N
Netflix TechBlog - Medium
B
Blog
博客园_首页
G
Google Developers Blog
Recent Announcements
Recent Announcements
博客园 - 【当耐特】
P
Proofpoint News Feed
博客园 - 司徒正美
Hugging Face - Blog
Hugging Face - Blog
MongoDB | Blog
MongoDB | Blog
Last Week in AI
Last Week in AI

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
fix: Slack inbound thread session routing (#72498) · open...
bek91 · 2026-04-27 · via Recent Commits to openclaw:main

@@ -20,6 +20,7 @@ export type SlackRoutingContextDeps = {

2020

export type SlackRoutingContext = {

2121

route: ReturnType<typeof resolveAgentRoute>;

2222

runtimeBinding: RuntimeConversationBindingRouteResult["bindingRecord"];

23+

runtimeBoundSessionKey: string | undefined;

2324

chatType: "direct" | "group" | "channel";

2425

replyToMode: ReturnType<typeof resolveSlackReplyToMode>;

2526

threadContext: ReturnType<typeof resolveSlackThreadContext>;

@@ -39,6 +40,25 @@ function resolveSlackBaseConversationId(params: {

3940

: params.message.channel;

4041

}

414243+

function resolveSlackInitialAgentRoute(params: {

44+

ctx: SlackRoutingContextDeps;

45+

account: ResolvedSlackAccount;

46+

message: SlackMessageEvent;

47+

isDirectMessage: boolean;

48+

isRoom: boolean;

49+

}) {

50+

return resolveAgentRoute({

51+

cfg: params.ctx.cfg,

52+

channel: "slack",

53+

accountId: params.account.accountId,

54+

teamId: params.ctx.teamId || undefined,

55+

peer: {

56+

kind: params.isDirectMessage ? "direct" : params.isRoom ? "channel" : "group",

57+

id: params.isDirectMessage ? (params.message.user ?? "unknown") : params.message.channel,

58+

},

59+

});

60+

}

61+4262

export function resolveSlackRoutingContext(params: {

4363

ctx: SlackRoutingContextDeps;

4464

account: ResolvedSlackAccount;

@@ -47,17 +67,24 @@ export function resolveSlackRoutingContext(params: {

4767

isGroupDm: boolean;

4868

isRoom: boolean;

4969

isRoomish: boolean;

70+

seedTopLevelRoomThread?: boolean;

5071

}): SlackRoutingContext {

51-

const { ctx, account, message, isDirectMessage, isGroupDm, isRoom, isRoomish } = params;

52-

let route = resolveAgentRoute({

53-

cfg: ctx.cfg,

54-

channel: "slack",

55-

accountId: account.accountId,

56-

teamId: ctx.teamId || undefined,

57-

peer: {

58-

kind: isDirectMessage ? "direct" : isRoom ? "channel" : "group",

59-

id: isDirectMessage ? (message.user ?? "unknown") : message.channel,

60-

},

72+

const {

73+

ctx,

74+

account,

75+

message,

76+

isDirectMessage,

77+

isGroupDm,

78+

isRoom,

79+

isRoomish,

80+

seedTopLevelRoomThread,

81+

} = params;

82+

let route = resolveSlackInitialAgentRoute({

83+

ctx,

84+

account,

85+

message,

86+

isDirectMessage,

87+

isRoom,

6188

});

62896390

const chatType = isDirectMessage ? "direct" : isGroupDm ? "group" : "channel";

@@ -72,21 +99,32 @@ export function resolveSlackRoutingContext(params: {

7299

!isThreadReply && replyToMode === "all" && threadContext.messageTs

73100

? threadContext.messageTs

74101

: undefined;

75-

// Only fork channel/group messages into thread-specific sessions when they are

76-

// actual thread replies (thread_ts present, different from message ts).

77-

// Top-level channel messages must stay on the per-channel session for continuity.

78-

// Before this fix, every channel message used its own ts as threadId, creating

79-

// isolated sessions per message (regression from #10686).

102+

// Keep ordinary top-level room messages on the per-channel session for

103+

// continuity, but preserve Slack thread identity when the event already has

104+

// one or when an actionable app mention will seed a reply thread.

105+

// This keeps a thread root and its later replies on one parent session

106+

// without returning to the old "every channel message is its own thread"

107+

// behavior (regression from #10686).

108+

const seedCandidateThreadId = threadContext.incomingThreadTs ?? threadContext.messageTs;

109+

const seededRoomThreadId =

110+

!isThreadReply &&

111+

isRoom &&

112+

seedTopLevelRoomThread &&

113+

replyToMode !== "off" &&

114+

seedCandidateThreadId

115+

? seedCandidateThreadId

116+

: undefined;

80117

const roomThreadId = isThreadReply && threadTs ? threadTs : undefined;

81118

const canonicalThreadId = isRoomish ? roomThreadId : isThreadReply ? threadTs : autoThreadId;

119+

const routedThreadId = canonicalThreadId ?? (isRoomish ? seededRoomThreadId : undefined);

82120

const baseConversationId = resolveSlackBaseConversationId({ message, isDirectMessage });

83-

const boundThreadRoute = canonicalThreadId

121+

const boundThreadRoute = routedThreadId

84122

? resolveRuntimeConversationBindingRoute({

85123

route,

86124

conversation: {

87125

channel: "slack",

88126

accountId: account.accountId,

89-

conversationId: canonicalThreadId,

127+

conversationId: routedThreadId,

90128

parentConversationId: baseConversationId,

91129

},

92130

})

@@ -107,9 +145,8 @@ export function resolveSlackRoutingContext(params: {

107145

? { sessionKey: route.sessionKey, parentSessionKey: undefined }

108146

: resolveThreadSessionKeys({

109147

baseSessionKey: route.sessionKey,

110-

threadId: canonicalThreadId,

111-

parentSessionKey:

112-

canonicalThreadId && ctx.threadInheritParent ? route.sessionKey : undefined,

148+

threadId: routedThreadId,

149+

parentSessionKey: routedThreadId && ctx.threadInheritParent ? route.sessionKey : undefined,

113150

});

114151

const sessionKey = threadKeys.sessionKey;

115152

const historyKey =

@@ -118,6 +155,7 @@ export function resolveSlackRoutingContext(params: {

118155

return {

119156

route,

120157

runtimeBinding: runtimeRoute.bindingRecord,

158+

runtimeBoundSessionKey: runtimeRoute.boundSessionKey,

121159

chatType,

122160

replyToMode,

123161

threadContext,