fix: handle shell early eof

Author: kKaskak

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@stremio/stremio-video",
-    "version": "0.0.81",
+    "version": "0.0.82",
     "description": "Abstraction layer on top of different media players",
     "author": "Smart Code OOD",
     "main": "src/index.js",

src/ShellVideo/ShellVideo.js

@@ -4,6 +4,8 @@ var deepFreeze = require('deep-freeze');
 var ERROR = require('../error');
 
 var SUBS_SCALE_FACTOR = 0.0066;
+var EOF_END_TOLERANCE = 5000;
+var HTTP_RECONNECT_OPTIONS = 'reconnect=1,reconnect_streamed=1,reconnect_on_network_error=1,reconnect_on_http_error=5xx,reconnect_delay_max=10,reconnect_max_retries=10';
 
 var stremioToMPVProps = {
     'loaded': 'loaded',
@@ -259,7 +261,9 @@ function ShellVideo(options) {
     ipc.on('mpv-event-ended', function(args) {
         // older shells report 'other' for every non-error reason, including eof
         if (args.error) onError(args.error);
-        else if (!args.reason || args.reason === 'eof' || args.reason === 'other') onEnded();
+        else if (!args.reason || args.reason === 'eof' || args.reason === 'other') {
+            if (!isKnownEarlyEof()) onEnded();
+        }
     });
 
     function getProp(propName) {
@@ -279,6 +283,15 @@ function ShellVideo(options) {
     function onEnded() {
         events.emit('ended');
     }
+    function isKnownEarlyEof() {
+        var time = props['time-pos'];
+        var duration = props.duration;
+        return typeof time === 'number' &&
+            isFinite(time) &&
+            typeof duration === 'number' &&
+            isFinite(duration) &&
+            time + EOF_END_TOLERANCE < duration;
+    }
     function onPropChanged(propName) {
         if (observedProps[propName]) {
             events.emit('propChanged', propName, getProp(propName));
@@ -409,6 +422,7 @@ function ShellVideo(options) {
 
                         var subAssOverride = commandArgs.assSubtitlesStyling ? 'strip' : 'no';
                         ipc.send('mpv-set-prop', ['sub-ass-override', subAssOverride]);
+                        ipc.send('mpv-set-prop', ['stream-lavf-o', HTTP_RECONNECT_OPTIONS]);
 
                         var gpuProcessing = !!commandArgs.gpuVideoProcessing &&
                             !!commandArgs.hardwareDecoding;