Add audio queue

AudioQueue.js

@@ -0,0 +1,23 @@
+module.exports = class AudioQueue {
+    constructor(connection) {
+        this.connection = connection;
+        this.queue = [];
+        this.current = undefined;
+    }
+    playNext() {
+        if (this.queue.length == 0) {
+            this.current = undefined;
+            return;
+        }
+        this.current = this.connection.play(this.queue[0]);
+        this.current.on('speaking', (val) => {if (val == 0) this.handleStop(this.current)});
+    }
+    handleStop(current) {
+        this.queue.shift();
+        this.playNext();
+    }
+    add(element) {
+        this.queue.push(element);
+        if (this.queue.length == 1) this.playNext();
+    }
+}

index.js

@@ -21,6 +21,7 @@ async function initDB() {
 
 const api = {
     db: undefined,
+    queue: undefined,
     ttsEngines: (() => {
         let engines = {};
         console.log(`Registering TTS engines...`);
@@ -77,9 +78,8 @@ const api = {
     },
 
     speak: async (channel, message, engine = api.announcementEngine, voice = api.announcementVoice, params = {}) => {
-        const conn = api.getConnectionForVoiceChannel(channel);
         const filepath = await api.generateVoice(message, engine, voice, params);
-        if (conn) conn.play(filepath);
+        api.queue.add(filepath);
     },
 
     registerCommand: async (commandString, commandFunc) => {

modules/announcer/index.js

@@ -1,3 +1,5 @@
+const AudioQueue=require('../../AudioQueue.js')
+
 module.exports = function (bot, api) {
     bot.on('voiceStateUpdate', async (oldState, newState) => {
         if (newState.member.user.bot) return;
@@ -11,6 +13,8 @@ module.exports = function (bot, api) {
         let joined = false;
         if (!oldState.channel) {
             joined = true;
+            let conn=api.getConnectionForVoiceChannel(channel);
+            api.queue=new AudioQueue(conn);
         }
 
         let username = newState.member.displayName;

modules/welcomer/index.js

@@ -1,10 +1,13 @@
+const AudioQueue=require('../../AudioQueue.js')
+
 module.exports = function (bot, api) {
     bot.on('ready', async () => {
         console.log("Bot initialized and listening");
         const guild = await bot.guilds.fetch(process.env.GUILD);
         const channel = await bot.channels.fetch(process.env.CHANNEL);
         await api.joinChannel(channel);
-
+        let conn=api.getConnectionForVoiceChannel(channel);
+        api.queue=new AudioQueue(conn);
         api.speak(channel, `Hey buddies! How does it feel like to be a buddy? Are you proud of being a buddy? Well that's great!'`);
     })
 }