#16 Update variable name

- Move PDAB socket server startup to function
- Updated join server wrapper to start the server before opening the python app

.gitea/workflows/DRBv3_server_build.yaml

@@ -12,18 +12,13 @@ env:
   DISCORD_TOKEN: ${{ secrets.DISCORD_TOKEN }}
 
 jobs:
-  drb_mocha_tests:
+  drb_server_build:
     runs-on: ubuntu-latest
 
     steps:
       - name: Checkout code
         uses: actions/checkout@v4
 
-      - name: Setup Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: '20'
-
       - name: Build the latest code
         working-directory: './server'
         run: make build

client/discordAudioBot/pdabHandler.mjs

@@ -19,26 +19,6 @@ const __dirname = dirname(__filename);
 
 let botCallback;
 
-const port = process.env.PDAB_PORT || 3000;
-
-io.on('connection', (socket) => {
-  console.log('A user connected');
-
-  socket.on('disconnect', () => {
-    console.log('User disconnected');
-  });
-
-  // Listen for the discord client ready event
-  socket.on('discord_ready', (message) => {
-    console.log("Message from local client", message);
-    botCallback();
-  });
-});
-
-server.listen(port, async () => {
-  console.log(`Server is running on port ${port}`);
-});
-
 export const initDiscordBotClient = (clientId, callback, runPDAB = true) => {
   botCallback = callback;
 
@@ -46,6 +26,29 @@ export const initDiscordBotClient = (clientId, callback, runPDAB = true) => {
   pdabProcess = true; // TODO - Make this more dynamic
 }
 
+export const startPdabSocketServer = () => {
+  const port = process.env.PDAB_PORT || 3000;
+
+  io.on('connection', (socket) => {
+    console.log('A user connected');
+
+    socket.on('disconnect', () => {
+      console.log('User disconnected');
+    });
+
+    // Listen for the discord client ready event
+    socket.on('discord_ready', (message) => {
+      console.log("Message from local client", message);
+      botCallback();
+    });
+  });
+
+  server.listen(port, async () => {
+    console.log(`Server is running on port ${port}`);
+  });
+  return
+}
+
 export const closePdabSocketServer = () => {
   if (io.sockets && io.sockets.length > 0) {
     io.sockets.forEach(socket => {
@@ -75,6 +78,15 @@ export const leaveVoiceChannel = async (guildId) => {
   });
 };
 
+// Set the presense of the discord client
+export const setDiscordClientPrsense = (system) => {
+  return new Promise((res) => {
+    io.timeout(25000).emit('set_system', { system: system }, (status) => {
+      res();
+    });
+  });
+};
+
 // Placeholder functions (replace with actual implementation)
 export const checkIfConnectedToVC = async (guildId) => {
   console.log("Pdab process var:", pdabProcess);

client/discordAudioBot/pdabWrappers.mjs

@@ -1,4 +1,4 @@
-import { connectToChannel, leaveVoiceChannel, checkIfConnectedToVC, initDiscordBotClient, requestDiscordUsername, requestDiscordID, requestDiscordClientClose, closePdabSocketServer } from './pdabHandler.mjs';
+import { connectToChannel, leaveVoiceChannel, checkIfConnectedToVC, initDiscordBotClient, requestDiscordUsername, requestDiscordID, requestDiscordClientClose, closePdabSocketServer, setDiscordClientPrsense, startPdabSocketServer } from './pdabHandler.mjs';
 import { openOP25, closeOP25 } from '../op25Handler/op25Handler.mjs';
 
 let activeDiscordClient = undefined;
@@ -14,13 +14,17 @@ export const joinDiscordVC = async (joinData) => {
         console.log("Checking if there is a client open");
         if (!await checkIfClientIsOpen()) {
             console.log("There is no open client, starting it now");
+            await startPdabSocketServer();
             // Open an instance of OP25
             console.log("Starting OP25")
             openOP25(joinData.system);
 
             // Open a new client and join the requested channel with the requested ID
             initDiscordBotClient(joinData.clientID, () => {
-                console.log("Started PDAB")
+                console.log("Started PDAB");
+
+                console.log("Setting the presense of the bot");
+                setDiscordClientPrsense(joinData.system);
 
                 // Add the client object to the IO instance
                 console.log("Connecting to channel")

client/post-update.sh

@@ -4,8 +4,8 @@
 npm install
 
 # Install OP25 Updates
-cd ./op25
+#cd ./op25
-bash rebuild.sh
+#bash rebuild.sh
 
 # Check for PDAB updates
 cd ../discordAudioBot/pdab

server/Dockerfile

@@ -8,6 +8,7 @@ WORKDIR /server
 COPY package*.json ./
 
 # Install dependencies
+RUN npm install -g node-gyp
 RUN npm install
 
 # Copy the rest of the application code to the working directory

server/discordBot/commands/join.mjs

@@ -57,13 +57,19 @@ export async function execute(nodeIo, interaction) {
     const joinSelectedNode = async (selectedNodeSocketId) => {
       const openSocket = await nodeIo.sockets.sockets.get(selectedNodeSocketId);
       // Get the open ID for this connection\
-      const discordToken = await getAvailableTokensInGuild(nodeIo, interaction.guild.id);
+      const ss = await getAvailableTokensInGuild(nodeIo, interaction.guild.id);
-      // TODO - Implement a method to have preferred tokens (bot users) for specific systems
+      console.log("Available discord tokens: ", discordTokens);
 
-      console.log("Joining selected open socket:", selectedNodeSocketId, system.name, channelToJoin.id, openSocket.node.name, discordToken);
+      if (discordTokens.length >= 1) {
+        // TODO - Implement a method to have preferred tokens (bot users) for specific systems
+        console.log("Joining selected open socket:", selectedNodeSocketId, system.name, channelToJoin.id, openSocket.node.name, discordTokens[0].token);
 
-      // Ask the node to join the selected channel and system
+        // Ask the node to join the selected channel and system
-      await requestNodeJoinSystem(openSocket, system.name, channelToJoin.id, discordToken[0].token);
+        await requestNodeJoinSystem(openSocket, system.name, channelToJoin.id, discordTokens[0].token);
+      }
+      else {
+        return await interaction.editReply({ content: `<@${interaction.member.id}>, there are no free bots. Free up or create a new bot ID (discord app) to listen to this system.`, ephemeral: true })
+      }
     }
 
     // Get all open socket nodes

server/discordBot/modules/wrappers.mjs

@@ -37,10 +37,7 @@ export const checkOnlineBotsInGuild = async (nodeIo, guildId) => {
         console.log("Online bots in the guild:", onlineBots);
 
         // Filter any discordIDs that are not active
-        var availableDiscordIDs = discordIDs.filter(discordID => discordID.active == true);
+        const availableDiscordIDs = discordIDs.filter(discordID => discordID.active == true).filter(discordID => !onlineBots.some(bot => Number(bot.discord_id) == discordID.discord_id));
-        
-        // Filter out discordIDs that are not found in onlineBots
-        availableDiscordIDs = availableDiscordIDs.filter(discordID => !onlineBots.some(bot => bot.discord_id === discordID.discord_id));
 
         // Return the unavailable discordIDs
         return availableDiscordIDs;