diff --git a/builder/monitor.py b/builder/monitor.py index 39b9d68..f6d74a5 100644 --- a/builder/monitor.py +++ b/builder/monitor.py @@ -4,6 +4,8 @@ import json import subprocess import os +from datetime import datetime + import redis @@ -47,6 +49,20 @@ class Monitor(RedisBase): else: print("tubearchivist builder already created") + def create_queue(self): + """set initial json object for queue""" + if self.conn.execute_command(f"EXISTS {self.TASK_KEY}"): + print(f"{self.TASK_KEY} already exists") + return + + message = { + "created": int(datetime.now().strftime("%s")), + "tasks": {} + } + self.conn.execute_command( + "JSON.SET", self.TASK_KEY, ".", json.dumps(message) + ) + @staticmethod def _create_builder(): """create buildx builder""" @@ -139,6 +155,7 @@ class Builder(RedisBase): if __name__ == "__main__": handler = Monitor() handler.bootstrap() + handler.create_queue() handler.check_stored() try: handler.watch()