Handle that two ads in a row can be merged into one break if option m…

…erge=true is provided
Eyevinn · Apr 14, 2020 · 571ff13 · 571ff13
1 parent bf0bf6a
commit 571ff13
Show file tree

Hide file tree

Showing 2 changed files with 59 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -24,6 +24,7 @@ class HLSSpliceVod {
     this.playlists = {};
     this.baseUrl = null;
     this.targetDuration = 0;
+    this.mergeBreaks = false; // Merge ad breaks at the same position into one single break
     if (options && options.baseUrl) {
       this.baseUrl = options.baseUrl;
     }
@@ -34,6 +35,9 @@ class HLSSpliceVod {
       }
 
     }
+    if (options && options.merge) {
+      this.mergeBreaks = true;
+    }
   }
 
   /**
@@ -124,6 +128,23 @@ class HLSSpliceVod {
             this.playlists[bw].addPlaylistItem({ 'cuein': true });
           }
           this.playlists[bw].set('targetDuration', this.targetDuration);
+          if (this.mergeBreaks) {
+            let adBreakDuration = 0;
+            let itemToUpdate = null;
+            for (let i = 0; i < this.playlists[bw].items.PlaylistItem.length; i++) {
+              if (this.playlists[bw].items.PlaylistItem[i].get('cueout') && this.playlists[bw].items.PlaylistItem[i].get('cuein')) {
+                adBreakDuration += this.playlists[bw].items.PlaylistItem[i].get('cueout');
+                this.playlists[bw].items.PlaylistItem[i].set('cueout', null);
+                this.playlists[bw].items.PlaylistItem[i].set('cuein', false);
+              } else if (this.playlists[bw].items.PlaylistItem[i].get('cueout') && !this.playlists[bw].items.PlaylistItem[i].get('cuein')) {
+                adBreakDuration = 0;
+                itemToUpdate = this.playlists[bw].items.PlaylistItem[i];
+              } else if (!this.playlists[bw].items.PlaylistItem[i].get('cueout') && this.playlists[bw].items.PlaylistItem[i].get('cuein')) {
+                const cueOut = itemToUpdate.get('cueout');
+                itemToUpdate.set('cueout', cueOut + adBreakDuration);
+              }
+            }
+          }  
         }
         //console.log(this.playlists[bandwidths[0]].toString());
         resolve();  

diff --git a/spec/hls_splice_spec.js b/spec/hls_splice_spec.js
@@ -144,6 +144,44 @@ describe("HLSSpliceVod", () => {
     });
   });
 
+  it("handles two ads in a row merged into one break", done => {
+    const mockVod = new HLSSpliceVod('http://mock.com/mock.m3u8', { merge: true });
+    mockVod.load(mockMasterManifest, mockMediaManifest)
+    .then(() => {
+      return mockVod.insertAdAt(0, 'http://mock.com/ad/mockad.m3u8', mockAdMasterManifest, mockAdMediaManifest);
+    })
+    .then(() => {
+      // This one will go first
+      return mockVod.insertAdAt(0, 'http://mock.com/ad/mockad.m3u8', mockAdMasterManifest3, mockAdMediaManifest3);
+    })
+    .then(() => {
+      const m3u8 = mockVod.getMediaManifest(4497000);
+      const lines = m3u8.split('\n');
+      expect(lines[8]).toEqual("#EXT-X-CUE-OUT:DURATION=18");
+      done();
+    });
+  });
+
+  it("handles two ads that should not be merged into one break", done => {
+    const mockVod = new HLSSpliceVod('http://mock.com/mock.m3u8', { merge: true });
+    mockVod.load(mockMasterManifest, mockMediaManifest)
+    .then(() => {
+      return mockVod.insertAdAt(9, 'http://mock.com/ad/mockad.m3u8', mockAdMasterManifest, mockAdMediaManifest);
+    })
+    .then(() => {
+      // This one will go first
+      return mockVod.insertAdAt(0, 'http://mock.com/ad/mockad.m3u8', mockAdMasterManifest3, mockAdMediaManifest3);
+    })
+    .then(() => {
+      const m3u8 = mockVod.getMediaManifest(4497000);
+      const lines = m3u8.split('\n');
+      expect(lines[8]).toEqual("#EXT-X-CUE-OUT:DURATION=3");
+      expect(lines[16]).toEqual("#EXT-X-CUE-OUT:DURATION=15");
+      done();
+    });
+  });
+
+
   it("handles post-roll ads", done => {
     const mockVod = new HLSSpliceVod('http://mock.com/mock.m3u8');
     mockVod.load(mockMasterManifest, mockMediaManifest)