Remove Python from this repo and add Node test

- Added wrappers
- Improved readability of command code

.gitea/workflows/DRBv3_node_linting.yaml

@@ -0,0 +1,26 @@
+name: Lint JavaScript/Node.js
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+
+jobs:
+  lint-js:
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout Code
+      uses: actions/checkout@v3
+
+    - name: Set up Node.js
+      uses: actions/setup-node@v3
+      with:
+        node-version: '16'  # Use your preferred Node.js version
+
+    - name: Install Dependencies
+      run: npm install
+
+    - name: Lint JavaScript/Node.js
+      run: npm run lint

.gitea/workflows/DRBv3_server_build.yaml

@@ -25,14 +25,14 @@ jobs:
         uses: docker/setup-buildx-action@v2
         with: # replace it with your local IP
           config-inline: |
-            [registry."${{ secrets.LOCAL_GITEA_IP}}:3000"] 
+            [registry."git.vpn.cusano.net"] 
-              http = true
+              http = false
-              insecure = true            
+              insecure = false            
 
       - name: Login to DockerHub
         uses: docker/login-action@v2
         with:
-          registry: ${{ secrets.LOCAL_GITEA_IP}}:3000 # replace it with your local IP
+          registry: git.vpn.cusano.net # replace it with your local IP
           username: ${{ secrets.DOCKER_USERNAME }}
           password: ${{ secrets.DOCKER_PASSWORD }}
           
@@ -52,5 +52,5 @@ jobs:
             linux/arm64                        
           push: true
           tags: | # replace it with your local IP and tags
-            ${{ secrets.LOCAL_GITEA_IP}}:3000/${{ env.DOCKER_ORG }}/${{ steps.meta.outputs.REPO_NAME }}:${{ steps.meta.outputs.REPO_VERSION }}
+            git.vpn.cusano.net/${{ vars.DOCKER_ORG }}/${{ steps.meta.outputs.REPO_NAME }}:${{ steps.meta.outputs.REPO_VERSION }}
-            ${{ secrets.LOCAL_GITEA_IP}}:3000/${{ env.DOCKER_ORG }}/${{ steps.meta.outputs.REPO_NAME }}:${{ env.DOCKER_LATEST }}
+            git.vpn.cusano.net/${{ vars.DOCKER_ORG }}/${{ steps.meta.outputs.REPO_NAME }}:${{ env.DOCKER_LATEST }}

Dockerfile

@@ -15,7 +15,7 @@ RUN npm install
 COPY . .
 
 # Expose the port on which your Node.js application will run
-EXPOSE 3000
+EXPOSE 3420
 
 # Command to run the Node.js application
 CMD ["node", "."]

discordBot/addons/gptInteraction.mjs

@@ -0,0 +1,53 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.addons.gptInteraction");
+import { gptHandler } from "../modules/gptHandler.mjs";
+
+export const gptInteraction = async (nodeIo, message) => {
+    let conversation = [];
+
+    let prevMessages = await message.channel.messages.fetch({ limit: 10 });
+    prevMessages.reverse();
+
+    prevMessages.forEach((msg) => {
+        // Check if the message was sent within the last 24 hours
+        if (new Date().getTime() - msg.createdTimestamp > (24 * 60 * 60 * 1000)) {
+            return;
+        }
+
+        // Check if it's from a bot other than the server
+        if (msg.author.bot && msg.author.id !== nodeIo.serverClient.user.id) return;
+
+        const username = msg.author.username.replace(/\s+/g, '_').replace(/[^\w\s]/gi, '');
+
+        if (msg.author.id === nodeIo.serverClient.user.id) {
+            conversation.push({
+                role: 'assistant',
+                //name: msg.author.id,
+                content: msg.content,
+            });
+
+            return;
+        }
+
+        conversation.push({
+            role: 'user',
+            //name: msg.author.id,
+            content: msg.content.replace(`<@${nodeIo.serverClient.user.id}>`, ''),
+        });
+    });    
+    const response = await gptHandler(conversation);
+    if (response) {
+        const responseMessage = response;
+        const chunkSize = 2500;
+
+        for (let i = 0; i < responseMessage.length; i += chunkSize) {
+            const chunk = responseMessage.substring(i, i + chunkSize);
+
+            log.DEBUG("Sending message chunk:", chunk);
+
+            await message.reply(chunk);
+        }
+    } else {
+        message.channel.send('Sorry, I encountered an error while processing your request.');
+    }
+}

discordBot/addons/linkCop.mjs

