Continued.

bitstam · Feb 17, 2020 · f6de6b4 · f6de6b4
1 parent e766fa3
commit f6de6b4
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/common/constants.py b/common/constants.py
@@ -5,6 +5,7 @@ class mercure_defs:
 class mercure_names:
     LOCK       = ".lock"
     PROCESSING = ".processing"
+    RUNNING    = ".running"
     ERROR      = ".error"
     TAGS       = ".tags"
     HALT       = "HALT"
@@ -31,6 +32,7 @@ class mercure_actions:
 
 class mercure_rule:
     RULE                            = "rule"
+    ACTION                          = "action"
     ACTION_TRIGGER                  = "action_trigger"
     STUDY_TRIGGER_CONDITION         = "study_trigger_condition"
     STUDY_TRIGGER                   = "study_trigger"

diff --git a/routing/route_series.py b/routing/route_series.py
@@ -190,18 +190,24 @@ def push_series_serieslevel(triggered_rules,file_list,series_UID,tags_list):
 
 
 def push_serieslevel_routing(triggered_rules,file_list,series_UID,tags_list):
-    # TODO
-    pass
+    for current_rule in triggered_rules:
+        if config.mercure[mercure_config.RULES][current_rule].get(mercure_rule.ACTION,"")==mercure_actions.ROUTE:
+            # TODO
+            pass
 
 
 def push_serieslevel_processing(triggered_rules,file_list,series_UID,tags_list):
-    # TODO
-    pass
+    for current_rule in triggered_rules:
+        if config.mercure[mercure_config.RULES][current_rule].get(mercure_rule.ACTION,"")==mercure_actions.PROCESS:
+            # TODO
+            pass
 
 
 def push_serieslevel_notification(triggered_rules,file_list,series_UID,tags_list):
-    # TODO
-    pass
+    for current_rule in triggered_rules:
+        if config.mercure[mercure_config.RULES][current_rule].get(mercure_rule.ACTION,"")==mercure_actions.NOTIFICATION:
+            # TODO
+            pass
 
 
 def remove_series(file_list):