feat(drivers): AbCip + FOCAS implement IBatchSubscribable

src/Drivers/ZB.MOM.WW.OtOpcUa.Driver.AbCip/AbCipDriver.cs

@@ -24,7 +24,7 @@ namespace ZB.MOM.WW.OtOpcUa.Driver.AbCip;
 ///     (called in <see cref="DeviceState.DisposeHandles"/>); the library's own finalizer
 ///     handles GC-collected tags.</para>
 /// </remarks>
-public sealed class AbCipDriver : IDriver, IReadable, IWritable, ITagDiscovery, ISubscribable,
+public sealed class AbCipDriver : IDriver, IReadable, IWritable, ITagDiscovery, ISubscribable, IBatchSubscribable,
     IHostConnectivityProbe, IPerCallHostResolver, IAlarmSource, ISkippedTagReporter, IDisposable, IAsyncDisposable
 {
     /// <summary>Authored tags this driver could not build into its poll table (Gitea #541).</summary>
@@ -114,6 +114,11 @@ public sealed class AbCipDriver : IDriver, IReadable, IWritable, ITagDiscovery,
     /// <summary>Occurs when a subscribed tag's value changes.</summary>
     public event EventHandler<DataChangeEventArgs>? OnDataChange;
 
+    /// <summary>Occurs once per poll cycle carrying every tag that changed in that cycle. The driver raises
+    /// BOTH events for every burst — this one once, and <see cref="OnDataChange"/> once per changed tag — so
+    /// a consumer must subscribe to EXACTLY ONE of the two or it double-delivers.</summary>
+    public event EventHandler<DataChangeBatchEventArgs>? OnDataChangeBatch;
+
     /// <summary>Occurs when a device's host connectivity status changes.</summary>
     public event EventHandler<HostStatusChangedEventArgs>? OnHostStatusChanged;
 
@@ -151,7 +156,9 @@ public sealed class AbCipDriver : IDriver, IReadable, IWritable, ITagDiscovery,
             onChange: (handle, tagRef, snapshot) =>
                 OnDataChange?.Invoke(this, new DataChangeEventArgs(handle, tagRef, snapshot)),
             onError: HandlePollError,
-            backoffCap: PollBackoffCap);
+            backoffCap: PollBackoffCap,
+            onBatch: (handle, items) =>
+                OnDataChangeBatch?.Invoke(this, new DataChangeBatchEventArgs(handle, items)));
         _alarmProjection = new AbCipAlarmProjection(this, _options.AlarmPollInterval, _logger);
     }
 

src/Drivers/ZB.MOM.WW.OtOpcUa.Driver.FOCAS/FocasDriver.cs

@@ -18,7 +18,7 @@ namespace ZB.MOM.WW.OtOpcUa.Driver.FOCAS;
 ///     + the default <see cref="UnimplementedFocasClientFactory"/> makes misconfigured servers
 ///     fail fast.
 /// </remarks>
-public sealed class FocasDriver : IDriver, IReadable, IWritable, ITagDiscovery, ISubscribable,
+public sealed class FocasDriver : IDriver, IReadable, IWritable, ITagDiscovery, ISubscribable, IBatchSubscribable,
     IHostConnectivityProbe, IPerCallHostResolver, IAlarmSource, ISkippedTagReporter, IDisposable, IAsyncDisposable
 {
     /// <summary>Authored tags this driver could not build into its poll table (Gitea #541). FOCAS has three
@@ -80,6 +80,10 @@ public sealed class FocasDriver : IDriver, IReadable, IWritable, ITagDiscovery,
 
     /// <summary>Occurs when data changes on a subscribed tag.</summary>
     public event EventHandler<DataChangeEventArgs>? OnDataChange;
+    /// <summary>Occurs once per poll cycle carrying every tag that changed in that cycle. The driver raises
+    /// BOTH events for every burst — this one once, and <see cref="OnDataChange"/> once per changed tag — so
+    /// a consumer must subscribe to EXACTLY ONE of the two or it double-delivers.</summary>
+    public event EventHandler<DataChangeBatchEventArgs>? OnDataChangeBatch;
     /// <summary>Occurs when a device host connection status changes.</summary>
     public event EventHandler<HostStatusChangedEventArgs>? OnHostStatusChanged;
     /// <summary>Occurs when an alarm event is raised.</summary>
@@ -112,7 +116,9 @@ public sealed class FocasDriver : IDriver, IReadable, IWritable, ITagDiscovery,
             onChange: (handle, tagRef, snapshot) =>
                 OnDataChange?.Invoke(this, new DataChangeEventArgs(handle, tagRef, snapshot)),
             onError: HandlePollError,
-            backoffCap: PollBackoffCap);
+            backoffCap: PollBackoffCap,
+            onBatch: (handle, items) =>
+                OnDataChangeBatch?.Invoke(this, new DataChangeBatchEventArgs(handle, items)));
     }
 
     /// <summary>True when the supplied DriverConfig JSON carries a real body. The bootstrapper always passes