draft up, now can handle signals

Author: NegaScout

config/ansible/config.ini

@@ -4,3 +4,5 @@ ansible_working_dir = /opt/linode_ansible/project
 ansible_setup_playbook = setup_linode.yml
 ansible_inventory = /opt/linode_ansible/inventory/inventory
 ansible_passwd_template = paswd_template.j2
+ansible_out_dump = /tmp/ansible_out_dump
+

src/Hermes/ansible.py

@@ -1,4 +1,5 @@
 from os import path
+from io import FileIO
 from ansible_runner import Runner, RunnerConfig, run_async
 from discord import app_commands
 from discord.app_commands import Group
@@ -20,6 +21,7 @@ def ansible_init(self):
     self.ansible_roles = path.join(config_predir['ansible_working_dir'], 'roles')
     self.linode_runner = None
     self.ansible_passwd_template = config_predir["ansible_passwd_template"]
+    self.ansible_out_dump = config_predir["ansible_out_dump"]
     self.ansible_command_group = AnsibleG(
         self, name="ansible", description="ansible module"
     )
@@ -71,7 +73,9 @@ def run_ansible(self):
                                        inventory = self.ansible_inventory,
                                        roles_path = self.ansible_roles,
                                        quiet = True,
-                                       status_handler= status_handler)
+                                       status_handler= status_handler,
+                                       _output=FileIO(self.ansible_out_dump, mode = 'w'),
+                                       _input=FileIO('/dev/null', mode = 'r'))
         # Runner.event_handler -> na progress
         # Runner.finished_callback -> na end
     except Exception as e:

src/Hermes/signals.py

@@ -0,0 +1,11 @@
+import signal
+
+def signals_init(self):
+
+    def hup_handler(signum, frame):
+        for callback in self.hup_callbacks:
+            callback()
+        self.logger.info("Recieved HUP")
+
+    self.hup_callbacks = [self.status_hup_handler]
+    signal.signal(signal.SIGHUP, hup_handler)

src/Hermes/status.py

@@ -17,15 +17,19 @@ def status_init(self):
     self.status_callbacks = []
     self.status_accumulator = {}
 
-def register_status_callback(self, status):
-    """
-    sync_tree docstring
-    """
-    for key in status.keys():
-        if key not in self.status_accumulator:
-            self.status_accumulator[key] = [status[key]]
-        else:
-            self.status_accumulator[key].append(status[key])
+def status_hup_handler(self):
+    print("Status recieved hup")
+
+# not used
+#def register_status_callback(self, status):
+#    """
+#    sync_tree docstring
+#    """
+#    for key in status.keys():
+#        if key not in self.status_accumulator:
+#            self.status_accumulator[key] = [status[key]]
+#        else:
+#            self.status_accumulator[key].append(status[key])
 
 class StatusG(Group):
     """

src/HermesBot.py

@@ -2,6 +2,7 @@
 from discord import Intents
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from discord import app_commands
+from os import getpid
 """
 Module docstring
 """
@@ -14,9 +15,13 @@ class Hermes(BotBase):
     """
 
     def __init__(self, *args, **kwargs):
-
+        print(f"The pid is: {getpid()}")
         self.start_logging()
         self.logger.info("###########################")
+        
+        # SIGNALS
+        self.signals_init()
+
         # CONFIGURATOR
         self.configurator_init()
         # DISCORD
@@ -36,7 +41,6 @@ def __init__(self, *args, **kwargs):
         # ANSIBLE
         self.ansible_init()
 
-
         super().__init__(
             command_prefix=self.prefix, intents=Intents.all(), *args, **kwargs
         )
@@ -134,5 +138,9 @@ def run(self):
         run_ansible
     )
     from src.Hermes.status import (
-        status_init
+        status_init,
+        status_hup_handler
+    )
+    from src.Hermes.signals import (
+        signals_init
     )