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

perf(feishu): avoid unconditional lifecycle waits

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-25 03:41:11 +01:00
parent a6d16a2153
commit 460720d0a1
1 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
extensions/feishu/src/test-support/lifecycle-test-support.ts
View File

@@ -298,6 +298,17 @@ export function createFeishuTextMessageEvent(params: {
};
}
async function expectFeishuLifecycleEventually(
assertion: () => void | Promise<void>,
timeoutMs: number,
) {
try {
await assertion();
} catch {
await vi.waitFor(assertion, { timeout: timeoutMs });
}
}
export async function replayFeishuLifecycleEvent(params: {
handler: (data: unknown) => Promise<void>;
event: unknown;
@@ -305,11 +316,11 @@ export async function replayFeishuLifecycleEvent(params: {
waitForSecond?: () => void | Promise<void>;
waitTimeoutMs?: number;
}) {
const waitOptions = { timeout: params.waitTimeoutMs ?? FEISHU_LIFECYCLE_WAIT_TIMEOUT_MS };
const waitTimeoutMs = params.waitTimeoutMs ?? FEISHU_LIFECYCLE_WAIT_TIMEOUT_MS;
await params.handler(params.event);
await vi.waitFor(params.waitForFirst, waitOptions);
await expectFeishuLifecycleEventually(params.waitForFirst, waitTimeoutMs);
await params.handler(params.event);
await vi.waitFor(params.waitForSecond ?? params.waitForFirst, waitOptions);
await expectFeishuLifecycleEventually(params.waitForSecond ?? params.waitForFirst, waitTimeoutMs);
}
export async function runFeishuLifecycleSequence(
@@ -318,9 +329,10 @@ export async function runFeishuLifecycleSequence(
) {
for (const [index, deliver] of deliveries.entries()) {
await deliver();
await vi.waitFor(waits[index] ?? waits.at(-1) ?? (() => {}), {
timeout: FEISHU_LIFECYCLE_WAIT_TIMEOUT_MS,
});
await expectFeishuLifecycleEventually(
waits[index] ?? waits.at(-1) ?? (() => {}),
FEISHU_LIFECYCLE_WAIT_TIMEOUT_MS,
);
}
}