fix: metrics on posthog

crates/goose/Cargo.toml

@@ -111,6 +111,7 @@ shellexpand = "3.1.1"
 indexmap = "2.12.0"
 ignore = "0.4.25"
 which = "8.0.0"
+posthog-rs = "0.3.7"
 
 
 [target.'cfg(target_os = "windows")'.dependencies]

crates/goose/src/lib.rs

@@ -9,6 +9,7 @@ pub mod mcp_utils;
 pub mod model;
 pub mod oauth;
 pub mod permission;
+pub mod posthog;
 pub mod prompt_template;
 pub mod providers;
 pub mod recipe;

crates/goose/src/posthog.rs

@@ -0,0 +1,56 @@
+//! PostHog telemetry - fires once per session creation.
+
+use crate::config::{get_enabled_extensions, Config};
+use crate::session::SessionManager;
+use once_cell::sync::Lazy;
+use std::sync::atomic::{AtomicBool, Ordering};
+
+const POSTHOG_API_KEY: &str = "phc_RyX5CaY01VtZJCQyhSR5KFh6qimUy81YwxsEpotAftT";
+
+static TELEMETRY_DISABLED: Lazy<AtomicBool> = Lazy::new(|| {
+    std::env::var("GOOSE_TELEMETRY_OFF")
+        .map(|v| v == "1" || v.to_lowercase() == "true")
+        .unwrap_or(false)
+        .into()
+});
+
+pub fn emit_session_started() {
+    if TELEMETRY_DISABLED.load(Ordering::Relaxed) {
+        return;
+    }
+
+    tokio::spawn(async {
+        let _ = send_session_event().await;
+    });
+}
+
+async fn send_session_event() -> Result<(), String> {
+    let client = posthog_rs::client(POSTHOG_API_KEY).await;
+    let mut event = posthog_rs::Event::new("session_started", "goose_user");
+
+    event.insert_prop("os", std::env::consts::OS).ok();
+    event.insert_prop("arch", std::env::consts::ARCH).ok();
+    event.insert_prop("version", env!("CARGO_PKG_VERSION")).ok();
+
+    let config = Config::global();
+    if let Ok(provider) = config.get_param::<String>("GOOSE_PROVIDER") {
+        event.insert_prop("provider", provider).ok();
+    }
+    if let Ok(model) = config.get_param::<String>("GOOSE_MODEL") {
+        event.insert_prop("model", model).ok();
+    }
+
+    let extensions = get_enabled_extensions();
+    event.insert_prop("extensions_count", extensions.len()).ok();
+
+    if let Ok(insights) = SessionManager::get_insights().await {
+        event
+            .insert_prop("total_sessions", insights.total_sessions)
+            .ok();
+        event
+            .insert_prop("total_tokens", insights.total_tokens)
+            .ok();
+    }
+
+    client.capture(event).await.map_err(|e| format!("{:?}", e))
+}

crates/goose/src/session/session_manager.rs

@@ -120,8 +120,8 @@ pub struct SessionUpdateBuilder {
 #[derive(Serialize, ToSchema, Debug)]
 #[serde(rename_all = "camelCase")]
 pub struct SessionInsights {
-    total_sessions: usize,
-    total_tokens: i64,
+    pub total_sessions: usize,
+    pub total_tokens: i64,
 }
 
 impl SessionUpdateBuilder {
@@ -887,6 +887,7 @@ impl SessionStorage {
             .await?;
 
         tx.commit().await?;
+        crate::posthog::emit_session_started();
         Ok(session)
     }