Merge pull request #146 from Kuadrant/cel_generated

Adds a test to validate generated CEL works

src/data/cel.rs

@@ -725,6 +725,25 @@ mod tests {
         assert!(predicate.test().expect("This must evaluate properly!"));
     }
 
+    #[test]
+    fn kuadrant_generated_predicates() {
+        property::test::TEST_PROPERTY_VALUE.set(Some((
+            "request.query".into(),
+            "param1=%F0%9F%91%BE%20&param2=Exterminate%21&%F0%9F%91%BE=123&%F0%9F%91%BE=456&%F0%9F%91%BE"
+                .bytes()
+                .collect(),
+        )));
+        let predicate = Predicate::route_rule(
+            "'👾' in queryMap(request.query) ? queryMap(request.query)['👾'] == '123' : false",
+        )
+        .expect("This is valid!");
+        assert_eq!(predicate.test(), Ok(true));
+
+        let predicate =
+            Predicate::route_rule("request.headers.exists(h, h.lowerAscii() == 'x-auth' && request.headers[h] == 'kuadrant')").expect("This is valid!");
+        assert_eq!(predicate.test(), Ok(true));
+    }
+
     #[test]
     fn attribute_resolve() {
         property::test::TEST_PROPERTY_VALUE.set(Some((

src/data/property.rs

@@ -47,7 +47,10 @@ pub(super) fn host_get_property(path: &Path) -> Result<Option<Vec<u8>>, Status>
 #[cfg(test)]
 pub fn host_get_map(path: &Path) -> Result<HashMap<String, String>, String> {
     match *path.tokens() {
-        ["request", "headers"] => Ok(HashMap::default()),
+        ["request", "headers"] => Ok(HashMap::from([(
+            "X-Auth".to_string(),
+            "kuadrant".to_string(),
+        )])),
         _ => Err(format!("Unknown map requested {:?}", path)),
     }
 }