Hotfix/fetch response status code checks (#10)

* Add status code checks to fetch commands Co-authored-by: Craig McEldowney <[email protected]>
Eyevinn · Sep 1, 2020 · 7f28c1c · 7f28c1c
1 parent fc2db0c
commit 7f28c1c
Showing 1 changed file with 20 additions and 3 deletions.
diff --git a/index.js b/index.js
@@ -166,7 +166,13 @@ class HLSVod {
       if (!_injectMasterManifest) {
         fetch(this.masterManifestUri)
         .then(res => {
-          res.body.pipe(parser);
+          if (res.status === 200) {
+	          res.body.pipe(parser);
+          }
+          else {
+          	throw new Error(res.status + ':: status code error trying to retrieve master manifest ' + masterManifestUri);
+          }  
+
         })
         .catch(reject);
       } else {
@@ -253,7 +259,7 @@ class HLSVod {
     const targetDuration = this._determineTargetDuration(this.mediaSequences[seqIdx].segments[bw]);
     let m3u8 = "#EXTM3U\n";
     m3u8 += "#EXT-X-VERSION:6\n";
-    m3u8 += "#EXT-X-INDEPENDENT-SEGMENTS\n";
+	m3u8 += "#EXT-X-INDEPENDENT-SEGMENTS\n";
     m3u8 += "#EXT-X-TARGETDURATION:" + targetDuration + "\n";
     m3u8 += "#EXT-X-MEDIA-SEQUENCE:" + (offset + seqIdx) + "\n";
     let discInOffset = discOffset;
@@ -725,7 +731,12 @@ class HLSVod {
       if (!_injectMediaManifest) {
         fetch(mediaManifestUri)
         .then(res => {
-          res.body.pipe(parser);
+          if (res.status === 200) {
+	          res.body.pipe(parser);
+          }
+          else {
+          	throw new Error(res.status + ':: status code error trying to retrieve media manifest ' + mediaManifestUri);
+          }          
         })
         .catch(reject);
       } else {
@@ -776,6 +787,12 @@ class HLSVod {
       if (!_injectAudioManifest) {
         fetch(audioManifestUri)
         .then(res => {
+	      if (res.status === 200) {
+	          res.body.pipe(parser);
+          }
+          else {
+          	throw new Error(res.status + ':: status code error trying to retrieve audio manifest ' + audioManifestUri);
+          }  
           res.body.pipe(parser);
         })
         .catch(reject);