advancing on notifications

server/src/uds/core/messaging/processor.py

@@ -51,8 +51,8 @@ class MessageProcessorThread(BaseThread):
 
     def run(self):
         # Load providers at beginning
-        providers: typing.List[NotificationProviderModule] = [
-            p.getInstance() for p in Notifier.objects.all()
+        providers: typing.List[typing.Tuple[int, NotificationProviderModule]] = [
+            (p.level, p.getInstance()) for p in Notifier.objects.all()
         ]
 
         while self.keepRunning:
@@ -83,10 +83,9 @@ class MessageProcessorThread(BaseThread):
                     )
 
                 if notify:
-                    for p in providers:
-                        if (
-                            not self.keepRunning
-                        ):  # if we are asked to stop, we don't try to send anymore
+                    for p in (i[1] for i in providers if i[0] >= n.level):
+                        # if we are asked to stop, we don't try to send anymore
+                        if not self.keepRunning:
                             break
                         p.notify(n.group, n.identificator, n.level, n.message)
 

server/src/uds/core/messaging/provider.py

@@ -78,8 +78,6 @@ class Notifier(Module):
     # : your own :py:meth:uds.core.module.BaseModule.icon method.
     iconFile: typing.ClassVar[str] = 'notifier.png'
 
-    level: NotificationLevel = NotificationLevel.ERROR
-
     def __init__(self, environment: 'Environment', values: Module.ValuesType):
         super().__init__(environment, values)
         self.initialize(values)

server/src/uds/models/notifications.py

@@ -53,7 +53,7 @@ class NotificationLevel(IntEnum):
     ERROR = 2
     CRITICAL = 3
 
-    # Return all notification levels as tuples of (level, name)
+    # Return all notification levels as tuples of (level value, level name)
     @classmethod
     def all(cls):
         return [(level.value, level.name) for level in (cls.INFO, cls.WARNING, cls.ERROR, cls.CRITICAL)]