vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-05 06:00:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: align qa wait cursor semantics

Browse Source
This commit is contained in:
Shakker
2026-04-08 21:15:52 +01:00
committed by Shakker
parent 7d818c32ba
commit 204d766b27
1 changed files with 20 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
extensions/qa-lab/src/suite.ts
View File

@@ -166,12 +166,22 @@ async function waitForCondition<T>(
throw new Error(`timed out after ${timeoutMs}ms`);
}
function findFailureOutboundMessage(state: QaBusState, options?: { sinceIndex?: number }) {
return state
.getSnapshot()
.messages.filter((message) => message.direction === "outbound")
.slice(options?.sinceIndex ?? 0)
.find((message) => Boolean(extractQaFailureReplyText(message.text)));
function findFailureOutboundMessage(
state: QaBusState,
options?: { sinceIndex?: number; cursorSpace?: "all" | "outbound" },
) {
const cursorSpace = options?.cursorSpace ?? "outbound";
const observedMessages =
cursorSpace === "all"
? state.getSnapshot().messages.slice(options?.sinceIndex ?? 0)
: state
.getSnapshot()
.messages.filter((message) => message.direction === "outbound")
.slice(options?.sinceIndex ?? 0);
return observedMessages.find(
(message) =>
message.direction === "outbound" && Boolean(extractQaFailureReplyText(message.text)),
);
}
function createScenarioWaitForCondition(state: QaBusState) {
@@ -183,7 +193,10 @@ function createScenarioWaitForCondition(state: QaBusState) {
): Promise<T> {
return await waitForCondition(
async () => {
const failureMessage = findFailureOutboundMessage(state, { sinceIndex });
const failureMessage = findFailureOutboundMessage(state, {
sinceIndex,
cursorSpace: "all",
});
if (failureMessage) {
throw new Error(extractQaFailureReplyText(failureMessage.text) ?? failureMessage.text);
}