Skip to content

Commit 7635fed

Browse files
implement peers event
1 parent dff06a6 commit 7635fed

File tree

2 files changed

+17
-8
lines changed

2 files changed

+17
-8
lines changed

lib/client/http-tracker.js

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -150,14 +150,21 @@ HTTPTracker.prototype._onAnnounceResponse = function (data) {
150150
} catch (err) {
151151
return self.client.emit('warning', err)
152152
}
153-
addrs.forEach(function (addr) {
154-
self.client.emit('peer', addr)
155-
})
153+
154+
if (addrs.length) {
155+
self.client.emit('peers', addrs)
156+
}
157+
156158
} else if (Array.isArray(data.peers)) {
157159
// tracker returned normal response
158-
data.peers.forEach(function (peer) {
159-
self.client.emit('peer', peer.ip + ':' + peer.port)
160+
addrs = data.peers.map(function (peer) {
161+
// self.client.emit('peer', peer.ip + ':' + peer.port)
162+
return peer.ip + ':' + peer.port;
160163
})
164+
165+
if (addrs.length) {
166+
self.client.emit('peers', addrs)
167+
}
161168
}
162169
}
163170

lib/client/udp-tracker.js

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,9 +134,11 @@ UDPTracker.prototype._request = function (opts) {
134134
} catch (err) {
135135
return self.client.emit('warning', err)
136136
}
137-
addrs.forEach(function (addr) {
138-
self.client.emit('peer', addr)
139-
})
137+
138+
if (addrs.length) {
139+
self.client.emit('peers', addrs);
140+
}
141+
140142
break
141143

142144
case 2: // scrape

0 commit comments

Comments
 (0)