fix(broker): reconnect application-dead node links

.agentworkforce/trajectories/completed/2026-08/traj_iv95g9euppbw.trace.json

@@ -0,0 +1,42 @@
+{
+  "version": "1.0.0",
+  "id": "f1c6df14-5543-4d93-ba01-81d22ed56675",
+  "timestamp": "2026-08-26T00:39:15.360Z",
+  "trajectory": "traj_iv95g9euppbw",
+  "files": [
+    {
+      "path": ".agentworkforce/trajectories/active/traj_iv95g9euppbw/trajectory.json",
+      "conversations": [
+        {
+          "contributor": {
+            "type": "ai"
+          },
+          "ranges": [
+            {
+              "start_line": 1,
+              "end_line": 50,
+              "revision": "8e46228dea1e0ab93b37e2fb5c9dc2754f2eb323"
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "path": "tests/relayflows/cases/1591-application-ack-reconnect/run.mjs",
+      "conversations": [
+        {
+          "contributor": {
+            "type": "ai"
+          },
+          "ranges": [
+            {
+              "start_line": 85,
+              "end_line": 113,
+              "revision": "8e46228dea1e0ab93b37e2fb5c9dc2754f2eb323"
+            }
+          ]
+        }
+      ]
+    }
+  ]
+}

.agentworkforce/trajectories/completed/2026-08/traj_iv95g9euppbw/summary.md

@@ -0,0 +1,39 @@
+# Trajectory: Stabilize PR 1610 proof shutdown
+
+> **Status:** ✅ Completed
+> **Task:** PR-1610
+> **Confidence:** 95%
+> **Started:** August 26, 2026 at 02:38 AM
+> **Completed:** August 26, 2026 at 02:39 AM
+
+---
+
+## Summary
+
+Removed the reconnect observation race from the application-ack RelayFlow harness.
+
+**Approach:** Kept the first socket responsive until closure, accepted the second connection deterministically, then aborted the client only for harness cleanup.
+
+---
+
+## Key Decisions
+
+### Keep the reconnected loopback WebSocket alive until the harness captures the reconnect
+- **Chose:** Keep the reconnected loopback WebSocket alive until the harness captures the reconnect
+- **Reasoning:** The harness only needs to deterministically observe a second public node-control connection; aborting the client afterward avoids an irrelevant shutdown race.
+
+---
+
+## Chapters
+
+### 1. Work
+*Agent: default*
+
+- Keep the reconnected loopback WebSocket alive until the harness captures the reconnect: Keep the reconnected loopback WebSocket alive until the harness captures the reconnect
+
+---
+
+## Artifacts
+
+**Commits:** 8e46228de
+**Files changed:** 2

.agentworkforce/trajectories/completed/2026-08/traj_iv95g9euppbw/trajectory.json

@@ -0,0 +1,63 @@
+{
+  "id": "traj_iv95g9euppbw",
+  "version": 1,
+  "task": {
+    "title": "Stabilize PR 1610 proof shutdown",
+    "source": {
+      "system": "plain",
+      "id": "PR-1610"
+    }
+  },
+  "status": "completed",
+  "startedAt": "2026-08-26T00:38:05.964Z",
+  "completedAt": "2026-08-26T00:39:14.893Z",
+  "agents": [
+    {
+      "name": "default",
+      "role": "lead",
+      "joinedAt": "2026-08-26T00:38:21.120Z"
+    }
+  ],
+  "chapters": [
+    {
+      "id": "chap_f2ig35c45rtp",
+      "title": "Work",
+      "agentName": "default",
+      "startedAt": "2026-08-26T00:38:21.120Z",
+      "endedAt": "2026-08-26T00:39:14.893Z",
+      "events": [
+        {
+          "ts": 1787704701149,
+          "type": "decision",
+          "content": "Keep the reconnected loopback WebSocket alive until the harness captures the reconnect: Keep the reconnected loopback WebSocket alive until the harness captures the reconnect",
+          "raw": {
+            "question": "Keep the reconnected loopback WebSocket alive until the harness captures the reconnect",
+            "chosen": "Keep the reconnected loopback WebSocket alive until the harness captures the reconnect",
+            "alternatives": [],
+            "reasoning": "The harness only needs to deterministically observe a second public node-control connection; aborting the client afterward avoids an irrelevant shutdown race."
+          },
+          "significance": "high"
+        }
+      ]
+    }
+  ],
+  "retrospective": {
+    "summary": "Removed the reconnect observation race from the application-ack RelayFlow harness.",
+    "approach": "Kept the first socket responsive until closure, accepted the second connection deterministically, then aborted the client only for harness cleanup.",
+    "confidence": 0.95
+  },
+  "commits": [
+    "8e46228de"
+  ],
+  "filesChanged": [
+    ".agentworkforce/trajectories/active/traj_iv95g9euppbw/trajectory.json",
+    "tests/relayflows/cases/1591-application-ack-reconnect/run.mjs"
+  ],
+  "projectId": "AgentWorkforce/relay",
+  "tags": [],
+  "_trace": {
+    "startRef": "4a3e03106837e71d9d1f223ae727300449e68431",
+    "endRef": "8e46228dea1e0ab93b37e2fb5c9dc2754f2eb323",
+    "traceId": "f1c6df14-5543-4d93-ba01-81d22ed56675"
+  }
+}

.agentworkforce/trajectories/completed/2026-08/traj_l0imiqugdc9k.trace.json

@@ -0,0 +1,52 @@
+{
+  "version": "1.0.0",
+  "id": "f0436409-faf2-4c70-8a78-761f272534b1",
+  "timestamp": "2026-08-26T00:37:34.286Z",
+  "trajectory": "traj_l0imiqugdc9k",
+  "files": [
+    {
+      "path": ".agentworkforce/trajectories/active/traj_l0imiqugdc9k/trajectory.json",
+      "conversations": [
+        {
+          "contributor": {
+            "type": "ai"
+          },
+          "ranges": [
+            {
+              "start_line": 1,
+              "end_line": 50,
+              "revision": "dbdea083abe058d5f94574b893103191f59d6c8b"
+            }
+          ]
+        }
+      ]
+    },
+    {
+      "path": "crates/broker/src/node_control.rs",
+      "conversations": [
+        {
+          "contributor": {
+            "type": "ai"
+          },
+          "ranges": [
+            {
+              "start_line": 1729,
+              "end_line": 1735,
+              "revision": "dbdea083abe058d5f94574b893103191f59d6c8b"
+            },
+            {
+              "start_line": 1738,
+              "end_line": 1779,
+              "revision": "dbdea083abe058d5f94574b893103191f59d6c8b"
+            },
+            {
+              "start_line": 3287,
+              "end_line": 3306,
+              "revision": "dbdea083abe058d5f94574b893103191f59d6c8b"
+            }
+          ]
+        }
+      ]
+    }
+  ]
+}

.agentworkforce/trajectories/completed/2026-08/traj_l0imiqugdc9k/summary.md

@@ -0,0 +1,39 @@
+# Trajectory: Address PR 1610 ordered liveness probe review
+
+> **Status:** ✅ Completed
+> **Task:** PR-1610
+> **Confidence:** 95%
+> **Started:** August 26, 2026 at 02:34 AM
+> **Completed:** August 26, 2026 at 02:37 AM
+
+---
+
+## Summary
+
+Preserved newer inventory probes across older acknowledgements and added an A-acknowledged/B-rejected regression.
+
+**Approach:** Tracked inventory probe IDs in send order and covered the ordered acknowledgement/rejection sequence with a focused regression test.
+
+---
+
+## Key Decisions
+
+### Track pending inventory probes in send order and drain only through the acknowledged probe
+- **Chose:** Track pending inventory probes in send order and drain only through the acknowledged probe
+- **Reasoning:** Relaycast serializes node control work; acknowledging A proves older probes but not newer B, whose later rejection must still force reconnect.
+
+---
+
+## Chapters
+
+### 1. Work
+*Agent: default*
+
+- Track pending inventory probes in send order and drain only through the acknowledged probe: Track pending inventory probes in send order and drain only through the acknowledged probe
+
+---
+
+## Artifacts
+
+**Commits:** dbdea083a
+**Files changed:** 2

.agentworkforce/trajectories/completed/2026-08/traj_l0imiqugdc9k/trajectory.json

@@ -0,0 +1,63 @@
+{
+  "id": "traj_l0imiqugdc9k",
+  "version": 1,
+  "task": {
+    "title": "Address PR 1610 ordered liveness probe review",
+    "source": {
+      "system": "plain",
+      "id": "PR-1610"
+    }
+  },
+  "status": "completed",
+  "startedAt": "2026-08-26T00:34:00.303Z",
+  "completedAt": "2026-08-26T00:37:33.497Z",
+  "agents": [
+    {
+      "name": "default",
+      "role": "lead",
+      "joinedAt": "2026-08-26T00:34:05.830Z"
+    }
+  ],
+  "chapters": [
+    {
+      "id": "chap_osj8m7sxxbfj",
+      "title": "Work",
+      "agentName": "default",
+      "startedAt": "2026-08-26T00:34:05.830Z",
+      "endedAt": "2026-08-26T00:37:33.497Z",
+      "events": [
+        {
+          "ts": 1787704445834,
+          "type": "decision",
+          "content": "Track pending inventory probes in send order and drain only through the acknowledged probe: Track pending inventory probes in send order and drain only through the acknowledged probe",
+          "raw": {
+            "question": "Track pending inventory probes in send order and drain only through the acknowledged probe",
+            "chosen": "Track pending inventory probes in send order and drain only through the acknowledged probe",
+            "alternatives": [],
+            "reasoning": "Relaycast serializes node control work; acknowledging A proves older probes but not newer B, whose later rejection must still force reconnect."
+          },
+          "significance": "high"
+        }
+      ]
+    }
+  ],
+  "retrospective": {
+    "summary": "Preserved newer inventory probes across older acknowledgements and added an A-acknowledged/B-rejected regression.",
+    "approach": "Tracked inventory probe IDs in send order and covered the ordered acknowledgement/rejection sequence with a focused regression test.",
+    "confidence": 0.95
+  },
+  "commits": [
+    "dbdea083a"
+  ],
+  "filesChanged": [
+    ".agentworkforce/trajectories/active/traj_l0imiqugdc9k/trajectory.json",
+    "crates/broker/src/node_control.rs"
+  ],
+  "projectId": "AgentWorkforce/relay",
+  "tags": [],
+  "_trace": {
+    "startRef": "5971b921932d6a0f0baffafa0b1fdb9239bd3fc5",
+    "endRef": "dbdea083abe058d5f94574b893103191f59d6c8b",
+    "traceId": "f0436409-faf2-4c70-8a78-761f272534b1"
+  }
+}