@@ -0,0 +1,83 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.addons.linkCop");
+import { gptHandler } from "../modules/gptHandler.mjs";
+import dotenv from 'dotenv';
+dotenv.config();
+
+const approvedLinksChannel = "767303243285790721";
+const restrictedChannelIds = process.env.LINKCOP_RESTRICTED_CHANNEL_IDS.split(',');
+
+const linkRegExp = /(?:http[s]?:\/\/)?(?:www\.)?[-a-zA-Z0-9@:%._\+~#=]{1,256}\.[a-zA-Z0-9()]{1,6}\b(?:[-a-zA-Z0-9()@:%_\+.~#?&\/=]*)/g
+
+export const linkCop = async (nodeIo, message) => {
+    if (message.channel.id == approvedLinksChannel || !restrictedChannelIds.includes(message.channel.id)) return false;    
+
+    const urls = String(message.content).matchAll(linkRegExp);
+    if (!urls || urls.length === 0) return false;
+    log.DEBUG("Found URLs: ", urls);
+
+    let conversation = [];
+
+    let prevMessages = await message.channel.messages.fetch({ limit: 2 });
+    prevMessages.reverse();
+
+    prevMessages.forEach((msg) => {
+        // Check if the message was sent within the last 5 minutes
+        if (new Date().getTime() - msg.createdTimestamp > (5 * 60 * 1000)) {
+            return;
+        }
+
+        // Check if it's from a bot other than the server
+        if (msg.author.bot && msg.author.id !== nodeIo.serverClient.user.id) return;
+
+        const username = msg.author.username.replace(/\s+/g, '_').replace(/[^\w\s]/gi, '');
+
+        if (msg.author.id === nodeIo.serverClient.user.id) {
+            conversation.push({
+                role: 'assistant',
+                //name: msg.author.id,
+                content: msg.content,
+            });
+
+            return;
+        }
+
+        conversation.push({
+            role: 'user',
+            //name: msg.author.id,
+            content: msg.content.replace(`<@${nodeIo.serverClient.user.id}>`, ''),
+        });
+    }); 
+
+    conversation.push({
+        role: 'assistant',
+        content: `There has been a link posted to a channel that links are not allowed in. The above messages are from the channel that links are not allowed including the message with the link. The message with the link is going to be deleted and moved to the '#links' channels. You are replying to the message with the link to let the user know.`
+    });
+
+    const response = await gptHandler(conversation);
+
+    if (response) {
+        const responseMessage = response;
+        const chunkSize = 2000;
+
+        for (let i = 0; i < responseMessage.length; i += chunkSize) {
+            const chunk = responseMessage.substring(i, i + chunkSize);
+
+            log.DEBUG("Sending message chunk:", chunk);
+
+            await message.reply(chunk);
+        }
+
+        const messageContent = {
+            'author': message.author,
+            'content': `<@${message.author.id}> - ${String(message.content)}`,
+            'channelId': message.channelId,
+            'links': urls
+        }
+    
+        await message.delete();
+        log.DEBUG("Message content: ", messageContent);    
+    
+        message.client.channels.cache.get(approvedLinksChannel).send(messageContent);
+    } 
+}

discordBot/commands/connections.mjs

@@ -0,0 +1,52 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.command.ping");
+import { SlashCommandBuilder } from 'discord.js';
+
+// Exporting data property that contains the command structure for discord including any params
+export const data = new SlashCommandBuilder()
+  .setName('connections')
+  .setDescription('Check to see what bots are online.');
+
+// Exporting other properties
+export const example = "/connections"; // An example of how the command would be run in discord chat, this will be used for the help command
+export const deferInitialReply = false; // If we the initial reply in discord should be deferred. This gives extra time to respond, however the method of replying is different.
+
+/**
+ * Function to give the user auto-reply suggestions
+ * @param {any} nodeIo The nodeIO server for manipulation of sockets
+ * @param {any} interaction The interaction object
+ */
+/*
+export async function autocomplete(nodeIo, interaction) {
+  const focusedValue = interaction.options.getFocused();
+  const choices = []; // The array to be filled with the autocorrect values
+  const filtered = choices.filter(choice => choice.name.startsWith(focusedValue));
+  log.INFO(focusedValue, choices, filtered);
+  await interaction.respond(filtered.map(choice => ({name: choice.name, value: choice.name})));
+}
+*/
+
+/**
+ * The function to run when the command is called by a discord user
+ * @param {any} nodeIo The nodeIO server for manipulation of sockets
+ * @param {any} interaction The interaction object
+ */
+export const execute = async (nodeIo, interaction) => {
+  try {
+	const sockets = await nodeIo.allSockets();
+	log.DEBUG("All open sockets: ",sockets);
+  let socketMessage = "";
+  
+  // Create the message for discord with each socket on a new line
+  sockets.forEach(socket => {
+    socketMessage += `\n${socket}`
+  });
+
+	await interaction.reply(`**Online Sockets: '${socketMessage}'**`);
+	//await interaction.reply('**Pong.**');
+	//await interaction.channel.send('**Pong.**');
+  } catch (err) {
+    console.error(err);
+    // await interaction.reply(err.toString());
+  }
+}

discordBot/commands/join.mjs

@@ -1,9 +1,9 @@
 import { DebugBuilder } from "../../modules/debugger.mjs";
+import { SlashCommandBuilder } from 'discord.js';
+import { joinNode, getAvailableNodes, promptNodeSelection, getUserVoiceChannel } from '../modules/wrappers.mjs';
+import { getAllSystems, getSystemByName } from '../../modules/mongo-wrappers/mongoSystemsWrappers.mjs';
+
 const log = new DebugBuilder("server", "discordBot.command.join");
-import { SlashCommandBuilder, ActionRowBuilder, ButtonBuilder, ButtonStyle } from 'discord.js';
-import { requestNodeJoinSystem, checkIfNodeIsConnectedToVC, checkIfNodeHasOpenDiscordClient, getNodeCurrentListeningSystem } from '../../modules/socketServerWrappers.mjs';
-import { getSystemsByNuid, getAllSystems, getSystemByName } from '../../modules/mongo-wrappers/mongoSystemsWrappers.mjs';
-import { getAvailableTokensInGuild } from '../modules/wrappers.mjs';
 
 // Exporting data property
 export const data = new SlashCommandBuilder()
@@ -13,7 +13,8 @@ export const data = new SlashCommandBuilder()
     system.setName('system')
       .setDescription('The radio system you would like to listen to')
       .setRequired(true)
-      .setAutocomplete(true));
+      .setAutocomplete(true)
+  );
 
 // Exporting other properties
 export const example = "/join";
