fmt

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

Author: erenatas

crates/flagd/src/lib.rs

@@ -471,9 +471,10 @@ impl FlagdProvider {
         value_converter: impl Fn(Value) -> Option<T>,
     ) -> Option<T> {
         if let Some(cache) = &self.cache
-            && let Some(cached_value) = cache.get(flag_key, context).await {
-                return value_converter(cached_value);
-            }
+            && let Some(cached_value) = cache.get(flag_key, context).await
+        {
+            return value_converter(cached_value);
+        }
         None
     }
 }

crates/flagd/src/resolver/in_process/resolver/file.rs

@@ -51,13 +51,14 @@ impl FileResolver {
         type_name: &str,
     ) -> Result<ResolutionDetails<T>, EvaluationError> {
         if let Some(cache) = &self.cache
-            && let Some(cached_value) = cache.get(flag_key, context).await {
-                debug!("Cache hit for key: {}", flag_key);
-                let json_value = cached_value.to_serde_json();
-                if let Some(value) = value_converter(&json_value) {
-                    return Ok(ResolutionDetails::new(value));
-                }
+            && let Some(cached_value) = cache.get(flag_key, context).await
+        {
+            debug!("Cache hit for key: {}", flag_key);
+            let json_value = cached_value.to_serde_json();
+            if let Some(value) = value_converter(&json_value) {
+                return Ok(ResolutionDetails::new(value));
             }
+        }
 
         let query_result = self.store.get_flag(flag_key).await;
 

crates/flagd/src/resolver/in_process/resolver/grpc.rs

@@ -86,9 +86,10 @@ impl InProcessResolver {
         value_converter: impl Fn(&OpenFeatureValue) -> Option<T>,
     ) -> Option<T> {
         if let Some(cache) = &self.cache
-            && let Some(cached_value) = cache.get(flag_key, context).await {
-                return value_converter(&cached_value);
-            }
+            && let Some(cached_value) = cache.get(flag_key, context).await
+        {
+            return value_converter(&cached_value);
+        }
         None
     }
 

crates/flagd/src/resolver/rpc.rs

@@ -159,18 +159,19 @@ impl RpcResolver {
 
         // Extend support for envoy names resolution
         if let Some(uri) = &options.target_uri
-            && uri.starts_with("envoy://") {
-                // Expected format: envoy://<host:port>/<desired_authority>
-                let without_prefix = uri.trim_start_matches("envoy://");
-                let segments: Vec<&str> = without_prefix.split('/').collect();
-                if segments.len() >= 2 {
-                    let authority_str = segments[1];
-                    // Create a full URI from the authority for endpoint.origin()
-                    let authority_uri =
-                        std::str::FromStr::from_str(&format!("http://{}", authority_str))?;
-                    endpoint = endpoint.origin(authority_uri);
-                }
+            && uri.starts_with("envoy://")
+        {
+            // Expected format: envoy://<host:port>/<desired_authority>
+            let without_prefix = uri.trim_start_matches("envoy://");
+            let segments: Vec<&str> = without_prefix.split('/').collect();
+            if segments.len() >= 2 {
+                let authority_str = segments[1];
+                // Create a full URI from the authority for endpoint.origin()
+                let authority_uri =
+                    std::str::FromStr::from_str(&format!("http://{}", authority_str))?;
+                endpoint = endpoint.origin(authority_uri);
             }
+        }
 
         let channel = endpoint
             .timeout(Duration::from_millis(options.deadline_ms as u64))