mirror of
https://github.com/sot-tech/mochi.git
synced 2026-05-11 06:39:08 -07:00
http: Unexport announce/scrape creation functions
This commit is contained in:
@@ -89,7 +89,7 @@ func (s *Server) serveAnnounce(w http.ResponseWriter, r *http.Request, p httprou
|
|||||||
stats.RecordEvent(stats.Announce)
|
stats.RecordEvent(stats.Announce)
|
||||||
|
|
||||||
writer := &Writer{w}
|
writer := &Writer{w}
|
||||||
ann, err := NewAnnounce(s.config, r, p)
|
ann, err := newAnnounce(s.config, r, p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return handleTorrentError(err, writer)
|
return handleTorrentError(err, writer)
|
||||||
}
|
}
|
||||||
@@ -101,7 +101,7 @@ func (s *Server) serveScrape(w http.ResponseWriter, r *http.Request, p httproute
|
|||||||
stats.RecordEvent(stats.Scrape)
|
stats.RecordEvent(stats.Scrape)
|
||||||
|
|
||||||
writer := &Writer{w}
|
writer := &Writer{w}
|
||||||
scrape, err := NewScrape(s.config, r, p)
|
scrape, err := newScrape(s.config, r, p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return handleTorrentError(err, writer)
|
return handleTorrentError(err, writer)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,8 +17,8 @@ import (
|
|||||||
"github.com/chihaya/chihaya/tracker/models"
|
"github.com/chihaya/chihaya/tracker/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
// NewAnnounce parses an HTTP request and generates a models.Announce.
|
// newAnnounce parses an HTTP request and generates a models.Announce.
|
||||||
func NewAnnounce(cfg *config.Config, r *http.Request, p httprouter.Params) (*models.Announce, error) {
|
func newAnnounce(cfg *config.Config, r *http.Request, p httprouter.Params) (*models.Announce, error) {
|
||||||
q, err := query.New(r.URL.RawQuery)
|
q, err := query.New(r.URL.RawQuery)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -80,8 +80,8 @@ func NewAnnounce(cfg *config.Config, r *http.Request, p httprouter.Params) (*mod
|
|||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewScrape parses an HTTP request and generates a models.Scrape.
|
// newScrape parses an HTTP request and generates a models.Scrape.
|
||||||
func NewScrape(cfg *config.Config, r *http.Request, p httprouter.Params) (*models.Scrape, error) {
|
func newScrape(cfg *config.Config, r *http.Request, p httprouter.Params) (*models.Scrape, error) {
|
||||||
q, err := query.New(r.URL.RawQuery)
|
q, err := query.New(r.URL.RawQuery)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -64,7 +64,8 @@ func (tkr *Tracker) LoadApprovedClients(clients []string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Writer serializes a tracker's responses, and is implemented for each
|
// Writer serializes a tracker's responses, and is implemented for each
|
||||||
// response transport used by the tracker.
|
// response transport used by the tracker. Only one of these may be called
|
||||||
|
// per request, and only once.
|
||||||
//
|
//
|
||||||
// Note, data passed into any of these functions will not contain sensitive
|
// Note, data passed into any of these functions will not contain sensitive
|
||||||
// information, so it may be passed back the client freely.
|
// information, so it may be passed back the client freely.
|
||||||
|
|||||||
Reference in New Issue
Block a user