return
}
switch h.Action {
- case Connect:
+ case ActionConnect:
if h.ConnectionId != connectRequestConnectionId {
return
}
connId := me.newConn()
err = me.respond(addr, ResponseHeader{
- Connect,
+ ActionConnect,
h.TransactionId,
}, ConnectionResponse{
connId,
})
return
- case Announce:
+ case ActionAnnounce:
if _, ok := me.conns[h.ConnectionId]; !ok {
me.respond(addr, ResponseHeader{
TransactionId: h.TransactionId,
- Action: Error,
+ Action: ActionError,
}, []byte("not connected"))
return
}
}
err = me.respond(addr, ResponseHeader{
TransactionId: h.TransactionId,
- Action: Announce,
+ Action: ActionAnnounce,
}, AnnounceResponseHeader{
Interval: 900,
Leechers: t.Leechers,
err = fmt.Errorf("unhandled action: %d", h.Action)
me.respond(addr, ResponseHeader{
TransactionId: h.TransactionId,
- Action: Error,
+ Action: ActionError,
}, []byte("unhandled action"))
return
}
type Action int32
const (
- Connect Action = iota
- Announce
- Scrape
- Error
+ ActionConnect Action = iota
+ ActionAnnounce
+ ActionScrape
+ ActionError
connectRequestConnectionId = 0x41727101980
// Clearly this limits the request URI to 255 bytes. BEP 41 supports
// longer but I'm not fussed.
options := append([]byte{optionTypeURLData, byte(len(reqURI))}, []byte(reqURI)...)
- b, err := c.request(Announce, req, options)
+ b, err := c.request(ActionAnnounce, req, options)
if err != nil {
return
}
continue
}
c.contiguousTimeouts = 0
- if h.Action == Error {
+ if h.Action == ActionError {
err = errors.New(buf.String())
}
responseBody = buf
}
c.socket = pproffd.WrapNetConn(c.socket)
}
- b, err := c.request(Connect, nil, nil)
+ b, err := c.request(ActionConnect, nil, nil)
if err != nil {
return
}