122 lines
3.8 KiB
JavaScript
122 lines
3.8 KiB
JavaScript
const events = require('events')
|
|
const channelCache = require("../channel-cache");
|
|
|
|
class ChannelService extends events.EventEmitter {
|
|
|
|
constructor(channelDB) {
|
|
super();
|
|
this.channelDB = channelDB;
|
|
this.onDemandService = null;
|
|
}
|
|
|
|
setOnDemandService(onDemandService) {
|
|
this.onDemandService = onDemandService;
|
|
}
|
|
|
|
async saveChannel(number, channelJson, options) {
|
|
|
|
let channel = cleanUpChannel(channelJson);
|
|
let ignoreOnDemand = true;
|
|
if (
|
|
(this.onDemandService != null)
|
|
&&
|
|
( (typeof(options) === 'undefined') || (options.ignoreOnDemand !== true) )
|
|
) {
|
|
ignoreOnDemand = false;
|
|
this.onDemandService.fixupChannelBeforeSave( channel );
|
|
}
|
|
channelCache.saveChannelConfig( number, channel);
|
|
await channelDB.saveChannel( number, channel );
|
|
|
|
this.emit('channel-update', { channelNumber: number, channel: channel, ignoreOnDemand: ignoreOnDemand} );
|
|
}
|
|
|
|
async deleteChannel(number) {
|
|
await channelDB.deleteChannel( number );
|
|
this.emit('channel-update', { channelNumber: number, channel: null} );
|
|
|
|
channelCache.clear();
|
|
}
|
|
|
|
async getChannel(number) {
|
|
let lis = await channelCache.getChannelConfig(this.channelDB, number)
|
|
if ( lis == null || lis.length !== 1) {
|
|
return null;
|
|
}
|
|
return lis[0];
|
|
}
|
|
|
|
async getAllChannelNumbers() {
|
|
return await channelCache.getAllNumbers(this.channelDB);
|
|
}
|
|
|
|
async getAllChannels() {
|
|
return await channelCache.getAllChannels(this.channelDB);
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
function cleanUpProgram(program) {
|
|
if (program.startPosition != null && program.startPosition !== '') {
|
|
// Convert startPosition to seekPosition for consistency
|
|
program.seekPosition = parseInt(program.startPosition, 10);
|
|
delete program.startPosition;
|
|
}
|
|
|
|
if (program.endPosition != null && program.endPosition !== '') {
|
|
program.endPosition = parseInt(program.endPosition, 10);
|
|
}
|
|
|
|
delete program.streams;
|
|
delete program.durationStr;
|
|
delete program.commercials;
|
|
if (
|
|
(typeof(program.duration) === 'undefined')
|
|
||
|
|
(program.duration <= 0)
|
|
) {
|
|
console.error(`Input contained a program with invalid duration: ${program.duration}. This program has been deleted`);
|
|
return [];
|
|
}
|
|
if (! Number.isInteger(program.duration) ) {
|
|
console.error(`Input contained a program with invalid duration: ${program.duration}. Duration got fixed to be integer.`);
|
|
program.duration = Math.ceil(program.duration);
|
|
}
|
|
return [ program ];
|
|
}
|
|
|
|
function cleanUpChannel(channel) {
|
|
if (
|
|
(typeof(channel.groupTitle) === 'undefined')
|
|
||
|
|
(channel.groupTitle === '')
|
|
) {
|
|
channel.groupTitle = "dizqueTV";
|
|
}
|
|
channel.programs = channel.programs.flatMap( cleanUpProgram );
|
|
delete channel.fillerContent;
|
|
delete channel.filler;
|
|
channel.fallback = channel.fallback.flatMap( cleanUpProgram );
|
|
|
|
// Set default for mergeAdjacentPrograms if not already defined
|
|
if (typeof channel.mergeAdjacentPrograms === 'undefined') {
|
|
channel.mergeAdjacentPrograms = false; // Disabled by default for backward compatibility
|
|
}
|
|
|
|
// Calculate total channel duration using effective durations
|
|
channel.duration = 0;
|
|
for (let i = 0; i < channel.programs.length; i++) {
|
|
let program = channel.programs[i];
|
|
let seek = typeof program.seekPosition === 'number' ? program.seekPosition : 0;
|
|
let end = typeof program.endPosition === 'number' ? program.endPosition : null;
|
|
let effectiveDuration = (end !== null ? end : program.duration) - seek;
|
|
|
|
channel.duration += effectiveDuration;
|
|
}
|
|
return channel;
|
|
}
|
|
|
|
|
|
module.exports = ChannelService |