From 75bc2b21406981f97caa8235c31bf7b7083e35b6 Mon Sep 17 00:00:00 2001
From: Victor Lee <dev-github@vslee.com>
Date: Sun, 27 Feb 2022 14:03:50 -0800
Subject: [PATCH] parse error in FTX trade stream

---
 src/ExchangeSharp/API/Exchanges/FTX/FTXGroupCommon.cs | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/ExchangeSharp/API/Exchanges/FTX/FTXGroupCommon.cs b/src/ExchangeSharp/API/Exchanges/FTX/FTXGroupCommon.cs
index 2a0abdc8..320065ae 100644
--- a/src/ExchangeSharp/API/Exchanges/FTX/FTXGroupCommon.cs
+++ b/src/ExchangeSharp/API/Exchanges/FTX/FTXGroupCommon.cs
@@ -404,7 +404,11 @@ protected override async Task<IWebSocket> OnGetTradesWebSocketAsync(Func<KeyValu
 			{
 				JToken parsedMsg = JToken.Parse(msg.ToStringFromUTF8());
 
-				if (parsedMsg["channel"].ToStringInvariant().Equals("trades")
+				if (parsedMsg["type"].ToStringInvariant() == "error")
+				{
+					throw new APIException(parsedMsg["msg"].ToStringInvariant());
+				}
+				else if (parsedMsg["channel"].ToStringInvariant().Equals("trades")
 				&& !parsedMsg["type"].ToStringInvariant().Equals("subscribed"))
 				{
 					foreach (var data in parsedMsg["data"])
@@ -424,7 +428,7 @@ await _socket.SendMessageAsync(new
 					{
 						op = "subscribe",
 						market = marketSymbols[i],
-						channel = "trades"
+						channel = "trades",
 					});
 				}
 			});