From cdba4f6791e5e832645d79bb31d174401b3107e1 Mon Sep 17 00:00:00 2001
From: Iris Deploy <noreply@iris.to>
Date: Wed, 28 Jan 2026 11:43:54 +0100
Subject: [PATCH] ndr: close existing bus before restart to prevent duplicate
 listeners
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>
---
 extensions/ndr/src/channel.ts | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/extensions/ndr/src/channel.ts b/extensions/ndr/src/channel.ts
index 8704cdf25..82e79c467 100644
--- a/extensions/ndr/src/channel.ts
+++ b/extensions/ndr/src/channel.ts
@@ -184,6 +184,14 @@ export const ndrPlugin: ChannelPlugin<ResolvedNdrAccount> = {
       });
       ctx.log?.info(`[${account.accountId}] starting NDR provider`);
 
+      // Close existing bus if any (prevents duplicate listeners on restart)
+      const existingBus = activeBuses.get(account.accountId);
+      if (existingBus) {
+        ctx.log?.info(`[${account.accountId}] closing existing NDR bus before restart`);
+        existingBus.close();
+        activeBuses.delete(account.accountId);
+      }
+
       const runtime = getNdrRuntime();
 
       const bus = await startNdrBus({