feat: implement semver strategy constraints

Cargo.toml

@@ -55,6 +55,7 @@ log = "0.4.14"
 murmur3 = "0.5.1"
 rand = "0.8.4"
 rustversion = "1.0.7"
+semver = "1.0.18"
 serde_json = "1.0.68"
 serde_plain = "1.0.0"
 surf = { version = "2.3.1", optional = true }

README.md

@@ -107,4 +107,4 @@ UNLEASH_API_URL=http://127.0.0.1:4242/api \
 
 or similar. The functional test suite looks for a manually setup set of
 features. E.g. log into the Unleash UI on port 4242 and create a feature called
-`default`.
+`default` & `semver` with a `SEMVER_EQ` strategy constraint.

docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3.3"
 services:
   web:
-    image: unleashorg/unleash-server:4.12.6
+    image: unleashorg/unleash-server:4.16.0
     ports:
       - "4242:4242"
     environment:

src/api.rs

@@ -50,13 +50,29 @@ pub struct Constraint {
 }
 
 #[derive(Clone, Serialize, Deserialize, Debug)]
-#[serde(tag = "operator", content = "values")]
+#[serde(tag = "operator")]
 #[cfg_attr(feature = "strict", serde(deny_unknown_fields))]
 pub enum ConstraintExpression {
     #[serde(rename = "IN")]
-    In(Vec<String>),
+    In(MultiValueExpression),
     #[serde(rename = "NOT_IN")]
-    NotIn(Vec<String>),
+    NotIn(MultiValueExpression),
+    #[serde(rename = "SEMVER_EQ")]
+    SemverEq(SingleValueExpression),
+    #[serde(rename = "SEMVER_GT")]
+    SemverGt(SingleValueExpression),
+    #[serde(rename = "SEMVER_LT")]
+    SemverLt(SingleValueExpression),
+}
+
+#[derive(Clone, Serialize, Deserialize, Debug)]
+pub struct MultiValueExpression {
+    pub values: Vec<String>,
+}
+
+#[derive(Clone, Serialize, Deserialize, Debug)]
+pub struct SingleValueExpression {
+    pub value: String,
 }
 
 #[derive(Clone, Serialize, Deserialize, Debug)]

src/client.rs

@@ -777,10 +777,9 @@ where
         self.polling.store(true, Ordering::Relaxed);
         loop {
             debug!("poll: retrieving features");
-            let res = self.http.get_json(&endpoint).await;
-            if let Ok(res) = res {
-                let features: Features = res;
-                match self.memoize(features.features) {
+            let res: Result<Features, C::Error> = self.http.get_json(&endpoint).await;
+            match res {
+                Ok(features) => match self.memoize(features.features) {
                     Ok(None) => {}
                     Ok(Some(metrics)) => {
                         if !self.disable_metric_submission {
@@ -800,9 +799,10 @@ where
                     Err(_) => {
                         warn!("poll: failed to memoize features");
                     }
+                },
+                Err(err) => {
+                    warn!("poll: failed to retrieve features {}", err);
                 }
-            } else {
-                warn!("poll: failed to retrieve features");
             }
 
             let duration = Duration::from_millis(self.interval);