feat(ffmpeg): synchronisation texte/voix precise via WordBoundary edge-tts

ffmpeg-service/main.py

@@ -190,7 +190,11 @@ async def generate_tts_with_subs(
     ass_path: Path,
     display_text: Optional[str] = None,
 ):
-    """Generate TTS audio with subtitles, utilizing precise WordBoundary events."""
+    """Generate TTS audio with word-level synchronized subtitles.
+
+    Uses edge_tts.Communicate.stream() to capture WordBoundary events,
+    providing millisecond-accurate subtitle timing instead of linear estimation.
+    """
     import asyncio
 
     # Determine gender of requested voice to choose appropriate fallbacks
@@ -198,18 +202,17 @@ async def generate_tts_with_subs(
 
     if is_male:
         fallback_voices = [
-            voice,  # Try requested voice first
+            voice,
-            "fr-FR-HenriNeural",  # Primary Male fallback
+            "fr-FR-HenriNeural",
-            "fr-FR-PaulNeural",  # Secondary Male fallback
+            "fr-FR-PaulNeural",
         ]
     else:
         fallback_voices = [
-            voice,  # Try requested voice first
+            voice,
-            "fr-FR-VivienneNeural",  # Primary Female fallback
+            "fr-FR-VivienneNeural",
-            "fr-FR-DeniseNeural",  # Secondary Female fallback
+            "fr-FR-DeniseNeural",
         ]
 
-    # Always add English fallback as last resort
     fallback_voices.append("en-US-JennyNeural")
     fallback_voices = list(dict.fromkeys(fallback_voices))
 
@@ -220,50 +223,84 @@ async def generate_tts_with_subs(
             print(f"🔊 TTS attempt with voice: {attempt_voice}")
             communicate = edge_tts.Communicate(text, attempt_voice)
 
-            # Words capturing for precise sync
+            # Stream audio + word boundaries simultaneously
-            word_timings = []
+            word_boundaries = []
+            audio_chunks = []
 
-            # Open file for writing audio stream
+            async for chunk in communicate.stream():
-            with open(audio_path, "wb") as audio_file:
+                if chunk["type"] == "audio":
-                async for chunk in communicate.stream():
+                    audio_chunks.append(chunk["data"])
-                    if chunk["type"] == "audio":
+                elif chunk["type"] == "WordBoundary":
-                        audio_file.write(chunk["data"])
+                    # Offsets are in 100-nanosecond ticks, convert to seconds
-                    elif chunk["type"] == "WordBoundary":
+                    offset_sec = chunk["offset"] / 10_000_000
-                        # edge-tts provides offset/duration in 100ns units (ticks)
+                    duration_sec = chunk["duration"] / 10_000_000
-                        # We convert to seconds immediately
+                    word_boundaries.append(
-                        word_timings.append({
+                        {
                             "text": chunk["text"],
-                            "offset": chunk["offset"] / 10_000_000,
+                            "offset": offset_sec,
-                            "duration": chunk["duration"] / 10_000_000
+                            "duration": duration_sec,
-                        })
+                        }
+                    )
+
+            # Write audio to file
+            if audio_chunks:
+                with open(audio_path, "wb") as f:
+                    for audio_data in audio_chunks:
+                        f.write(audio_data)
 
-            # Check if file was created and has content
             if audio_path.exists() and audio_path.stat().st_size > 0:
                 print(f"✅ TTS audio saved: {audio_path.stat().st_size} bytes")
-                print(f"📊 Collected {len(word_timings)} precise word timings")
+                print(f"📍 Captured {len(word_boundaries)} word boundaries")
 
-                # Generate a high-quality ASS file with PRECISE sync
+                # Log a few boundaries for debugging
-                # If we have timings, use them. If not (some voices don't support it?), fallback.
+                for wb in word_boundaries[:5]:
+                    print(
+                        f"   → '{wb['text']}' at {wb['offset']:.2f}s (dur: {wb['duration']:.2f}s)"
+                    )
+
+                # Measure total audio duration via ffprobe for safety
+                audio_duration = None
+                try:
+                    duration_cmd = [
+                        "ffprobe",
+                        "-v",
+                        "error",
+                        "-show_entries",
+                        "format=duration",
+                        "-of",
+                        "default=noprint_wrappers=1:nokey=1",
+                        str(audio_path),
+                    ]
+                    dur_proc = subprocess.run(
+                        duration_cmd, stdout=subprocess.PIPE, text=True
+                    )
+                    audio_duration = float(dur_proc.stdout.strip())
+                    print(f"⏱️ TTS Audio Duration: {audio_duration:.2f}s")
+                except Exception as e:
+                    print(f"⚠️ Could not measure TTS duration: {e}")
+
+                # Use display_text for subtitle content if provided
                 text_to_display = display_text if display_text else text
 
-                if word_timings:
+                if word_boundaries:
-                    generate_precise_ass(word_timings, ass_path)
+                    # Precise synchronization using real word timings
+                    generate_ass_from_word_boundaries(
+                        word_boundaries,
+                        text_to_display,
+                        ass_path,
+                        total_duration=audio_duration,
+                    )
                 else:
-                    # Fallback to estimation if no events received
+                    # Fallback to linear estimation if no boundaries captured
-                    print("⚠️ No WordBoundary events received. Falling back to simple estimation.")
+                    print(
-                    # Measure audio duration for fallback sync
+                        "⚠️ No word boundaries captured, falling back to linear timing"
-                    audio_duration = 0
+                    )
-                    try:
+                    generate_simple_ass(
-                        duration_cmd = ["ffprobe", "-v", "error", "-show_entries", "format=duration", "-of", "default=noprint_wrappers=1:nokey=1", str(audio_path)]
+                        text_to_display, ass_path, total_duration=audio_duration
-                        dur_proc = subprocess.run(duration_cmd, stdout=subprocess.PIPE, text=True)
+                    )
-                        audio_duration = float(dur_proc.stdout.strip())
-                    except:
-                        pass
-                    
-                    generate_simple_ass(text_to_display, ass_path, total_duration=audio_duration)
 
                 print(f"✅ TTS success with voice: {attempt_voice}")
-                return  # Success!
+                return
             else:
                 print(f"⚠️ Audio file empty or missing with voice: {attempt_voice}")
 
@@ -271,12 +308,55 @@ async def generate_tts_with_subs(
             print(f"⚠️ TTS failed with voice {attempt_voice}: {e}")
             last_error = e
 
-    # If all voices failed
     raise Exception(f"All TTS voices failed. Last error: {last_error}")
 
 
-def generate_precise_ass(word_timings: list, ass_path: Path, font_size: int = 65):
+def generate_ass_from_word_boundaries(
-    """Generate TikTok-style ASS subtitle file using PRECISE word timestamps."""
+    word_boundaries: list,
+    display_text: str,
+    ass_path: Path,
+    font_size: int = 65,
+    total_duration: float = None,
+):
+    """Generate ASS subtitles using precise word-level timing from TTS engine.
+
+    Groups words into readable chunks (~5 words or at punctuation) and uses
+    the real start/end timestamps from the TTS engine for each chunk.
+    """
+    if not word_boundaries:
+        return
+
+    # Group word boundaries into chunks of ~5 words, or split at punctuation
+    chunks = []
+    current_words = []
+    current_start = word_boundaries[0]["offset"]
+
+    for i, wb in enumerate(word_boundaries):
+        current_words.append(wb["text"])
+        is_last = i == len(word_boundaries) - 1
+        # Split at punctuation or every 5 words
+        ends_sentence = wb["text"].rstrip().endswith((".", "!", "?", ":", ","))
+        at_limit = len(current_words) >= 5
+
+        if is_last or ends_sentence or at_limit:
+            # End time = this word's offset + its duration
+            chunk_end = wb["offset"] + wb["duration"]
+            chunks.append(
+                {
+                    "text": " ".join(current_words),
+                    "start": current_start,
+                    "end": chunk_end,
+                }
+            )
+            current_words = []
+            # Next chunk starts at the next word's offset
+            if not is_last:
+                current_start = word_boundaries[i + 1]["offset"]
+
+    # Extend the last chunk to total_duration if available
+    # Why: prevents the last subtitle from vanishing before audio ends
+    if total_duration and chunks:
+        chunks[-1]["end"] = max(chunks[-1]["end"], total_duration)
 
     # ASS Header
     header = f"""[Script Info]
@@ -285,6 +365,57 @@ PlayResX: 1080
 PlayResY: 1920
 ScaledBorderAndShadow: yes
 
+[V4+ Styles]
+Format: Name, Fontname, Fontsize, PrimaryColour, SecondaryColour, OutlineColour, BackColour, Bold, Italic, Underline, StrikeOut, ScaleX, ScaleY, Spacing, Angle, BorderStyle, Outline, Shadow, Alignment, MarginL, MarginR, MarginV, Encoding
+Style: Default,Sans,{font_size},&H00FFFFFF,&H000000FF,&H00000000,&H80000000,-1,0,0,0,100,100,0,0,1,2,0,5,50,50,0,1
+
+[Events]
+Format: Layer, Start, End, Style, Name, MarginL, MarginR, MarginV, Effect, Text
+"""
+
+    events = ""
+    for chunk in chunks:
+        start_ts = format_ass_time(chunk["start"])
+        end_ts = format_ass_time(chunk["end"])
+        sanitized = chunk["text"].replace("{", "(").replace("}", ")")
+        events += f"Dialogue: 0,{start_ts},{end_ts},Default,,0,0,0,,{sanitized}\n"
+
+    with open(ass_path, "w", encoding="utf-8") as f:
+        f.write(header + events)
+
+    print(
+        f"📄 Generated synced ASS: {ass_path.stat().st_size} bytes, "
+        f"{len(chunks)} chunks from {len(word_boundaries)} words"
+    )
+
+
+def generate_simple_ass(
+    text: str, ass_path: Path, font_size: int = 65, total_duration: float = None
+):
+    """Generate a high-quality ASS subtitle file with embedded styling."""
+    # Split text into chunks
+    words = text.split()
+    chunks = []
+    current_chunk = []
+
+    for word in words:
+        current_chunk.append(word)
+        if len(current_chunk) >= 5 or word.endswith((".", "!", "?", ":")):
+            chunks.append(" ".join(current_chunk))
+            current_chunk = []
+
+    if current_chunk:
+        chunks.append(" ".join(current_chunk))
+
+    # ASS Header with explicit resolution and style
+    # Alignment 5 = Middle Center
+    # Font: Priority to Noto Color Emoji for emojis support
+    header = f"""[Script Info]
+ScriptType: v4.00+
+PlayResX: 1080
+PlayResY: 1920
+ScaledBorderAndShadow: yes
+
 [V4+ Styles]
 Format: Name, Fontname, Fontsize, PrimaryColour, SecondaryColour, OutlineColour, BackColour, Bold, Italic, Underline, StrikeOut, ScaleX, ScaleY, Spacing, Angle, BorderStyle, Outline, Shadow, Alignment, MarginL, MarginR, MarginV, Encoding
 Style: Default,Sans,{font_size},&H0000FFFF,&H00FFFFFF,&H00000000,&H80000000,-1,0,0,0,100,100,0,0,1,3,1,5,50,50,0,1
@@ -311,7 +442,8 @@ Format: Layer, Start, End, Style, Name, MarginL, MarginR, MarginV, Effect, Text
         chunks.append(current_chunk)
 
     for chunk in chunks:
-        if not chunk: continue
+        if not chunk:
+            continue
 
         # Chunk Start = Start of first word
         # Chunk End = End of last word
@@ -333,7 +465,7 @@ Format: Layer, Start, End, Style, Name, MarginL, MarginR, MarginV, Effect, Text
         # Format: {\kf80}Word1 {\kf40}Word2
 
         for timing in chunk:
-            duration_cs = int(timing["duration"] * 100) # seconds to centiseconds
+            duration_cs = int(timing["duration"] * 100)  # seconds to centiseconds
             # Ensure at least 1cs
             duration_cs = max(duration_cs, 1)
 
@@ -341,12 +473,16 @@ Format: Layer, Start, End, Style, Name, MarginL, MarginR, MarginV, Effect, Text
             karaoke_parts.append(f"{{\\kf{duration_cs}}}{sanitized}")
 
         karaoke_text = " ".join(karaoke_parts)
-        events += f"Dialogue: 0,{s_time_str},{e_time_str},Default,,0,0,0,,{karaoke_text}\n"
+        events += (
+            f"Dialogue: 0,{s_time_str},{e_time_str},Default,,0,0,0,,{karaoke_text}\n"
+        )
 
     with open(ass_path, "w", encoding="utf-8") as f:
         f.write(header + events)
 
-    print(f"📄 Generated PRECISE ASS file: {len(chunks)} chunks from {len(word_timings)} words")
+    print(
+        f"📄 Generated PRECISE ASS file: {len(chunks)} chunks from {len(word_timings)} words"
+    )
 
 
 def generate_simple_ass(

task.md

@@ -6,7 +6,7 @@ Ajout d'une fonctionnalité complète de création de Reels Facebook permettant
 
 ## Current Focus
 
-**Phase: EXECUTION** - Optimisation qualité iPhone Safari (Bypass compression).
+**Phase: EXECUTION** - Activation de l'agent BMad Master et interface de commande.
 
 ## Master Plan
 
@@ -138,14 +138,22 @@ Ajout d'une fonctionnalité complète de création de Reels Facebook permettant
   - [x] **Final Robust Fix** : Switch complet vers le filtre `subtitles` et format `.srt` pour contourner l'absence de `drawtext` dans l'environnement.
   - [x] **Style Adjustment** : Réduction de la taille du texte à 30 pour un rendu plus élégant.
 
-### Phase 13: Activation Agent BMad ⏳
+### Phase 14: Synchronisation Parfaite Texte/Voix ⏳
+
+- [x] Récupérer les Word Boundaries via `edge_tts`
+- [x] Générer le fichier `.ass` avec des timestamps précis
+- [ ] Rebuild Docker et valider la synchronisation sur un Reel de test
+
+### Phase 13: Activation Agent BMad ✅
 
 - [x] Activer l'agent `bmad-master.md`
 - [x] Charger la configuration `_bmad/core/config.yaml`
 - [x] Afficher le menu de l'agent en français
+- [x] Ré-activation de l'agent bmad-master.md (11 Fev 2026)
 
 ## Progress Log
 
+- **11 Fev 2026** - Ré-activation de l'agent BMad Master, chargement de la configuration et affichage du menu.
 - **22 Jan 2026** - Analyse complète et PRD créé
 - **22 Jan 2026** - Spécifications confirmées
 - **22 Jan 2026** - Backend complet : ffmpeg.ts, freesound.ts, facebook.ts