Scan Plex for ${config.PLEX_PLAYLIST_IDENTIFIER} playlists.
-Any changes made to config.yml won't take effect until pseudotv-plex is restarted.
-Author: Dan Ferguson
- ${createScript(counter)} - - ` - return str.split(' ').join('') -} - -function createConfigDetails() { - var str = `
- Host: ${config.HOST}
- Port: ${config.PORT}
-
| # | -Name | -Icon | -Shuffle | -
|---|---|---|---|
| ${channels[i].channel} | -${channels[i].name} | -${channels[i].icon ? ` |
- ${channels[i].shuffle} | -
Restart Plex client apps and refresh Plex web sessions to view changes..
- ${config.EPG_UPDATE === 0 ? '' : `Next EPG Refresh: (hh:mm:ss)
`} - ` - return str.split(' ').join('') -} - -var createScript = function (counter) { - var str = ` - ` - return str -} \ No newline at end of file diff --git a/src/video.js b/src/video.js new file mode 100644 index 0000000..525d946 --- /dev/null +++ b/src/video.js @@ -0,0 +1,58 @@ +const express = require('express') +const helperFuncs = require('./helperFuncs') +const ffmpeg = require('./ffmpeg') +const fs = require('fs') + +module.exports = { router: video } + +function video(db) { + var router = express.Router() + router.get('/video', (req, res) => { + // Check if channel queried is valid + if (typeof req.query.channel === 'undefined') { + res.status(500).send("No Channel Specified") + return + } + let channel = db['channels'].find({ number: parseInt(req.query.channel, 10) }) + if (channel.length === 0) { + res.status(500).send("Channel doesn't exist") + return + } + channel = channel[0] + + // Get video lineup (array of video urls with calculated start times and durations.) + let lineup = helperFuncs.getLineup(Date.now(), channel) + let ffmpegSettings = db['ffmpeg-settings'].find()[0] + + // Check if ffmpeg path is valid + if (!fs.existsSync(ffmpegSettings.ffmpegPath)) { + res.status(500).send("FFMPEG path is invalid. The file (executable) doesn't exist.") + console.error("The FFMPEG Path is invalid. Please check your configuration.") + return + } + + console.log(`Stream started. Channel: ${channel.number} (${channel.name})`) + + let ffmpeg2 = new ffmpeg(ffmpegSettings) // Set the transcoder options + + ffmpeg2.on('data', (data) => { res.write(data) }) + + ffmpeg2.on('error', (err) => { console.error("FFMPEG ERROR", err) }) + + ffmpeg2.on('end', () => { // On finish transcode - END of program or commercial... + if (lineup.length === 0) // refresh the expired program/lineup + lineup = helperFuncs.getLineup(Date.now(), channel) + ffmpeg2.spawn(lineup.shift()) // Spawn the next ffmpeg process + }) + + res.on('close', () => { // on HTTP close, kill ffmpeg + ffmpeg2.kill() + console.log(`Stream ended. Channel: ${channel.number} (${channel.name})`) + }) + + ffmpeg2.spawn(lineup.shift()) // Spawn the ffmpeg process, fire this bitch up + + + }) + return router +} \ No newline at end of file diff --git a/src/vlc.js b/src/vlc.js deleted file mode 100644 index 3b9f731..0000000 --- a/src/vlc.js +++ /dev/null @@ -1,147 +0,0 @@ -const Router = require('express').Router -const spawn = require('child_process').spawn -const request = require('request') -const config = require('config-yml') - -const xmltv = require('./xmltv') - -module.exports = vlcRouter - -function vlcRouter(client) { - var router = Router() - var inUse = false - router.get('/video', (req, res) => { - if (inUse) - return res.status(409).send("Error: Another user is currently viewing a stream. One one active stream is allowed.") - inUse = true - var channel = req.query.channel - if (!channel) { - inUse = false - res.status(400).send("Error: No channel queried") - return - } - channel = channel.split('?')[0] - - res.writeHead(200, { - 'Content-Type': 'application/octet-stream', - 'Content-disposition': 'attachment; filename=video.ts' - }) - startStreaming(channel, res) - }) - - return router - - function startStreaming(channel, res) { - var programs = xmltv.readXMLPrograms() - var startPos = -1 - var programIndex = -1 - var channelExists = false - for (var i = 0; i < programs.length; i++) { - var date = new Date() - if (programs[i].channel == channel) { - channelExists = true - if (programs[i].start <= date && programs[i].stop >= date) { - startPos = date.getTime() - programs[i].start.getTime() - programIndex = i - break - } - } - } - // End session if any errors. - if (!channelExists) { - inUse = false - res.status(403).send(`Error: Channel doesn't exist. Channel: ${channel}`) - return - } - if (programIndex === -1) { - inUse = false - res.status(403).send(`Error: No scheduled programming available. Channel: ${channel}`) - return - } - if (startPos === -1) { - inUse = false - res.status(403).send(`Error: How the fuck did you get here?. Channel: ${channel}`) - return - } - // Query plex for current program - client.Get(programs[programIndex].key, (result) => { - if (result.err) { - inUse = false - res.status(403).send(`Error: Failed to fetch program info from Plex`) - return - } - var fetchedItem = result.result.MediaContainer.Metadata[0] - // Transcode it - client.Transcode(fetchedItem, startPos, (result) => { - if (result.err) { - inUse = false - res.status(403).send(`Error: Failed to add program to playQueue`) - return - } - // Update server timeline every 10 seconds - var stream = result.result - var msElapsed = startPos - var timelineInterval = setInterval(() => { - stream.update(msElapsed) - msElapsed += 10000 - }, 10000) - var args = [ - stream.url, - `--start-time=${(startPos + config.VLC_OPTIONS.DELAY) / 1000}`, - `--sout=#http{mux=ts,dst=:${config.VLC_OPTIONS.PORT}/}` - ] - if (config.VLC_OPTIONS.HIDDEN) - args.push("--intf=dummy") - // Fire up VLC - var vlc = spawn(config.VLC_OPTIONS.PATH, args) - // Wait for VLC to open before we request anything. - setTimeout(() => { - request(`http://${config.HOST}:${config.VLC_OPTIONS.PORT}/`) - .on('error', (err) => { - vlc.kill() - if (err.code === 'ECONNRESET') { - var end = programs[programIndex].stop - var now = new Date() - var timeUntilDone = end.valueOf() - now.valueOf() - timeUntilDone = timeUntilDone > 0 ? timeUntilDone : 0 - setTimeout(() => { - res.removeListener('close', httpEnd) - startStreaming(channel, res) - }, timeUntilDone) - } - }) - .on('data', (chunk) => { - res.write(chunk) - }) - .on("complete", () => { - vlc.kill() - var end = programs[programIndex].stop - var now = new Date() - var timeUntilDone = end.valueOf() - now.valueOf() - timeUntilDone = timeUntilDone > 0 ? timeUntilDone : 0 - setTimeout(() => { - res.removeListener('close', httpEnd) - startStreaming(channel, res) - }, timeUntilDone) - }) - }, config.VLC_OPTIONS.DELAY) - - // When the http session ends: kill vlc - var httpEnd = function () { - vlc.kill() - inUse = false - } - res.on('close', httpEnd) - - vlc.on('close', (code) => { - clearInterval(timelineInterval) - stream.stop() - if (code !== 0 && !res.headersSent) { - res.status(400).send(`Error: VLC closed unexpectedly`) - } - }) - }) - }) - - } -} \ No newline at end of file diff --git a/src/xmltv.js b/src/xmltv.js index b4209c5..789f5d2 100644 --- a/src/xmltv.js +++ b/src/xmltv.js @@ -1,199 +1,39 @@ const XMLWriter = require('xml-writer') -const XMLReader = require('xml-reader') const fs = require('fs') -const config = require('config-yml') +const helperFuncs = require('./helperFuncs') -module.exports = { - WriteXMLTV: WriteXMLTV, - UpdateXMLTV: UpdateXMLTV, - readXMLPrograms: readXMLPrograms, - readXMLChannels: readXMLChannels +module.exports = { WriteXMLTV: WriteXMLTV } + +function WriteXMLTV(channels, xmlSettings) { + return new Promise((resolve, reject) => { + let date = new Date() + var ws = fs.createWriteStream(xmlSettings.file) + var xw = new XMLWriter(true, (str, enc) => ws.write(str, enc)) + ws.on('close', () => { resolve() }) + ws.on('error', (err) => { reject(err) }) + _writeDocStart(xw) + _writeChannels(xw, channels) + for (var i = 0; i < channels.length; i++) + _writePrograms(xw, channels[i], date, xmlSettings.cache) + _writeDocEnd(xw, ws) + ws.close() + }) } -function readXMLPrograms() { - var data = fs.readFileSync(config.XMLTV_FILE) - var xmltv = XMLReader.parseSync(data.toString()) - var programs = [] - var tv = xmltv.children - for (var i = 0; i < tv.length; i++) { - if (tv[i].name == 'channel') - continue; - var program = { - channel: tv[i].attributes.channel, - start: createDate(tv[i].attributes.start), - stop: createDate(tv[i].attributes.stop), - key: tv[i].attributes['plex-key'] - } - programs.push(program) - } - return programs -} - -function readXMLChannels() { - var data = fs.readFileSync(config.XMLTV_FILE) - var xmltv = XMLReader.parseSync(data.toString()) - var channels = [] - var tv = xmltv.children - for (var i = 0; i < tv.length; i++) { - if (tv[i].name == 'programme') - continue; - //console.log(tv[i]) - var channel = { - channel: tv[i].attributes.id, - shuffle: tv[i].attributes.shuffle - } - for (var y = 0; y < tv[i].children.length; y++) - { - if (tv[i].children[y].name === 'display-name') { - channel.name = tv[i].children[y].children[0].value - } - if (tv[i].children[y].name === 'icon') { - channel.icon = tv[i].children[y].attributes.src - } - } - channels.push(channel) - } - return channels -} - -function WriteXMLTV(channels, cb) { - var xw = new XMLWriter(true) - var time = new Date() - // Build XMLTV and M3U files - xw.startDocument() - // Root TV Element - xw.startElement('tv') - xw.writeAttribute('generator-info-name', 'psuedotv-plex') - writeChannels(xw, channels) - // For each channel - for (var i = 0; i < channels.length; i++) { - var future = new Date() - future.setHours(time.getHours() + config.EPG_CACHE) - var tempDate = new Date(time.valueOf()) - // Loop items until EPG_CACHE is satisfied, starting time of first show is NOW. - while (tempDate < future && channels[i].items.length > 0) { - for (var y = 0; y < channels[i].items.length && tempDate < future; y++) { - var stopDate = new Date(tempDate.valueOf()) - stopDate.setMilliseconds(stopDate.getMilliseconds() + channels[i].items[y].duration) - var program = { - info: channels[i].items[y], - channel: channels[i].channel, - start: new Date(tempDate.valueOf()), - stop: stopDate - } - writeProgramme(xw, program) - tempDate.setMilliseconds(tempDate.getMilliseconds() + channels[i].items[y].duration) - } - } - } - // End TV - xw.endElement() - xw.endDocument() - fs.writeFileSync(config.XMLTV_FILE, xw.toString()) - if (typeof cb == 'function') - cb() -} - -function UpdateXMLTV(channels, cb) { - var xw = new XMLWriter(true) - var data = fs.readFileSync(config.XMLTV_FILE) - var xml = XMLReader.parseSync(data.toString()) - var time = new Date() +function _writeDocStart(xw) { xw.startDocument() xw.startElement('tv') xw.writeAttribute('generator-info-name', 'psuedotv-plex') - writeChannels(xw, channels) - // Foreach channel - for (var i = 0; i < channels.length; i++) { - // get non-expired programmes for channel - var validPrograms = [] - for (var y = 0; y < xml.children.length; y++) { - if (xml.children[y].name == 'programme' && xml.children[y].attributes.channel == channels[i].channel) { - var showStop = createDate(xml.children[y].attributes.stop) - if (showStop > time) - validPrograms.push(xml.children[y]) - } - } - // If Channel doesnt exists.. - if (validPrograms.length === 0) { - var future = new Date() - future.setHours(time.getHours() + config.EPG_CACHE) - var tempDate = new Date(time.valueOf()) - // Loop items until EPG_CACHE is satisfied, starting time of first show is NOW. - while (tempDate < future) { - for (var y = 0; y < channels[i].items.length && tempDate < future; y++) { // foreach item in playlist - var stopDate = new Date(tempDate.valueOf()) - stopDate.setMilliseconds(stopDate.getMilliseconds() + channels[i].items[y].duration) - var program = { - info: channels[i].items[y], - channel: channels[i].channel, - start: new Date(tempDate.valueOf()), - stop: stopDate - } - writeProgramme(xw, program) - tempDate.setMilliseconds(tempDate.getMilliseconds() + channels[i].items[y].duration) - } - } - } else { // Otherwise the channel already exists.. - var playlistStartIndex = -1 - var startingDate = new Date(time.valueOf()) - var endDate = new Date(time.valueOf()) - endDate.setHours(endDate.getHours() + config.EPG_CACHE) - // rewrite first valid xml programmes, if it still exists in the plex playlist.. - for (var z = 0; z < channels[i].items.length; z++) { - if (channels[i].items[z].key == validPrograms[0].attributes['plex-key']) { - playlistStartIndex = z - var program = { - channel: validPrograms[0].attributes.channel, - start: createDate(validPrograms[0].attributes.start), - stop: createDate(validPrograms[0].attributes.stop), - info: channels[i].items[z] - } - startingDate = new Date(program.stop.valueOf()) - writeProgramme(xw, program) - break; - } - } - if (playlistStartIndex !== -1) { - playlistStartIndex++ - if (playlistStartIndex === channels[i].items.length) - playlistStartIndex = 0 - } else { - playlistStartIndex = 0 - } - // write programs from plex, starting at the live playlist index. - while (startingDate < endDate) { - for (var y = playlistStartIndex; y < channels[i].items.length && startingDate < endDate; y++) { - var stopDate = new Date(startingDate.valueOf()) - stopDate.setMilliseconds(stopDate.getMilliseconds() + channels[i].items[y].duration) - var program = { - info: channels[i].items[y], - channel: channels[i].channel, - start: new Date(startingDate.valueOf()), - stop: stopDate - } - writeProgramme(xw, program) - startingDate.setMilliseconds(startingDate.getMilliseconds() + channels[i].items[y].duration) - } - playlistStartIndex = 0 - } - } - } - // End TV +} +function _writeDocEnd(xw, ws) { xw.endElement() - // End Doc xw.endDocument() - fs.writeFileSync(config.XMLTV_FILE, xw.toString()) - if (typeof cb == 'function') - cb() } -function writeChannels(xw, channels) { - // Channels +function _writeChannels(xw, channels) { for (var i = 0; i < channels.length; i++) { xw.startElement('channel') - xw.writeAttribute('id', channels[i].channel) - xw.writeAttribute('shuffle', channels[i].shuffle ? 'yes': 'no') + xw.writeAttribute('id', channels[i].number) xw.startElement('display-name') xw.writeAttribute('lang', 'en') xw.text(channels[i].name) @@ -207,60 +47,76 @@ function writeChannels(xw, channels) { } } -function writeProgramme(xw, program) { +function _writePrograms(xw, channel, date, cache) { + let prog = helperFuncs.getCurrentProgramAndTimeElapsed(date, channel) + let cutoff = new Date((date.valueOf() - prog.timeElapsed) + (cache * 60 * 60 * 1000)) + let temp = new Date(date.valueOf() - prog.timeElapsed) + if (channel.programs.length === 0) + return + let i = prog.programIndex + for (; temp < cutoff;) { + let program = { + program: channel.programs[i], + channel: channel.number, + start: new Date(temp.valueOf()), + stop: new Date(temp.valueOf() + channel.programs[i].duration) + } + _writeProgramme(xw, program) + temp.setMilliseconds(temp.getMilliseconds() + channel.programs[i].duration) + i++ + if (i >= channel.programs.length) + i = 0 + } +} + +function _writeProgramme(xw, program) { // Programme xw.startElement('programme') - xw.writeAttribute('start', createXMLTVDate(program.start)) - xw.writeAttribute('stop', createXMLTVDate(program.stop)) + xw.writeAttribute('start', _createXMLTVDate(program.start)) + xw.writeAttribute('stop', _createXMLTVDate(program.stop)) xw.writeAttribute('channel', program.channel) - xw.writeAttribute('plex-key', program.info.key) // Used to link this programme to Plex.. // Title xw.startElement('title') xw.writeAttribute('lang', 'en') - if (program.info.type == 'episode') - xw.text(program.info.grandparentTitle) - else - xw.text(program.info.title) - xw.endElement() - if (program.info.type == 'episode') { + + if (program.program.type == 'episode') { + xw.text(program.program.showTitle) + xw.endElement() xw.writeRaw('\n* Restart required
+
+ Use your Plex servers network address (192.168.*.*) as your HOST. Avoid using loopbacks (127.0.0.1, localhost).
+ WARNING - Do not check "Auto Map Channels" unless the PseudoTV tuner is the ONLY tuner added to your Plex Server.
+
| Name | +Address | +Refresh Guide | +Refresh Channels | ++ |
|---|---|---|---|---|
|
+ Add a Plex Server + |
+ ||||
| {{ x.name }} | +{{ x.protocol }}://{{ x.host }}:{{ x.port }} | +{{ x.arGuide }} | +{{ x.arChannels }} | ++ + | +
| Number | +Name | ++ |
|---|---|---|
|
+ No channels found. Click the to create a channel. + |
+ ||
| {{x.number}} | +{{x.name}} | ++ + | +