# app/workers/tasks.py

import redis
import json
import uuid
import os

r = redis.Redis(
    host=os.getenv("REDIS_HOST", "localhost"),
    port=int(os.getenv("REDIS_PORT", 6379)),
    password=os.getenv("REDIS_PASSWORD", None),
    decode_responses=True
)

def enqueue_task(task: dict):
    task_id = str(uuid.uuid4())
    task["task_id"] = task_id

    r.lpush("tasks", json.dumps(task))

    return task_id