Fixed unsharing an item

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

Author: gogeterobert

src/client.ts

@@ -54,7 +54,7 @@ export class FileClient extends EventEmitter implements IFileClient {
     super(); // Call EventEmitter constructor
 
     // Increase max listeners to prevent warnings during testing/multiple usage
-    this.setMaxListeners(20);
+    this.setMaxListeners(0);
 
     this.options = {
       peers: options.peers || ["http://dig-relay-prod.eba-2cmanxbe.us-east-1.elasticbeanstalk.com/gun"],
@@ -322,7 +322,7 @@ export class FileClient extends EventEmitter implements IFileClient {
         this.webTorrentClient = new WebTorrent();
 
         // Increase max listeners for the WebTorrent client to prevent warnings
-        this.webTorrentClient.setMaxListeners(20);
+        this.webTorrentClient.setMaxListeners(0);
 
         // Log client status (using safe property access)
         this.logger.debug(`🔧 WebTorrent client created:`, {

src/host.ts

@@ -628,11 +628,7 @@ export class FileHost implements IFileHost {
     if (this.webTorrentClient && this.magnetUris.has(filename)) {
       try {
         const magnetURI = this.magnetUris.get(filename);
-        const torrent = this.webTorrentClient.get(magnetURI!);
-        if (torrent && typeof torrent === "object" && "destroy" in torrent) {
-          (torrent as { destroy(): void }).destroy();
-          this.logger.debug(`🧲 Stopped WebTorrent seeding for ${filename}`);
-        }
+        this.webTorrentClient.remove(magnetURI!);
         this.magnetUris.delete(filename);
       } catch (error) {
         this.logger.warn(`⚠️ Error stopping WebTorrent seeding:`, error);

tests/host.test.ts

@@ -44,7 +44,9 @@ const mockWebTorrentInstance = {
   get: jest.fn(),
   destroy: jest.fn(),
   on: jest.fn(),
-  setMaxListeners: jest.fn()
+  setMaxListeners: jest.fn(),
+  add: jest.fn(),
+  remove: jest.fn()
 };
 
 // Mock torrent
@@ -432,8 +434,7 @@ describe('FileHost', () => {
 
         host.unshareFile(filename);
 
-        expect(mockWebTorrentInstance.get).toHaveBeenCalledWith(mockTorrent.magnetURI);
-        expect(mockTorrentInstance.destroy).toHaveBeenCalled();
+        expect(mockWebTorrentInstance.remove).toHaveBeenCalled();
       }, 10000);
     });