Increased maximum number of emitters to allow multiple torrents

Signed-off-by: Robert Gogete <[email protected]>

Author: gogeterobert

examples/test-host.js

@@ -84,20 +84,20 @@ async function runExample() {
 
     // Re-announce all files every 5 seconds
     let announceCount = 0;
-    const announceInterval = setInterval(async () => {
-      try {
-        announceCount++;
-        console.log(`📢 Re-announcing ${sharedFiles.length} files #${announceCount} at ${new Date().toLocaleTimeString()}`);
+    // const announceInterval = setInterval(async () => {
+    //   try {
+    //     announceCount++;
+    //     console.log(`📢 Re-announcing ${sharedFiles.length} files #${announceCount} at ${new Date().toLocaleTimeString()}`);
 
-        // Re-share all files to trigger re-announcement
-        for (const fileInfo of sharedFiles) {
-          await host.shareFile(fileInfo.path);
-        }
-        console.log(`✅ All ${sharedFiles.length} files re-announced`);
-      } catch (error) {
-        console.error('❌ Error re-announcing files:', error.message);
-      }
-    }, 5000); // Every 5 seconds
+    //     // Re-share all files to trigger re-announcement
+    //     for (const fileInfo of sharedFiles) {
+    //       await host.shareFile(fileInfo.path);
+    //     }
+    //     console.log(`✅ All ${sharedFiles.length} files re-announced`);
+    //   } catch (error) {
+    //     console.error('❌ Error re-announcing files:', error.message);
+    //   }
+    // }, 5000); // Every 5 seconds
 
     // Handle graceful shutdown
     process.on('SIGINT', async () => {

src/host.ts

@@ -337,6 +337,11 @@ export class FileHost implements IFileHost {
         this.logger.debug(`🔄 Initializing WebTorrent client...`);
         this.webTorrentClient = new WebTorrent();
 
+        // Fix EventEmitter warning when seeding multiple torrents
+        // WebTorrent reuses a single DHT instance, causing listener count to exceed default limit
+        this.webTorrentClient.setMaxListeners(0); // Disable limit
+        this.logger.debug(`🔧 Set WebTorrent maxListeners to unlimited for multiple torrents`);
+
         // Add error handling for the WebTorrent client
         this.webTorrentClient.on("error", (err: string | Error) => {
           this.logger.error("❌ WebTorrent client error:", err);