fix(#45): resolve redirect before handing over to engine

docs/changelog.md

@@ -12,7 +12,7 @@ Channel Engine v4.3.11 including the following bugfixes and features:
 - Option to protect session health endpoint with a key
 - Fix timeOffset - Once enabled, Forever
 - Fix missing Newlines in Dummy Webvtt Response
-- Fix performance bottlenecks when running in High Availability mode with Redis. 
+- Fix performance bottlenecks when running in High Availability mode with Redis.
 - Fix disable eventstream by default
 - Fix HA & Demux - Audio Increment Not Respecting Position Diff-Threshold
 - Fix Subtitle Track Playhead is dependant Of Video Track
@@ -28,7 +28,7 @@ New Features:
 
 ### Version 1.8.1
 
-Verify URLs that must be HLS URLs 
+Verify URLs that must be HLS URLs
 
 ### Version 1.8.2
 

src/plugins/plugin_loop.ts

@@ -13,7 +13,8 @@ import {
   getDefaultChannelAudioProfile,
   getDefaultChannelVideoProfile,
   getDefaultChannelSubtitleProfile,
-  getVodUrlWithPreroll
+  getVodUrlWithPreroll,
+  resolveRedirect
 } from './utils';
 
 class LoopAssetManager implements IAssetManager {
@@ -30,6 +31,7 @@ class LoopAssetManager implements IAssetManager {
   // eslint-disable-next-line @typescript-eslint/no-unused-vars
   async getNextVod(vodRequest: VodRequest): Promise<VodResponse> {
     let hlsUrl = this.vodToLoop.toString();
+    hlsUrl = await resolveRedirect(this.vodToLoop.toString());
     if (this.prerollVod) {
       hlsUrl = getVodUrlWithPreroll(
         this.vodToLoop.toString(),

src/plugins/plugin_playlist.ts

@@ -14,7 +14,8 @@ import {
   getDefaultChannelAudioProfile,
   getDefaultChannelSubtitleProfile,
   getDefaultChannelVideoProfile,
-  getVodUrlWithPreroll
+  getVodUrlWithPreroll,
+  resolveRedirect
 } from './utils';
 
 interface PlaylistUrl {
@@ -92,7 +93,9 @@ class PlaylistAssetManager implements IAssetManager {
         await this._updatePlaylist(vodRequest.playlistId);
       }
       if (playlist.position !== -1) {
-        let hlsUrl = playlist.hlsUrls[playlist.position].toString();
+        let hlsUrl = await resolveRedirect(
+          playlist.hlsUrls[playlist.position].toString()
+        );
         if (this.prerollVod) {
           hlsUrl = getVodUrlWithPreroll(
             playlist.hlsUrls[playlist.position].toString(),

src/plugins/plugin_webhook.test.ts

@@ -37,7 +37,7 @@ describe('webhook plugin', () => {
     expect(fetchMock.mock.calls[0][0]).toEqual(
       'http://localhost:8002/nextVod?channelId=test'
     );
-    expect(fetchMock.mock.calls[1][0]).toEqual(
+    expect(fetchMock.mock.calls[2][0]).toEqual(
       'http://localhost:8002/nextVod?channelId=test'
     );
   });

src/plugins/plugin_webhook.ts

@@ -14,7 +14,8 @@ import {
   getDefaultChannelAudioProfile,
   getDefaultChannelVideoProfile,
   getDefaultChannelSubtitleProfile,
-  getVodUrlWithPreroll
+  getVodUrlWithPreroll,
+  resolveRedirect
 } from './utils';
 
 export interface WebHookNextVodResponse {
@@ -52,7 +53,7 @@ class WebHookAssetManager implements IAssetManager {
     });
     if (response.ok) {
       const payload: WebHookNextVodResponse = await response.json();
-      let hlsUrl = payload.hlsUrl;
+      let hlsUrl = await resolveRedirect(payload.hlsUrl);
       if (payload.prerollUrl && payload.prerollDurationMs) {
         hlsUrl = getVodUrlWithPreroll(
           hlsUrl,

src/plugins/utils.ts

@@ -259,3 +259,12 @@ export function getVodUrlWithPreroll(
   }
   return url;
 }
+
+export async function resolveRedirect(url: string) {
+  const response = await fetch(url);
+  if (response.redirected) {
+    console.log('Redirect: ' + response.url);
+    return response.url || url;
+  }
+  return url;
+}