Python 3 SDK (`httpx` / `requests` + FastAPI Webhook Receiver)

import hashlib, hmac, time, requests

class DaVinciCloudClient:
    def __init__(self, api_key: str, base_url: str = "https://www.davincideluxe.fr/api/v1/cloud"):
        self.base_url = base_url.rstrip("/")
        self.session = requests.Session()
        self.session.headers.update({"Authorization": f"Bearer {api_key}"})

    def submit_job(self, bin_path: str, ecu_brand: str, ecu_family: str,
                   services: list[str], tuning_options: list[str] | None = None,
                   dtc_codes: str = "", webhook_url: str = "") -> dict:
        with open(bin_path, "rb") as fh:
            files = {"file": (bin_path.split("/")[-1], fh, "application/octet-stream")}
            data = {
                "ecu_brand": ecu_brand,
                "ecu_family": ecu_family,
                "services": ",".join(services),
                "tuning_options": ",".join(tuning_options or []),
                "dtc_codes": dtc_codes,
                "webhook_url": webhook_url,
            }
            r = self.session.post(f"{self.base_url}/jobs", files=files, data=data, timeout=90)
            r.raise_for_status()
            return r.json()

    def wait_and_download(self, job_id: str, out_path: str, timeout_s: int = 180) -> str:
        deadline = time.time() + timeout_s
        while time.time() < deadline:
            st = self.session.get(f"{self.base_url}/jobs/{job_id}", timeout=20).json()
            if st.get("status") == "done" and st.get("result_available"):
                raw = self.session.get(f"{self.base_url}/jobs/{job_id}/result", timeout=90)
                raw.raise_for_status()
                with open(out_path, "wb") as f:
                    f.write(raw.content)
                return hashlib.sha256(raw.content).hexdigest()
            if st.get("status") in ("error", "rejected"):
                raise RuntimeError(f"Job {job_id} failed: {st}")
            time.sleep(3)
        raise TimeoutError(f"Job {job_id} timed out")

    @staticmethod
    def verify_webhook(raw_body: bytes, sig_header: str, whsec: str) -> bool:
        digest = "sha256=" + hmac.new(whsec.encode(), raw_body, hashlib.sha256).hexdigest()
        return hmac.compare_digest(sig_header or "", digest)