10 "github.com/anacrolix/dht/v2/krpc"
11 trHttp "github.com/anacrolix/torrent/tracker/http"
12 "github.com/anacrolix/torrent/tracker/shared"
13 "github.com/anacrolix/torrent/tracker/udp"
18 Started = shared.Started
19 Stopped = shared.Stopped
20 Completed = shared.Completed
23 type AnnounceRequest = udp.AnnounceRequest
25 type AnnounceResponse = trHttp.AnnounceResponse
27 type Peer = trHttp.Peer
29 type AnnounceEvent = udp.AnnounceEvent
31 var ErrBadScheme = errors.New("unknown scheme")
33 type Announce struct {
35 Request AnnounceRequest
37 HTTPProxy func(*http.Request) (*url.URL, error)
41 // If the port is zero, it's assumed to be the same as the Request.Port.
42 ClientIp4 krpc.NodeAddr
43 // If the port is zero, it's assumed to be the same as the Request.Port.
44 ClientIp6 krpc.NodeAddr
45 Context context.Context
48 // The code *is* the documentation.
49 const DefaultTrackerAnnounceTimeout = 15 * time.Second
51 func (me Announce) Do() (res AnnounceResponse, err error) {
52 cl, err := NewClient(me.TrackerUrl, NewClientOpts{
53 Http: trHttp.NewClientOpts{
55 ServerName: me.ServerName,
57 UdpNetwork: me.UdpNetwork,
63 if me.Context == nil {
64 // This is just to maintain the old behaviour that should be a timeout of 15s. Users can
65 // override it by providing their own Context. See comments elsewhere about longer timeouts
66 // acting as rate limiting overloaded trackers.
67 ctx, cancel := context.WithTimeout(context.Background(), DefaultTrackerAnnounceTimeout)
71 return cl.Announce(me.Context, me.Request, trHttp.AnnounceOpt{
72 UserAgent: me.UserAgent,
73 HostHeader: me.HostHeader,
74 ClientIp4: me.ClientIp4.IP,
75 ClientIp6: me.ClientIp6.IP,