Updated apply conditions to handle more firewall rules

core/runtime/applyconditions.py

@@ -49,8 +49,12 @@ def applyConditions(definition, dictionary, outputs):
                         return True, filter
 
                 if filter["operator"] == "in":
-                    if filtervalue in dictionary:
-                        return True, filter
+                    if filter["filterkey"] == "called_dictionary":
+                        if filtervalue in dictionary:
+                            return True, filter
+                    else:
+                        if filtervalue in dictionary.get(filter["filterkey"], {}):
+                            return True, filter
 
                 if filter["operator"] == "is":
                     if resolvedvalue is filtervalue:

core/runtime/firewall.py

@@ -20,15 +20,6 @@ def buildFirewall(listener, outputs):
                 logging.info(f"Returning status_code: {status_code}")
             continue
 
-        #This needs to be moved into definitions but until logic is put in place it lives here.
-        if "com.loxthelion.rmass_message_id" in item.get("content", {}):
-            status_code = 200
-            if firewall_log:
-                logging.info("Excluding previously imported items")
-                logging.info(f"Returning status_code: {status_code}")
-
-            continue
-
         outputs["firewall_allowed"].append(item)
     
     if outputs["firewall_allowed"] != []: