feat: add user-agent in http request

Author: SSebo

Cargo.lock

@@ -43,8 +43,8 @@ thiserror = "1.0"
 tracing = "0.1"
 url = "2"
 
-feature-probe-event-std = { optional = true, version = "1.0.2", package="feature-probe-event" }
-feature-probe-event-tokio = { optional = true, version = "1.0.2", features=["use_tokio"], default-features=false, package="feature-probe-event" }
+feature-probe-event-std = { optional = true, version = "1.0.3", package="feature-probe-event" }
+feature-probe-event-tokio = { optional = true, version = "1.0.3", features=["use_tokio"], default-features=false, package="feature-probe-event" }
 
 reqwest = { optional = true, version = "0.11", default-features = false, features = ["rustls-tls", "json"] }
 tokio = {optional = true, version = "1", features = ["full"]}

Cargo.toml

@@ -199,7 +199,13 @@ impl FeatureProbe {
         };
         let flush_interval = self.config.refresh_interval;
         let auth = SdkAuthorization(self.config.server_sdk_key.clone()).encode();
-        let event_recorder = EventRecorder::new(events_url, auth, flush_interval, 100);
+        let event_recorder = EventRecorder::new(
+            events_url,
+            auth,
+            (*crate::USER_AGENT).clone(),
+            flush_interval,
+            100,
+        );
         self.event_recorder = Some(event_recorder);
         Ok(())
     }

src/feature_probe.rs

@@ -8,11 +8,18 @@ pub use crate::feature_probe::{FPConfig, FeatureProbe};
 pub use crate::user::FPUser;
 use headers::{Error, Header, HeaderName, HeaderValue};
 use http::header::AUTHORIZATION;
+use lazy_static::lazy_static;
 use serde::{Deserialize, Serialize};
 use std::fmt::Debug;
 use thiserror::Error;
 pub use url::Url;
 
+lazy_static! {
+    pub(crate) static ref USER_AGENT: String = "Rust/".to_owned() + VERSION;
+}
+
+const VERSION: &str = env!("CARGO_PKG_VERSION");
+
 #[derive(Serialize, Deserialize, Debug, PartialEq, Default)]
 #[serde(rename_all = "camelCase")]
 pub struct FPDetail<T: Default + Debug> {

src/lib.rs

@@ -97,9 +97,12 @@ impl Synchronizer {
 impl Inner {
     #[cfg(feature = "use_tokio")]
     async fn do_sync(&self, client: &Client) {
+        use http::header::USER_AGENT;
+
         let request = client
             .request(Method::GET, self.toggles_url.clone())
             .header(AUTHORIZATION, self.auth.clone())
+            .header(USER_AGENT, &*crate::USER_AGENT)
             .timeout(self.refresh_interval);
 
         //TODO: report failure
@@ -129,6 +132,7 @@ impl Inner {
                 "authorization",
                 self.auth.to_str().expect("already valid header value"),
             )
+            .set("user-agent", &*crate::USER_AGENT)
             .timeout(self.refresh_interval)
             .call()
         {