Skip to content

Commit 42a2f00

Browse files
Robert GogeteRobert Gogete
authored andcommitted
improved logging
1 parent b09b88b commit 42a2f00

File tree

1 file changed

+14
-18
lines changed

1 file changed

+14
-18
lines changed

β€Žsrc/webtorrent-manager.tsβ€Ž

Lines changed: 14 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -99,11 +99,7 @@ class WebTorrentManager extends EventEmitter {
9999
this.logger.debug("πŸš€ Initializing shared WebTorrent client...");
100100

101101
try {
102-
this.webTorrentClient = new WebTorrent({
103-
maxConns: 100, // Increase max connections (default: 55)
104-
downloadLimit: -1, // No download limit
105-
uploadLimit: -1 // No upload limit (helps with reciprocity)
106-
});
102+
this.webTorrentClient = new WebTorrent();
107103

108104
// Set unlimited max listeners for the WebTorrent client (if method exists)
109105
if (typeof this.webTorrentClient.setMaxListeners === 'function') {
@@ -220,33 +216,33 @@ class WebTorrentManager extends EventEmitter {
220216

221217
// ANTI-CHOKING STRATEGY: Handle wire connections to express interest immediately
222218
torrent.on('wire', (wire: any, addr: string) => {
223-
this.logger.debug(`πŸ”Œ Connected to peer: ${addr}`);
219+
this.logger.info(`πŸ”Œ Connected to peer: ${addr}`);
224220

225221
// Express interest immediately when connected
226222
wire.interested();
227-
this.logger.debug(`βœ‹ Expressed interest to peer: ${addr}`);
223+
this.logger.info(`βœ‹ Expressed interest to peer: ${addr}`);
228224

229225
// Handle choke events - re-express interest when choked
230226
wire.on('choke', () => {
231-
this.logger.debug(`🚫 Choked by peer: ${addr} - re-expressing interest`);
227+
this.logger.info(`🚫 Choked by peer: ${addr} - re-expressing interest`);
232228
if (!wire.amInterested) {
233229
wire.interested(); // Request to be unchoked
234230
}
235231
});
236232

237233
// Log unchoke events
238234
wire.on('unchoke', () => {
239-
this.logger.debug(`βœ… Unchoked by peer: ${addr} - can download`);
235+
this.logger.info(`βœ… Unchoked by peer: ${addr} - can download`);
240236
});
241237

242238
// Log when peer is interested
243239
wire.on('interested', () => {
244-
this.logger.debug(`πŸ‘€ Peer ${addr} is interested in our data`);
240+
this.logger.info(`πŸ‘€ Peer ${addr} is interested in our data`);
245241
});
246242

247243
// Log when peer is not interested
248244
wire.on('uninterested', () => {
249-
this.logger.debug(`😴 Peer ${addr} is not interested in our data`);
245+
this.logger.info(`😴 Peer ${addr} is not interested in our data`);
250246
});
251247
});
252248

@@ -266,7 +262,7 @@ class WebTorrentManager extends EventEmitter {
266262
this.emit('metadata', metadataData);
267263

268264
setTimeout(() => {
269-
this.logger.debug(`πŸ‘₯ Peers sharing this torrent: ${torrent.numPeers}`);
265+
this.logger.info(`πŸ‘₯ Peers sharing this torrent: ${torrent.numPeers}`);
270266
}, 1000);
271267
});
272268

@@ -366,7 +362,7 @@ class WebTorrentManager extends EventEmitter {
366362
});
367363

368364
torrent.on('noPeers', () => {
369-
this.logger.warn("⚠️ No peers found for torrent", {
365+
this.logger.debug("⚠️ No peers found for torrent", {
370366
magnetUri: magnetUri.substring(0, 100) + '...',
371367
infoHash: torrent.infoHash,
372368
name: torrent.name
@@ -413,25 +409,25 @@ class WebTorrentManager extends EventEmitter {
413409

414410
// ANTI-CHOKING STRATEGY FOR SEEDING: Immediately unchoke all connected peers
415411
torrent.on('wire', (wire: any, addr: string) => {
416-
this.logger.debug(`πŸ”Œ Peer connected to seeder: ${addr}`);
412+
this.logger.info(`πŸ”Œ Peer connected to this seeder: ${addr}`);
417413

418414
// Immediately unchoke the peer
419415
wire.unchoke();
420-
this.logger.debug(`βœ… Unchoked peer: ${addr}`);
416+
this.logger.info(`βœ… Unchoked peer: ${addr}`);
421417

422418
// Keep peers unchoked when they show interest
423419
wire.on('interested', () => {
424-
this.logger.debug(`πŸ‘€ Peer ${addr} interested - ensuring unchoked`);
420+
this.logger.info(`πŸ‘€ Peer ${addr} interested - ensuring unchoked`);
425421
wire.unchoke();
426422
});
427423

428424
// Log choke/unchoke state changes
429425
wire.on('choke', () => {
430-
this.logger.debug(`🚫 We choked peer: ${addr}`);
426+
this.logger.info(`🚫 We choked peer: ${addr}`);
431427
});
432428

433429
wire.on('unchoke', () => {
434-
this.logger.debug(`βœ… We unchoked peer: ${addr}`);
430+
this.logger.info(`βœ… We unchoked peer: ${addr}`);
435431
});
436432
});
437433

0 commit comments

Comments
Β (0)