Fix TTS call (async), add HF Hub cloud upload for art_reels

modules/art_reels/router.py

@@ -173,13 +173,16 @@ async def generate_stick_figure_video(job_id: str, script: str, voice: str):
         
         # Step 1: Generate TTS audio from script
         logger.info(f"Generating TTS audio for job {job_id}")
-        audio_path = os.path.join(temp_dir, "voice.mp3")
-        await asyncio.to_thread(
-            tts_client.generate,
-            text=script,
-            voice=voice,
-            output_path=audio_path
-        )
+        audio_path = os.path.join(temp_dir, "voice.wav")
+        
+        # TTS generate is async and returns (audio_bytes, duration)
+        audio_bytes, audio_duration = await tts_client.generate(text=script, voice=voice)
+        
+        # Save audio to file
+        with open(audio_path, "wb") as f:
+            f.write(audio_bytes)
+        
+        logger.info(f"TTS audio saved: {audio_path}, duration: {audio_duration:.2f}s")
         
         if not os.path.exists(audio_path):
             raise Exception("TTS audio generation failed")
@@ -241,12 +244,31 @@ async def generate_stick_figure_video(job_id: str, script: str, voice: str):
         
         update_job(job_id, "processing", 95)
         
+        # Step 7: Upload to HF Hub (if enabled)
+        from pathlib import Path
+        from modules.shared.services.hf_storage import get_hf_storage
+        
+        hf_storage = get_hf_storage()
+        cloud_url = None
+        
+        if hf_storage and hf_storage.enabled:
+            logger.info(f"Uploading to HF Hub for job {job_id}")
+            cloud_url = hf_storage.upload_video(
+                local_path=Path(video_path),
+                video_id=job_id,
+                folder="art_reels"
+            )
+            if cloud_url:
+                logger.info(f"Uploaded to cloud: {cloud_url}")
+        
         # Cleanup
         video_composer.cleanup_frames(frame_paths)
         if os.path.exists(temp_dir):
             shutil.rmtree(temp_dir)
         
-        update_job(job_id, "ready", 100, video_url=f"/api/art/video/{job_id}")
+        # Set video URL (cloud if available, otherwise local)
+        video_url = cloud_url or f"/api/art/video/{job_id}"
+        update_job(job_id, "ready", 100, video_url=video_url)
         logger.info(f"Stick figure video with TTS ready: {job_id}")
         
     except Exception as e: