35 lines
651 B
Go
35 lines
651 B
Go
package torrent
|
|
|
|
import (
|
|
"github.com/anacrolix/dht/v2/krpc"
|
|
|
|
"github.com/anacrolix/torrent/peer_protocol"
|
|
"github.com/anacrolix/torrent/tracker"
|
|
)
|
|
|
|
type Peers []Peer
|
|
|
|
func (me *Peers) AppendFromPex(nas []krpc.NodeAddr, fs []peer_protocol.PexPeerFlags) {
|
|
for i, na := range nas {
|
|
var p Peer
|
|
var f peer_protocol.PexPeerFlags
|
|
if i < len(fs) {
|
|
f = fs[i]
|
|
}
|
|
p.FromPex(na, f)
|
|
*me = append(*me, p)
|
|
}
|
|
}
|
|
|
|
func (ret Peers) AppendFromTracker(ps []tracker.Peer) Peers {
|
|
for _, p := range ps {
|
|
_p := Peer{
|
|
Addr: ipPortAddr{p.IP, p.Port},
|
|
Source: peerSourceTracker,
|
|
}
|
|
copy(_p.Id[:], p.ID)
|
|
ret = append(ret, _p)
|
|
}
|
|
return ret
|
|
}
|