From cb8d0f81b19dccc36d5d2ff8bccfbf2a790ae3f6 Mon Sep 17 00:00:00 2001
From: M1 <m1-pro@M1s-MacBook-Pro.local>
Date: Wed, 18 Mar 2026 13:17:11 +0400
Subject: [PATCH] debug: add warn logs to curl thread, fix temp file uniqueness

---
 apps/monitor/src/runner.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/apps/monitor/src/runner.rs b/apps/monitor/src/runner.rs
index 9e7870d..d6d931a 100644
--- a/apps/monitor/src/runner.rs
+++ b/apps/monitor/src/runner.rs
@@ -190,7 +190,8 @@ async fn run_curl(
     use std::process::Stdio;
 
     // Write output to a temp file so we just wait for the process to exit
-    let tmp = format!("/tmp/pingql-curl-{}.txt", std::process::id());
+    let tmp = format!("/tmp/pingql-curl-{}-{}.txt", std::process::id(), 
+        std::time::SystemTime::now().duration_since(std::time::UNIX_EPOCH).unwrap_or_default().subsec_nanos());
 
     let mut args: Vec<String> = vec![
         "--silent".into(),
@@ -224,13 +225,16 @@ async fn run_curl(
     let tmp_owned = tmp.clone();
 
     let (tx, rx) = tokio::sync::oneshot::channel::<(std::io::Result<std::process::ExitStatus>, Vec<u8>)>();
+    let url_log = url.to_string();
     std::thread::spawn(move || {
+        tracing::warn!("curl thread starting for {url_log}");
         let status = std::process::Command::new("curl")
             .args(&args_owned)
             .stdin(Stdio::null())
             .stdout(Stdio::null())
             .stderr(Stdio::null())
             .status();
+        tracing::warn!("curl thread done for {url_log}: {:?}", status);
         let output = std::fs::read(&tmp_owned).unwrap_or_default();
         let _ = std::fs::remove_file(&tmp_owned);
         let _ = tx.send((status, output));