"""Dünner Celery-Client: die API SCHICKT Tasks an den Worker, führt sie nie aus.

Bis 23.07. gab es überhaupt keinen Code-Pfad, der je einen Rip auslöste —
kein POST /jobs, kein udev-Daemon. Dieser Client schließt die Lücke.
"""

import os

from celery import Celery

REDIS_URL = os.getenv("REDIS_URL", "redis://localhost:6379/0")

celery_client = Celery("rippy_api", broker=REDIS_URL, backend=REDIS_URL)


def start_rip(device_path: str, job_id: str, target_dir: str = None):
    """Schickt den Rip-Task an den Worker (Task-Name aus worker/tasks.py)."""
    return celery_client.send_task(
        "worker.tasks.rip_disc", args=[device_path, job_id, target_dir]
    )