Merge pull request #4854 from bigscoop/gate-stream-fix-orderbook

[gateio-stream] Fix getting of orderbook
knowm · Apr 26, 2024 · 345d120 · 345d120
2 parents 31cd4f5 + 47733ed
commit 345d120
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...tream-gateio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingAdapters.java b/...tream-gateio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingAdapters.java
@@ -94,7 +94,7 @@ public OrderBook toOrderBook(GateioOrderBookNotification notification) {
     Stream<LimitOrder> asks = orderBookPayload.getAsks().stream()
         .map(priceSizeEntry -> new LimitOrder(OrderType.ASK, priceSizeEntry.getSize(), orderBookPayload.getCurrencyPair(), null, null, priceSizeEntry.getPrice()));
 
-    Stream<LimitOrder> bids = orderBookPayload.getAsks().stream()
+    Stream<LimitOrder> bids = orderBookPayload.getBids().stream()
         .map(priceSizeEntry -> new LimitOrder(OrderType.BID, priceSizeEntry.getSize(), orderBookPayload.getCurrencyPair(), null, null, priceSizeEntry.getPrice()));
 
     return new OrderBook(Date.from(orderBookPayload.getTimestamp()), asks, bids);

diff --git a/...t/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataServiceIntegration.java b/...t/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataServiceIntegration.java
@@ -33,6 +33,9 @@ void order_book() {
     assertThat(orderBook).hasNoNullFieldsOrProperties();
     assertThat(orderBook.getBids()).hasSize(10);
     assertThat(orderBook.getAsks()).hasSize(10);
+
+    // bids should be lower than asks
+    assertThat(orderBook.getBids().get(0).getLimitPrice()).isLessThan(orderBook.getAsks().get(0).getLimitPrice());
   }