@@ -31,126 +32,62 @@ export async function autocomplete(nodeIo, interaction) {
 
   log.DEBUG(focusedValue, choices, filtered);
 
-  await interaction.respond(
+  try {
-    filtered.map(choice => ({ name: choice.name, value: choice.name })),
+    await interaction.respond(
-  );
+      filtered.map(choice => ({ name: choice.name, value: choice.name }))
+    );
+  }
+  catch (e) {
+    log.WARN("Autocomplete interaction failure", e);
+  }
 }
 
 /**
- * The function to run when the command is called by a discord user
+ * Handle join command execution
  * @param {any} nodeIo The nodeIO server for manipulation of sockets
  * @param {any} interaction The interaction object
  */
 export async function execute(nodeIo, interaction) {
-  // Check if the user is in a VC
-  if (!interaction.member.voice.channel) { return await interaction.editReply({ content: `<@${interaction.member.id}>, you need to enter a voice channel before you use this command`, ephemeral: true }) }
-  // Grab the channel if the user is connected to VC
-  const channelToJoin = interaction.member.voice.channel;
-  log.INFO(`The user '${interaction.member.id}' is in the voice channel '${channelToJoin}'`);
-
-  // Get the selected system option from the command interaction
-  const selectedSystem = interaction.options.getString('system');
-
   try {
-    // Get the selected system object from the DB
+    // Validate user is in a voice channel
-    const system = await getSystemByName(selectedSystem);
+    const channelToJoin = getUserVoiceChannel(interaction);
+    if (!channelToJoin) return;
 
-    // Function wrapper to request the selected/only node to join the selected system
+    // Get the selected system
-    const joinSelectedNode = async (selectedNodeSocketId) => {
+    const selectedSystemName = interaction.options.getString('system');
-      const openSocket = await nodeIo.sockets.sockets.get(selectedNodeSocketId);
+    const system = await getSystemByName(selectedSystemName);
-      // Get the open ID for this connection\
-      const discordTokens = await getAvailableTokensInGuild(nodeIo, interaction.guild.id);
-      log.DEBUG("Available discord tokens: ", discordTokens);
 
-      if (discordTokens.length >= 1) {
+    // Check if there was a system found by the given system name
-        // TODO - Implement a method to have preferred tokens (bot users) for specific systems
+    if (!system) {
-        log.INFO("Joining selected open socket:", selectedNodeSocketId, system.name, channelToJoin.id, openSocket.node.name, discordTokens[0].token);
+      await interaction.editReply({ content: `System '${selectedSystemName}' not found.`, ephemeral: true });
-
+      return;
-        // Ask the node to join the selected channel and system
-        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
+    // Get the available nodes for this system
-    const openSockets = [...await nodeIo.allSockets()]; // TODO - Filter the returned nodes to only nodes that have the radio capability
+    const availableNodes = await getAvailableNodes(nodeIo, interaction.guild.id, system);
-    log.DEBUG("All open sockets: ", openSockets);
 
-    var availableNodes = [];
+    // Check if there are available nodes
-    // Check each open socket to see if the node has the requested system
+    if (availableNodes.length === 0) {
-    await Promise.all(openSockets.map(async openSocket => {
+      // If not, let the user know
-      openSocket = await nodeIo.sockets.sockets.get(openSocket);
+      await interaction.editReply(`<@${interaction.member.id}>, the selected system has no available nodes`);
-      // Check if the node has an existing open client (meaning the radio is already being listened to)
+      return;
-      const hasOpenClient = await checkIfNodeHasOpenDiscordClient(openSocket);
+    }
-      if (hasOpenClient) {
-        let currentSystem = await getNodeCurrentListeningSystem(openSocket);
-        if (currentSystem != system.name) {
-          log.INFO("Node is listening to a different system than requested", openSocket.node.name);
-          return;
-        }
-      }
 
-      // Check if the bot has an open voice connection in the requested server already
+    // If there is one available node, request that node join
-      const connected = await checkIfNodeIsConnectedToVC(nodeIo, interaction.guild.id, openSocket.node.nuid);
+    if (availableNodes.length === 1) {
-      log.INFO("Connected:", connected);
+      await joinNode(nodeIo, interaction, availableNodes[0].id, system, channelToJoin);
-      if (!connected) {
+    }
-        // Check if this node has the requested system, if so add it to the availble array
-        if (system.nodes.includes(openSocket.node.nuid)) {
-          availableNodes.push(openSocket);
-        }
-      }
 
-    }));
+    // If there are more than one available, prompt the user for their selected node
-
+    else {
-    log.DEBUG("Availble nodes:", availableNodes.map(socket => socket.node.name));
+      await promptNodeSelection(interaction, availableNodes, async selectedNode => {
-
+        await joinNode(nodeIo, interaction, selectedNode, system, channelToJoin);
-    // If there are no available nodes, let the user know there are none available
-    if (availableNodes.length == 0) {
-      // There are no nodes availble for the requested system
-      return await interaction.editReply(`<@${interaction.member.id}>, the selected system has no available nodes`);
-    } else if (availableNodes.length == 1) {
-      // There is only one node available for the requested system
-      // Request the node to join
-      await joinSelectedNode(availableNodes[0].id);
-      // Let the user know
-      await interaction.editReply({ content: `Ok <@${interaction.member.id}>, a bot will join your channel listening to *'${system.name}'* shortly`, components: [] });
-    } else if (availableNodes.length > 1) {
-      // There is more than one node availble for the requested system
-      const nodeSelectionButtons = []
-
-      // Create a button for each available node
-      for (const availableNode of availableNodes) {
-        nodeSelectionButtons.push(new ButtonBuilder().setCustomId(availableNode.id).setLabel(availableNode.node.name).setStyle(ButtonStyle.Primary));
-      }
-
-      const actionRow = new ActionRowBuilder().addComponents(nodeSelectionButtons);
-
-      // Reply to the user with the button prompts
-      const response = await interaction.editReply({
-        content: `<@${interaction.member.id}>, Please select the Node you would like to join with this system`,
-        components: [actionRow]
       });
-
-      // Make sure the responding selection is from the user who initiated the command
-      const collectorFilter = i => i.user.id === interaction.user.id;
-
-      // Wait for the confirmation from the user on which node to join
-      try {
-        const selectedNode = await response.awaitMessageComponent({ filter: collectorFilter, time: 60_000 });
-        // Run the local wrapper to listen to the selected node
-        await joinSelectedNode(selectedNode.customId);
-        // Let the user know
-        await selectedNodeConfirmation.update({ content: `Ok <@${interaction.member.id}>, a bot will join your channel listening to *'${system.name}'*`, components: [] });
-      } catch (e) {
-        console.error(e);
-        // Timeout the prompt if the user doesn't interact with it
-        await interaction.editReply({ content: 'Confirmation not received within 1 minute, cancelling', components: [] });
-      }
     }
-  } catch (err) {
+  }
-    console.error(err);
+
-    // await interaction.reply(err.toString());
+  catch (err) {
+    log.ERROR(err);
+    await interaction.editReply({ content: `An error occurred: ${err.message}`, ephemeral: true });
   }
 }

discordBot/commands/leave.mjs

@@ -1,8 +1,9 @@
 import { DebugBuilder } from "../../modules/debugger.mjs";
-const log = new DebugBuilder("server", "discordBot.command.leave");
 import { SlashCommandBuilder } from 'discord.js';
 import { requestBotLeaveServer, getSocketIdByNuid } from '../../modules/socketServerWrappers.mjs';
-import { checkOnlineBotsInGuild } from '../modules/wrappers.mjs'
+import { checkOnlineBotsInGuild } from '../modules/wrappers.mjs';
+
+const log = new DebugBuilder("server", "discordBot.command.leave");
 
 // Exporting data property
 export const data = new SlashCommandBuilder()
@@ -12,7 +13,8 @@ export const data = new SlashCommandBuilder()
     system.setName('bot')
       .setDescription('The bot you would like to disconnect')
       .setRequired(true)
-      .setAutocomplete(true));;
+      .setAutocomplete(true)
+  );
 
 // Exporting other properties
 export const example = "/leave *{Bot Name}*";
@@ -25,15 +27,22 @@ export const deferInitialReply = true;
  */
 export async function autocomplete(nodeIo, interaction) {
   const focusedValue = interaction.options.getFocused();
-  const choices = (await checkOnlineBotsInGuild(nodeIo, interaction.guild.id));
+  const choices = await checkOnlineBotsInGuild(nodeIo, interaction.guild.id);
 
   log.DEBUG(choices);
 
-  const filtered = choices.filter(choice => choice.name.startsWith(focusedValue)).map(choice => choice = {name: choice.name, value: choice.nuid});
+  const filtered = choices
+    .filter(choice => choice.name.startsWith(focusedValue))
+    .map(choice => ({ name: choice.name, value: choice.nuid }));
 
   log.DEBUG(focusedValue, choices, filtered);
 
-  await interaction.respond(filtered);
+  try{
+    await interaction.respond(filtered);
+  }  
+  catch (e) {
+    log.WARN("Autocomplete interaction failure", e);
+  }
 }
 
 /**
@@ -43,16 +52,19 @@ export async function autocomplete(nodeIo, interaction) {
  */
 export async function execute(nodeIo, interaction) {
   try {
-    // Get the requested bot
     const selectedNode = interaction.options.getString('bot');
     const socket = await getSocketIdByNuid(nodeIo, selectedNode);
-    log.DEBUG("All open sockets:", socket, selectedNode);
+
+    if (!socket) {
+      await interaction.editReply({ content: `Bot '${selectedNode}' not found or not connected.`, ephemeral: true });
+      return;
+    }
+
     await requestBotLeaveServer(socket, interaction.guild.id);
-    //await interaction.reply(`**Online Sockets: '${sockets}'**`);
+
-    await interaction.editReply(`Ok <@${interaction.member.id}>, the bot is leaving shortly`);
+    await interaction.editReply(`Ok <@${interaction.member.id}>, the bot is leaving shortly.`);
-    //await interaction.channel.send('**Pong.**');
   } catch (err) {
-    console.error(err);
+    log.ERROR("Failed to disconnect bot:", err);
-    // await interaction.reply(err.toString());
+    await interaction.editReply({ content: `An error occurred: ${err.message}`, ephemeral: true });
   }
 }

discordBot/commands/rssAdd.mjs

@@ -54,18 +54,19 @@ export const execute = async (nodeIo, interaction) => {
     var category = interaction.options.getString('category');
 
     if (!category) category = "ALL";
+    await interaction.reply(`Adding ${title} to the list of RSS sources, please wait...`);
 
     await addSource(title, link, category, interaction.guildId, interaction.channelId, (err, result) => {
       log.DEBUG("Result from adding entry", result);
 
       if (result) {
-        interaction.reply(`Successfully added ${title} to the list of RSS sources`);
+        interaction.editReply(`Successfully added ${title} to the list of RSS sources`);
       } else {
-        interaction.reply(`${title} already exists in the list of RSS sources`);
+        interaction.editReply(`${title} already exists in the list of RSS sources`);
       }
     });
   } catch (err) {
     log.ERROR(err)
-    await interaction.reply(err.toString());
+    await interaction.editReply(err.toString());
   }
 }

discordBot/commands/rssRemove.mjs

@@ -42,17 +42,17 @@ export async function autocomplete(nodeIo, interaction) {
 export const execute = async (nodeIo, interaction) => {
   try {
     var title = interaction.options.getString('title');
-    interaction.reply(`Removing ${title} from the list of RSS sources, please wait...`);
+    await interaction.reply(`Removing ${title} from the list of RSS sources, please wait...`);
 
     const results = await deleteFeedByTitle(title);
     if (!results) {
       log.WARN(`Failed to remove source: ${title}`);
-      interaction.editReply(`Failed to remove source: '${title}'`);
+      await interaction.editReply(`Failed to remove source: '${title}'`);
       return;
     }
-    interaction.editReply(`${title} was successfully removed from the RSS sources.`)
+    await interaction.editReply(`${title} was successfully removed from the RSS sources.`)
   } catch (err) {
     log.ERROR(err)
-    interaction.editReply(err.toString());
+    await interaction.editReply(err.toString());
   }
 }

discordBot/commands/rssTrigger.mjs

@@ -38,6 +38,7 @@ export const execute = async (nodeIo, interaction) => {
         //await interaction.reply(`**Online Sockets: '${sockets}'**`);
         await interaction.reply('Triggering RSS update');
         await updateFeeds(interaction.client);
+        await interaction.editReply('RSS Update Completed');
         //await interaction.channel.send('**Pong.**');
     } catch (err) {
         console.error(err);

discordBot/discordBot.mjs

@@ -79,7 +79,7 @@ export function addEnabledEventListeners(serverClient, _eventsPath = "./events")
 }
 
 // The discord client
-export const serverClient = new Client({ intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildVoiceStates] });
+export const serverClient = new Client({ intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildVoiceStates, GatewayIntentBits.GuildMessages, GatewayIntentBits.MessageContent, GatewayIntentBits.GuildMembers, GatewayIntentBits.GuildPresences] });
 
 // Run when the bot is ready
 serverClient.on('ready', async () => {

discordBot/events/guildCreate.mjs

@@ -0,0 +1,16 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.events.guildCreate");
+import { Events } from 'discord.js';
+import { addEnabledCommands, addEnabledEventListeners } from "../discordBot.mjs";
+
+export const name = Events.GuildMemberAdd;
+
+export async function execute(nodeIo, guild) {
+    log.INFO("Bot has joined a new server", guild);
+
+    log.DEBUG("Refreshing commands enabled");
+    await addEnabledCommands(nodeIo.serverClient);
+
+    log.DEBUG("Refreshing events enabled");
+    await addEnabledEventListeners(nodeIo.serverClient);
+}

discordBot/events/guildMemberAdd.mjs

@@ -0,0 +1,34 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.events.guildMemberAdd");
+import dotenv from 'dotenv';
+dotenv.config();
+import { Events } from 'discord.js';
+import { gptHandler } from "../modules/gptHandler.mjs";
+
+const welcomeChannel = process.env.WELCOME_CHANNEL_ID; // TODO - Need to add a DB section for server configs so it's not static to one server
+
+export const name = Events.GuildMemberAdd;
+
+export async function execute(nodeIo, member) {
+    log.INFO("New user joined the server", member);
+    let conversation = [];
+    conversation.push({
+        role: 'assistant',
+        content: `A new user has joined the server. Their name is '<@${member.id}>'. Please welcome them to the server and remind them about the rules.`
+    })
+
+    const response = await gptHandler(conversation);
+    if (response) {
+        const responseMessage = response.choices[0].message.content;
+        const chunkSize = 2500;
+
+        for (let i = 0; i < responseMessage.length; i += chunkSize) {
+            const chunk = responseMessage.substring(i, i + chunkSize);
+
+            log.DEBUG("Sending message chunk:", chunk);
+
+            await nodeIo.serverClient.channels.cache.get(welcomeChannel).send(chunk);
+        }
+    }
+
+}

discordBot/events/messageCreate.mjs

@@ -0,0 +1,29 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.events.messageCreate");
+import dotenv from 'dotenv';
+dotenv.config();
+import { Events } from 'discord.js';
+import { gptInteraction } from '../addons/gptInteraction.mjs';
+import { linkCop } from '../addons/linkCop.mjs';
+
+const IGNORED_CHANNELS = process.env.IGNORED_CHANNEL_IDS.split(',');
+
+export const name = Events.MessageCreate;
+
+export async function execute(nodeIo, message) {
+    // Ignore ignored channels
+    if (IGNORED_CHANNELS.includes(message.channel.id)) return;
+
+    // Ignore messages from a bot
+    if (message.author.bot) return;
+
+    log.INFO("Message create", message);
+
+    // Check if the message mentions the bot
+    if (message.mentions.users.has(nodeIo.serverClient.user.id)) {
+        return await gptInteraction(nodeIo, message);
+    }
+
+    // Check if the message contains a link in a channel it shouldn't
+    if (await linkCop(nodeIo, message)) return;
+}

discordBot/modules/gptHandler.mjs

@@ -0,0 +1,122 @@
+import { DebugBuilder } from "../../modules/debugger.mjs";
+const log = new DebugBuilder("server", "discordBot.modules.gptHandler");
+import dotenv from 'dotenv';
+dotenv.config();
+
+import { OpenAI } from 'openai';
+import { EventEmitter } from 'events';
+
+const openai = new OpenAI(process.env.OPENAI_API_KEY);
+
+const assistant = await openai.beta.assistants.create({
+    name: "Emmelia",
+    instructions: process.env.DRB_SERVER_INITIAL_PROMPT,
+    model: "gpt-4o",    
+});
+
+class EventHandler extends EventEmitter {
+    constructor(client) {
+        super();
+        this.client = client;
+    }
+
+    async onEvent(event) {
+        try {
+            console.log(event);
+            // Retrieve events that are denoted with 'requires_action'
+            // since these will have our tool_calls
+            if (event.event === "thread.run.requires_action") {
+                await this.handleRequiresAction(
+                    event.data,
+                    event.data.id,
+                    event.data.thread_id,
+                );
+            }
+        } catch (error) {
+            console.error("Error handling event:", error);
+        }
+    }
+
+    async handleRequiresAction(data, runId, threadId) {
+        try {
+            const toolOutputs =
+                data.required_action.submit_tool_outputs.tool_calls.map((toolCall) => {
+                    // Call the function
+                    switch (toolCall.function.name) {
+                        case "getCurrentTemperature": return {
+                            tool_call_id: toolCall.id,
+                            output: "57",
+                        };
+                    }
+                });
+            // Submit all the tool outputs at the same time
+            await this.submitToolOutputs(toolOutputs, runId, threadId);
+        } catch (error) {
+            console.error("Error processing required action:", error);
+        }
+    }
+
+    async submitToolOutputs(toolOutputs, runId, threadId) {
+        try {
+            // Use the submitToolOutputsStream helper
+            const stream = this.client.beta.threads.runs.submitToolOutputsStream(
+                threadId,
+                runId,
+                { tool_outputs: toolOutputs },
+            );
+            for await (const event of stream) {
+                this.emit("event", event);
+            }
+        } catch (error) {
+            console.error("Error submitting tool outputs:", error);
+        }
+    }
+}
+
+const eventHandler = new EventHandler(openai);
+eventHandler.on("event", eventHandler.onEvent.bind(eventHandler));
+
+export const gptHandler = async (additionalMessages) => {
+    const thread = await openai.beta.threads.create();
+
+    // Add the additional messages to the conversation
+    for (const msgObj of additionalMessages) {
+        await openai.beta.threads.messages.create(
+            thread.id,
+            msgObj
+        );
+    }
+
+    log.DEBUG("AI Conversation:", thread);
+
+    // Run the thread to get a response
+    try {
+        const stream = await openai.beta.threads.runs.stream(
+            thread.id,
+            { assistant_id: assistant.id },
+            eventHandler,
+        );
+
+        for await (const event of stream) {
+            eventHandler.emit("event", event);
+        }
+
+        let response;
+        const messages = await openai.beta.threads.messages.list(
+            thread.id
+        );
+        response = messages.data[0].content[0].text.value;
+
+        log.DEBUG("AI Response:", response);
+
+        if (!response) {
+            return false;
+        }
+
+        return response;
+
+    } catch (error) {
+        console.error('Error generating response:', error);
+        return false;
+    }
+}

discordBot/modules/wrappers.mjs

@@ -1,50 +1,167 @@
 import { DebugBuilder } from "../../modules/debugger.mjs";
 const log = new DebugBuilder("server", "discordBot.modules.wrappers");
-import { checkIfNodeIsConnectedToVC, getNodeDiscordID, getNodeDiscordUsername } from '../../modules/socketServerWrappers.mjs';
+import { checkIfNodeIsConnectedToVC, getNodeDiscordID, getNodeDiscordUsername, checkIfNodeHasOpenDiscordClient, getNodeCurrentListeningSystem, requestNodeJoinSystem } from '../../modules/socketServerWrappers.mjs';
 import { getAllDiscordIDs } from '../../modules/mongo-wrappers/mongoDiscordIDWrappers.mjs'
+import { ActionRowBuilder, ButtonBuilder, ButtonStyle } from 'discord.js';
+
 
 
 export const checkOnlineBotsInGuild = async (nodeIo, guildId) => {
-    let onlineBots = [];
+  let onlineBots = [];
-    const openSockets = [...await nodeIo.allSockets()];
+  const openSockets = [...await nodeIo.allSockets()];
-    await Promise.all(openSockets.map(async openSocket => {
+  await Promise.all(openSockets.map(async openSocket => {
-      openSocket = await nodeIo.sockets.sockets.get(openSocket);
+    openSocket = await nodeIo.sockets.sockets.get(openSocket);
-      const connected = await checkIfNodeIsConnectedToVC(nodeIo, guildId, openSocket.node.nuid);
+    const connected = await checkIfNodeIsConnectedToVC(nodeIo, guildId, openSocket.node.nuid);
-      log.INFO("Connected:", connected);
+    log.INFO("Connected:", connected);
-      if (connected) {
+    if (connected) {
-        const username = await getNodeDiscordUsername(openSocket, guildId);
+      const username = await getNodeDiscordUsername(openSocket, guildId);
-        const discordID = await getNodeDiscordID(openSocket);
+      const discordID = await getNodeDiscordID(openSocket);
-        onlineBots.push({
+      onlineBots.push({
-          name: username,
+        name: username,
-          discord_id: discordID,
+        discord_id: discordID,
-          nuid: openSocket.node.nuid
+        nuid: openSocket.node.nuid
-        });
+      });
-      }
-    }));
-  
-    return onlineBots;
-  }
-
-
-  export const getAvailableTokensInGuild = async (nodeIo, guildId) => {
-    try {
-        // Execute both asynchronous functions concurrently
-        const [discordIDs, onlineBots] = await Promise.all([
-            getAllDiscordIDs(), // Fetch all Discord IDs
-            checkOnlineBotsInGuild(nodeIo, guildId) // Check online bots in the guild
-        ]);
-
-        // Use the results of both promises here
-        log.INFO("Available Discord IDs:", discordIDs);
-        log.INFO("Online bots in the guild:", onlineBots);
-
-        // Filter any discordIDs that are not active
-        const availableDiscordIDs = discordIDs.filter(discordID => discordID.active == true).filter(discordID => !onlineBots.some(bot => Number(bot.discord_id) == discordID.discord_id));
-
-        // Return the unavailable discordIDs
-        return availableDiscordIDs;
-    } catch (error) {
-        console.error('Error getting available tokens in guild:', error);
-        throw error;
     }
+  }));
+
+  return onlineBots;
+}
+
+
+export const getAvailableTokensInGuild = async (nodeIo, guildId) => {
+  try {
+    // Execute both asynchronous functions concurrently
+    const [discordIDs, onlineBots] = await Promise.all([
+      getAllDiscordIDs(), // Fetch all Discord IDs
+      checkOnlineBotsInGuild(nodeIo, guildId) // Check online bots in the guild
+    ]);
+
+    // Use the results of both promises here
+    log.INFO("Available Discord IDs:", discordIDs);
+    log.INFO("Online bots in the guild:", onlineBots);
+
+    // Filter any discordIDs that are not active
+    const availableDiscordIDs = discordIDs.filter(discordID => discordID.active == true).filter(discordID => !onlineBots.some(bot => Number(bot.discord_id) == discordID.discord_id));
+
+    // Return the unavailable discordIDs
+    return availableDiscordIDs;
+  } catch (error) {
+    console.error('Error getting available tokens in guild:', error);
+    throw error;
+  }
 };
+
+
+
+/**
+ * Get the nodes with given system that are available to be used within a given server 
+ * @param {any} nodeIo The nodeIO object contained in the discord server object
+ * @param {any} guildId The guild ID to search in 
+ * @param {any} system The system to filter the nodes by
+ * @returns {any}
+ */
+export const getAvailableNodes = async (nodeIo, guildId, system) => {
+  // Get all open socket nodes
+  const openSockets = [...await nodeIo.allSockets()]; // TODO - Filter the returned nodes to only nodes that have the radio capability
+  log.DEBUG("All open sockets: ", openSockets);
+
+  var availableNodes = [];
+  // Check each open socket to see if the node has the requested system
+  await Promise.all(openSockets.map(async openSocket => {
+    openSocket = await nodeIo.sockets.sockets.get(openSocket);
+    // Check if the node has an existing open client (meaning the radio is already being listened to)
+    const hasOpenClient = await checkIfNodeHasOpenDiscordClient(openSocket);
+    if (hasOpenClient) {
+      let currentSystem = await getNodeCurrentListeningSystem(openSocket);
+      if (currentSystem != system.name) {
+        log.INFO("Node is listening to a different system than requested", openSocket.node.name);
+        return;
+      }
+    }
+
+    // Check if the bot has an open voice connection in the requested server already
+    const connected = await checkIfNodeIsConnectedToVC(nodeIo, guildId, openSocket.node.nuid);
+    log.INFO("Connected:", connected);
+    if (!connected) {
+      // Check if this node has the requested system, if so add it to the availble array
+      if (system.nodes.includes(openSocket.node.nuid)) {
+        availableNodes.push(openSocket);
+      }
+    }
+
+  }));
+
+  log.DEBUG("Availble nodes:", availableNodes.map(socket => socket.node.name));
+
+  return availableNodes;
+}
+
+/**
+ * Gets the voice channel the user is currently in.
+ * @param {any} interaction - The interaction object.
+ * @returns {any} - The voice channel object, or null if the user is not in a voice channel.
+ */
+export const getUserVoiceChannel = (interaction) => {
+  if (!interaction.member.voice.channel) {
+    interaction.editReply({ content: `<@${interaction.member.id}>, you need to enter a voice channel before using this command`, ephemeral: true });
+    return null;
+  }
+  return interaction.member.voice.channel;
+}
+
+/**
+ * Joins a node to a specified system and voice channel.
+ * @param {any} nodeIo - The nodeIO server for manipulation of sockets.
+ * @param {any} interaction - The interaction object.
+ * @param {string} nodeId - The ID of the node to join.
+ * @param {any} system - The system object to join.
+ * @param {any} channel - The voice channel to join.
+ */
+export const joinNode = async (nodeIo, interaction, nodeId, system, channel) => {
+  try {
+    const openSocket = await nodeIo.sockets.sockets.get(nodeId);
+    const discordTokens = await getAvailableTokensInGuild(nodeIo, interaction.guild.id);
+
+    if (discordTokens.length === 0) {
+      await interaction.editReply({ content: `<@${interaction.member.id}>, there are no free bots available.`, ephemeral: true });
+      return;
+    }
+
+    log.INFO("Joining node:", nodeId, system.name, channel.id, openSocket.node.name, discordTokens[0].token);
+    await requestNodeJoinSystem(openSocket, system.name, channel.id, discordTokens[0].token);
+
+    await interaction.editReply({ content: `<@${interaction.member.id}>, a bot will join your channel listening to '${system.name}' shortly.`, ephemeral: true });
+  } catch (err) {
+    log.ERROR("Failed to join node:", err);
+    await interaction.editReply({ content: `<@${interaction.member.id}>, an error occurred while joining the node: ${err.message}`, ephemeral: true });
+  }
+}
+
+/**
+ * Prompts the user to select a node from available nodes.
+ * @param {any} interaction - The interaction object.
+ * @param {Array} availableNodes - The list of available nodes.
+ * @param {Function} onNodeSelected - Callback function to handle the selected node.
+ */
+export const promptNodeSelection = async (interaction, availableNodes, onNodeSelected) => {
+  const nodeSelectionButtons = availableNodes.map(node =>
+    new ButtonBuilder().setCustomId(node.id).setLabel(node.node.name).setStyle(ButtonStyle.Primary)
+  );
+
+  const actionRow = new ActionRowBuilder().addComponents(nodeSelectionButtons);
+
+  const response = await interaction.editReply({
+    content: `<@${interaction.member.id}>, please select the Node you would like to join with this system:`,
+    components: [actionRow],
+    ephemeral: true
+  });
+
+  const collectorFilter = i => i.user.id === interaction.user.id;
+  try {
+    const selectedNode = await response.awaitMessageComponent({ filter: collectorFilter, time: 60_000 });
+    await onNodeSelected(selectedNode.customId);
+  } catch (e) {
+    log.ERROR("Node selection timeout:", e);
+    await interaction.editReply({ content: 'Confirmation not received within 1 minute, cancelling.', components: [] });
+  }
+}

makefile

@@ -20,6 +20,13 @@ run:
 				-e SERVER_PORT=${SERVER_PORT} \
 				-e MONGO_URL=${MONGO_URL} \
 				-e DISCORD_TOKEN=${DISCORD_TOKEN} \
+				-e RSS_REFRESH_INTERVAL=${RSS_REFRESH_INTERVAL} \
+				-e WELCOME_CHANNEL_ID=${WELCOME_CHANNEL_ID} \
+				-e IGNORED_CHANNEL_IDS=${IGNORED_CHANNEL_IDS} \
+				-e LINKCOP_RESTRICTED_CHANNEL_IDS=${LINKCOP_RESTRICTED_CHANNEL_IDS} \
+				-e DRB_SERVER_INITIAL_PROMPT=${DRB_SERVER_INITIAL_PROMPT} \
+				-e OPENAI_API_KEY=${OPENAI_API_KEY} \
+				-e LOG_LOCATION="./logs/server.log" \
 				-p ${SERVER_PORT}:${SERVER_PORT} \
 				--name=drb \
 				$(DOCKER_IMAGE_NAME)

modules/socketServerWrappers.mjs

@@ -195,6 +195,7 @@ export const checkIfNodeHasOpenDiscordClient = async (openSocket) => {
     // Check the open socket to see if the node has an open discord client
     let hasOpenDiscordClient = false;
     await new Promise((res) => {
+        log.INFO("Checking if socket has an open connection:", openSocket.node.name)
         openSocket.emit('node-check-discord-open-client', (status) => {
             if (status) {
                 log.INFO("Socket has an open discord client:", openSocket.node.name, status);
@@ -216,6 +217,7 @@ export const getNodeCurrentListeningSystem = async (openSocket) => {
     // check what system the socket is listening to
     let currentSystem = undefined;
     await new Promise((res) => {
+        log.INFO("Checking system node is currently listening to:", openSocket.node.name)
         openSocket.emit('node-check-current-system', (system) => {
             if (system) {
                 log.INFO("Socket is listening to system:", openSocket.node.name, system);

package.json

@@ -4,6 +4,7 @@
   "description": "",
   "main": "server.js",
   "scripts": {
+    "lint": "eslint . --ext .js,.mjs",
     "test": "mocha --timeout 5000",
     "start": "node server.js"
   },
@@ -11,19 +12,20 @@
   "license": "ISC",
   "type": "module",
   "devDependencies": {
-    "chai": "^5.1.0",
+    "chai": "^5.1.1",
     "mocha": "^10.4.0",
     "socket.io-client": "^4.7.5"
   },
   "dependencies": {
-    "discord.js": "^14.14.1",
+    "discord.js": "^14.15.2",
-    "dotenv": "^16.3.1",
+    "dotenv": "^16.4.5",
-    "express": "^4.18.2",
+    "express": "^4.19.2",
-    "mongodb": "^6.3.0",
+    "mongodb": "^6.7.0",
     "morgan": "^1.10.0",
     "node-html-parser": "^6.1.13",
+    "openai": "^4.47.3",
     "rss-parser": "^3.13.0",
-    "socket.io": "^4.7.2",
+    "socket.io": "^4.7.5",
-    "user-agents": "^1.1.208"
+    "user-agents": "^1.1.222"
   }
 }

rss-manager/sourceManager.mjs

@@ -1,3 +1,5 @@
+import { DebugBuilder } from "../modules/debugger.mjs";
+const log = new DebugBuilder("server", "sourceManager");
 import { createFeed, getFeedByLink, deleteFeedByLink } from '../modules/mongo-wrappers/mongoFeedsWrappers.mjs';
 
 class SourceManager {