perf: chore: flagd: Update dependencies, reuse reqwest client for better performance, add cargo audit to CI (#47)

Signed-off-by: Eren Atas <[email protected]>

Author: erenatas

.github/workflows/flagd-check.yml

@@ -39,4 +39,10 @@ jobs:
         run: |
           cargo readme --no-title --no-license > README.md.generated
           diff README.md README.md.generated
+          
+      - name: Install and run cargo-audit
+        run: |
+          cargo install cargo-audit --locked
+          # Run from root directory where Cargo.lock is located
+          cargo audit
 

crates/flagd/Cargo.toml

@@ -21,40 +21,35 @@ include = [
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [build-dependencies]
-tonic-build = "0.12"
-prost = "0.13"
-prost-build = "0.13"
+tonic-build = "0.13"
 
 [dev-dependencies]
 cucumber = "0.21"
 tokio-stream = "0.1"
 futures-core = "0.3"
 testcontainers = { version = "0.24.0", features = ["http_wait", "blocking"] }
 wiremock = "0.6.3"
-tempfile = "3.19.0"
+tempfile = "3.20.0"
 serial_test = "3.2"
-tracing-test = "0.2"
 test-log = { version = "0.2", features = ["trace"] }
 
 [dependencies]
 open-feature = "0.2"
 async-trait = "0.1"
-tonic = { version = "0.12", features = ["tls"] }
+tonic = { version = "0.13" }
 prost = "0.13"
 prost-types = "0.13"
-tokio = { version = "1.44", features = ["full"] }
+tokio = { version = "1.45", features = ["full"] }
 serde_json = "1.0"
 serde = { version = "1.0", features = ["derive"] }
 lru = "0.14"
 futures = "0.3"
 reqwest = { version = "0.12", default-features = false, features = ["json", "stream", "rustls-tls"] }
 tracing = "0.1"
-tracing-subscriber = "0.3"
-anyhow = "1.0.97"
-regex = "1.11.1"
+anyhow = "1.0.98"
 semver = "1.0.26"
 murmurhash3 = "0.0.5"
 tower = "0.5"
 hyper-util = { version = "0.1", features = ["tokio"] }
 thiserror = "2.0"
-datalogic-rs = "3.0.22"
+datalogic-rs = "3.0.24"

crates/flagd/src/resolver/rest.rs

@@ -48,6 +48,7 @@ use open_feature::{
     EvaluationContext, EvaluationContextFieldValue, EvaluationError, EvaluationErrorCode,
     EvaluationResult, StructValue, Value,
 };
+use reqwest::Client;
 use serde_json;
 use tracing::{debug, error, instrument};
 
@@ -60,6 +61,8 @@ pub struct RestResolver {
     endpoint: String,
     /// Provider metadata
     metadata: ProviderMetadata,
+    /// HTTP client for making requests
+    client: Client,
 }
 
 impl RestResolver {
@@ -81,6 +84,7 @@ impl RestResolver {
         Self {
             endpoint,
             metadata: ProviderMetadata::new("flagd-rest-provider"),
+            client: Client::new(),
         }
     }
 }
@@ -108,12 +112,13 @@ impl FeatureProvider for RestResolver {
         evaluation_context: &EvaluationContext,
     ) -> EvaluationResult<ResolutionDetails<bool>> {
         debug!("Resolving boolean flag");
-        let client = reqwest::Client::new();
+
         let payload = serde_json::json!({
             "context": context_to_json(evaluation_context)
         });
 
-        let response = client
+        let response = self
+            .client
             .post(format!(
                 "{}/ofrep/v1/evaluate/flags/{}",
                 self.endpoint, flag_key
@@ -176,12 +181,13 @@ impl FeatureProvider for RestResolver {
         evaluation_context: &EvaluationContext,
     ) -> EvaluationResult<ResolutionDetails<String>> {
         debug!("Resolving string flag");
-        let client = reqwest::Client::new();
+
         let payload = serde_json::json!({
             "context": context_to_json(evaluation_context)
         });
 
-        let response = client
+        let response = self
+            .client
             .post(format!(
                 "{}/ofrep/v1/evaluate/flags/{}",
                 self.endpoint, flag_key
@@ -247,12 +253,13 @@ impl FeatureProvider for RestResolver {
         evaluation_context: &EvaluationContext,
     ) -> EvaluationResult<ResolutionDetails<f64>> {
         debug!("Resolving float flag");
-        let client = reqwest::Client::new();
+
         let payload = serde_json::json!({
             "context": context_to_json(evaluation_context)
         });
 
-        let response = client
+        let response = self
+            .client
             .post(format!(
                 "{}/ofrep/v1/evaluate/flags/{}",
                 self.endpoint, flag_key
@@ -313,12 +320,13 @@ impl FeatureProvider for RestResolver {
         evaluation_context: &EvaluationContext,
     ) -> EvaluationResult<ResolutionDetails<i64>> {
         debug!("Resolving integer flag");
-        let client = reqwest::Client::new();
+
         let payload = serde_json::json!({
             "context": context_to_json(evaluation_context)
         });
 
-        let response = client
+        let response = self
+            .client
             .post(format!(
                 "{}/ofrep/v1/evaluate/flags/{}",
                 self.endpoint, flag_key
@@ -382,12 +390,13 @@ impl FeatureProvider for RestResolver {
         evaluation_context: &EvaluationContext,
     ) -> EvaluationResult<ResolutionDetails<StructValue>> {
         debug!("Resolving struct flag");
-        let client = reqwest::Client::new();
+
         let payload = serde_json::json!({
             "context": context_to_json(evaluation_context)
         });
 
-        let response = client
+        let response = self
+            .client
             .post(format!(
                 "{}/ofrep/v1/evaluate/flags/{}",
                 self.endpoint, flag_key