forked from anacrolix/torrent
/
Peer.go
37 lines (31 loc) · 816 Bytes
/
Peer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package torrent
import (
"net"
"github.com/anacrolix/dht/v2/krpc"
"github.com/sickyoon/torrent/peer_protocol"
)
// Peer connection info, handed about publicly.
type Peer struct {
Id [20]byte
IP net.IP
Port int
Source peerSource
// Peer is known to support encryption.
SupportsEncryption bool
peer_protocol.PexPeerFlags
// Whether we can ignore poor or bad behaviour from the peer.
Trusted bool
}
func (me *Peer) FromPex(na krpc.NodeAddr, fs peer_protocol.PexPeerFlags) {
me.IP = append([]byte(nil), na.IP...)
me.Port = na.Port
me.Source = peerSourcePex
// If they prefer encryption, they must support it.
if fs.Get(peer_protocol.PexPrefersEncryption) {
me.SupportsEncryption = true
}
me.PexPeerFlags = fs
}
func (me Peer) addr() IpPort {
return IpPort{me.IP, uint16(me.Port)}
}