Added session number metric to node death received event. Fixes #60.

src/SparkplugNet.Examples/Program.cs

@@ -460,7 +460,7 @@ private static Task OnApplicationVersionANodeDataReceived(VersionA.SparkplugAppl
     /// <summary>
     /// Handles the node death received callback for version A applications.
     /// </summary>
-    private static Task OnApplicationVersionANodeDeathReceived(Core.SparkplugBase<VersionAData.KuraMetric>.NodeEventArgs args)
+    private static Task OnApplicationVersionANodeDeathReceived(Core.SparkplugBase<VersionAData.KuraMetric>.NodeDeathEventArgs args)
     {
         // Do something.
         return Task.CompletedTask;
@@ -602,7 +602,7 @@ private static Task OnApplicationVersionBNodeDataReceived(VersionB.SparkplugAppl
     /// <summary>
     /// Handles the node death received callback for version B applications.
     /// </summary>
-    private static Task OnApplicationVersionBNodeDeathReceived(Core.SparkplugBase<VersionBData.Metric>.NodeEventArgs args)
+    private static Task OnApplicationVersionBNodeDeathReceived(Core.SparkplugBase<VersionBData.Metric>.NodeDeathEventArgs args)
     {
         // Do something.
         return Task.CompletedTask;

src/SparkplugNet/Core/Application/SparkplugApplicationBase.Events.cs

@@ -162,12 +162,12 @@ protected virtual Task FireNodeBirthReceived(string groupIdentifier, string edge
     /// <summary>
     /// The node death received event.
     /// </summary>
-    protected AsyncEvent<NodeEventArgs> NodeDeathReceivedEvent = new();
+    protected AsyncEvent<NodeDeathEventArgs> NodeDeathReceivedEvent = new();
 
     /// <summary>
     /// Occurs when the node death was received.
     /// </summary>
-    public event Func<NodeEventArgs, Task> NodeDeathReceived
+    public event Func<NodeDeathEventArgs, Task> NodeDeathReceived
     {
         add => this.NodeDeathReceivedEvent.AddHandler(value);
         remove => this.NodeDeathReceivedEvent.RemoveHandler(value);
@@ -178,9 +178,10 @@ protected virtual Task FireNodeBirthReceived(string groupIdentifier, string edge
     /// </summary>
     /// <param name="groupIdentifier">The group identifier.</param>
     /// <param name="edgeNodeIdentifier">The edge node identifier.</param>
-    protected virtual Task FireNodeDeathReceived(string groupIdentifier, string edgeNodeIdentifier)
+    /// <param name="sessionNumberMetric">The session number metric.</param>
+    protected virtual Task FireNodeDeathReceived(string groupIdentifier, string edgeNodeIdentifier, T? sessionNumberMetric)
     {
-        var nodeEventArgs = new NodeEventArgs(this, groupIdentifier, edgeNodeIdentifier);
+        var nodeEventArgs = new NodeDeathEventArgs(this, groupIdentifier, edgeNodeIdentifier, sessionNumberMetric);
         return this.NodeDeathReceivedEvent.InvokeAsync(nodeEventArgs);
     }
     #endregion

src/SparkplugNet/Core/SparkplugBase.EventArgs.cs

@@ -154,4 +154,32 @@ public NodeBirthEventArgs(SparkplugBase<T> sender, string groupIdentifier, strin
         /// </summary>
         public IEnumerable<T> Metrics { get; }
     }
+
+    /// <inheritdoc cref="NodeEventArgs" />
+    /// <summary>
+    /// A class for the node death event args.
+    /// </summary>
+    /// <seealso cref="NodeEventArgs" />
+    public sealed class NodeDeathEventArgs : NodeEventArgs
+    {
+        /// <inheritdoc cref="NodeEventArgs" />
+        /// <summary>
+        /// Initializes a new instance of the <see cref="NodeDeathEventArgs"/> class.
+        /// </summary>
+        /// <param name="sender">The sender.</param>
+        /// <param name="groupIdentifier">The group identifier.</param>
+        /// <param name="edgeNodeIdentifier">The edge node identifier.</param>
+        /// <param name="sessionNumberMetric">The session number metric.</param>
+        /// <seealso cref="NodeEventArgs" />
+        public NodeDeathEventArgs(SparkplugBase<T> sender, string groupIdentifier, string edgeNodeIdentifier, T? sessionNumberMetric)
+            : base(sender, groupIdentifier, edgeNodeIdentifier)
+        {
+            this.SessionNumberMetric = sessionNumberMetric;
+        }
+
+        /// <summary>
+        /// Gets the session number metric.
+        /// </summary>
+        public T? SessionNumberMetric { get; }
+    }
 }

src/SparkplugNet/VersionA/SparkplugApplication.cs

@@ -202,7 +202,7 @@ private async Task HandleMessagesForVersionA(SparkplugMessageTopic topic, Versio
                 break;
             case SparkplugMessageType.NodeDeath:
                 this.ProcessPayload(topic, filteredMetrics, SparkplugMetricStatus.Offline);
-                await this.FireNodeDeathReceived(topic.GroupIdentifier, topic.EdgeNodeIdentifier);
+                await this.FireNodeDeathReceived(topic.GroupIdentifier, topic.EdgeNodeIdentifier, sessionNumberMetric);
                 break;
             case SparkplugMessageType.DeviceDeath:
                 if (string.IsNullOrWhiteSpace(topic.DeviceIdentifier))

src/SparkplugNet/VersionB/SparkplugApplication.cs

@@ -188,7 +188,7 @@ private async Task HandleMessagesForVersionB(SparkplugMessageTopic topic, Payloa
                 break;
             case SparkplugMessageType.NodeDeath:
                 this.ProcessPayload(topic, filteredMetrics, SparkplugMetricStatus.Offline);
-                await this.FireNodeDeathReceived(topic.GroupIdentifier, topic.EdgeNodeIdentifier);
+                await this.FireNodeDeathReceived(topic.GroupIdentifier, topic.EdgeNodeIdentifier, sessionNumberMetric);
                 break;
             case SparkplugMessageType.DeviceDeath:
                 if (string.IsNullOrWhiteSpace(topic.DeviceIdentifier))