refactor: use DTO pattern for Binance models to remove Serde rename clutter

Author: VictorAgahi

sentigraph-harvester/src/models.rs

@@ -6,74 +6,105 @@ pub struct BinanceStreamWrapper<T> {
     pub data: T,
 }
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Debug, Serialize, Deserialize)]
+#[serde(from = "RawTicker")]
 pub struct BinanceTicker {
-    #[serde(rename = "e")]
     pub event_type: String,
-    #[serde(rename = "E")]
     pub event_time: u64,
-    #[serde(rename = "s")]
     pub symbol: String,
-    #[serde(rename = "a")]
     pub agg_trade_id: u64,
-    #[serde(rename = "p")]
     pub price: String,
-    #[serde(rename = "q")]
     pub quantity: String,
-    #[serde(rename = "f")]
     pub first_trade_id: u64,
-    #[serde(rename = "l")]
     pub last_trade_id: u64,
-    #[serde(rename = "T")]
     pub trade_time: u64,
-    #[serde(rename = "m")]
     pub is_buyer_market_maker: bool,
-    #[serde(rename = "M")]
     pub ignore: bool,
 }
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Deserialize)]
+struct RawTicker {
+    e: String, E: u64, s: String, a: u64, p: String, q: String,
+    f: u64, l: u64, T: u64, m: bool, M: bool,
+}
+
+impl From<RawTicker> for BinanceTicker {
+    fn from(r: RawTicker) -> Self {
+        Self {
+            event_type: r.e, event_time: r.E, symbol: r.s, agg_trade_id: r.a,
+            price: r.p, quantity: r.q, first_trade_id: r.f, last_trade_id: r.l,
+            trade_time: r.T, is_buyer_market_maker: r.m, ignore: r.M,
+        }
+    }
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+#[serde(from = "RawDepth")]
 pub struct BinanceDepth {
-    #[serde(rename = "u")]
     pub last_update_id: u64,
-    #[serde(rename = "b")]
     pub bids: Vec<[String; 2]>,
-    #[serde(rename = "a")]
     pub asks: Vec<[String; 2]>,
 }
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Deserialize)]
+struct RawDepth {
+    u: u64, b: Vec<[String; 2]>, a: Vec<[String; 2]>,
+}
+
+impl From<RawDepth> for BinanceDepth {
+    fn from(r: RawDepth) -> Self {
+        Self { last_update_id: r.u, bids: r.b, asks: r.a }
+    }
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+#[serde(from = "RawLiquidation")]
 pub struct BinanceLiquidation {
-    #[serde(rename = "e")]
     pub event_type: String,
-    #[serde(rename = "E")]
     pub event_time: u64,
-    #[serde(rename = "o")]
     pub order: Order,
 }
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Deserialize)]
+struct RawLiquidation {
+    e: String, E: u64, o: Order,
+}
+
+impl From<RawLiquidation> for BinanceLiquidation {
+    fn from(r: RawLiquidation) -> Self {
+        Self { event_type: r.e, event_time: r.E, order: r.o }
+    }
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+#[serde(from = "RawOrder")]
 pub struct Order {
-    #[serde(rename = "s")]
     pub symbol: String,
-    #[serde(rename = "S")]
     pub side: String,
-    #[serde(rename = "o")]
     pub order_type: String,
-    #[serde(rename = "f")]
     pub time_in_force: String,
-    #[serde(rename = "q")]
     pub original_quantity: String,
-    #[serde(rename = "p")]
     pub price: String,
-    #[serde(rename = "ap")]
     pub average_price: String,
-    #[serde(rename = "X")]
     pub order_status: String,
-    #[serde(rename = "l")]
     pub last_filled_quantity: String,
-    #[serde(rename = "z")]
     pub cumulative_filled_quantity: String,
-    #[serde(rename = "T")]
     pub order_trade_time: u64,
 }
+
+#[derive(Deserialize)]
+struct RawOrder {
+    s: String, S: String, o: String, f: String, q: String,
+    p: String, ap: String, X: String, l: String, z: String, T: u64,
+}
+
+impl From<RawOrder> for Order {
+    fn from(r: RawOrder) -> Self {
+        Self {
+            symbol: r.s, side: r.S, order_type: r.o, time_in_force: r.f,
+            original_quantity: r.q, price: r.p, average_price: r.ap,
+            order_status: r.X, last_filled_quantity: r.l,
+            cumulative_filled_quantity: r.z, order_trade_time: r.T,
+        }
+    }
+}