fix(qa): scope no-outbound waits · openclaw/openclaw@960b9fa

Recent Commits to openclaw:main

vincentkoc · 2026-06-24 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@ import {`
`6`	`6`	`findFailureOutboundMessage,`
`7`	`7`	`formatTransportTranscript,`
`8`	`8`	`readTransportTranscript,`
	`9`	`+waitForNoOutbound,`
`9`	`10`	`waitForOutboundMessage,`
`10`	`11`	`waitForTransportOutboundMessage,`
`11`	`12`	`} from "./suite-runtime-transport.js";`
`@@ -98,6 +99,31 @@ describe("qa suite transport helpers", () => {`
`98`	`99`	`await expect(pending).rejects.toThrow("Tool read not found");`
`99`	`100`	`});`
`100`	`101`
	`102`	`+it("checks no-outbound waits from the supplied outbound cursor", async () => {`
	`103`	`+const state = createQaBusState();`
	`104`	`+state.addOutboundMessage({`
	`105`	`+to: "channel:qa-room",`
	`106`	`+text: "previous scenario reply",`
	`107`	`+senderId: "openclaw",`
	`108`	`+senderName: "OpenClaw QA",`
	`109`	`+});`
	`110`	`+const sinceIndex = state`
	`111`	`+.getSnapshot()`
	`112`	`+.messages.filter((message) => message.direction === "outbound").length;`
	`113`	`+`
	`114`	`+await expect(waitForNoOutbound(state, 1, { sinceIndex })).resolves.toBeUndefined();`
	`115`	`+`
	`116`	`+state.addOutboundMessage({`
	`117`	`+to: "channel:qa-room",`
	`118`	`+text: "current scenario reply",`
	`119`	`+senderId: "openclaw",`
	`120`	`+senderName: "OpenClaw QA",`
	`121`	`+});`
	`122`	`+await expect(waitForNoOutbound(state, 1, { sinceIndex })).rejects.toThrow(`
	`123`	`+"expected no outbound messages, saw 1",`
	`124`	`+);`
	`125`	`+});`
	`126`	`+`
`101`	`127`	`it("fails raw scenario waitForCondition calls when a classified failure reply arrives", async () => {`
`102`	`128`	`const state = createQaBusState();`
`103`	`129`	`const waitForCondition = createScenarioWaitForCondition(state);`

Original file line number	Diff line number	Diff line change
`@@ -47,11 +47,16 @@ async function waitForOutboundMessage(`
`47`	`47`	`}, timeoutMs);`
`48`	`48`	`}`
`49`	`49`
`50`		`-async function waitForNoOutbound(state: QaTransportState, timeoutMs = 1_200) {`
	`50`	`+async function waitForNoOutbound(`
	`51`	`+state: QaTransportState,`
	`52`	`+timeoutMs = 1_200,`
	`53`	`+options?: { sinceIndex?: number },`
	`54`	`+) {`
`51`	`55`	`await sleep(timeoutMs);`
`52`	`56`	`const outbound = state`
`53`	`57`	`.getSnapshot()`
`54`		`-.messages.filter((message: QaBusMessage) => message.direction === "outbound");`
	`58`	`+.messages.filter((message: QaBusMessage) => message.direction === "outbound")`
	`59`	`+.slice(options?.sinceIndex ?? 0);`
`55`	`60`	`if (outbound.length > 0) {`
`56`	`61`	throw new Error(`expected no outbound messages, saw ${outbound.length}`);
`57`	`62`	`}`
`@@ -141,8 +146,12 @@ async function waitForChannelOutboundMessage(`
`141`	`146`	`return await waitForTransportOutboundMessage(state, predicate, timeoutMs);`
`142`	`147`	`}`
`143`	`148`
`144`		`-async function waitForNoTransportOutbound(state: QaTransportState, timeoutMs = 1_200) {`
`145`		`-await waitForNoOutbound(state, timeoutMs);`
	`149`	`+async function waitForNoTransportOutbound(`
	`150`	`+state: QaTransportState,`
	`151`	`+timeoutMs = 1_200,`
	`152`	`+options?: { sinceIndex?: number },`
	`153`	`+) {`
	`154`	`+await waitForNoOutbound(state, timeoutMs, options);`
`146`	`155`	`}`
`147`	`156`
`148`	`157`	`export {`

Original file line number	Diff line number	Diff line change
`@@ -40,6 +40,9 @@ flow:`
`40`	`40`	`- ref: env`
`41`	`41`	`- 60000`
`42`	`42`	`- call: reset`
	`43`	`+ - set: outboundStartIndex`
	`44`	`+value:`
	`45`	`+expr: "state.getSnapshot().messages.filter((message) => message.direction === 'outbound').length"`
`43`	`46`	`- call: state.addInboundMessage`
`44`	`47`	`args:`
`45`	`48`	`- conversation:`
`@@ -52,6 +55,9 @@ flow:`
`52`	`55`	`- call: waitForNoOutbound`
`53`	`56`	`args:`
`54`	`57`	`- ref: state`
	`58`	`+ - 1200`
	`59`	`+ - sinceIndex:`
	`60`	`+ref: outboundStartIndex`
`55`	`61`	`- name: replies when mentioned in channel`
`56`	`62`	`actions:`
`57`	`63`	`- call: waitForGatewayHealthy`

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

推荐订阅源

Recent Commits to openclaw:main