11 "github.com/anacrolix/dht/v2/krpc"
13 "github.com/anacrolix/torrent/tracker"
16 // Announces a torrent to a tracker at regular intervals, when peers are
18 type trackerScraper struct {
21 lastAnnounce trackerAnnounceResult
24 type torrentTrackerAnnouncer interface {
29 func (me trackerScraper) URL() url.URL {
33 func (ts *trackerScraper) statusLine() string {
35 fmt.Fprintf(&w, "%q\t%s\t%s",
38 na := time.Until(ts.lastAnnounce.Completed.Add(ts.lastAnnounce.Interval))
48 if ts.lastAnnounce.Err != nil {
49 return ts.lastAnnounce.Err.Error()
51 if ts.lastAnnounce.Completed.IsZero() {
54 return fmt.Sprintf("%d peers", ts.lastAnnounce.NumPeers)
60 type trackerAnnounceResult struct {
63 Interval time.Duration
67 func (me *trackerScraper) getIp() (ip net.IP, err error) {
68 ips, err := net.LookupIP(me.u.Hostname())
73 err = errors.New("no ips")
76 for _, ip = range ips {
77 if me.t.cl.ipIsBlocked(ip) {
92 err = errors.New("no acceptable ips")
96 func (me *trackerScraper) trackerUrl(ip net.IP) string {
99 u.Host = net.JoinHostPort(ip.String(), u.Port())
104 // Return how long to wait before trying again. For most errors, we return 5
105 // minutes, a relatively quick turn around for DNS changes.
106 func (me *trackerScraper) announce(event tracker.AnnounceEvent) (ret trackerAnnounceResult) {
108 ret.Completed = time.Now()
110 ret.Interval = time.Minute
111 ip, err := me.getIp()
113 ret.Err = fmt.Errorf("error getting ip: %s", err)
117 req := me.t.announceRequest(event)
119 //log.Printf("announcing %s %s to %q", me.t, req.Event, me.u.String())
120 res, err := tracker.Announce{
121 HTTPProxy: me.t.cl.config.HTTPProxy,
122 UserAgent: me.t.cl.config.HTTPUserAgent,
123 TrackerUrl: me.trackerUrl(ip),
125 HostHeader: me.u.Host,
126 ServerName: me.u.Hostname(),
127 UdpNetwork: me.u.Scheme,
128 ClientIp4: krpc.NodeAddr{IP: me.t.cl.config.PublicIp4},
129 ClientIp6: krpc.NodeAddr{IP: me.t.cl.config.PublicIp6},
132 ret.Err = fmt.Errorf("error announcing: %s", err)
135 me.t.AddPeers(Peers(nil).AppendFromTracker(res.Peers))
136 ret.NumPeers = len(res.Peers)
137 ret.Interval = time.Duration(res.Interval) * time.Second
141 func (me *trackerScraper) Run() {
142 defer me.announceStopped()
143 // make sure first announce is a "started"
147 // after first announce, get back to regular "none"
154 interval := ar.Interval
155 if interval < time.Minute {
156 interval = time.Minute
158 wantPeers := me.t.wantPeersEvent.LockedChan(me.t.cl.locker())
161 if interval > time.Minute {
162 interval = time.Minute
169 case <-me.t.closed.LockedChan(me.t.cl.locker()):
173 case <-time.After(time.Until(ar.Completed.Add(interval))):
178 func (me *trackerScraper) announceStopped() {
179 me.announce(tracker.Stopped)