warengroup/eximiabots-radiox
warengroup/eximiabots-radiox
1
0
Fork 0
mirror of https://github.com/warengroup/eximiabots-radiox.git synced 2024-11-10 05:40:24 +00:00
Code Issues Packages Releases Activity

Update Streamer class

Browse Source
This commit is contained in:
Christer Warén 2021-09-15 17:25:55 +03:00
parent 7040300b3e
commit 9d9c8a6a07
1 changed files with 43 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/client/classes/Streamer.js
View File

@ -1,6 +1,8 @@
const { const {
createAudioPlayer, createAudioPlayer,
createAudioResource createAudioResource,
AudioPlayerStatus,
NoSubscriberBehavior
} = require("@discordjs/voice"); } = require("@discordjs/voice");
module.exports = class { module.exports = class {
@ -43,7 +45,12 @@ module.exports = class {
play(station) { play(station) {
let audioPlayer = this.map.get(station.name); let audioPlayer = this.map.get(station.name);
if(!audioPlayer) { if(!audioPlayer) {
audioPlayer = createAudioPlayer(); audioPlayer = createAudioPlayer({
behaviors: {
noSubscriber: NoSubscriberBehavior.Play,
maxMissedFrames: Math.round(5000 / 20),
},
});
this.map.set(station.name, audioPlayer); this.map.set(station.name, audioPlayer);
} }
const url = station.stream[station.stream.default]; const url = station.stream[station.stream.default];
@ -62,6 +69,40 @@ module.exports = class {
this.logger('Streamer', station.name + " / " + "Error"); this.logger('Streamer', station.name + " / " + "Error");
this.play(station); this.play(station);
}); });
audioPlayer
.on('playing', () => {
this.logger('Streamer', station.name + " / " + "Playing");
})
.on('idle', () => {
this.logger('Streamer', station.name + " / " + "Idle");
this.play(station);
})
.on('paused', () => {
this.logger('Streamer', station.name + " / " + "Paused");
this.play(station);
})
.on('buffering', () => {
this.logger('Streamer', station.name + " / " + "Buffering");
})
.on('autopaused', () => {
this.logger('Streamer', station.name + " / " + "AutoPaused");
this.play(station);
})
.on('stateChange', (oldState, newState) => {
if (oldState.status === AudioPlayerStatus.Idle && newState.status === AudioPlayerStatus.Playing) {
this.logger('Streamer', station.name + " / " + "Playing");
} else if (newState.status === AudioPlayerStatus.Idle) {
this.logger('Streamer', station.name + " / " + "Idle");
this.play(station);
}
})
.on('error', (error) => {
this.logger('Streamer', station.name + " / " + "Error" + "\n" + error);
this.play(station);
});
return audioPlayer; return audioPlayer;
} }