Refactor Redis connection handling and update Dockerfile for environment variable support

.gitignore

@@ -0,0 +1 @@
+.env

Dockerfile

@@ -8,8 +8,10 @@ WORKDIR /app
 
 COPY --chown=user ./requirements.txt requirements.txt
 RUN pip install --no-cache-dir --upgrade -r requirements.txt
+COPY --chown=user .env /app/.env
+RUN pip install python-dotenv
 
 EXPOSE 7860
 
 COPY --chown=user . /app
-CMD ["python","run.py"]
+CMD ["python","run.py"]

video_encoder/api/main.py

@@ -7,9 +7,11 @@ import hmac
 import hashlib
 from datetime import datetime
 from rq import Queue
-from redis import Redis
-from ..config import EncodingConfig
-from ..worker.tasks import encode_video_task, q
+from redis import from_url
+from ..config import EncodingConfig, RedisConfig
+from ..worker.tasks import encode_video_task
+
+q = Queue(connection=RedisConfig.get_connection(), default_timeout=3600)
 
 app = FastAPI(title="Video Encoding Service")
 
@@ -32,7 +34,7 @@ async def upload_video(file: UploadFile):
 
 @app.get("/status/{job_id}")
 async def get_status(job_id: str):
-    redis = Redis()
+    redis = RedisConfig.get_connection()
     progress = redis.hget(f"job:{job_id}", "progress")
     
     if not progress:

video_encoder/config.py

@@ -1,8 +1,25 @@
 import os
 from typing import List, Dict
 
+import os
+from redis import from_url
+from dotenv import load_dotenv
+
+load_dotenv()
+
 class EncodingConfig:
     TEMP_DIR = "./tmp"
+
+class RedisConfig:
+    URL = os.getenv("REDIS_URL")
+    CONN_POOL = None  # Will be initialized on first use
+    QUEUE_NAME = "video_encoding_queue"
+
+    @classmethod
+    def get_connection(cls):
+        if not cls.CONN_POOL:
+            cls.CONN_POOL = from_url(cls.URL, max_connections=20)
+        return cls.CONN_POOL
     HMAC_SECRET = os.getenv("VIDEO_HMAC_SECRET", "default-secret-change-me")
     
     RESOLUTIONS: List[Dict] = [

video_encoder/worker/tasks.py

@@ -1,7 +1,8 @@
 import os
 import logging
 import shutil
-from redis import Redis
+from redis import from_url
+from ..config import RedisConfig
 from rq import Queue
 from pathlib import Path
 from typing import Optional
@@ -11,10 +12,10 @@ from ..config import EncodingConfig
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
-q = Queue(connection=Redis(), default_timeout=3600)
+q = Queue(connection=RedisConfig.get_connection(), default_timeout=3600)
 
 def update_job_progress(job_id: str, progress: float):
-    Redis().hset(f"job:{job_id}", "progress", progress)
+    RedisConfig.get_connection().hset(f"job:{job_id}", "progress", progress)
 
 def encode_video_task(job_id: str, input_path: str) -> Optional[str]:
     try: