chatBot/bot.js

@@ -1,10 +1,14 @@
 import fs from 'fs';
 import path from 'path';
-import Client from './includes/client.js'; // Adjust the import path as necessary
+import chatBot from './includes/chatBot.js'; // Adjust the import path as necessary
-import 'dotenv/config';
+import 'dotenv/config'
+
+// Generate a Buffer from the hexadecimal topic value
+const topicHex = process.env.LINKUP_ROOM_ID;
+const topicBuffer = Buffer.from(topicHex, 'hex');
 
 // Create a new instance of the chatBot class with a valid botName
-const botName = process.env.BOT_NAME; // Replace 'MyBot' with the desired bot name
+const botName = process.env.BOT_NAME;; // Replace 'MyBot' with the desired bot name
 
 // Load commands from the 'commands' directory
 const commandsDir = path.join(new URL('./commands/', import.meta.url).pathname);
@@ -34,11 +38,7 @@ async function loadCommands() {
 }
 
 loadCommands().then(commands => {
-  // Create the chatBot instance with the defined onMessageReceived function
+  const onMessageReceived = (peer, message) => {
-  const bot = new Client(process.env.LINKUP_ROOM_ID, botName);
-
-  // We use Event Emitter here to handle new messages
-  bot.on('onMessage', (peer, message) => {
     if (message.type == "icon") return;
     console.log(message);
 
@@ -57,7 +57,10 @@ loadCommands().then(commands => {
         commandHandler.handler(bot, args, message);
       }
     }
-  })
+  };
+
+  // Create the chatBot instance with the defined onMessageReceived function
+  const bot = new chatBot(topicBuffer, botName, onMessageReceived);
   bot.joinChatRoom();
 
   // Wait for 2 seconds for the bot to connect

chatBot/includes/chatBot.js

@@ -1,18 +1,17 @@
 import Hyperswarm from 'hyperswarm';
-import EventEmitter from 'node:events'
 
-class Client extends EventEmitter {
+class chatBot {
-  constructor(chatRoomID, botName) {
+  constructor(topicBuffer, botName, onMessageReceived) {
-    super();
+    this.topicBuffer = topicBuffer;
-    this.topicBuffer = Buffer.from(chatRoomID, 'hex');
     this.botName = botName;
     this.swarm = new Hyperswarm();
+    this.onMessageReceived = onMessageReceived;
     this.setupSwarm();
   }
 
   setupSwarm() {
     this.swarm.on('connection', (peer) => {
-      peer.on('data', message => this.emit("onMessage", peer, JSON.parse(message.toString())));
+      peer.on('data', message => this.onMessageReceived(peer, JSON.parse(message.toString())));
       peer.on('error', e => console.log(`Connection error: ${e}`));
     });
 
@@ -42,4 +41,4 @@ class Client extends EventEmitter {
   }
 }
 
-export default Client;
+export default chatBot;

package.json

@@ -22,7 +22,6 @@
   "dependencies": {
     "b4a": "^1.6.6",
     "corestore": "^6.18.2",
-    "dotenv": "^16.4.5",
     "electron": "^30.0.8",
     "hypercore-crypto": "^3.4.1",
     "hyperdrive": "^11.8.1",