Creepso/stremio-web
1
0
Fork 0
mirror of https://github.com/Stremio/stremio-web.git synced 2026-03-30 06:38:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

withStreamingServer middleware implemented

Browse source
This commit is contained in:
nklhrstv 2020-03-16 20:39:50 +02:00
parent 781adb45a6
commit 5a6dda4f0d
2 changed files with 139 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/video/index.js
View file

@ -1,9 +1,11 @@
const HTMLVideo = require('./HTMLVideo');
const MPVVideo = require('./MPVVideo');
const YouTubeVideo = require('./YouTubeVideo');
var HTMLVideo = require('./HTMLVideo');
var MPVVideo = require('./MPVVideo');
var YouTubeVideo = require('./YouTubeVideo');
var withStreamingServer = require('./withStreamingServer');
module.exports = {
HTMLVideo,
MPVVideo,
YouTubeVideo
YouTubeVideo,
withStreamingServer
};

133
src/video/withStreamingServer.js Normal file
View file

@ -0,0 +1,133 @@
var UrlUtils = require('url');
var EventEmitter = require('events');
function withStreamingServer(Video) {
function StreamingServerVideo(options) {
var video = new Video(options);
var events = new EventEmitter();
var destroyed = false;
var stream = null;
events.on('error', function() { });
function onError(error) {
if (!error) {
return;
}
Object.freeze(error);
events.emit('error', error);
if (error.critical) {
video.dispatch({ commandName: 'stop' });
}
}
function on(eventName, listener) {
if (!destroyed) {
events.on(eventName, listener);
}
video.on(eventName, listener);
}
function dispatch(args) {
if (args && args.commandName === 'load') {
stream = null;
if (args.commandArgs && args.commandArgs.stream && typeof args.commandArgs.stream.infoHash === 'string' && typeof args.commandArgs.streamingServerUrl === 'string') {
stream = args.commandArgs.stream;
video.dispatch({ commandName: 'stop' });
if (stream.fileIdx !== null && !isNaN(stream.fileIdx)) {
video.dispatch({
commandName: 'load',
commandArgs: {
autoplay: args.commandArgs.autoplay,
time: args.commandArgs.time,
stream: {
url: UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/' + String(stream.fileIdx))
}
}
});
} else {
fetch(UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/create'), {
method: 'POST',
headers: {
'content-type': 'application/json'
},
body: JSON.stringify({
torrent: {
infoHash: stream.infoHash
}
})
}).then(function(resp) {
return resp.json();
}).then(function(resp) {
if (stream !== args.commandArgs.stream) {
return;
}
if (!Array.isArray(resp.files) || resp.files.length === 0) {
onError({
message: 'Unable to get files from torrent',
critical: true
});
return;
}
var fileIdx = resp.files.reduce((fileIdx, _, index, files) => {
if (files[index].length > files[fileIdx].length) {
return index;
}
return fileIdx;
}, 0);
video.dispatch({
commandName: 'load',
commandArgs: {
autoplay: args.commandArgs.autoplay,
time: args.commandArgs.time,
stream: {
url: UrlUtils.resolve(args.commandArgs.streamingServerUrl, stream.infoHash + '/' + fileIdx)
}
}
});
}).catch(function(error) {
if (stream !== args.commandArgs.stream) {
return;
}
onError({
message: 'Unable to get files from torrent',
critical: true,
error: error
});
});
}
}
} else {
if (args && args.commandName === 'destroy') {
destroyed = true;
events.removeAllListeners();
events.on('error', function() { });
}
video.dispatch(args);
}
}
this.on = on;
this.dispatch = dispatch;
Object.freeze(this);
}
StreamingServerVideo.manifest = Object.freeze({
name: Video.manifest.name + 'WithStreamingServer',
embedded: true,
props: Object.freeze(Video.manifest.props)
});
Object.freeze(StreamingServerVideo);
return StreamingServerVideo;
}
module.exports = withStreamingServer;