// Package http implements a BitTorrent frontend via the HTTP protocol as // described in BEP 3 and BEP 23. package http import ( "context" "crypto/tls" "errors" "net" "net/http" "time" "github.com/julienschmidt/httprouter" "github.com/chihaya/chihaya/bittorrent" "github.com/chihaya/chihaya/frontend" "github.com/chihaya/chihaya/pkg/log" "github.com/chihaya/chihaya/pkg/stop" ) // Config represents all of the configurable options for an HTTP BitTorrent // Frontend. type Config struct { Addr string `yaml:"addr"` HTTPSAddr string `yaml:"https_addr"` ReadTimeout time.Duration `yaml:"read_timeout"` WriteTimeout time.Duration `yaml:"write_timeout"` IdleTimeout time.Duration `yaml:"idle_timeout"` EnableKeepAlive bool `yaml:"enable_keepalive"` TLSCertPath string `yaml:"tls_cert_path"` TLSKeyPath string `yaml:"tls_key_path"` AnnounceRoutes []string `yaml:"announce_routes"` ScrapeRoutes []string `yaml:"scrape_routes"` EnableRequestTiming bool `yaml:"enable_request_timing"` ParseOptions `yaml:",inline"` } // LogFields renders the current config as a set of Logrus fields. func (cfg Config) LogFields() log.Fields { return log.Fields{ "addr": cfg.Addr, "httpsAddr": cfg.HTTPSAddr, "readTimeout": cfg.ReadTimeout, "writeTimeout": cfg.WriteTimeout, "idleTimeout": cfg.IdleTimeout, "enableKeepAlive": cfg.EnableKeepAlive, "tlsCertPath": cfg.TLSCertPath, "tlsKeyPath": cfg.TLSKeyPath, "announceRoutes": cfg.AnnounceRoutes, "scrapeRoutes": cfg.ScrapeRoutes, "enableRequestTiming": cfg.EnableRequestTiming, "allowIPSpoofing": cfg.AllowIPSpoofing, "realIPHeader": cfg.RealIPHeader, "maxNumWant": cfg.MaxNumWant, "defaultNumWant": cfg.DefaultNumWant, "maxScrapeInfoHashes": cfg.MaxScrapeInfoHashes, } } // Default config constants. const ( defaultReadTimeout = 2 * time.Second defaultWriteTimeout = 2 * time.Second defaultIdleTimeout = 30 * time.Second ) // Validate sanity checks values set in a config and returns a new config with // default values replacing anything that is invalid. // // This function warns to the logger when a value is changed. func (cfg Config) Validate() Config { validcfg := cfg if cfg.ReadTimeout <= 0 { validcfg.ReadTimeout = defaultReadTimeout log.Warn("falling back to default configuration", log.Fields{ "name": "http.ReadTimeout", "provided": cfg.ReadTimeout, "default": validcfg.ReadTimeout, }) } if cfg.WriteTimeout <= 0 { validcfg.WriteTimeout = defaultWriteTimeout log.Warn("falling back to default configuration", log.Fields{ "name": "http.WriteTimeout", "provided": cfg.WriteTimeout, "default": validcfg.WriteTimeout, }) } if cfg.IdleTimeout <= 0 { validcfg.IdleTimeout = defaultIdleTimeout if cfg.EnableKeepAlive { // If keepalive is disabled, this configuration isn't used anyway. log.Warn("falling back to default configuration", log.Fields{ "name": "http.IdleTimeout", "provided": cfg.IdleTimeout, "default": validcfg.IdleTimeout, }) } } if cfg.MaxNumWant <= 0 { validcfg.MaxNumWant = defaultMaxNumWant log.Warn("falling back to default configuration", log.Fields{ "name": "http.MaxNumWant", "provided": cfg.MaxNumWant, "default": validcfg.MaxNumWant, }) } if cfg.DefaultNumWant <= 0 { validcfg.DefaultNumWant = defaultDefaultNumWant log.Warn("falling back to default configuration", log.Fields{ "name": "http.DefaultNumWant", "provided": cfg.DefaultNumWant, "default": validcfg.DefaultNumWant, }) } if cfg.MaxScrapeInfoHashes <= 0 { validcfg.MaxScrapeInfoHashes = defaultMaxScrapeInfoHashes log.Warn("falling back to default configuration", log.Fields{ "name": "http.MaxScrapeInfoHashes", "provided": cfg.MaxScrapeInfoHashes, "default": validcfg.MaxScrapeInfoHashes, }) } return validcfg } // Frontend represents the state of an HTTP BitTorrent Frontend. type Frontend struct { srv *http.Server tlsSrv *http.Server tlsCfg *tls.Config logic frontend.TrackerLogic Config } // NewFrontend creates a new instance of an HTTP Frontend that asynchronously // serves requests. func NewFrontend(logic frontend.TrackerLogic, provided Config) (*Frontend, error) { cfg := provided.Validate() f := &Frontend{ logic: logic, Config: cfg, } if cfg.Addr == "" && cfg.HTTPSAddr == "" { return nil, errors.New("must specify addr or https_addr or both") } if len(cfg.AnnounceRoutes) < 1 || len(cfg.ScrapeRoutes) < 1 { return nil, errors.New("must specify routes") } // If TLS is enabled, create a key pair. if cfg.TLSCertPath != "" && cfg.TLSKeyPath != "" { var err error f.tlsCfg = &tls.Config{ Certificates: make([]tls.Certificate, 1), } f.tlsCfg.Certificates[0], err = tls.LoadX509KeyPair(cfg.TLSCertPath, cfg.TLSKeyPath) if err != nil { return nil, err } } if cfg.HTTPSAddr != "" && f.tlsCfg == nil { return nil, errors.New("must specify tls_cert_path and tls_key_path when using https_addr") } if cfg.HTTPSAddr == "" && f.tlsCfg != nil { return nil, errors.New("must specify https_addr when using tls_cert_path and tls_key_path") } var listenerHTTP, listenerHTTPS net.Listener var err error if cfg.Addr != "" { listenerHTTP, err = net.Listen("tcp", f.Addr) if err != nil { return nil, err } } if cfg.HTTPSAddr != "" { listenerHTTPS, err = net.Listen("tcp", f.HTTPSAddr) if err != nil { if listenerHTTP != nil { listenerHTTP.Close() } return nil, err } } if cfg.Addr != "" { go func() { if err := f.serveHTTP(listenerHTTP); err != nil { log.Fatal("failed while serving http", log.Err(err)) } }() } if cfg.HTTPSAddr != "" { go func() { if err := f.serveHTTPS(listenerHTTPS); err != nil { log.Fatal("failed while serving https", log.Err(err)) } }() } return f, nil } // Stop provides a thread-safe way to shutdown a currently running Frontend. func (f *Frontend) Stop() stop.Result { stopGroup := stop.NewGroup() if f.srv != nil { stopGroup.AddFunc(f.makeStopFunc(f.srv)) } if f.tlsSrv != nil { stopGroup.AddFunc(f.makeStopFunc(f.tlsSrv)) } return stopGroup.Stop() } func (f *Frontend) makeStopFunc(stopSrv *http.Server) stop.Func { return func() stop.Result { c := make(stop.Channel) go func() { c.Done(stopSrv.Shutdown(context.Background())) }() return c.Result() } } func (f *Frontend) handler() http.Handler { router := httprouter.New() for _, route := range f.AnnounceRoutes { router.GET(route, f.announceRoute) } for _, route := range f.ScrapeRoutes { router.GET(route, f.scrapeRoute) } return router } // serveHTTP blocks while listening and serving non-TLS HTTP BitTorrent // requests until Stop() is called or an error is returned. func (f *Frontend) serveHTTP(l net.Listener) error { f.srv = &http.Server{ Addr: f.Addr, Handler: f.handler(), ReadTimeout: f.ReadTimeout, WriteTimeout: f.WriteTimeout, IdleTimeout: f.IdleTimeout, } f.srv.SetKeepAlivesEnabled(f.EnableKeepAlive) // Start the HTTP server. if err := f.srv.Serve(l); err != http.ErrServerClosed { return err } return nil } // serveHTTPS blocks while listening and serving TLS HTTP BitTorrent // requests until Stop() is called or an error is returned. func (f *Frontend) serveHTTPS(l net.Listener) error { f.tlsSrv = &http.Server{ Addr: f.HTTPSAddr, TLSConfig: f.tlsCfg, Handler: f.handler(), ReadTimeout: f.ReadTimeout, WriteTimeout: f.WriteTimeout, } f.tlsSrv.SetKeepAlivesEnabled(f.EnableKeepAlive) // Start the HTTP server. if err := f.tlsSrv.ServeTLS(l, "", ""); err != http.ErrServerClosed { return err } return nil } func injectRouteParamsToContext(ctx context.Context, ps httprouter.Params) context.Context { rp := bittorrent.RouteParams{} for _, p := range ps { rp = append(rp, bittorrent.RouteParam{Key: p.Key, Value: p.Value}) } return context.WithValue(ctx, bittorrent.RouteParamsKey, rp) } // announceRoute parses and responds to an Announce. func (f *Frontend) announceRoute(w http.ResponseWriter, r *http.Request, ps httprouter.Params) { var err error var start time.Time if f.EnableRequestTiming { start = time.Now() } var af *bittorrent.AddressFamily defer func() { if f.EnableRequestTiming { recordResponseDuration("announce", af, err, time.Since(start)) } else { recordResponseDuration("announce", af, err, time.Duration(0)) } }() req, err := ParseAnnounce(r, f.ParseOptions) if err != nil { _ = WriteError(w, err) return } af = new(bittorrent.AddressFamily) *af = req.IP.AddressFamily ctx := injectRouteParamsToContext(context.Background(), ps) ctx, resp, err := f.logic.HandleAnnounce(ctx, req) if err != nil { _ = WriteError(w, err) return } w.Header().Set("Content-Type", "text/plain; charset=utf-8") err = WriteAnnounceResponse(w, resp) if err != nil { _ = WriteError(w, err) return } go f.logic.AfterAnnounce(ctx, req, resp) } // scrapeRoute parses and responds to a Scrape. func (f *Frontend) scrapeRoute(w http.ResponseWriter, r *http.Request, ps httprouter.Params) { var err error var start time.Time if f.EnableRequestTiming { start = time.Now() } var af *bittorrent.AddressFamily defer func() { if f.EnableRequestTiming { recordResponseDuration("scrape", af, err, time.Since(start)) } else { recordResponseDuration("scrape", af, err, time.Duration(0)) } }() req, err := ParseScrape(r, f.ParseOptions) if err != nil { _ = WriteError(w, err) return } host, _, err := net.SplitHostPort(r.RemoteAddr) if err != nil { log.Error("http: unable to determine remote address for scrape", log.Err(err)) _ = WriteError(w, err) return } reqIP := net.ParseIP(host) if reqIP.To4() != nil { req.AddressFamily = bittorrent.IPv4 } else if len(reqIP) == net.IPv6len { // implies reqIP.To4() == nil req.AddressFamily = bittorrent.IPv6 } else { log.Error("http: invalid IP: neither v4 nor v6", log.Fields{"RemoteAddr": r.RemoteAddr}) _ = WriteError(w, bittorrent.ErrInvalidIP) return } af = new(bittorrent.AddressFamily) *af = req.AddressFamily ctx := injectRouteParamsToContext(context.Background(), ps) ctx, resp, err := f.logic.HandleScrape(ctx, req) if err != nil { _ = WriteError(w, err) return } w.Header().Set("Content-Type", "text/plain; charset=utf-8") err = WriteScrapeResponse(w, resp) if err != nil { _ = WriteError(w, err) return } go f.logic.AfterScrape(ctx, req, resp) }