Start telemetry earlier and add a timeout

src/dependency_registry/mod.rs

@@ -1,3 +1,8 @@
+use crate::{
+    telemetry::{Telemetry, TELEMETRY_HEADER_NAME},
+    FSM_XDG_PREFIX,
+};
+use eyre::eyre;
 use serde::Deserialize;
 use std::{path::Path, sync::Arc};
 use tokio::{
@@ -8,11 +13,6 @@ use tokio::{
 };
 use xdg::{BaseDirectories, BaseDirectoriesError};
 
-use crate::{
-    telemetry::{Telemetry, TELEMETRY_HEADER_NAME},
-    FSM_XDG_PREFIX,
-};
-
 use self::rust::RustDependencyRegistryData;
 
 pub(crate) mod rust;
@@ -44,6 +44,7 @@ pub struct DependencyRegistry {
 impl DependencyRegistry {
     #[tracing::instrument(skip_all, fields(%disable_telemetry))]
     pub async fn new(disable_telemetry: bool) -> Result<Self, DependencyRegistryError> {
+        let telemetry_handle = tokio::spawn(Telemetry::new());
         let xdg_dirs = BaseDirectories::with_prefix(FSM_XDG_PREFIX)?;
         // Create the directory if needed
         let cached_registry_pathbuf =
@@ -80,7 +81,11 @@ impl DependencyRegistry {
             // Refresh the cache
             // We don't want to fail if we can't build telemetry data...
             let telemetry = if !disable_telemetry {
-                match Telemetry::new().await.as_header_data() {
+                match telemetry_handle
+                    .await
+                    .map_err(|v| eyre!(v))
+                    .and_then(|v| v.as_header_data().map_err(|e| eyre!(e)))
+                {
                     Ok(telemetry) => Some(telemetry), // But we do want to fail if we can build it but can't parse it
                     Err(err) => {
                         tracing::debug!(%err, "Telemetry build error");

src/telemetry.rs

@@ -1,4 +1,4 @@
-use std::{collections::HashSet, path::Path};
+use std::{collections::HashSet, path::Path, time::Duration};
 
 use clap::Parser;
 use eyre::eyre;
@@ -110,7 +110,8 @@ impl Telemetry {
         let http_client = reqwest::Client::new();
         let req = http_client
             .post(TELEMETRY_REMOTE_URL)
-            .header(TELEMETRY_HEADER_NAME, &header_data);
+            .header(TELEMETRY_HEADER_NAME, &header_data)
+            .timeout(Duration::from_millis(250));
         let res = req.send().await?;
         tracing::debug!(telemetry = %header_data, "Sent telemetry data to {TELEMETRY_REMOTE_URL}");
         Ok(res)