Add contagions seitn

common-utils

@@ -1 +1 @@
-Subproject commit 1ae213fc016e05903e7c41aced495a65fe6cae23
+Subproject commit f28bc83d3e2dbd2e43f93d2edcb9a5be5ca97e14

server-plugins/single-static-video.js

@@ -77,7 +77,10 @@ export class SingleStaticVideoPlugin extends Plugin {
       }
     }
 
-    combinedBubbles = await this.combineAllTranscriptBubbles(transcript)
+    combinedBubbles = await this.combineAllTranscriptBubbles(transcript, {
+      contagious: this.options.contagious || false,
+      contagiousDelay: this.options.contagiousDelay ?? 0
+    })
     await Promise.all([
       this.combineAllAudioCaptions(transcript, combinedAudioCaptionsFilePath),
       this.combineAllAudios(transcript, combinedAudioPath)
@@ -166,8 +169,11 @@ export class SingleStaticVideoPlugin extends Plugin {
     }
   }
 
-  // Takes all transcipts and returns a single array with  bubbles from different sections put into a single array and sorted by start time. The bubbles are also adjusted to have the correct start and end times based on the section duration and bubble duration.  Return array of bubbles
-  async combineAllTranscriptBubbles(transcripts) {
+  // Takes all transcripts and returns a single array with bubbles from different sections put into a single array and sorted by start time. The bubbles are also adjusted to have the correct start and end times based on the section duration and bubble duration.  Return array of bubbles.
+  // Options:
+  //   contagious {boolean} - if true, each bubble[N+1].fromSec is forced to bubble[N].toSec + contagiousDelay after sorting
+  //   contagiousDelay {number} - gap in seconds between consecutive bubbles when contagious=true (default: 0)
+  async combineAllTranscriptBubbles(transcripts, { contagious = false, contagiousDelay = 0 } = {}) {
     let combinedBubbles = [];
     let cumulativeOffset = 0;
 
@@ -196,6 +202,34 @@ export class SingleStaticVideoPlugin extends Plugin {
     // Sort bubbles by their start time
     combinedBubbles.sort((a, b) => (a.fromSec || 0) - (b.fromSec || 0));
 
+    // Apply contagious chaining: bubble[N+1].fromSec = bubble[N].toSec + contagiousDelay
+    if (contagious && combinedBubbles.length > 1) {
+      this.log(`Applying contagious chaining with delay=${contagiousDelay}s across ${combinedBubbles.length} bubbles.`);
+      for (let i = 1; i < combinedBubbles.length; i++) {
+        const prev = combinedBubbles[i - 1];
+        if (prev.toSec !== undefined && prev.toSec !== null) {
+          const newFromSec = prev.toSec + contagiousDelay;
+          if (combinedBubbles[i].fromSec !== undefined && combinedBubbles[i].toSec !== undefined) {
+            // Preserve original duration, shift the window forward
+            const originalDur = combinedBubbles[i].toSec - combinedBubbles[i].fromSec;
+            combinedBubbles[i].fromSec = newFromSec;
+            combinedBubbles[i].toSec = Math.round((newFromSec + originalDur) * 1000) / 1000;
+          } else {
+            combinedBubbles[i].fromSec = newFromSec;
+          }
+          // Mirror into mediaTextPrompts if present
+          if (combinedBubbles[i].mediaTextPrompts?.length) {
+            combinedBubbles[i].mediaTextPrompts[0].fromSec = combinedBubbles[i].fromSec;
+            combinedBubbles[i].mediaTextPrompts[0].toSec = combinedBubbles[i].toSec;
+            if (combinedBubbles[i].durationSec !== undefined) {
+              combinedBubbles[i].durationSec = Math.round((combinedBubbles[i].toSec - combinedBubbles[i].fromSec) * 1000) / 1000;
+              combinedBubbles[i].mediaTextPrompts[0].durationSec = combinedBubbles[i].durationSec;
+            }
+          }
+        }
+      }
+    }
+
     this.log(`Combined ${combinedBubbles.length} bubbles from ${transcripts.length} sections`);
     return combinedBubbles;
   }