@@ -2385,7 +2385,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => {
23852385);
23862386});
238723872388-it("no-ops stale isolated cron run media completions", async () => {
2388+it("directly delivers stale isolated cron run media completions", async () => {
23892389const callGateway = createGatewayMock();
23902390const sendMessage = createSendMessageMock();
23912391const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(true);
@@ -2416,6 +2416,40 @@ describe("deliverSubagentAnnouncement completion delivery", () => {
24162416],
24172417});
241824182419+expectRecordFields(result, {
2420+delivered: true,
2421+path: "direct",
2422+});
2423+expect(queueEmbeddedPiMessageWithOutcome).not.toHaveBeenCalled();
2424+expect(callGateway).not.toHaveBeenCalled();
2425+expect(sendMessage).toHaveBeenCalledWith(
2426+expect.objectContaining({
2427+channel: "slack",
2428+accountId: "acct-1",
2429+to: "channel:C123",
2430+content: "The generated image is ready.",
2431+mediaUrls: ["/tmp/generated-daily.png"],
2432+idempotencyKey: "announce-stale-cron-media:generated-media-direct",
2433+}),
2434+);
2435+});
2436+2437+it("no-ops stale isolated cron run text completions", async () => {
2438+const callGateway = createGatewayMock();
2439+const sendMessage = createSendMessageMock();
2440+const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(true);
2441+const result = await deliverSlackChannelAnnouncement({
2442+ callGateway,
2443+ sendMessage,
2444+ queueEmbeddedPiMessageWithOutcome,
2445+sessionId: "stale-cron-run-session",
2446+isActive: false,
2447+requesterSessionKey: "agent:main:cron:daily-text:run:run-123",
2448+expectsCompletionMessage: true,
2449+directIdempotencyKey: "announce-stale-cron-text",
2450+sourceTool: "subagent_announce",
2451+});
2452+24192453expectRecordFields(result, {
24202454delivered: true,
24212455path: "none",
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。