Fixed a bug in server update command #10

- Didn't properly get the open sockets

client/discordAudioBot/dab.mjs

@@ -17,7 +17,8 @@ import { Client, Events, ActivityType } from 'discord.js';
 import prism_media from 'prism-media';
 const { FFmpeg } = prism_media;
 
-const device = "VoiceMeeter VAIO3 Output (VB-Audio VoiceMeeter VAIO3)", maxTransmissionGap = 500, type = "dshow";
+// Import the DAB settings from the dynamic settings file
+import {device, maxTransmissionGap, type} from './dabSettings.mjs'
 
 const player = createAudioPlayer({
 	behaviors: {

client/discordAudioBot/dabSettings.mjs

@@ -0,0 +1,18 @@
+import { executeCommand } from '../modules/cliHandler.mjs';
+import { extractValue } from '../modules/baseUtils.mjs';
+import os from 'os';
+
+// Defaults to Windows values for testing
+let device = "VoiceMeeter VAIO3 Output (VB-Audio VoiceMeeter VAIO3)";
+let maxTransmissionGap = 500;
+let type = "dshow";
+
+// Set Linux values for use in production
+if (os.platform() === 'linux') {
+    await executeCommand("pactl", ['list', 'short', 'sources']).then(cliOutput => {
+        device = extractValue(cliOutput, '(?:\d[ ]{4,12}(.+?)[ ]{4,12}(?:.+?[ ]{4,12}){2,4}RUNNING)')
+    });    
+    type = "pulse"; // Replace with appropriate type for Linux
+}
+
+export { device, maxTransmissionGap, type };

client/modules/baseUtils.mjs

@@ -62,3 +62,16 @@ export const generateUniqueID  = () => {
 
     return uniqueID;
 }
+
+
+/**
+ * Extracts the value after a specific pattern from a string using regular expressions.
+ * @param {string} input - The input string.
+ * @param {string} pattern - The pattern to match.
+ * @returns {string|null} The value found after the pattern, or null if not found.
+ */
+export const extractValue = (input, pattern) => {
+    const regex = new RegExp(`${pattern}\\s+(\\S+)`);
+    const match = input.match(regex);
+    return match ? match[1] : null;
+};

client/modules/cliHandler.mjs

@@ -0,0 +1,39 @@
+import { spawn } from "child_process";
+
+/**
+ * Executes a command and retrieves its output.
+ * @param {string} command - The command to execute.
+ * @param {string[]} args - The arguments to pass to the command.
+ * @returns {Promise<string>} A promise that resolves with the output of the command.
+ */
+export const executeCommand = (command, args) => {
+    return new Promise((resolve, reject) => {
+        const childProcess = spawn(command, args);
+
+        let commandOutput = '';
+
+        childProcess.stdout.on('data', (data) => {
+            commandOutput += data.toString();
+        });
+
+        childProcess.stderr.on('data', (data) => {
+            // Log any errors to stderr
+            console.error(data.toString());
+        });
+
+        childProcess.on('error', (error) => {
+            // Reject the promise if there's an error executing the command
+            reject(error);
+        });
+
+        childProcess.on('close', (code) => {
+            if (code === 0) {
+                // Resolve the promise with the command output if it exits successfully
+                resolve(commandOutput.trim());
+            } else {
+                // Reject the promise if the command exits with a non-zero code
+                reject(new Error(`Command '${command}' exited with code ${code}`));
+            }
+        });
+    });
+};

client/serviceStart.sh

@@ -1 +1 @@
-node . 2> stderr.2
+node .

server/discordBot/commands/update.mjs

@@ -17,14 +17,17 @@ export const deferInitialReply = false; // If we the initial reply in discord sh
  */
 export const execute = async (nodeIo, interaction) => {
   try {
-	const sockets = await nodeIo.allSockets();
-	console.log("All open sockets: ",sockets);
-  await sockets.map(openSocket => {
-    requestNodeUpdate(openSocket);
-  })
-	//await interaction.reply(`**Online Sockets: '${sockets}'**`);
-	await interaction.reply('**Pong.**');
-	//await interaction.channel.send('**Pong.**');
+    const openSockets = [...await nodeIo.allSockets()]; // TODO - Filter the returned nodes to only nodes that have the radio capability
+    console.log("All open sockets: ", openSockets);
+
+    // Check each open socket to see if the node has the requested system
+    await Promise.all(openSockets.map(openSocket => {
+      openSocket = nodeIo.sockets.sockets.get(openSocket);
+      requestNodeUpdate(openSocket);
+    }));
+    //await interaction.reply(`**Online Sockets: '${sockets}'**`);
+    await interaction.reply('All nodes have been requested to update');
+    //await interaction.channel.send('**Pong.**');
   } catch (err) {
     console.error(err);
     // await interaction.reply(err.toString());