feat(galaxy): wire SubscriptionRegistry handle resolver into the production writer

2026-06-18 04:20:34 -04:00
parent 2e3f528afc
commit 3ffe45db53
1 changed files with 5 additions and 1 deletions
@@ -253,7 +253,11 @@ public sealed class GalaxyDriver
        _subscriber = new TracedGalaxySubscriber(
            new GatewayGalaxySubscriber(_ownedMxSession), _options.MxAccess.ClientName);
        _dataWriter = new TracedGalaxyDataWriter(
-            new GatewayGalaxyDataWriter(_ownedMxSession, _options.MxAccess.WriteUserId, _logger),
+            // Let the writer borrow live MXAccess item handles the subscription registry already
+            // holds, so the first write to an already-subscribed tag skips a redundant AddItem.
+            new GatewayGalaxyDataWriter(
+                _ownedMxSession, _options.MxAccess.WriteUserId, _logger,
+                _subscriptions.TryResolveItemHandle),
            _options.MxAccess.ClientName);

        _supervisor = new ReconnectSupervisor(