test: _

Author: valeratrades

Cargo.lock

@@ -1,4 +1,5 @@
 use serde::{Deserialize, Serialize};
+use serde_json::Value;
 use serde_with::{DisplayFromStr, serde_as};
 
 //TODO: make these actually consistent
@@ -10,7 +11,7 @@ use serde_with::{DisplayFromStr, serde_as};
 #[serde_as]
 #[derive(Debug, Serialize, Deserialize, Clone)]
 #[serde(rename_all = "camelCase")]
-pub struct KlineCore {
+pub struct KlineCoreNamed {
 	#[serde(rename = "t")]
 	pub open_time: i64,
 
@@ -52,9 +53,8 @@ pub struct KlineCore {
 	#[serde(rename = "Q")]
 	pub taker_buy_quote_asset_volume: f64,
 
-	#[serde_as(as = "DisplayFromStr")]
 	#[serde(skip, rename = "B")]
-	pub __ignore: Option<f64>,
+	__ignore: Option<Value>,
 }
 
 #[serde_as]
@@ -101,11 +101,36 @@ pub struct Kline {
 	pub __ignore: u64,
 }
 
+#[serde_as]
+#[derive(Debug, Serialize, Deserialize, Clone)]
+pub struct KlineCore {
+	pub open_time: i64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub open: f64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub close: f64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub high: f64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub low: f64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub volume: f64,
+	pub close_time: i64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub quote_asset_volume: f64,
+	pub number_of_trades: i64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub taker_buy_base_asset_volume: f64,
+	#[serde_as(as = "DisplayFromStr")]
+	pub taker_buy_quote_asset_volume: f64,
+	__ignore: Option<Value>,
+}
+
 #[cfg(test)]
 mod tests {
 	#[test]
 	fn kline_core() {
-		let raw_str = r#"[1731448080000,\"88591.90\",\"88630.90\",\"88560.00\",\"88574.10\",\"173.581\",1731448139999,\"15378315.48720\",2800,\"113.654\",\"10069629.84420\",\"0\"]"#;
+		let raw_str = "[1731448080000,\"88591.90\",\"88630.90\",\"88560.00\",\"88574.10\",\"173.581\",1731448139999,\"15378315.48720\",2800,\"113.654\",\"10069629.84420\",\"0\"]";
 		let _: super::KlineCore = serde_json::from_str(raw_str).unwrap();
 	}
 }

v_exchanges/src/binance/futures/core.rs

@@ -6,7 +6,7 @@ use v_exchanges_adapters::{
 mod binance;
 
 use binance::futures::KlineCore;
-use v_utils::utils::init_subscriber;
+use v_utils::utils::{LogDestination, init_subscriber};
 
 //- [ ] generics request for klines rest
 //- [ ] generics request for klines ws
@@ -15,8 +15,7 @@ use v_utils::utils::init_subscriber;
 #[tokio::main]
 async fn main() {
 	color_eyre::install().unwrap();
-	//init_subscriber(Some(std::path::PathBuf::from("/home/v/.local/share/v_exchanges/.log").into())); //dbg
-	init_subscriber(None);
+	init_subscriber(LogDestination::xdg_data_home("v_exchanges"));
 
 	tracing::info!("Starting...");
 	let mut client = Client::new();