fixed result output, equal filter, customers

CHANGELOG.md

@@ -1,4 +1,9 @@
 ## 2.2.x
+### 2.2.2
+#### Bugfix
+* Fixed result output
+* Fixed customer stream type
+* Fixed equal filter
 ### 2.2.1
 #### Bugfix
 * Fixed bug in *match()* method of *Routing* class

routingfilter/filters/filters.py

@@ -94,13 +94,13 @@ def match(self, event: DictQuery):
         """
         filter_value = []
         for value in self._value:
-            value = value.lower() if isinstance(value, str) else value
+            value = value.lower() if isinstance(value, str) else str(value)
             filter_value.append(value)
         for key in self._key:
             event_value = event.get(key, [])
             event_value = event_value if isinstance(event_value, list) else [event_value]
             for value in event_value:
-                value = value.lower() if isinstance(value, str) else value
+                value = value.lower() if isinstance(value, str) else str(value)
                 if value in filter_value:
                     return True
         return False

routingfilter/filters/results.py

@@ -8,7 +8,7 @@ class Results:
 
     def __init__(self, rules, output):
         self.rules = rules
-        self.output = output
+        self.output = output["customer"] if output is not None and "customer" in output.keys() else output
 
     def to_dict(self):
-        return {"output": self.output, "rules_uid": self.rules}
+        return {"output": self.output, "rules": self.rules}

routingfilter/routing.py

@@ -100,7 +100,7 @@ def load_from_dicts(self, rules_list: List[dict], validate_rules: bool = True, v
                 # check stream
                 if stream_type == "streams":
                     streams = self.streams
-                elif stream_type == "customer":
+                elif stream_type == "customers":
                     streams = self.customer
                 else:
                     self.logger.error(f"Error during loading rule. Invalid Stream: {stream_type}")
@@ -115,7 +115,7 @@ def load_from_dicts(self, rules_list: List[dict], validate_rules: bool = True, v
                         streams.add_rulemanager(rule_manager)
                     for rule in rule_file[stream_type]["rules"][tag]:
                         # add rule to rule manager and filters to rule
-                        output = rule["streams"] if "streams" in rule.keys() else None
+                        output = rule[stream_type] if stream_type in rule.keys() else None
                         if "id" not in rule.keys():
                             rule["id"] = str(uuid.uuid4())
                         uid = rule["id"]

setup.py

@@ -5,7 +5,7 @@
 
 setup(
     name="routingfilter",
-    version="2.2.1",
+    version="2.2.2",
     packages=find_packages(include=["routingfilter", "routingfilter.*"]),
     include_package_data=True,
     install_requires=["IPy~=1.1", "macaddress~=2.0.2"],

test_data/test_rule_3_customer_equals.json

@@ -1,5 +1,5 @@
 {
-  "customer": {
+  "customers": {
     "rules": {
       "all": [
         {
@@ -15,7 +15,7 @@
               ]
             }
           ],
-          "streams": {
+          "customer": {
             "Workshop": {
               "workers_needed": 1
             }