about summary refs log tree commit diff
diff options
context:
space:
mode:
-rw-r--r--fs-tracer/src/main.rs19
1 files changed, 10 insertions, 9 deletions
diff --git a/fs-tracer/src/main.rs b/fs-tracer/src/main.rs
index a6d41b7..4e59469 100644
--- a/fs-tracer/src/main.rs
+++ b/fs-tracer/src/main.rs
@@ -109,18 +109,19 @@ async fn main() -> Result<(), anyhow::Error> {
     }
 
     info!("Waiting for threads to stop");
+    let mut batched_req = vec![];
+    let mut i = 0;
     for elt in resolved_files_recv {
-        // TODO: Batching.
+        batched_req.push(elt);
+        i += 1;
+        // Batching.
+        if i % 40 != 0 {
+            continue;
+        }
+        let request_body = format!("[{}]", batched_req.join(","));
         let resp = ureq::post(&url)
             .set("API_KEY", &fs_tracer_api_key)
-            .send_string(&format!(
-                r#"
-                [
-                    {}
-                ]
-                "#,
-                elt
-            ))
+            .send_string(&request_body)
             .expect("Failed to send request");
         if resp.status() != 200 {
             panic!("Failed to send request: {:?}", resp);