fix: Only metric a recipe run from ui on the first /reply call (#4679)

crates/goose-server/src/routes/reply.rs

@@ -178,17 +178,24 @@ async fn reply_handler(
         "Session started"
     );
 
-    if let Some(recipe_name) = &request.recipe_name {
-        let recipe_version = request.recipe_version.as_deref().unwrap_or("unknown");
+    if let (Some(recipe_name), Some(session_id)) =
+        (request.recipe_name.clone(), request.session_id.clone())
+    {
+        if state.mark_recipe_run_if_absent(&session_id).await {
+            let recipe_version = request
+                .recipe_version
+                .clone()
+                .unwrap_or_else(|| "unknown".to_string());
 
-        tracing::info!(
-            counter.goose.recipe_runs = 1,
-            recipe_name = %recipe_name,
-            recipe_version = %recipe_version,
-            session_type = "app",
-            interface = "ui",
-            "Recipe execution started"
-        );
+            tracing::info!(
+                counter.goose.recipe_runs = 1,
+                recipe_name = %recipe_name,
+                recipe_version = %recipe_version,
+                session_type = "app",
+                interface = "ui",
+                "Recipe execution started"
+            );
+        }
     }
 
     let (tx, rx) = mpsc::channel(100);

crates/goose-server/src/state.rs

@@ -1,6 +1,6 @@
 use goose::agents::Agent;
 use goose::scheduler_trait::SchedulerTrait;
-use std::collections::HashMap;
+use std::collections::{HashMap, HashSet};
 use std::path::PathBuf;
 use std::sync::atomic::AtomicUsize;
 use std::sync::Arc;
@@ -15,6 +15,8 @@ pub struct AppState {
     pub scheduler: Arc<RwLock<Option<Arc<dyn SchedulerTrait>>>>,
     pub recipe_file_hash_map: Arc<Mutex<HashMap<String, PathBuf>>>,
     pub session_counter: Arc<AtomicUsize>,
+    /// Tracks sessions that have already emitted recipe telemetry to prevent double counting.
+    recipe_session_tracker: Arc<Mutex<HashSet<String>>>,
 }
 
 impl AppState {
@@ -24,6 +26,7 @@ impl AppState {
             scheduler: Arc::new(RwLock::new(None)),
             recipe_file_hash_map: Arc::new(Mutex::new(HashMap::new())),
             session_counter: Arc::new(AtomicUsize::new(0)),
+            recipe_session_tracker: Arc::new(Mutex::new(HashSet::new())),
         })
     }
 
@@ -53,4 +56,14 @@ impl AppState {
         let mut agent = self.agent.write().await;
         *agent = Arc::new(Agent::new());
     }
+
+    pub async fn mark_recipe_run_if_absent(&self, session_id: &str) -> bool {
+        let mut sessions = self.recipe_session_tracker.lock().await;
+        if sessions.contains(session_id) {
+            false
+        } else {
+            sessions.insert(session_id.to_string());
+            true
+        }
+    }
 }