132 lines
4.1 KiB
JavaScript
132 lines
4.1 KiB
JavaScript
const streamController = require('./restream/StreamController');
|
|
const Channel = require('../models/Channel');
|
|
const storageService = require('./restream/StorageService');
|
|
const ChannelStorage = require('./ChannelStorage');
|
|
|
|
|
|
class ChannelService {
|
|
constructor() {
|
|
this.channels = ChannelStorage.load();
|
|
this.currentChannel = this.channels[0];
|
|
}
|
|
|
|
clearChannels() {
|
|
ChannelStorage.clear();
|
|
this.channels = ChannelStorage.load();
|
|
this.currentChannel = this.channels[0];
|
|
}
|
|
|
|
getChannels() {
|
|
return this.channels;
|
|
}
|
|
|
|
getChannelById(id) {
|
|
return this.channels.find(channel => channel.id === id);
|
|
}
|
|
|
|
getFilteredChannels({ playlistName, group }) {
|
|
let filtered = this.channels;
|
|
if (playlistName) {
|
|
filtered = filtered.filter(ch => ch.playlistName && ch.playlistName.toLowerCase() == playlistName.toLowerCase());
|
|
}
|
|
if (group) {
|
|
filtered = filtered.filter(ch => ch.group && ch.group.toLowerCase() === group.toLowerCase());
|
|
}
|
|
return filtered;
|
|
}
|
|
|
|
addChannel({ name, url, avatar, mode, headersJson, group = null, playlist = null, playlistName = null, playlistUpdate = false }, save = true) {
|
|
// const existing = this.channels.find(channel => channel.url === url);
|
|
// if (existing) {
|
|
// throw new Error('Channel already exists');
|
|
// }
|
|
|
|
let headers = headersJson;
|
|
try {
|
|
//Try to parse headers if not already parsed
|
|
headers = JSON.parse(headersJson);
|
|
} catch (error) {
|
|
}
|
|
|
|
const newChannel = new Channel(name, url, avatar, mode, headers, group, playlist, playlistName, playlistUpdate);
|
|
this.channels.push(newChannel);
|
|
if(save) ChannelStorage.save(this.channels);
|
|
|
|
return newChannel;
|
|
}
|
|
|
|
async setCurrentChannel(id) {
|
|
const nextChannel = this.channels.find(channel => channel.id === id);
|
|
if (!nextChannel) {
|
|
throw new Error('Channel does not exist');
|
|
}
|
|
|
|
if (this.currentChannel !== nextChannel) {
|
|
if (nextChannel.restream()) {
|
|
streamController.stop(this.currentChannel);
|
|
storageService.deleteChannelStorage(nextChannel.id);
|
|
await streamController.start(nextChannel);
|
|
} else {
|
|
streamController.stop(this.currentChannel);
|
|
}
|
|
this.currentChannel = nextChannel;
|
|
}
|
|
return nextChannel;
|
|
}
|
|
|
|
getCurrentChannel() {
|
|
return this.currentChannel;
|
|
}
|
|
|
|
getChannelById(id) {
|
|
return this.channels.find(channel => channel.id === id);
|
|
}
|
|
|
|
async deleteChannel(id, save = true) {
|
|
const channelIndex = this.channels.findIndex(channel => channel.id === id);
|
|
if (channelIndex === -1) {
|
|
throw new Error('Channel does not exist');
|
|
}
|
|
|
|
const [deletedChannel] = this.channels.splice(channelIndex, 1);
|
|
|
|
if (this.currentChannel.id === id) {
|
|
await this.setCurrentChannel(0);
|
|
}
|
|
|
|
if(save) ChannelStorage.save(this.channels);
|
|
|
|
return this.currentChannel;
|
|
}
|
|
|
|
async updateChannel(id, updatedAttributes, save = true) {
|
|
|
|
const channelIndex = this.channels.findIndex(channel => channel.id === id);
|
|
if (channelIndex === -1) {
|
|
throw new Error('Channel does not exist');
|
|
}
|
|
|
|
const streamChanged = updatedAttributes.url != this.currentChannel.url ||
|
|
JSON.stringify(updatedAttributes.headers) != JSON.stringify(this.currentChannel.headers) ||
|
|
updatedAttributes.mode != this.currentChannel.mode;
|
|
|
|
const channel = this.channels[channelIndex];
|
|
Object.assign(channel, updatedAttributes);
|
|
|
|
if (this.currentChannel.id == id) {
|
|
if (streamChanged) {
|
|
streamController.stop(channel);
|
|
if (channel.restream()) {
|
|
await streamController.start(channel);
|
|
}
|
|
}
|
|
}
|
|
|
|
if(save) ChannelStorage.save(this.channels);
|
|
|
|
return channel;
|
|
}
|
|
}
|
|
|
|
module.exports = new ChannelService();
|