add active/inactive events

Author: robswc

src/components/events/base/event.py

@@ -42,6 +42,7 @@ class Event:
 
     def __init__(self):
         self.name = self.get_name()
+        self.active = True
         self.webhook = True  # all events are webhooks by default
         self.key = f'{self.name}:{md5(f"{self.name + UNIQUE_KEY}".encode()).hexdigest()[:6]}'
         self._actions = []
@@ -70,15 +71,17 @@ def register_action(self, action):
         self._actions.append(action)
 
     def trigger(self, *args, **kwargs):
-        # handle logging
-        logger.info(f'EVENT TRIGGERED --->\t{str(self)}')
-        log_event = LogEvent(self.name, 'triggered', datetime.now(), f'{self.name} was triggered')
-        log_event.write()
-
-        # pass data
-        data = kwargs.get('data')
-
-        self.logs.append(log_event)
-        for action in self._actions:
-            action.set_data(data)
-            action.run()
+        if self.active:
+            logger.info(f'EVENT TRIGGERED --->\t{str(self)}')
+            log_event = LogEvent(self.name, 'triggered', datetime.now(), f'{self.name} was triggered')
+            log_event.write()
+
+            # pass data
+            data = kwargs.get('data')
+
+            self.logs.append(log_event)
+            for action in self._actions:
+                action.set_data(data)
+                action.run()
+        else:
+            logger.info(f'EVENT NOT TRIGGERED (event is inactive) --->\t{str(self)}')

src/main.py

@@ -85,5 +85,25 @@ def get_logs():
         return jsonify([log.as_json() for log in logs])
 
 
+@app.route("/event/active", methods=["POST"])
+def activate_event():
+    if request.method == 'POST':
+        # get query parameters
+        event_name = request.args.get('event', None)
+
+        # if event name is not provided, or cannot be found, 404
+        if event_name is None:
+            return Response(f'Event name cannot be empty ({event_name})', status=404)
+        try:
+            event = em.get(event_name)
+        except ValueError:
+            return Response(f'Cannot find event with name: {event_name}', status=404)
+
+        # set event to active or inactive, depending on current state
+        event.active = request.args.get('active', True) == 'true'
+        logger.info(f'Event {event.name} active set to: {event.active}, via POST request')
+        return Response(response={event.name: {'active': event.active}}, status=200)
+
+
 if __name__ == '__main__':
     app.run(debug=True)