Stabilize edge gateway CI assertions

2026-07-01 11:25:01 +02:00
parent 2ba39b8174
commit 581d28e9ce
3 changed files with 21 additions and 7 deletions
@@ -778,11 +778,14 @@ async function main() {
      { timeoutMs: 15_000, message: "Gateway stream never became ready." }
    );

-    const readyMessage = streamMessages.find((message) => message?.type === "gateway.stream.ready");
-    assert.equal(
-      Boolean(readyMessage?.connected),
-      true,
-      "Gateway stream became ready before the broker reported the gateway as connected."
+    await waitForSocketMessage(
+      streamMessages,
+      (message) => (
+        message?.type === "gateway.stream.ready" && message?.connected === true
+      ) || (
+        message?.type === "presence.changed" && message?.status === "connected"
+      ),
+      { timeoutMs: 45_000, message: "Gateway stream never observed a connected broker presence." }
    );

    const operationResponse = await apiRequest(baseUrl, "POST", `/edge-gateways/${gatewayId}/operations`, {