Add project open event

Give the caller of report_app_event() the choice of whether to immediately flush the queue or not.

crates/client/src/telemetry.rs

@@ -340,18 +340,18 @@ impl Telemetry {
         self.report_clickhouse_event(event, telemetry_settings, false)
     }
 
-    // app_events are called at app open and app close, so flush is set to immediately send
     pub fn report_app_event(
         self: &Arc<Self>,
         telemetry_settings: TelemetrySettings,
         operation: &'static str,
+        immediate_flush: bool,
     ) {
         let event = ClickhouseEvent::App {
             operation,
             milliseconds_since_first_event: self.milliseconds_since_first_event(),
         };
 
-        self.report_clickhouse_event(event, telemetry_settings, true)
+        self.report_clickhouse_event(event, telemetry_settings, immediate_flush)
     }
 
     fn milliseconds_since_first_event(&self) -> i64 {

crates/client2/src/telemetry.rs

@@ -173,7 +173,7 @@ impl Telemetry {
     #[cfg(not(any(test, feature = "test-support")))]
     fn shutdown_telemetry(self: &Arc<Self>, cx: &mut AppContext) -> impl Future<Output = ()> {
         let telemetry_settings = TelemetrySettings::get_global(cx).clone();
-        self.report_app_event(telemetry_settings, "close");
+        self.report_app_event(telemetry_settings, "close", true);
         Task::ready(())
     }
 
@@ -364,18 +364,18 @@ impl Telemetry {
         self.report_clickhouse_event(event, telemetry_settings, false)
     }
 
-    // app_events are called at app open and app close, so flush is set to immediately send
     pub fn report_app_event(
         self: &Arc<Self>,
         telemetry_settings: TelemetrySettings,
         operation: &'static str,
+        immediate_flush: bool,
     ) {
         let event = ClickhouseEvent::App {
             operation,
             milliseconds_since_first_event: self.milliseconds_since_first_event(),
         };
 
-        self.report_clickhouse_event(event, telemetry_settings, true)
+        self.report_clickhouse_event(event, telemetry_settings, immediate_flush)
     }
 
     fn milliseconds_since_first_event(&self) -> i64 {

crates/workspace/src/workspace.rs

@@ -14,7 +14,7 @@ use anyhow::{anyhow, Context, Result};
 use call::ActiveCall;
 use client::{
     proto::{self, PeerId},
-    Client, Status, TypedEnvelope, UserStore,
+    Client, Status, TelemetrySettings, TypedEnvelope, UserStore,
 };
 use collections::{hash_map, HashMap, HashSet};
 use drag_and_drop::DragAndDrop;
@@ -1462,6 +1462,10 @@ impl Workspace {
     }
 
     pub fn open(&mut self, _: &Open, cx: &mut ViewContext<Self>) -> Option<Task<Result<()>>> {
+        let telemetry_settings = *settings::get::<TelemetrySettings>(cx);
+        self.client()
+            .telemetry()
+            .report_app_event(telemetry_settings, "open project", false);
         let mut paths = cx.prompt_for_paths(PathPromptOptions {
             files: true,
             directories: true,

crates/workspace2/src/workspace2.rs

@@ -15,7 +15,7 @@ use anyhow::{anyhow, Context as _, Result};
 use call::ActiveCall;
 use client::{
     proto::{self, PeerId},
-    Client, Status, TypedEnvelope, UserStore,
+    Client, Status, TelemetrySettings, TypedEnvelope, UserStore,
 };
 use collections::{hash_map, HashMap, HashSet};
 use dock::{Dock, DockPosition, Panel, PanelButtons, PanelHandle};
@@ -1250,6 +1250,10 @@ impl Workspace {
     }
 
     pub fn open(&mut self, _: &Open, cx: &mut ViewContext<Self>) {
+        let telemetry_settings = TelemetrySettings::get_global(cx).clone();
+        self.client()
+            .telemetry()
+            .report_app_event(telemetry_settings, "open project", false);
         let paths = cx.prompt_for_paths(PathPromptOptions {
             files: true,
             directories: true,

crates/zed/src/main.rs

@@ -174,7 +174,7 @@ fn main() {
         };
         client
             .telemetry()
-            .report_app_event(telemetry_settings, event_operation);
+            .report_app_event(telemetry_settings, event_operation, true);
 
         let app_state = Arc::new(AppState {
             languages,

crates/zed2/src/main.rs

@@ -184,7 +184,7 @@ fn main() {
         };
         client
             .telemetry()
-            .report_app_event(telemetry_settings, event_operation);
+            .report_app_event(telemetry_settings, event_operation, true);
 
         let app_state = Arc::new(AppState {
             languages: languages.clone(),