generate clients

Author: theo-s68

clients/algo/docs/rest-api/migration-guide.md

@@ -22,7 +22,7 @@ With the transition to a modularized structure, the Binance Connector has been s
 <dependency>
   <groupId>io.github.binance</groupId>
   <artifactId>binance-algo</artifactId>
-  <version>1.2.0</version>
+  <version>1.2.1</version>
 </dependency>
 ```
 
@@ -91,7 +91,7 @@ by:
  <dependency>
      <groupId>io.github.binance</groupId>
      <artifactId>binance-algo</artifactId>
-     <version>1.2.0</version>
+     <version>1.2.1</version>
  </dependency>
 ```
 

clients/c2c/docs/rest-api/migration-guide.md

@@ -22,7 +22,7 @@ With the transition to a modularized structure, the Binance Connector has been s
 <dependency>
   <groupId>io.github.binance</groupId>
   <artifactId>binance-c2c</artifactId>
-  <version>1.2.0</version>
+  <version>1.2.1</version>
 </dependency>
 ```
 
@@ -91,7 +91,7 @@ by:
  <dependency>
      <groupId>io.github.binance</groupId>
      <artifactId>binance-c2c</artifactId>
-     <version>1.2.0</version>
+     <version>1.2.1</version>
  </dependency>
 ```
 

clients/common/pom.xml

@@ -10,6 +10,6 @@
 
     <artifactId>binance-common</artifactId>
     <name>common</name>
-    <version>2.0.1</version>
+    <version>2.1.0</version>
     <packaging>jar</packaging>
 </project>

clients/common/src/main/java/com/binance/connector/client/common/websocket/adapter/stream/StreamConnectionWrapper.java

@@ -32,6 +32,12 @@ public class StreamConnectionWrapper extends ConnectionWrapper
     private final HashMap<String, List<StreamBlockingQueue<String>>> subscriptions =
             new HashMap<>();
 
+    private StreamResponse defaultStreamResponse = new StreamResponse();
+
+    private Boolean isRaw = false;
+
+    private static String DEFAULT_QUEUE = "DEFAULT";
+
     public StreamConnectionWrapper(WebSocketClientConfiguration configuration, Gson json) {
         super(configuration, json);
     }
@@ -45,6 +51,12 @@ public StreamConnectionWrapper(
         super(configuration, webSocketClient);
     }
 
+    public StreamResponse subscribeRaw(RequestWrapperDTO<Set<String>, Object> requestWrapperDTO) {
+        this.innerSend(requestWrapperDTO);
+        this.isRaw = true;
+        return defaultStreamResponse;
+    }
+
     public Map<String, StreamBlockingQueue<String>> subscribe(
             RequestWrapperDTO<Set<String>, Object> requestWrapperDTO) {
         HashMap<String, StreamBlockingQueue<String>> queueMap = new HashMap<>();
@@ -92,6 +104,10 @@ public void unsubscribe(StreamBlockingQueue queue) {
 
     @Override
     public void onWebSocketText(String message) {
+        if (isRaw) {
+            this.defaultStreamResponse.produce(message);
+            return;
+        }
         try {
             JsonElement root = JsonParser.parseString(message);
             JsonObject obj = root.getAsJsonObject();

clients/common/src/main/java/com/binance/connector/client/common/websocket/adapter/stream/StreamResponse.java

@@ -0,0 +1,17 @@
+package com.binance.connector.client.common.websocket.adapter.stream;
+
+import java.util.function.Consumer;
+
+public class StreamResponse {
+    private Consumer<String> onMessage;
+
+    public void onMessage(Consumer<String> callback) {
+        this.onMessage = callback;
+    }
+
+    public void produce(String item) {
+        if (onMessage != null) {
+            onMessage.accept(item);
+        }
+    }
+}