Upload 2 files

app.py

@@ -65,6 +65,7 @@ async def generate_speech(text, selected_voice):
         
         # Configure the voice settings
         speech_config = genai.types.SpeechConfig(
+            language_code=language_code,
             voice_config=genai.types.VoiceConfig(
                 prebuilt_voice_config=genai.types.PrebuiltVoiceConfig(
                     voice_name=selected_voice
@@ -170,12 +171,30 @@ async def generate_podcast_route():
             "message": "Démarrage de la génération..."
         }
         
+        # Start the background task for podcast generation
+        # We'll return immediately and let the client poll for progress
+        asyncio.create_task(generate_podcast_background(scenario))
+        
+        return jsonify({
+            "status": "started",
+            "message": "Génération du podcast commencée. Suivez la progression sur l'interface."
+        })
+    
+    except Exception as e:
+        logger.error(f"Error in generate-podcast endpoint: {str(e)}")
+        update_progress(0, 0, f"Erreur: {str(e)}")
+        return jsonify({"error": str(e)}), 500
+
+async def generate_podcast_background(scenario):
+    """Generate a podcast in the background."""
+    try:
         # Generate audio for each character
         characters = scenario.get('characters', [])
         total_characters = len(characters)
         update_progress(0, total_characters, f"Préparation du podcast avec {total_characters} personnages...")
         
         audio_segments = []
+        podcast_filename = None
         
         for idx, character in enumerate(characters):
             character_name = character.get('name', 'Unknown')
@@ -189,8 +208,13 @@ async def generate_podcast_route():
                 voice = 'Kore'
             
             # Generate speech for this character
-            audio_file = await generate_speech(text, voice)
-            audio_segments.append(audio_file)
+            try:
+                audio_file = await generate_speech(text, voice)
+                audio_segments.append(audio_file)
+            except Exception as e:
+                logger.error(f"Error generating speech for {character_name}: {str(e)}")
+                update_progress(0, 0, f"Erreur lors de la génération pour {character_name}: {str(e)}")
+                return
         
         update_progress(total_characters, total_characters, "Assemblage des segments audio...")
         
@@ -205,21 +229,33 @@ async def generate_podcast_route():
         
         # Export the combined audio
         with tempfile.NamedTemporaryFile(suffix=".wav", delete=False) as output_file:
-            output_filename = output_file.name
-            combined.export(output_filename, format="wav")
+            podcast_filename = output_file.name
+            combined.export(podcast_filename, format="wav")
         
-        update_progress(total_characters + 1, total_characters + 1, "Podcast généré avec succès!")
+        update_progress(total_characters + 1, total_characters + 1, f"Podcast généré avec succès! audio:{os.path.basename(podcast_filename)}")
         
-        return jsonify({
-            "status": "success",
-            "message": "Podcast generated successfully",
-            "audioUrl": f"/audio/{os.path.basename(output_filename)}"
-        })
-    
     except Exception as e:
-        logger.error(f"Error in generate-podcast endpoint: {str(e)}")
+        logger.error(f"Error in podcast background task: {str(e)}")
         update_progress(0, 0, f"Erreur: {str(e)}")
-        return jsonify({"error": str(e)}), 500
+
+@app.route('/podcast-status')
+def podcast_status():
+    """Get the current status of the podcast generation."""
+    global generation_progress
+    
+    # If status is complete and contains an audioUrl in the message, extract it
+    if generation_progress["status"] == "complete" and "audio:" in generation_progress["message"]:
+        message_parts = generation_progress["message"].split("audio:")
+        if len(message_parts) > 1:
+            audio_filename = message_parts[1].strip()
+            return jsonify({
+                "status": "complete",
+                "message": message_parts[0].strip(),
+                "audioUrl": f"/audio/{audio_filename}"
+            })
+    
+    # Otherwise just return the current progress
+    return jsonify(generation_progress)
 
 @app.route('/generation-progress')
 def get_generation_progress():