Add video async polling + Higgsfield models via WaveSpeed

- Fixed video generation async polling (same issue as img2img)
- Added Higgsfield Soul (image edit) and DoP (video) via WaveSpeed API
- Updated UI dropdowns with Higgsfield options

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

src/content_engine/api/routes_video.py

@@ -185,6 +185,58 @@ async def generate_video_cloud(
     }
 
 
+async def _poll_wavespeed_video(poll_url: str, api_key: str, job_id: str, max_attempts: int = 120, interval: float = 3.0) -> str | None:
+    """Poll the WaveSpeed async video job URL until outputs are ready.
+
+    Returns the first output URL when available, or None on failure.
+    """
+    import httpx
+
+    async with httpx.AsyncClient(timeout=60) as client:
+        for attempt in range(max_attempts):
+            try:
+                resp = await client.get(
+                    poll_url,
+                    headers={"Authorization": f"Bearer {api_key}"},
+                )
+                resp.raise_for_status()
+                result = resp.json()
+
+                data = result.get("data", result)
+                status = data.get("status", "")
+
+                if status == "failed":
+                    error_msg = data.get("error", "Unknown error")
+                    logger.error("WaveSpeed video job failed: %s", error_msg)
+                    return None
+
+                outputs = data.get("outputs", [])
+                if outputs:
+                    logger.info("WaveSpeed video job completed after %d polls", attempt + 1)
+                    return outputs[0]
+
+                # Also check for 'output' field
+                if "output" in data:
+                    out = data["output"]
+                    if isinstance(out, list) and out:
+                        return out[0]
+                    elif isinstance(out, str):
+                        return out
+
+                # Update job status with progress
+                _video_jobs[job_id]["message"] = f"Generating video... (poll {attempt + 1}/{max_attempts})"
+
+                logger.debug("WaveSpeed video job pending (attempt %d/%d)", attempt + 1, max_attempts)
+                await asyncio.sleep(interval)
+
+            except Exception as e:
+                logger.warning("Video poll request failed: %s", e)
+                await asyncio.sleep(interval)
+
+    logger.error("WaveSpeed video job timed out after %d attempts", max_attempts)
+    return None
+
+
 async def _generate_cloud_video(
     job_id: str,
     image_bytes: bytes,
@@ -244,10 +296,18 @@ async def _generate_cloud_video(
                 _video_jobs[job_id]["error"] = error_msg
                 return
 
-            # Extract video URL
+            # Extract video URL - handle async response (outputs empty, urls.get present)
             video_url = None
             outputs = data.get("outputs", [])
-            if outputs:
+            urls_data = data.get("urls", {})
+
+            # Check for async response first
+            if not outputs and urls_data and urls_data.get("get"):
+                poll_url = urls_data["get"]
+                logger.info("WaveSpeed video returned async job, polling: %s", poll_url[:80])
+                _video_jobs[job_id]["message"] = "Polling for video result..."
+                video_url = await _poll_wavespeed_video(poll_url, api_key, job_id)
+            elif outputs:
                 video_url = outputs[0]
             elif "output" in data:
                 out = data["output"]
@@ -258,7 +318,7 @@ async def _generate_cloud_video(
 
             if not video_url:
                 _video_jobs[job_id]["status"] = "failed"
-                _video_jobs[job_id]["error"] = "No video URL in response"
+                _video_jobs[job_id]["error"] = f"No video URL in response: {data}"
                 return
 
             # Download the video

src/content_engine/api/ui.html

@@ -910,6 +910,9 @@ select { cursor: pointer; }
           <div id="cloud-edit-model-select" style="display:none">
             <label>Cloud Edit Model (Image-to-Image)</label>
             <select id="gen-cloud-edit-model">
+              <optgroup label="Higgsfield (Character Consistency)">
+                <option value="higgsfield-soul">Higgsfield Soul (Best for Faces)</option>
+              </optgroup>
               <optgroup label="SeeDream Edit - NSFW OK">
                 <option value="seedream-4.5-edit">SeeDream v4.5 Edit (Best Quality)</option>
                 <option value="seedream-4-edit">SeeDream v4 Edit</option>
@@ -987,6 +990,11 @@ select { cursor: pointer; }
             <div id="video-cloud-model-select">
               <label>Video Model</label>
               <select id="video-cloud-model">
+                <optgroup label="Higgsfield (Cinematic Motion)">
+                  <option value="higgsfield-dop">Higgsfield DoP (5s Cinematic)</option>
+                  <option value="higgsfield-dop-turbo">Higgsfield DoP Turbo (Fast)</option>
+                  <option value="higgsfield-dop-lite">Higgsfield DoP Lite</option>
+                </optgroup>
                 <optgroup label="WAN 2.6 I2V (Alibaba)">
                   <option value="wan-2.6-i2v-pro" selected>WAN 2.6 I2V Pro (Best)</option>
                   <option value="wan-2.6-i2v">WAN 2.6 I2V</option>

src/content_engine/services/cloud_providers/wavespeed_provider.py

@@ -64,6 +64,10 @@ MODEL_MAP = {
 # Image-to-Video models
 # Based on https://wavespeed.ai/models
 VIDEO_MODEL_MAP = {
+    # Higgsfield DoP (Cinematic Motion)
+    "higgsfield-dop": "higgsfield/dop/image-to-video",
+    "higgsfield-dop-lite": "higgsfield/dop/image-to-video",  # Use options param
+    "higgsfield-dop-turbo": "higgsfield/dop/image-to-video",  # Use options param
     # WAN 2.6 I2V (Alibaba)
     "wan-2.6-i2v-pro": "alibaba/wan-2.6/image-to-video-pro",
     "wan-2.6-i2v": "alibaba/wan-2.6/image-to-video",
@@ -94,6 +98,8 @@ VIDEO_MODEL_MAP = {
 # Map friendly names to WaveSpeed edit model API paths
 # Based on https://wavespeed.ai/models
 EDIT_MODEL_MAP = {
+    # Higgsfield Soul (Character Consistency)
+    "higgsfield-soul": "higgsfield/soul/image-to-image",
     # SeeDream Edit (ByteDance) - NSFW OK
     "seedream-4.5-edit": "bytedance/seedream-v4.5/edit",
     "seedream-4-edit": "bytedance/seedream-v4/edit",