Fix: reuse provider http client for Kling Motion, fix indentation

src/content_engine/api/routes_video.py

@@ -344,55 +344,55 @@ async def _generate_kling_motion_video(
         _video_jobs[job_id]["message"] = "Calling Kling Motion Control API..."
         logger.info("Calling Kling Motion Control: %s", endpoint)
 
-        async with httpx.AsyncClient(timeout=60) as client:
-            resp = await client.post(
-                endpoint,
-                json=payload,
-                headers={"Authorization": f"Bearer {api_key}", "Content-Type": "application/json"},
-            )
-
-            if resp.status_code != 200:
-                error_text = resp.text[:500]
-                logger.error("Kling Motion API error: %s", error_text)
-                _video_jobs[job_id]["status"] = "failed"
-                _video_jobs[job_id]["error"] = f"API error: {error_text[:200]}"
-                return
+        # Reuse the provider's existing httpx client (avoids SSL reconnect issues)
+        http = _wavespeed_provider._http_client
+        resp = await http.post(
+            endpoint,
+            json=payload,
+            headers={"Authorization": f"Bearer {api_key}", "Content-Type": "application/json"},
+        )
 
-            result = resp.json()
-            data = result.get("data", result)
-            logger.info("Kling Motion API response: %s", str(result)[:300])
+        if resp.status_code != 200:
+            error_text = resp.text[:500]
+            logger.error("Kling Motion API error: %s", error_text)
+            _video_jobs[job_id]["status"] = "failed"
+            _video_jobs[job_id]["error"] = f"API error: {error_text[:200]}"
+            return
 
-            # Poll if async
-            outputs = data.get("outputs", [])
-            urls_data = data.get("urls", {})
-            if not outputs and urls_data.get("get"):
-                _video_jobs[job_id]["message"] = "Waiting for Kling Motion to complete..."
-                video_url_out = await _poll_wavespeed_video(urls_data["get"], api_key, job_id, max_attempts=300, interval=5.0)
-            elif outputs:
-                video_url_out = outputs[0] if isinstance(outputs[0], str) else outputs[0].get("url")
-            else:
-                _video_jobs[job_id]["status"] = "failed"
-                _video_jobs[job_id]["error"] = "No output URL in response"
-                return
+        result = resp.json()
+        data = result.get("data", result)
+        logger.info("Kling Motion API response: %s", str(result)[:300])
+
+        # Poll if async
+        outputs = data.get("outputs", [])
+        urls_data = data.get("urls", {})
+        if not outputs and urls_data.get("get"):
+            _video_jobs[job_id]["message"] = "Waiting for Kling Motion to complete..."
+            video_url_out = await _poll_wavespeed_video(urls_data["get"], api_key, job_id, max_attempts=300, interval=5.0)
+        elif outputs:
+            video_url_out = outputs[0] if isinstance(outputs[0], str) else outputs[0].get("url")
+        else:
+            _video_jobs[job_id]["status"] = "failed"
+            _video_jobs[job_id]["error"] = "No output URL in response"
+            return
 
-            if not video_url_out:
-                return  # poll already set status
+        if not video_url_out:
+            return  # poll already set status
 
-            # Download and save
-            _video_jobs[job_id]["message"] = "Downloading video..."
-            output_dir = Path(os.environ.get("OUTPUT_DIR", "outputs")) / "videos"
-            output_dir.mkdir(parents=True, exist_ok=True)
-            filename = f"kling_motion_{job_id}.mp4"
-            output_path = output_dir / filename
+        # Download and save
+        _video_jobs[job_id]["message"] = "Downloading video..."
+        output_dir = Path(os.environ.get("OUTPUT_DIR", "outputs")) / "videos"
+        output_dir.mkdir(parents=True, exist_ok=True)
+        filename = f"kling_motion_{job_id}.mp4"
+        output_path = output_dir / filename
 
-            async with httpx.AsyncClient(timeout=120) as dl_client:
-                r = await dl_client.get(video_url_out)
-                output_path.write_bytes(r.content)
+        r = await http.get(video_url_out)
+        output_path.write_bytes(r.content)
 
-            _video_jobs[job_id]["status"] = "completed"
-            _video_jobs[job_id]["filename"] = filename
-            _video_jobs[job_id]["message"] = "Done"
-            logger.info("Kling Motion video saved: %s", filename)
+        _video_jobs[job_id]["status"] = "completed"
+        _video_jobs[job_id]["filename"] = filename
+        _video_jobs[job_id]["message"] = "Done"
+        logger.info("Kling Motion video saved: %s", filename)
 
     except Exception as e:
         logger.exception("Kling Motion generation failed: %s", e)