diff --git a/src/main.rs b/src/main.rs index b59a2819d57c4ca802167bb87876bbd96bdc725f..beedb7c47c39ca837f5eeccc17e31552c6b29068 100644 --- a/src/main.rs +++ b/src/main.rs @@ -292,7 +292,7 @@ async fn main() -> Result<(), anyhow::Error> { chain_id, time_since_beginning, simulation_behavior.quantity, - Bytes::default(), // Bytes::from_static(&behavior.mobility_record), + simulation_behavior.mobility_record.to_bytes() ).await; info!("Sent bx({:?}): {:?}",simulation_behavior.id,bx_hash); } diff --git a/src/utils/mobility_data.rs b/src/utils/mobility_data.rs index 44d77f1c74fcc055e6d974364d2b64af9016b66d..364057764dd03263407b3dd4b92a62346ad9b320 100644 --- a/src/utils/mobility_data.rs +++ b/src/utils/mobility_data.rs @@ -45,7 +45,7 @@ pub struct MobilityRecord { impl MobilityRecord { // Convert to a byte array - // TODO: update serialization when CSV struct is final + // TODO: update serialization when CSV struct is in final version pub fn to_bytes(&self) -> Bytes { let serialized_mobility_record = serde_json::to_string(self).unwrap(); let bytes = serialized_mobility_record.as_bytes();