fix: Fix HLS lazy-loading with DRM (#4646)

Now that DRM info is only parsed after playback has begun, the manifest
parser needs to communicate back to the other components that new DRM
info is available after lazy-loading a playlist.

Closes #4622

Author: joeyparrish

externs/shaka/manifest_parser.js

@@ -112,7 +112,8 @@ shaka.extern.ManifestParser = class {
  *   isLowLatencyMode: function():boolean,
  *   isAutoLowLatencyMode: function():boolean,
  *   enableLowLatencyMode: function(),
- *   updateDuration: function()
+ *   updateDuration: function(),
+ *   newDrmInfo: function(shaka.extern.Stream)
  * }}
  *
  * @description
@@ -150,6 +151,9 @@ shaka.extern.ManifestParser = class {
  *   Enable low latency streaming mode.
  * @property {function()} updateDuration
  *   Update the presentation duration based on PresentationTimeline.
+ * @property {function(shaka.extern.Stream)} newDrmInfo
+ *   Inform the player of new DRM info that needs to be processed for the given
+ *   stream.
  * @exportDoc
  */
 shaka.extern.ManifestParser.PlayerInterface;

lib/hls/hls_parser.js

@@ -1615,6 +1615,12 @@ shaka.hls.HlsParser = class {
       stream.roles = realStream.roles;
       stream.mimeType = realStream.mimeType;
 
+      // Since we lazy-loaded this content, the player may need to create new
+      // sessions for the DRM info in this stream.
+      if (stream.drmInfos.length) {
+        this.playerInterface_.newDrmInfo(stream);
+      }
+
       const ContentType = shaka.util.ManifestParserUtils.ContentType;
       if (type == ContentType.VIDEO || type == ContentType.AUDIO) {
         for (const otherStreamInfo of this.uriToStreamInfosMap_.values()) {

lib/offline/storage.js

@@ -1170,6 +1170,7 @@ shaka.offline.Storage = class {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
 
     parser.configure(config.manifest);

lib/player.js

@@ -1889,6 +1889,15 @@ shaka.Player = class extends shaka.util.FakeEventTarget {
           this.streamingEngine_.updateDuration();
         }
       },
+      newDrmInfo: (stream) => {
+        // We may need to create new sessions for any new init data.
+        const currentDrmInfo =
+            this.drmEngine_ ? this.drmEngine_.getDrmInfo() : null;
+        // DrmEngine.newInitData() requires mediaKeys to be available.
+        if (currentDrmInfo && this.drmEngine_.getMediaKeys()) {
+          this.processDrmInfos_(currentDrmInfo.keySystem, stream);
+        }
+      },
     };
 
     const startTime = Date.now() / 1000;
@@ -5410,27 +5419,39 @@ shaka.Player = class extends shaka.util.FakeEventTarget {
     }
 
     // We may need to create new sessions for any new init data.
-    const curDrmInfo = this.drmEngine_ ? this.drmEngine_.getDrmInfo() : null;
+    const currentDrmInfo =
+        this.drmEngine_ ? this.drmEngine_.getDrmInfo() : null;
     // DrmEngine.newInitData() requires mediaKeys to be available.
-    if (curDrmInfo && this.drmEngine_.getMediaKeys()) {
+    if (currentDrmInfo && this.drmEngine_.getMediaKeys()) {
       for (const variant of manifest.variants) {
-        const videoDrmInfos = variant.video ? variant.video.drmInfos : [];
-        const audioDrmInfos = variant.audio ? variant.audio.drmInfos : [];
-        const drmInfos = videoDrmInfos.concat(audioDrmInfos);
-        for (const drmInfo of drmInfos) {
-          // Ignore any data for different key systems.
-          if (drmInfo.keySystem == curDrmInfo.keySystem) {
-            for (const initData of (drmInfo.initData || [])) {
-              this.drmEngine_.newInitData(
-                  initData.initDataType, initData.initData);
-            }
-          }
-        }
+        this.processDrmInfos_(currentDrmInfo.keySystem, variant.video);
+        this.processDrmInfos_(currentDrmInfo.keySystem, variant.audio);
       }
     }
     this.checkRestrictedVariants_(manifest);
   }
 
+  /**
+   * @param {string} keySystem
+   * @param {?shaka.extern.Stream} stream
+   * @private
+   */
+  processDrmInfos_(keySystem, stream) {
+    if (!stream) {
+      return;
+    }
+
+    for (const drmInfo of stream.drmInfos) {
+      // Ignore any data for different key systems.
+      if (drmInfo.keySystem == keySystem) {
+        for (const initData of (drmInfo.initData || [])) {
+          this.drmEngine_.newInitData(
+              initData.initDataType, initData.initData);
+        }
+      }
+    }
+  }
+
   /**
    * @private
    */

test/dash/dash_parser_content_protection_unit.js

@@ -44,6 +44,7 @@ describe('DashParser ContentProtection', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
 
     const actual = await dashParser.start(

test/dash/dash_parser_live_unit.js

@@ -37,6 +37,7 @@ describe('DashParser Live', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
   });
 

test/dash/dash_parser_manifest_unit.js

@@ -53,6 +53,7 @@ describe('DashParser Manifest', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
   });
 

test/dash/dash_parser_segment_base_unit.js

@@ -39,6 +39,7 @@ describe('DashParser SegmentBase', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
   });
 

test/dash/dash_parser_segment_list_unit.js

@@ -349,6 +349,7 @@ describe('DashParser SegmentList', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
     const manifest = await dashParser.start('dummy://foo', playerInterface);
     const stream = manifest.variants[0].video;

test/dash/dash_parser_segment_template_unit.js

@@ -48,6 +48,7 @@ describe('DashParser SegmentTemplate', () => {
       isAutoLowLatencyMode: () => false,
       enableLowLatencyMode: () => {},
       updateDuration: () => {},
+      newDrmInfo: (stream) => {},
     };
   });