Skip to content

Commit 02a6858

Browse files
committed
Added check in socketClient.SpotApi order book queries for null message
1 parent bbaeee9 commit 02a6858

1 file changed

Lines changed: 14 additions & 2 deletions

File tree

HTX.Net/Clients/SpotApi/HTXSocketClientSpotApi.cs

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,13 @@ public async Task<CallResult<HTXOrderBook>> GetOrderBookWithMergeStepAsync(strin
109109

110110
var query = new HTXQuery<HTXOrderBook>(this, $"market.{symbol}.depth.step{mergeStep}", false);
111111
var result = await QueryAsync(BaseAddress.AppendPath("ws"), query).ConfigureAwait(false);
112-
return result ? result.As(result.Data.Data) : result.AsError<HTXOrderBook>(result.Error!);
112+
if (!result)
113+
return result.AsError<HTXOrderBook>(result.Error!);
114+
115+
if (result.Data.Data == null)
116+
return result.AsError<HTXOrderBook>(new ServerError(ErrorInfo.Unknown with { Message = "No data in message" }));
117+
118+
return result.As(result.Data.Data);
113119
}
114120

115121
/// <inheritdoc />
@@ -120,7 +126,13 @@ public async Task<CallResult<HTXIncementalOrderBook>> GetOrderBookAsync(string s
120126

121127
var query = new HTXQuery<HTXIncementalOrderBook>(this, $"market.{symbol}.mbp.{levels}", false);
122128
var result = await QueryAsync(BaseAddress.AppendPath("feed"), query).ConfigureAwait(false);
123-
return result ? result.As(result.Data.Data) : result.AsError<HTXIncementalOrderBook>(result.Error!);
129+
if (!result)
130+
return result.AsError<HTXIncementalOrderBook>(result.Error!);
131+
132+
if (result.Data.Data == null)
133+
return result.AsError<HTXIncementalOrderBook>(new ServerError(ErrorInfo.Unknown with { Message = "No data in message" }));
134+
135+
return result.As(result.Data.Data);
124136
}
125137

126138
/// <inheritdoc />

0 commit comments

Comments
 (0)