diff --git a/client.js b/client.js index 1416d47..bf3ba61 100644 --- a/client.js +++ b/client.js @@ -352,9 +352,13 @@ Tracker.prototype._requestUdp = function (requestUrl, opts) { incomplete: msg.readUInt32BE(12) }) - compact2string.multi(msg.slice(20)).forEach(function (addr) { - self.client.emit('peer', addr) - }) + try { + compact2string.multi(msg.slice(20)).forEach(function (addr) { + self.client.emit('peer', addr) + }) + } catch (err) { + return self.client.emit('error', err) + } break case 2: // scrape @@ -478,9 +482,13 @@ Tracker.prototype._handleResponse = function (requestUrl, data) { if (Buffer.isBuffer(data.peers)) { // tracker returned compact response - compact2string.multi(data.peers).forEach(function (addr) { - self.client.emit('peer', addr) - }) + try { + compact2string.multi(data.peers).forEach(function (addr) { + self.client.emit('peer', addr) + }) + } catch (err) { + return self.client.emit('error', err) + } } else if (Array.isArray(data.peers)) { // tracker returned normal response data.peers.forEach(function (peer) {