wip: mixing HLS+Widevine with non-DRM

Author: birme

package-lock.json

@@ -26,7 +26,7 @@
   "dependencies": {
     "@eyevinn/hls-repeat": "^0.2.0",
     "@eyevinn/hls-truncate": "^0.2.0",
-    "@eyevinn/hls-vodtolive": "^2.2.1",
+    "@eyevinn/hls-vodtolive": "2.3.0",
     "@eyevinn/m3u8": "^0.5.3",
     "abort-controller": "^3.0.0",
     "debug": "^3.2.7",

package.json

@@ -0,0 +1,120 @@
+/*
+ * Reference implementation of Channel Engine library using DRM (HLS+Widevine) VOD assets.
+ *
+ * Playback: https://shaka-player-demo.appspot.com/demo/#audiolang=sv-SE;textlang=sv-SE;uilang=sv-SE;asset=http://localhost:8000/channels/1/master.m3u8;license=https://cwip-shaka-proxy.appspot.com/no_auth;panel=CUSTOM%20CONTENT;build=uncompiled
+ */
+
+import {
+  ChannelEngine,
+  ChannelEngineOpts,
+  IAssetManager,
+  IChannelManager,
+  VodRequest,
+  VodResponse,
+  Channel,
+  ChannelProfile,
+  AudioTracks,
+} from "./index";
+
+class RefAssetManager implements IAssetManager {
+  private assets;
+  private pos;
+  constructor(opts?) {
+    this.assets = {
+      1: [
+        {
+          id: 1,
+          title: "Angel One DRM",
+          uri: "https://storage.googleapis.com/shaka-demo-assets/angel-one-widevine-hls/hls.m3u8",
+          // license url: https://cwip-shaka-proxy.appspot.com/no_auth
+        },
+        {
+          id: 2,
+          title: "Angel One DRM",
+          uri: "https://storage.googleapis.com/shaka-demo-assets/angel-one-widevine-hls/hls.m3u8",
+          // license url: https://cwip-shaka-proxy.appspot.com/no_auth
+        },
+        {
+          id: 3,
+          title: "BBB No DRM",
+          uri: "https://storage.googleapis.com/shaka-demo-assets/bbb-dark-truths-hls/hls.m3u8"
+        }
+      ],
+    };
+    this.pos = {
+      1: 0,
+    };
+  }
+
+  /**
+   *
+   * @param {Object} vodRequest
+   *   {
+   *      sessionId,
+   *      category,
+   *      playlistId
+   *   }
+   */
+  getNextVod(vodRequest: VodRequest): Promise<VodResponse> {
+    return new Promise((resolve, reject) => {
+      const channelId = vodRequest.playlistId;
+      if (this.assets[channelId]) {
+        let vod: VodResponse = this.assets[channelId][this.pos[channelId]++];
+        if (this.pos[channelId] > this.assets[channelId].length - 1) {
+          this.pos[channelId] = 0;
+        }
+        resolve(vod);
+      } else {
+        reject("Invalid channelId provided");
+      }
+    });
+  }
+}
+
+class RefChannelManager implements IChannelManager {
+  getChannels(): Channel[] {
+    return [{ id: "1", profile: this._getProfile(), audioTracks: this._getAudioTracks() }];
+  }
+
+  _getProfile(): ChannelProfile[] {
+    return [
+      {
+        bw: 7934000,
+        codecs: "avc1.4d001f,mp4a.40.2",
+        resolution: [2880, 1440],
+      },
+      {
+        bw: 7514000,
+        codecs: "avc1.4d001f,mp4a.40.2",
+        resolution: [1920, 1080],
+      },
+      { bw: 7134000, codecs: "avc1.4d001f,mp4a.40.2", resolution: [1280, 720] },
+      { bw: 6134000, codecs: "avc1.4d001f,mp4a.40.2", resolution: [1024, 458] },
+      { bw: 2323000, codecs: "avc1.4d001f,mp4a.40.2", resolution: [640, 286] },
+      { bw: 495894, codecs: "avc1.4d001f,mp4a.40.2", resolution: [480, 214] },
+    ];
+  }
+  _getAudioTracks(): AudioTracks[] {
+    return [
+      { language: "en", name: "English" },
+    ];
+  }
+}
+
+const refAssetManager = new RefAssetManager();
+const refChannelManager = new RefChannelManager();
+
+const engineOptions: ChannelEngineOpts = {
+  heartbeat: "/",
+  averageSegmentDuration: 4000,
+  channelManager: refChannelManager,
+  defaultSlateUri: "https://maitv-vod.lab.eyevinn.technology/slate-consuo.mp4/master.m3u8",
+  slateRepetitions: 10,
+  redisUrl: process.env.REDIS_URL,
+  useDemuxedAudio: true,
+  alwaysNewSegments: true,
+};
+
+const engine = new ChannelEngine(refAssetManager, engineOptions);
+engine.start();
+engine.listen(process.env.PORT || 8000);

server-drm.ts

@@ -6,5 +6,5 @@
     "esModuleInterop": true,
     "declaration": true
   },
-  "include": ["./server.ts", "./server-demux.ts", "./server-livemix.ts", "./engine/**/*"]
+  "include": ["./server.ts", "./server-demux.ts", "./server-livemix.ts", "./server-drm.ts", "./engine/**/*"]
 }