janitor: drop service and add as job

Signed-off-by: Paul Spooren <mail@aparcar.org>

asu/asu.py

@@ -5,12 +5,14 @@
 from flask import Flask, render_template, send_from_directory
 from pkg_resources import resource_filename
 from prometheus_client import CollectorRegistry, make_wsgi_app
-from redis import Redis
+from rq import Queue
 from werkzeug.middleware.dispatcher import DispatcherMiddleware
 from yaml import safe_load
 
 import asu.common
 from asu import __version__
+from asu.janitor import update
+from redis import Redis
 
 
 def create_app(test_config: dict = None) -> Flask:
@@ -138,4 +140,18 @@ def stats():
         validate_responses=app.config["TESTING"],
     )
 
+    queue = Queue(
+        connection=app.config["REDIS_CONN"],
+        is_async=app.config["ASYNC_QUEUE"],
+    )
+    queue.enqueue(
+        update,
+        {
+            "JSON_PATH": app.config["JSON_PATH"],
+            "BRANCHES": app.config["BRANCHES"],
+            "UPSTREAM_URL": app.config["UPSTREAM_URL"],
+        },
+        job_timeout="10m",
+    )
+
     return app

asu/common.py

@@ -12,14 +12,11 @@
 import requests
 from flask import current_app
 from podman import PodmanClient
-
-
-def get_redis():
-    return current_app.config["REDIS_CONN"]
+from rq import Queue, get_current_job
 
 
 def is_modified(url: str) -> bool:
-    r = get_redis()
+    r = get_current_job().connection
 
     modified_local = r.hget("last-modified", url)
     if modified_local: