feat: worker thread to process workflow queue

sendlog/main.py

@@ -2,6 +2,16 @@
 from utils.workflow_manager import WorkflowManager
 from log_monitor import LogMonitor
 
+import threading
+import queue
+import time
+
+def process_workflows(workflow_queue):
+    while True:
+        workflow, msg = workflow_queue.get()
+        workflow.execute(msg)
+        workflow_queue.task_done()
+
 def main():
     # Load config into ConfigHandler
     config_handler = ConfigHandler("sendlog.yml")
@@ -16,13 +26,19 @@ def main():
     # Load file workflows from config
     for data in config_handler.files():
         workflow_manager.load_workflow(*data)
-
+
+    # Set up worker thread
+    workflow_queue = queue.Queue()
+    worker_thread = threading.Thread(target=process_workflows, args=(workflow_queue,))
+    worker_thread.daemon = True
+    worker_thread.start()
+
     # Start file monitoring
     paths = workflow_manager.get_paths()
     log_monitor = LogMonitor(paths)
     for path, msg in log_monitor.monitor():
-        print(f"{path}: {msg}")
-        # workflow_manager.get_workflow(path).execute(msg)
+        workflow = workflow_manager.get_workflow(path)
+        workflow_queue.put((workflow, msg))
 
 
 if __name__ == "__main__":