feat: write flight log to csv

flight-computer/Cargo.toml

@@ -5,7 +5,11 @@ edition = "2024"
 
 [dependencies]
 protocols = { version = "0.1.0", path = "../protocols" }
-tokio = { version = "1.48.0", features = ["macros", "rt-multi-thread", "time"] }
+tokio = { version = "1.48.0", features = ["macros", "rt-multi-thread", "time", "fs"] }
+csv-async = "1.3.1"
+serde = "1.0.228"
+
 
 [lints]
 workspace = true
+

flight-computer/src/input.rs

@@ -6,8 +6,10 @@
 use protocols::api::{TelemetryDataMessage, Velocity};
 use protocols::client::MessageSender;
 use protocols::server::MessageReceiver;
+use serde::Serialize;
 
 /// Stores the current inputs of the system, given by the avionics
+#[derive(serde::Serialize)]
 pub struct Inputs {
     pub location: Location,
     pub velocity: Velocity,

flight-computer/src/main.rs

@@ -1,16 +1,34 @@
 use std::time::Duration;
 
+use csv_async::{AsyncSerializer, AsyncWriterBuilder};
 use protocols::api::{
     AvionicsCommandMessage, SensorMessage, TelemetryCommandMessage, TelemetryDataMessage,
 };
 use protocols::client::MessageSender;
 use protocols::server::MessageReceiver;
+use std::error::Error;
+use tokio::fs::File;
 
 pub mod input;
 pub mod state_machine;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    // create csv file
+    let mut file_location = File::create("loc.csv").await?;
+
+    let mut file_velocity = File::create("velocity.csv").await?;
+
+    // initialize writer
+    let mut wrt = AsyncWriterBuilder::new().has_headers(true).create_writer(vec![]);
+
+    // initialize serializer
+    let mut ser = AsyncSerializer::from_writer(vec![]);
+
+    let mut wrt = AsyncWriterBuilder::new().has_headers(true).create_writer(vec![]);
+    let mut ser_2 = AsyncSerializer::from_writer(vec![]);
+
+
     // Initialize inputs
     let mut inputs = input::Inputs::default();
 
@@ -41,6 +59,15 @@
                 inputs.location.altitude,
                 inputs.velocity.down
             );
+            // insert data
+            ser.serialize(&
+                inputs.location
+            ).await?;
+
+            ser_2.serialize(&inputs.velocity).await?;
+
+
+
         }
 
         // Handle incoming telemetry commands