From 7efd0cd4f3abf0cf72143b5a34e3294e50434642 Mon Sep 17 00:00:00 2001 From: Logan Cusano Date: Sun, 3 Mar 2024 21:31:14 -0500 Subject: [PATCH] Fixed a bug in server update command #10 - Didn't properly get the open sockets --- server/discordBot/commands/update.mjs | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/server/discordBot/commands/update.mjs b/server/discordBot/commands/update.mjs index 122469b..b9f4150 100644 --- a/server/discordBot/commands/update.mjs +++ b/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());