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

[gateio-stream] Fix getting of orderbook
duplessisc · May 28, 2024 · 42f76de · 42f76de
2 parents f9fea8e + 011e37c
commit 42f76de
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());
   }