Runtime rules engine ⚙️

lib/flags/local_flags.js

@@ -12,7 +12,12 @@
  * */
 
 const FeatureFlagsProvider = require("./flags");
-const { normalizedHash } = require("./utils");
+const {
+  normalizedHash,
+  lowercaseAllKeysAndValues,
+  lowercaseLeafNodes,
+} = require("./utils");
+const { apply } = require("json-logic-js");
 
 class LocalFeatureFlagsProvider extends FeatureFlagsProvider {
   /**
@@ -316,13 +321,39 @@ class LocalFeatureFlagsProvider extends FeatureFlagsProvider {
     };
   }
 
+  _extractRuntimeParameters(context) {
+    const customProperties = context.custom_properties;
+    if (!customProperties || typeof customProperties !== "object") {
+      return null;
+    }
+    return lowercaseAllKeysAndValues(customProperties);
+  }
+
+  _isRuntimeRuleSatisfied(rollout, context) {
+    try {
+      return apply(
+        lowercaseLeafNodes(rollout.runtime_evaluation_rule),
+        this._extractRuntimeParameters(context),
+      );
+    } catch (error) {
+      this.logger?.error(`Error evaluating runtime rule: ${error.message}`);
+      return false;
+    }
+  }
+
   _isRuntimeEvaluationSatisfied(rollout, context) {
-    if (!rollout.runtime_evaluation_definition) {
+    if (rollout.runtime_evaluation_rule) {
+      return this._isRuntimeRuleSatisfied(rollout, context);
+    } else if (rollout.runtime_evaluation_definition) {
+      return this._isLegacyRuntimeEvaluationSatisfied(rollout, context);
+    } else {
       return true;
     }
+  }
 
-    const customProperties = context.custom_properties;
-    if (!customProperties || typeof customProperties !== "object") {
+  _isLegacyRuntimeEvaluationSatisfied(rollout, context) {
+    const customProperties = this._extractRuntimeParameters(context);
+    if (!customProperties) {
       return false;
     }
 

lib/flags/utils.js

@@ -70,10 +70,51 @@ function generateTraceparent() {
   return `${version}-${traceId}-${parentId}-${traceFlags}`;
 }
 
+function lowercaseAllKeysAndValues(obj) {
+  if (obj === null || obj === undefined) {
+    return obj;
+  } else if (typeof obj === "string") {
+    return obj.toLowerCase();
+  } else if (typeof obj === "object") {
+    if (Array.isArray(obj)) {
+      return obj.map(lowercaseAllKeysAndValues);
+    } else {
+      return Object.fromEntries(
+        Object.entries(obj).map(([k, v]) => [
+          k.toLowerCase(),
+          lowercaseAllKeysAndValues(v),
+        ]),
+      );
+    }
+  } else {
+    return obj;
+  }
+}
+
+function lowercaseLeafNodes(obj) {
+  if (obj === null || obj === undefined) {
+    return obj;
+  } else if (typeof obj === "string") {
+    return obj.toLowerCase();
+  } else if (typeof obj === "object") {
+    if (Array.isArray(obj)) {
+      return obj.map(lowercaseLeafNodes);
+    } else {
+      return Object.fromEntries(
+        Object.entries(obj).map(([k, v]) => [k, lowercaseLeafNodes(v)]),
+      );
+    }
+  } else {
+    return obj;
+  }
+}
+
 module.exports = {
   EXPOSURE_EVENT,
   REQUEST_HEADERS,
   normalizedHash,
   prepareCommonQueryParams,
   generateTraceparent,
+  lowercaseAllKeysAndValues,
+  lowercaseLeafNodes,
 };

package.json

@@ -40,6 +40,7 @@
     "vitest": "^4.0.8"
   },
   "dependencies": {
-    "https-proxy-agent": "7.0.6"
+    "https-proxy-agent": "7.0.6",
+    "json-logic-js": "^2.0.5"
   }
 }