Wire up XplatLogger for edenfs_events in Rust CLI and config manager

Summary:
Add config-gated routing so edenfs_events telemetry can use XplatLogger instead of the legacy ScubaClient/scribe_cat path. The config flag enable-xplatlogger-events is read from the EdenFS daemon (via thrift) for CLI commands and from the TOML config for the config manager.

- Add send_sample_with_xplatlogger() in edenfs-commands that queries daemon config before routing. If daemon is not running when config is read, it will read the local config (~/.edenrc)
- Add create_telemetry_logger_from_options_with_xplatlogger() in config manager for TOML-based routing
- Add create_logger_with_xplatlogger() and send_with_xplatlogger() APIs in edenfs-telemetry
- Add ConfigData::get_bool() and EdenFsClient::get_enable_xplatlogger_events() for reading the config from the daemon
- Refactor telemetry_disabled() for reuse across logger creation paths

Reviewed By: muirdm, kavehahmadi60

Differential Revision: D105882904

fbshipit-source-id: 1e5a6edd9a1b2f17a00088d28421722795a8ee6c

Author: janezhang10

eden/fs/cli_rs/edenfs-client/src/config.rs

@@ -17,6 +17,8 @@ use crate::client::Client;
 use crate::client::EdenFsClient;
 use crate::methods::EdenThriftMethod;
 
+pub const ENABLE_XPLATLOGGER_EVENTS_CONFIG_KEY: &str = "telemetry:enable-xplatlogger-events";
+
 #[derive(Copy, Clone, Debug, Eq, PartialEq, Ord, PartialOrd, Hash)]
 pub enum ConfigSourceType {
     Default = 0,
@@ -63,6 +65,16 @@ pub struct ConfigData {
     pub values: BTreeMap<String, ConfigValue>,
 }
 
+impl ConfigData {
+    pub fn get_bool(&self, key: &str) -> Option<bool> {
+        match self.values.get(key)?.parsed_value.as_str() {
+            "true" | "1" => Some(true),
+            "false" | "0" => Some(false),
+            _ => None,
+        }
+    }
+}
+
 impl From<thrift_types::edenfs_config::EdenConfigData> for ConfigData {
     fn from(from: thrift_types::edenfs_config::EdenConfigData) -> Self {
         Self {
@@ -84,4 +96,23 @@ impl EdenFsClient {
             .map(|config_data| config_data.into())
             .map_err(EdenFsError::from)
     }
+
+    pub async fn get_enable_xplatlogger_events(&self) -> bool {
+        match self.get_config_default().await {
+            Ok(config) => {
+                let enabled = config
+                    .get_bool(ENABLE_XPLATLOGGER_EVENTS_CONFIG_KEY)
+                    .unwrap_or(false);
+                tracing::debug!(enabled, "read edenfs_events XplatLogger config from daemon");
+                enabled
+            }
+            Err(error) => {
+                tracing::debug!(
+                    ?error,
+                    "failed to read edenfs_events XplatLogger config; using legacy logger"
+                );
+                false
+            }
+        }
+    }
 }

eden/fs/cli_rs/edenfs-commands/src/lib.rs

@@ -65,6 +65,20 @@ pub(crate) fn get_edenfs_instance() -> &'static EdenFsInstance {
         .expect("EdenFsInstance is not initialized")
 }
 
+#[cfg(fbcode_build)]
+pub(crate) async fn send_sample_with_config(
+    data_set: &'static str,
+    xplat_logger_config: edenfs_telemetry::XplatLoggerConfig,
+    sample: edenfs_telemetry::EdenSample,
+) {
+    let xplat_logger_config = get_edenfs_instance()
+        .get_client()
+        .get_enable_xplatlogger_events()
+        .await
+        .then_some(xplat_logger_config);
+    edenfs_telemetry::send_with_config(data_set, sample, xplat_logger_config);
+}
+
 fn init_edenfs_instance(
     config_dir: PathBuf,
     etc_eden_dir: PathBuf,