Merge pull request #56 from iKonoTelecomunicaciones/55-parametrize-ev…

…ent-log-file-generation

feat(events): ✨ Parametrized event log generation

menuflow/config.py

@@ -26,6 +26,7 @@ def do_update(self, helper: ConfigUpdateHelper) -> None:
         copy("server.port")
         copy("server.public_url")
         copy("server.base_path")
+        copy_dict("events")
         copy_dict("nats")
         copy_dict("logging")
         shared_secret = self["server.unshared_secret"]

menuflow/events/base_event.py

@@ -9,6 +9,7 @@
 from mautrix.util.logging import TraceLogger
 from nats.js.client import JetStreamContext
 
+from ..config import Config
 from .event_types import MenuflowEventTypes, MenuflowNodeEvents
 from .nats_publisher import NatsPublisher
 
@@ -22,17 +23,20 @@ class BaseEvent(SerializableAttrs):
     timestamp: float = ib(factory=float)
     sender: UserID = ib(factory=UserID)
 
-    def send(self):
+    def send(self, config: Config):
+        log.error(f"Sending event {self.serialize()}")
         asyncio.create_task(self.send_to_nats())
 
-    async def send_to_nats(self):
-        jetstream: JetStreamContext = None
+        if config["events.write_to_file"]:
+            self.write_to_file()
 
+    def write_to_file(self):
         file = open("/data/room_events.txt", "a")
         file.write(f"{json.dumps(self.serialize())}\n\n")
         file.close()
-        log.error(f"Sending event {self.serialize()}")
 
+    async def send_to_nats(self):
+        jetstream: JetStreamContext = None
         _, jetstream = await NatsPublisher.get_connection()
         if jetstream:
             try:

menuflow/events/event_generator.py

@@ -14,7 +14,7 @@
 def send_node_event(
     event_type: MenuflowNodeEvents, config: Config, send_event: Optional[bool] = None, **kwargs
 ):
-    general_send_event = config["menuflow.send_events"]
+    general_send_event = config["events.send_events"]
     send_node_event = send_event if send_event is not None else general_send_event
     if not send_node_event:
         return
@@ -54,4 +54,4 @@ def send_node_event(
             variables=kwargs.get("variables"),
         )
 
-    event.send()
+    event.send(config=config)

menuflow/example-config.yaml

@@ -35,8 +35,6 @@ menuflow:
         start: 1
         end: 3
 
-    # Do you want that nodes generate events when they are excecuted?
-    send_events: true
 
 server:
     # The IP and port to listen to.
@@ -51,6 +49,11 @@ server:
     # Set to "generate" to generate and save a new token at startup.
     unshared_secret: generate
 
+events:
+    write_to_file: false
+    # Do you want that nodes generate events when they are excecuted?
+    send_events: true
+
 # Nats configuration
 nats:
     enabled: false