ohlcv latency fix

coinapi · Mar 29, 2024 · ec85c33 · ec85c33
1 parent be0b48d
commit ec85c33
Showing 1 changed file with 11 additions and 14 deletions.
diff --git a/data-api/csharp-ws/CoinAPI.WebSocket.Stats.Console/Program.cs b/data-api/csharp-ws/CoinAPI.WebSocket.Stats.Console/Program.cs
@@ -149,7 +149,7 @@ public async Task MakeRequest([FromService] IConfiguration configuration, string
                     wsClient.TradeEvent += (s, i) => { ProcessMsg(i.time_exchange, i.time_coinapi, latencyType); };
                     break;
                 case "ohlcv":
-                    wsClient.OHLCVEvent += (s, i) => { ProcessMsg(null, null, latencyType); };
+                    wsClient.OHLCVEvent += (s, i) => { ProcessMsg(i.time_close, null, latencyType); };
                     break;
                 case "exrate":
                     wsClient.ExchangeRateEvent += (s, i) => { msgCount++; };
@@ -185,20 +185,17 @@ void WsClient_Error(object? sender, Exception e)
     private void ProcessMsg(DateTime? time_exchange, DateTime? time_coinapi, LatencyType latencyType)
     {
         msgCount++;
-        if (time_coinapi.HasValue && time_exchange.HasValue)
+        if (latencyType == LatencyType.nc && time_coinapi.HasValue)
         {
-            switch (latencyType)
-            {
-                case LatencyType.nc:
-                    latencyList.Add((DateTime.UtcNow, time_coinapi.Value));
-                    break;
-                case LatencyType.ne:
-                    latencyList.Add((DateTime.UtcNow, time_exchange.Value));
-                    break;
-                case LatencyType.ce:
-                    latencyList.Add((time_coinapi.Value, time_exchange.Value));
-                    break;
-            }
+            latencyList.Add((DateTime.UtcNow, time_coinapi.Value));
+        }
+        else if (latencyType == LatencyType.ne && time_exchange.HasValue)
+        {
+            latencyList.Add((DateTime.UtcNow, time_exchange.Value));
+        }
+        else if (latencyType == LatencyType.ce && time_coinapi.HasValue && time_exchange.HasValue)
+        {
+            latencyList.Add((time_coinapi.Value, time_exchange.Value));
         }
     }