import Hyperswarm from 'hyperswarm'; import EventEmitter from 'node:events' class Client extends EventEmitter { constructor(botName) { super(); if(!botName) return console.error("BotName is not defined!"); this.botName = botName; this.swarm = new Hyperswarm(); this.setupSwarm(); } setupSwarm() { this.swarm.on('connection', (peer) => { peer.on('data', message => this.emit('onMessage', peer, JSON.parse(message.toString()))); peer.on('error', e => { this.emit('onError', e); console.error(`Connection error: ${e}`) }); }); this.swarm.on('update', () => { console.log(`Peers count: ${this.swarm.connections.size}`); }); } joinChatRoom(chatRoomID) { this.discovery = this.swarm.join(Buffer.from(chatRoomID, 'hex'), {client: true, server: true}); this.discovery.flushed().then(() => { console.log(`Bot ${this.botName} joined the chat room.`); this.emit('onBotJoinRoom'); }); } sendMessage(message) { console.log('Bot name:', this.botName); const timestamp = Date.now(); // Generate timestamp const peers = [...this.swarm.connections]; const data = JSON.stringify({name: this.botName, message, timestamp}); // Include timestamp for (const peer of peers) peer.write(data); } destroy() { this.swarm.destroy(); console.log(`Bot ${this.botName} disconnected.`); } } export default Client;