feat(ablegacy): resolve equipment-tag refs (read + write) via EquipmentTagRefResolver

src/Drivers/ZB.MOM.WW.OtOpcUa.Driver.AbLegacy/AbLegacyDriver.cs

@@ -21,6 +21,11 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
     private readonly Dictionary<string, DeviceState> _devices = new(StringComparer.OrdinalIgnoreCase);
     private readonly Dictionary<string, AbLegacyTagDefinition> _tagsByName = new(StringComparer.OrdinalIgnoreCase);
 
+    // Resolves a read/write/subscribe fullReference to a tag definition, bridging the two
+    // authoring models: an authored tag-table entry (by name) OR an equipment tag whose
+    // reference is its raw TagConfig JSON (parsed once via AbLegacyEquipmentTagParser, cached).
+    private readonly EquipmentTagRefResolver<AbLegacyTagDefinition> _resolver;
+
     // volatile: _health is read by GetHealth() on any thread while ReadAsync / WriteAsync /
     // InitializeAsync write it from worker / poll threads. The record-reference assignment is
     // atomic on all .NET platforms, but without a memory barrier a reader can see a stale
@@ -54,6 +59,9 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
         _driverInstanceId = driverInstanceId;
         _tagFactory = tagFactory ?? new LibplctagLegacyTagFactory();
         _logger = logger ?? NullLogger<AbLegacyDriver>.Instance;
+        _resolver = new EquipmentTagRefResolver<AbLegacyTagDefinition>(
+            r => _tagsByName.TryGetValue(r, out var t) ? t : null,
+            r => AbLegacyEquipmentTagParser.TryParse(r, out var d) ? d : null);
         _poll = new PollGroupEngine(
             reader: ReadAsync,
             onChange: (handle, tagRef, snapshot) =>
@@ -143,6 +151,7 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
             }
             _devices.Clear();
             _tagsByName.Clear();
+            _resolver.Clear(); // drop transient equipment-tag parses so a config change re-parses
             throw;
         }
         return Task.CompletedTask;
@@ -177,6 +186,7 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
         }
         _devices.Clear();
         _tagsByName.Clear();
+        _resolver.Clear(); // drop transient equipment-tag parses so a config change re-parses
         _health = new DriverHealth(DriverState.Unknown, _health.LastSuccessfulRead, null);
     }
 
@@ -230,7 +240,7 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
         for (var i = 0; i < fullReferences.Count; i++)
         {
             var reference = fullReferences[i];
-            if (!_tagsByName.TryGetValue(reference, out var def))
+            if (!_resolver.TryResolve(reference, out var def))
             {
                 results[i] = new DataValueSnapshot(null, AbLegacyStatusMapper.BadNodeIdUnknown, null, now);
                 continue;
@@ -320,7 +330,7 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
         for (var i = 0; i < writes.Count; i++)
         {
             var w = writes[i];
-            if (!_tagsByName.TryGetValue(w.FullReference, out var def))
+            if (!_resolver.TryResolve(w.FullReference, out var def))
             {
                 results[i] = new WriteResult(AbLegacyStatusMapper.BadNodeIdUnknown);
                 continue;
@@ -734,6 +744,7 @@ public sealed class AbLegacyDriver : IDriver, IReadable, IWritable, ITagDiscover
         }
         _devices.Clear();
         _tagsByName.Clear();
+        _resolver.Clear(); // drop transient equipment-tag parses so a config change re-parses
         _health = new DriverHealth(DriverState.Unknown, _health.LastSuccessfulRead, null);
     }