|
20 | 20 |
|
21 | 21 | from absl.testing import absltest |
22 | 22 | from cel_expr_python import cel |
| 23 | +from cel.expr.conformance.proto2 import test_all_types_pb2 as test_all_types_pb |
23 | 24 |
|
24 | 25 |
|
25 | 26 | class CelEnvTest(absltest.TestCase): |
@@ -85,11 +86,156 @@ def test_invalid_yaml(self): |
85 | 86 | cel.NewEnvConfigFromYaml(" invalid yaml") |
86 | 87 | self.assertIn( |
87 | 88 | "1:2: Invalid CEL environment config YAML\n" |
88 | | - "| invalid yaml\n" |
89 | | - "| ^", |
| 89 | + + "| invalid yaml\n" |
| 90 | + + "| ^", |
90 | 91 | str(e.exception), |
91 | 92 | ) |
92 | 93 |
|
| 94 | + def test_config_export_variables(self): |
| 95 | + config = cel.NewEnv( |
| 96 | + variables={ |
| 97 | + "var_bool": cel.Type.BOOL, |
| 98 | + "var_int": cel.Type.INT, |
| 99 | + "var_uint": cel.Type.UINT, |
| 100 | + "var_double": cel.Type.DOUBLE, |
| 101 | + "var_str": cel.Type.STRING, |
| 102 | + "var_bytes": cel.Type.BYTES, |
| 103 | + "var_msg": cel.Type("cel.expr.conformance.proto2.TestAllTypes"), |
| 104 | + "var_string_list": cel.Type.List(cel.Type.STRING), |
| 105 | + "var_timestamp": cel.Type.TIMESTAMP, |
| 106 | + "var_duration": cel.Type.DURATION, |
| 107 | + "var_dyn_list": cel.Type.LIST, |
| 108 | + "var_int_map": cel.Type.Map(cel.Type.INT, cel.Type.STRING), |
| 109 | + "var_string_map": cel.Type.Map(cel.Type.STRING, cel.Type.BOOL), |
| 110 | + "var_dyn_map": cel.Type.MAP, |
| 111 | + "var_dyn": cel.Type.DYN, |
| 112 | + } |
| 113 | + ) |
| 114 | + yaml = config.config().to_yaml() |
| 115 | + self.assertEqual( |
| 116 | + normalize_yaml(yaml), |
| 117 | + normalize_yaml(""" |
| 118 | + variables: |
| 119 | + - name: "var_bool" |
| 120 | + type_name: "bool" |
| 121 | + - name: "var_bytes" |
| 122 | + type_name: "bytes" |
| 123 | + - name: "var_double" |
| 124 | + type_name: "double" |
| 125 | + - name: "var_duration" |
| 126 | + type_name: "duration" |
| 127 | + - name: "var_dyn" |
| 128 | + type_name: "dyn" |
| 129 | + - name: "var_dyn_list" |
| 130 | + type_name: "list" |
| 131 | + params: |
| 132 | + - type_name: "dyn" |
| 133 | + - name: "var_dyn_map" |
| 134 | + type_name: "map" |
| 135 | + params: |
| 136 | + - type_name: "dyn" |
| 137 | + - type_name: "dyn" |
| 138 | + - name: "var_int" |
| 139 | + type_name: "int" |
| 140 | + - name: "var_int_map" |
| 141 | + type_name: "map" |
| 142 | + params: |
| 143 | + - type_name: "int" |
| 144 | + - type_name: "string" |
| 145 | + - name: "var_msg" |
| 146 | + type_name: "cel.expr.conformance.proto2.TestAllTypes" |
| 147 | + - name: "var_str" |
| 148 | + type_name: "string" |
| 149 | + - name: "var_string_list" |
| 150 | + type_name: "list" |
| 151 | + params: |
| 152 | + - type_name: "string" |
| 153 | + - name: "var_string_map" |
| 154 | + type_name: "map" |
| 155 | + params: |
| 156 | + - type_name: "string" |
| 157 | + - type_name: "bool" |
| 158 | + - name: "var_timestamp" |
| 159 | + type_name: "timestamp" |
| 160 | + - name: "var_uint" |
| 161 | + type_name: "uint" |
| 162 | + """), |
| 163 | + ) |
| 164 | + |
| 165 | + def test_config_augmented_variables(self): |
| 166 | + config = cel.NewEnvConfigFromYaml(""" |
| 167 | + variables: |
| 168 | + - name: "var_bool" |
| 169 | + type_name: "bool" |
| 170 | + """) |
| 171 | + env = cel.NewEnv( |
| 172 | + config=config, |
| 173 | + variables={ |
| 174 | + "var_msg": cel.Type("cel.expr.conformance.proto2.TestAllTypes"), |
| 175 | + }, |
| 176 | + ) |
| 177 | + yaml = env.config().to_yaml() |
| 178 | + self.assertEqual( |
| 179 | + normalize_yaml(yaml), |
| 180 | + normalize_yaml(""" |
| 181 | + variables: |
| 182 | + - name: "var_bool" |
| 183 | + type_name: "bool" |
| 184 | + - name: "var_msg" |
| 185 | + type_name: "cel.expr.conformance.proto2.TestAllTypes" |
| 186 | + """), |
| 187 | + ) |
| 188 | + |
| 189 | + def test_config_variable_override(self): |
| 190 | + config = cel.NewEnvConfigFromYaml(""" |
| 191 | + variables: |
| 192 | + - name: "var_bool" |
| 193 | + type_name: "bool" |
| 194 | + """) |
| 195 | + |
| 196 | + with self.assertRaises(Exception) as e: |
| 197 | + cel.NewEnv( |
| 198 | + config=config, |
| 199 | + variables={ |
| 200 | + "var_bool": cel.Type.INT, |
| 201 | + }, |
| 202 | + ) |
| 203 | + self.assertIn( |
| 204 | + "Variable 'var_bool' is already included", |
| 205 | + str(e.exception), |
| 206 | + ) |
| 207 | + |
| 208 | + def test_config_variable_types(self): |
| 209 | + config = cel.NewEnvConfigFromYaml(""" |
| 210 | + variables: |
| 211 | + - name: "var_bool" |
| 212 | + type_name: "bool" |
| 213 | + - name: "var_int" |
| 214 | + type_name: "int" |
| 215 | + value: 42 |
| 216 | + """) |
| 217 | + env = cel.NewEnv( |
| 218 | + config=config, |
| 219 | + variables={ |
| 220 | + "var_msg": cel.Type("cel.expr.conformance.proto2.TestAllTypes"), |
| 221 | + }, |
| 222 | + ) |
| 223 | + data = { |
| 224 | + "var_bool": True, |
| 225 | + "var_msg": test_all_types_pb.TestAllTypes(single_string="hello"), |
| 226 | + } |
| 227 | + res = env.compile("var_bool").eval(data=data) |
| 228 | + self.assertEqual(res.type(), cel.Type.BOOL) |
| 229 | + self.assertTrue(res.value()) |
| 230 | + |
| 231 | + res = env.compile("var_msg.single_string").eval(data=data) |
| 232 | + self.assertEqual(res.type(), cel.Type.STRING) |
| 233 | + self.assertEqual(res.value(), "hello") |
| 234 | + |
| 235 | + res = env.compile("var_int").eval(data=data) |
| 236 | + self.assertEqual(res.type(), cel.Type.INT) |
| 237 | + self.assertEqual(res.value(), 42) |
| 238 | + |
93 | 239 |
|
94 | 240 | def normalize_yaml(yaml: str) -> str: |
95 | 241 | lines = yaml.split("\n") |
|
0 commit comments