wip

Author: valeratrades

.envrc

@@ -1 +1,6 @@
 use flake
+
+toolchain_path="./.cargo/rust-toolchain.toml"
+if rg -q "nightly" "$toolchain_path"; then
+  export RUSTFLAGS="$RUSTFLAGS -C link-arg=-fuse-ld=mold --cfg tokio_unstable -Z threads=8 -Z track-diagnostics"
+fi

Cargo.toml

@@ -1,3 +1,5 @@
+cargo-features = ["codegen-backend"]
+
 [workspace]
 members = [
 	"v_exchanges",
@@ -22,7 +24,7 @@ serde_json = "1.0.133"
 serde_with = "3.11.0"
 thiserror = "2.0.7"
 tokio = { version = "^1.42.0", features = ["full"] }
-tokio-tungstenite = { version = "^0.25.0", features = ["native-tls"] }
+tokio-tungstenite = { version = "^0.26.0", features = ["native-tls"] }
 tracing = "0.1.41"
 url = "2.5.4"
 v_utils = { version = "^1.9.1", features = ["trades", "tracing"], path = "../v_utils/v_utils" }

v_exchanges/Cargo.toml

@@ -23,6 +23,6 @@ v_utils.workspace = true
 color-eyre.workspace = true
 
 # #dbg
-rust_decimal = { version = "1.33.0", features = ["serde-with-str", "serde-with-float"] }
-env_logger = "0.10.1"
+rust_decimal = { version = "1.36.0", features = ["serde-with-str", "serde-with-float"] }
+env_logger = "0.11.5"
 #

v_exchanges/src/main.rs

@@ -1,6 +1,4 @@
-use rust_decimal::prelude::*;
-use serde::{Deserialize, Serialize};
-use serde_json::json;
+use serde::Serialize;
 use v_exchanges_adapters::{
 	Client,
 	binance::{BinanceHttpUrl, BinanceOption},

v_exchanges_adapters/Cargo.toml

@@ -1,3 +1,5 @@
+cargo-features = ["codegen-backend"]
+
 [package]
 name = "v_exchanges_adapters"
 version = "0.1.0"

v_exchanges_api_generics/Cargo.toml

@@ -1,3 +1,5 @@
+cargo-features = ["codegen-backend"]
+
 [package]
 name = "v_exchanges_api_generics"
 version = "0.3.0"
@@ -20,7 +22,7 @@ reqwest.workspace = true
 serde.workspace = true
 thiserror.workspace = true
 tokio.workspace = true
-tokio-tungstenite = "0.25.0"
+tokio-tungstenite = "0.26.0"
 tracing.workspace = true
 
 [features]

v_exchanges_api_generics/src/lib.rs

@@ -1,4 +1,5 @@
 #![warn(future_incompatible, let_underscore, nonstandard_style, missing_docs)]
+#![feature(slice_pattern)]
 
 //! # Generic-API-Client
 //! This is a crate for interacting with HTTP/HTTPS/WebSocket APIs.

v_exchanges_api_generics/src/websocket.rs

@@ -7,11 +7,11 @@ use std::{
 	},
 	time::Duration,
 };
-use tokio_tungstenite::tungstenite::protocol::frame::Payload;
 use futures_util::{
 	sink::SinkExt,
 	stream::{SplitSink, StreamExt},
 };
+use core::slice::SlicePattern;
 use parking_lot::Mutex as SyncMutex;
 use tokio::{
 	net::TcpStream,