fix(qa): settle channel no-reply check · openclaw/openclaw@ab9d3ad
vincentkoc
·
2026-06-24
·
via Recent Commits to openclaw:main
| Original file line number | Diff line number | Diff line change |
|---|
@@ -102,7 +102,7 @@ describe("qa suite transport helpers", () => {
|
102 | 102 | it("checks no-outbound waits from the supplied outbound cursor", async () => { |
103 | 103 | const state = createQaBusState(); |
104 | 104 | state.addOutboundMessage({ |
105 | | -to: "channel:qa-room", |
| 105 | +to: "dm:qa-operator", |
106 | 106 | text: "previous scenario reply", |
107 | 107 | senderId: "openclaw", |
108 | 108 | senderName: "OpenClaw QA", |
|
| Original file line number | Diff line number | Diff line change |
|---|
@@ -9,6 +9,10 @@ import {
|
9 | 9 | import { extractQaFailureReplyText } from "./reply-failure.js"; |
10 | 10 | import type { QaBusMessage } from "./runtime-api.js"; |
11 | 11 | |
| 12 | +type WaitForNoOutboundOptions = { |
| 13 | +sinceIndex?: number; |
| 14 | +}; |
| 15 | + |
12 | 16 | function findFailureOutboundMessage( |
13 | 17 | state: QaTransportState, |
14 | 18 | options?: { sinceIndex?: number; cursorSpace?: "all" | "outbound" }, |
@@ -50,7 +54,7 @@ async function waitForOutboundMessage(
|
50 | 54 | async function waitForNoOutbound( |
51 | 55 | state: QaTransportState, |
52 | 56 | timeoutMs = 1_200, |
53 | | -options?: { sinceIndex?: number }, |
| 57 | +options?: WaitForNoOutboundOptions, |
54 | 58 | ) { |
55 | 59 | await sleep(timeoutMs); |
56 | 60 | const outbound = state |
@@ -149,7 +153,7 @@ async function waitForChannelOutboundMessage(
|
149 | 153 | async function waitForNoTransportOutbound( |
150 | 154 | state: QaTransportState, |
151 | 155 | timeoutMs = 1_200, |
152 | | -options?: { sinceIndex?: number }, |
| 156 | +options?: WaitForNoOutboundOptions, |
153 | 157 | ) { |
154 | 158 | await waitForNoOutbound(state, timeoutMs, options); |
155 | 159 | } |
|
| 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 | + - call: sleep |
| 44 | +args: |
| 45 | + - 1200 |
43 | 46 | - set: outboundStartIndex |
44 | 47 | value: |
45 | 48 | expr: "state.getSnapshot().messages.filter((message) => message.direction === 'outbound').length" |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。
