Implement sending file chunk

Author: fangpenlin

Cargo.lock

@@ -32,6 +32,7 @@ futures = "0.3.31"
 serde = { version = "1.0.217", features = ["derive"] }
 serde_json = "1.0.134"
 time = { version = "0.3.37", features = ["std", "serde-human-readable"] }
+rmp-serde = "1.3.0"
 
 [[package.metadata.esp-idf-sys.extra_components]]
 remote_component = { name = "espressif/esp_tinyusb", version = "96cbb5b308f92d2493a0c714f097dcfc51add807", git = "https://github.com/LaunchPlatform/esp-usb.git", path = "device/esp_tinyusb" }

Cargo.toml

@@ -95,7 +95,10 @@ impl Processor {
 
     fn list_files(&self, path: &str) -> anyhow::Result<Response> {
         let dir_path = Path::new(&self.root_dir).join(path);
-        log::info!("Listing files at {}", dir_path.to_str().unwrap_or("<Unknown>"));
+        log::info!(
+            "Listing files at {}",
+            dir_path.to_str().unwrap_or("<Unknown>")
+        );
         // Ideally we should find a way to learn the size of all files, but we need to
         // iterate over all files anyway... so.. maybe not? :/
         let mut files: Vec<File> = vec![];
@@ -143,7 +146,8 @@ impl Processor {
         let mut buf = vec![0; chunk_size as usize];
         for offset in (0..file_size).step_by(chunk_size as usize) {
             file.read(&mut buf)?;
-            assert_eq!(file.stream_position().unwrap(), offset);
+            // TODO: somehow stream_position doesn't work correctly?
+            // assert_eq!(file.stream_position().unwrap(), offset);
             send(CommandResponse {
                 id: req_id.to_string(),
                 response: FetchFileChunk {
@@ -216,9 +220,12 @@ pub async fn process_events(
                     Ok(request) => processor.as_mut().unwrap().process(
                         &request,
                         |response: CommandResponse| match response.response {
-                            FetchFileChunk { .. } => {
-                                // TODO:
-                            }
+                            FetchFileChunk { .. } => client
+                                .send(
+                                    FrameType::Binary(false),
+                                    &rmp_serde::to_vec(&response).unwrap(),
+                                )
+                                .unwrap(),
                             _ => client
                                 .send(
                                     FrameType::Text(false),