Elaborate system that fails to fix unreliable connections.

lynxkite-app/web/tests/lynxkite.ts

@@ -97,10 +97,7 @@ export class Workspace {
   }
 
   getBoxHandle(boxId: string, pos?: string) {
-    if (pos) {
-      return this.page.locator(`[data-id="${boxId}"] [data-handlepos="${pos}"]`);
-    }
-    return this.page.getByTestId(boxId);
+    return this.page.locator(`.connectable[data-nodeid="${boxId}"][data-handlepos="${pos}"]`);
   }
 
   async moveBox(
@@ -129,13 +126,26 @@ export class Workspace {
     await this.page.mouse.up();
   }
 
-  async connectBoxes(sourceId: string, targetId: string) {
+  async tryToConnectBoxes(sourceId: string, targetId: string) {
     const sourceHandle = this.getBoxHandle(sourceId, "right");
     const targetHandle = this.getBoxHandle(targetId, "left");
     await sourceHandle.hover();
     await this.page.mouse.down();
+    await expect(this.page.locator(".react-flow__connectionline")).toBeVisible({ timeout: 1000 });
     await targetHandle.hover();
     await this.page.mouse.up();
+    await expect(
+      this.page.locator(`.react-flow__edge[aria-label="Edge from ${sourceId} to ${targetId}"`),
+    ).toBeVisible({ timeout: 1000 });
+  }
+  async connectBoxes(sourceId: string, targetId: string) {
+    for (let retry = 0; retry < 10; retry++) {
+      try {
+        await this.tryToConnectBoxes(sourceId, targetId);
+        return;
+      } catch (e) {}
+    }
+    await this.tryToConnectBoxes(sourceId, targetId);
   }
 
   async execute() {