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

推荐订阅源

G
Google Developers Blog
F
Fortinet All Blogs
Microsoft Azure Blog
Microsoft Azure Blog
腾讯CDC
Vercel News
Vercel News
Recent Announcements
Recent Announcements
博客园 - Franky
小众软件
小众软件
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
The Cloudflare Blog
宝玉的分享
宝玉的分享
I
InfoQ
博客园 - 聂微东
Jina AI
Jina AI
J
Java Code Geeks
V
V2EX
U
Unit 42
Stack Overflow Blog
Stack Overflow Blog
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
阮一峰的网络日志
阮一峰的网络日志
L
LangChain Blog
T
The Blog of Author Tim Ferriss
量子位

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): normalize direct interactive sends · openclaw...
steipete · 2026-05-10 · via Recent Commits to openclaw:main
Original file line numberDiff line numberDiff line change

@@ -44,6 +44,7 @@ Docs: https://docs.openclaw.ai

4444

- Slack: add scoped message-tool formatting hints so agents use Markdown for plain sends and direct mrkdwn for Block Kit fields. Fixes #34609. (#50979) Thanks @carrotRakko.

4545

- Slack: describe `download-file` file ids separately from message timestamps and return a targeted recovery error when agents pass `messageId` instead of `fileId`. (#74155) Thanks @jarvis-ai-gregmoser.

4646

- Slack: retain processed room messages for `requireMention=false` channels so always-on Slack rooms keep recent conversation context between turns. (#38658) Thanks @syedamaann.

47+

- Slack: compile interactive reply directives for direct outbound sends without bypassing the `interactiveReplies` capability gate, preserving Block Kit for Slack CLI and cron deliveries. (#78220) Thanks @kazamak.

4748

- Gateway/agents: keep structured reasons when active-run queueing fails and deprecate the legacy boolean queue helper, so steering and subagent wake diagnostics distinguish completed, non-streaming, and compacting runs. Fixes #80156. Thanks @markus-lassfolk.

4849

- Agents/UI: compact exec and tool progress rows by hiding redundant shell tool names, replacing known workspace paths with short context markers, and preserving Discord trace scrubbing for compact command lines.

4950

- ACPX: run and await the embedded ACP backend startup probe by default so the gateway `ready` signal no longer fires before the acpx runtime has either become usable or reported a probe failure; set `OPENCLAW_ACPX_RUNTIME_STARTUP_PROBE=0` to restore lazy startup. Fixes #79596. Thanks @bzelones.

Original file line numberDiff line numberDiff line change

@@ -1,2 +1,2 @@

1-

0fff629c16bf8d215832c7526a1cf78877a4a97e696cfd1d932023905ae4cce9 plugin-sdk-api-baseline.json

2-

5f0862e41455f46c0f68ca8ccd322a76a7b5f4ff50c3dd743904705c0c943cba plugin-sdk-api-baseline.jsonl

1+

5219fe6237bdf573740840ef3c29631a8465abb73dd60128fb94589384ae2a96 plugin-sdk-api-baseline.json

2+

f63c9723859bb900cf636e5e3fc1349a48563e279ca09e01a7ffafad9efe72f8 plugin-sdk-api-baseline.jsonl

Original file line numberDiff line numberDiff line change

@@ -821,6 +821,40 @@ describe("slackPlugin outbound", () => {

821821

expect(result).toEqual({ channel: "slack", messageId: "m-media-local" });

822822

});

823823
824+

it("normalizes slack button directives for direct outbound delivery", () => {

825+

const normalized = slackPlugin.outbound?.normalizePayload?.({

826+

cfg: {

827+

channels: {

828+

slack: {

829+

botToken: "xoxb-test",

830+

appToken: "xapp-test",

831+

capabilities: { interactiveReplies: true },

832+

},

833+

},

834+

},

835+

accountId: "default",

836+

payload: {

837+

text: "Slack interactive minimal test\n[[slack_buttons: Test:test-value]]",

838+

},

839+

});

840+
841+

expect(normalized).toEqual({

842+

text: "Slack interactive minimal test",

843+

interactive: {

844+

blocks: [

845+

{

846+

type: "text",

847+

text: "Slack interactive minimal test",

848+

},

849+

{

850+

type: "buttons",

851+

buttons: [{ label: "Test", value: "test-value" }],

852+

},

853+

],

854+

},

855+

});

856+

});

857+
824858

it("sends block payload media first, then the final block message", async () => {

825859

const sendSlack = vi

826860

.fn()

Original file line numberDiff line numberDiff line change

@@ -378,6 +378,10 @@ const slackChannelOutbound: ChannelOutboundAdapter = {

378378

deliveryMode: "direct",

379379

chunker: null,

380380

textChunkLimit: SLACK_TEXT_LIMIT,

381+

normalizePayload: ({ payload, cfg, accountId }) =>

382+

isSlackInteractiveRepliesEnabled({ cfg, accountId })

383+

? compileSlackInteractiveReplies(payload)

384+

: payload,

381385

deliveryCapabilities: {

382386

durableFinal: {

383387

text: true,

Original file line numberDiff line numberDiff line change

@@ -90,6 +90,12 @@ export type ChannelOutboundChunkContext = {

9090

formatting?: OutboundDeliveryFormattingOptions;

9191

};

9292
93+

export type ChannelOutboundNormalizePayloadParams = {

94+

payload: ReplyPayload;

95+

cfg: OpenClawConfig;

96+

accountId?: string | null;

97+

};

98+
9399

export type ChannelOutboundAdapter = {

94100

deliveryMode: "direct" | "gateway" | "hybrid";

95101

chunker?: ((text: string, limit: number, ctx?: ChannelOutboundChunkContext) => string[]) | null;

@@ -101,7 +107,7 @@ export type ChannelOutboundAdapter = {

101107

pollMaxOptions?: number;

102108

supportsPollDurationSeconds?: boolean;

103109

supportsAnonymousPolls?: boolean;

104-

normalizePayload?: (params: { payload: ReplyPayload }) => ReplyPayload | null;

110+

normalizePayload?: (params: ChannelOutboundNormalizePayloadParams) => ReplyPayload | null;

105111

sendTextOnlyErrorPayloads?: boolean;

106112

shouldSkipPlainTextSanitization?: (params: { payload: ReplyPayload }) => boolean;

107113

resolveEffectiveTextChunkLimit?: (params: {

Original file line numberDiff line numberDiff line change

@@ -86,6 +86,49 @@ describe("createChannelOutboundRuntimeSend", () => {

8686

);

8787

});

8888
89+

it("routes block sends through payload delivery", async () => {

90+

const sendPayload = vi.fn(async () => ({ channel: "slack", messageId: "slack-blocks" }));

91+

const sendText = vi.fn();

92+

mocks.loadChannelOutboundAdapter.mockResolvedValue({

93+

sendPayload,

94+

sendText,

95+

});

96+
97+

const { createChannelOutboundRuntimeSend } = await import("./channel-outbound-send.js");

98+

const runtimeSend = createChannelOutboundRuntimeSend({

99+

channelId: "slack" as never,

100+

unavailableMessage: "unavailable",

101+

});

102+

const blocks = [

103+

{

104+

type: "actions",

105+

elements: [{ type: "button", text: { type: "plain_text", text: "OK" }, value: "ok" }],

106+

},

107+

];

108+
109+

await runtimeSend.sendMessage("C123", "fallback", {

110+

cfg: {},

111+

accountId: "default",

112+

blocks,

113+

});

114+
115+

expect(sendPayload).toHaveBeenCalledWith(

116+

expect.objectContaining({

117+

accountId: "default",

118+

cfg: {},

119+

payload: {

120+

channelData: {

121+

slack: { blocks },

122+

},

123+

text: "fallback",

124+

},

125+

text: "fallback",

126+

to: "C123",

127+

}),

128+

);

129+

expect(sendText).not.toHaveBeenCalled();

130+

});

131+
89132

it("accepts plugin outbound thread and reply aliases", async () => {

90133

const sendText = vi.fn(async () => ({ channel: "matrix", messageId: "$reply" }));

91134

mocks.loadChannelOutboundAdapter.mockResolvedValue({

Original file line numberDiff line numberDiff line change

@@ -7,6 +7,7 @@ import { normalizeOptionalString } from "../../shared/string-coerce.js";

77
88

type RuntimeSendOpts = {

99

cfg?: OpenClawConfig;

10+

blocks?: unknown;

1011

mediaUrl?: string;

1112

mediaAccess?: OutboundMediaAccess;

1213

mediaLocalRoots?: readonly string[];

@@ -58,6 +59,19 @@ export function createChannelOutboundRuntimeSend(params: {

5859

gatewayClientScopes: opts.gatewayClientScopes,

5960

});

6061

const hasMedia = Boolean(opts.mediaUrl);

62+

if (opts.blocks && outbound?.sendPayload) {

63+

return await outbound.sendPayload({

64+

...buildContext(),

65+

payload: {

66+

text,

67+

channelData: {

68+

[params.channelId]: {

69+

blocks: opts.blocks,

70+

},

71+

},

72+

},

73+

});

74+

}

6175

if (hasMedia && outbound?.sendMedia) {

6276

return await outbound.sendMedia(buildContext());

6377

}

Original file line numberDiff line numberDiff line change

@@ -1515,6 +1515,56 @@ describe("deliverOutboundPayloads", () => {

15151515

expect(deliveredPayload?.channelData).toStrictEqual({ copiedText: "visible" });

15161516

});

15171517
1518+

it("passes delivery config and account context to adapter payload normalization", async () => {

1519+

const normalizePayload = vi.fn(({ payload }) => ({

1520+

...payload,

1521+

channelData: { normalized: true },

1522+

}));

1523+

const sendPayload = vi.fn().mockResolvedValue({

1524+

channel: "matrix" as const,

1525+

messageId: "context",

1526+

roomId: "!room",

1527+

});

1528+

const cfg = { channels: { matrix: { enabled: true } } } as unknown as OpenClawConfig;

1529+

setActivePluginRegistry(

1530+

createTestRegistry([

1531+

{

1532+

pluginId: "matrix",

1533+

source: "test",

1534+

plugin: createOutboundTestPlugin({

1535+

id: "matrix",

1536+

outbound: {

1537+

deliveryMode: "direct",

1538+

normalizePayload,

1539+

sendText: vi.fn(),

1540+

sendMedia: vi.fn(),

1541+

sendPayload,

1542+

},

1543+

}),

1544+

},

1545+

]),

1546+

);

1547+
1548+

await deliverOutboundPayloads({

1549+

cfg,

1550+

channel: "matrix",

1551+

to: "!room",

1552+

accountId: "workspace-a",

1553+

payloads: [{ text: "visible" }],

1554+

});

1555+
1556+

expect(normalizePayload).toHaveBeenCalledWith({

1557+

accountId: "workspace-a",

1558+

cfg,

1559+

payload: expect.objectContaining({ text: "visible" }),

1560+

});

1561+

expect(sendPayload).toHaveBeenCalledWith(

1562+

expect.objectContaining({

1563+

payload: expect.objectContaining({ channelData: { normalized: true } }),

1564+

}),

1565+

);

1566+

});

1567+
15181568

it("strips internal runtime scaffolding copied into rendered and normalized nested payloads", async () => {

15191569

const sendPayload = vi.fn().mockResolvedValue({

15201570

channel: "matrix" as const,

Original file line numberDiff line numberDiff line change

@@ -372,7 +372,12 @@ function createPluginHandler(

372372

? (payload) => outbound.sanitizeText!({ text: payload.text ?? "", payload })

373373

: undefined,

374374

normalizePayload: outbound?.normalizePayload

375-

? (payload) => outbound.normalizePayload!({ payload })

375+

? (payload) =>

376+

outbound.normalizePayload!({

377+

payload,

378+

cfg: params.cfg,

379+

accountId: params.accountId,

380+

})

376381

: undefined,

377382

sendTextOnlyErrorPayloads: outbound?.sendTextOnlyErrorPayloads === true,

378383

renderPresentation: outbound?.renderPresentation