redis: add support to connect using unix socket

Signed-off-by: Christoph Heiss <christoph@c8h4.io>

tubearchivist/home/src/ta/settings.py

@@ -31,6 +31,9 @@ class EnvironmentSettings:
     # Redis
     REDIS_HOST: str = str(environ.get("REDIS_HOST"))
     REDIS_PORT: int = int(environ.get("REDIS_PORT", 6379))
+    REDIS_SOCKET: str | None = (
+        str(environ.get("REDIS_SOCKET")) if "REDIS_SOCKET" in environ else None
+    )
     REDIS_NAME_SPACE: str = str(environ.get("REDIS_NAME_SPACE", "ta:"))
 
     # ElasticSearch

tubearchivist/home/src/ta/ta_redis.py

@@ -17,11 +17,16 @@ class RedisBase:
     NAME_SPACE: str = EnvironmentSettings.REDIS_NAME_SPACE
 
     def __init__(self):
-        self.conn = redis.Redis(
-            host=EnvironmentSettings.REDIS_HOST,
-            port=EnvironmentSettings.REDIS_PORT,
-            decode_responses=True,
-        )
+        kwargs = {
+            "decode_responses": True,
+            "host": EnvironmentSettings.REDIS_HOST,
+            "port": EnvironmentSettings.REDIS_PORT,
+        }
+
+        if EnvironmentSettings.REDIS_SOCKET:
+            kwargs["unix_socket_path"] = EnvironmentSettings.REDIS_SOCKET
+
+        self.conn = redis.Redis(**kwargs)
 
 
 class RedisArchivist(RedisBase):