add "prioritize_live_data" option

tools/utils/src/push_data.rs

@@ -23,14 +23,15 @@ struct ShadowPayload {
 
 #[tokio::main]
 async fn main() {
+    let stream = std::env::args().nth(1).unwrap_or_else(|| "c2c_can".to_string());
     let port = std::env::args().nth(2).unwrap_or_else(|| "127.0.0.1:5050".to_string());
     let mut framed = Framed::new(TcpStream::connect(port).await.unwrap(), LinesCodec::new());
     let mut idx = 0;
     loop {
         idx += 1;
         // calculate and send consecutive squares
         let data = ShadowPayload {
-            stream: "c2c_can".to_string(),
+            stream: stream.clone(),
             sequence: idx,
             timestamp: SystemTime::now().duration_since(UNIX_EPOCH).unwrap().as_millis() as u64,
             can_id: idx % 1024,

uplink/src/base/serializer/mod.rs

@@ -276,7 +276,7 @@ impl<C: MqttClient> Serializer<C> {
 
         let mut packet_to_write = Some(publish);
         let (storage, live_data, live_data_version) = self.sorted_storages.get_mut(&sk).unwrap();
-        if false {
+        if self.config.prioritize_live_data {
             std::mem::swap(&mut packet_to_write, live_data);
             *live_data_version = self.live_data_counter;
         }
@@ -637,6 +637,7 @@ pub fn construct_publish(
 #[cfg(test)]
 pub mod tests {
     use std::path::PathBuf;
+    use bytes::Bytes;
     use flume::bounded;
     use serde::{Deserialize, Serialize};
     use serde_json::Value;

uplink/src/config.rs

@@ -301,4 +301,6 @@ pub struct Config {
     #[cfg(target_os = "android")]
     pub logging: Option<LogcatConfig>,
     pub precondition_checks: Option<PreconditionCheckerConfig>,
+    #[serde(default)]
+    pub prioritize_live_data: bool,
 }