refactor: DataReceived event

jirikostiha · Jan 2, 2025 · 8d66f1c · 8d66f1c
1 parent 2ac80c3
commit 8d66f1c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/SyncAPIConnector/StreamingApiConnector.cs b/src/SyncAPIConnector/StreamingApiConnector.cs
@@ -37,6 +37,7 @@ public StreamingApiConnector(IPEndPoint endpoint, IStreamingListener? streamingL
     }
 
     #region Events
+
     /// <summary>
     /// Event raised when a command is being executed.
     /// </summary>
@@ -45,7 +46,7 @@ public StreamingApiConnector(IPEndPoint endpoint, IStreamingListener? streamingL
     /// <summary>
     /// Event raised when a streaming data is being received.
     /// </summary>
-    public event EventHandler<string>? StreamingDataReceived;
+    public event EventHandler<DataReceivedEventArgs>? DataReceived;
 
     /// <summary>
     /// Event raised when a tick record is received.
@@ -179,7 +180,7 @@ private async Task ReadStreamMessageAsync(CancellationToken cancellationToken =
 
             var jsonDataObject = jsonSubnode.AsObject();
 
-            StreamingDataReceived?.Invoke(this, dataType);
+            DataReceived?.Invoke(this, new(dataType, responseBody));
 
             if (dataType == StreamingDataType.TickPrices)
             {

diff --git a/src/SyncAPIConnector/abstraction/EventArgs.cs b/src/SyncAPIConnector/abstraction/EventArgs.cs
@@ -1,5 +1,6 @@
 using System;
 using System.Net;
+using System.Text.Json.Nodes;
 using Xtb.XApi.Records;
 
 namespace Xtb.XApi;
@@ -28,9 +29,11 @@ public class EndpointEventArgs(IPEndPoint endpoint) : EventArgs
     public IPEndPoint EndPoint { get; } = endpoint;
 }
 
-public class StreamingDataReceivedEventArgs(string dataType) : EventArgs
+public class DataReceivedEventArgs(string dataType, JsonNode responseObject) : EventArgs
 {
     public string DataType { get; } = dataType;
+
+    public JsonNode ResponseBody { get; } = responseObject;
 }
 
 public class TickReceivedEventArgs(StreamingTickRecord tickRecord) : EventArgs