12 "github.com/anacrolix/dht/v2/krpc"
13 "github.com/anacrolix/log"
15 trHttp "github.com/anacrolix/torrent/tracker/http"
16 "github.com/anacrolix/torrent/tracker/shared"
17 "github.com/anacrolix/torrent/tracker/udp"
22 Started = shared.Started
23 Stopped = shared.Stopped
24 Completed = shared.Completed
27 type AnnounceRequest = udp.AnnounceRequest
29 type AnnounceResponse = trHttp.AnnounceResponse
31 type Peer = trHttp.Peer
33 type AnnounceEvent = udp.AnnounceEvent
35 var ErrBadScheme = errors.New("unknown scheme")
37 type Announce struct {
39 Request AnnounceRequest
41 HTTPProxy func(*http.Request) (*url.URL, error)
42 HTTPRequestDirector func(*http.Request) error
43 DialContext func(ctx context.Context, network, addr string) (net.Conn, error)
44 ListenPacket func(network, addr string) (net.PacketConn, error)
48 // If the port is zero, it's assumed to be the same as the Request.Port.
49 ClientIp4 krpc.NodeAddr
50 // If the port is zero, it's assumed to be the same as the Request.Port.
51 ClientIp6 krpc.NodeAddr
52 Context context.Context
56 // The code *is* the documentation.
57 const DefaultTrackerAnnounceTimeout = 15 * time.Second
59 func (me Announce) Do() (res AnnounceResponse, err error) {
60 cl, err := NewClient(me.TrackerUrl, NewClientOpts{
61 Http: trHttp.NewClientOpts{
63 DialContext: me.DialContext,
64 ServerName: me.ServerName,
66 UdpNetwork: me.UdpNetwork,
67 Logger: me.Logger.WithContextValue(fmt.Sprintf("tracker client for %q", me.TrackerUrl)),
68 ListenPacket: me.ListenPacket,
74 if me.Context == nil {
75 // This is just to maintain the old behaviour that should be a timeout of 15s. Users can
76 // override it by providing their own Context. See comments elsewhere about longer timeouts
77 // acting as rate limiting overloaded trackers.
78 ctx, cancel := context.WithTimeout(context.Background(), DefaultTrackerAnnounceTimeout)
82 return cl.Announce(me.Context, me.Request, trHttp.AnnounceOpt{
83 UserAgent: me.UserAgent,
84 HostHeader: me.HostHeader,
85 ClientIp4: me.ClientIp4.IP,
86 ClientIp6: me.ClientIp6.IP,
87 HTTPRequestDirector: me.HTTPRequestDirector,