Method StartAddRoute

internal/entrypoint/routes.go:48–97

(r types.Route)

}

func (ep *Entrypoint) StartAddRoute(r types.Route) error {
	if r.ShouldExclude() {
		ep.excludedRoutes.Add(r)
		r.Task().OnCancel("remove_route", func() {
			ep.excludedRoutes.Del(r)
		})
		return nil
	}
	switch r := r.(type) {
	case types.HTTPRoute:
		if err := ep.AddHTTPRoute(r); err != nil {
			return err
		}
		ep.shortLinkMatcher.AddRoute(r.Key())
		r.Task().OnCancel("remove_route", func() {
			ep.delHTTPRoute(r)
			ep.shortLinkMatcher.DelRoute(r.Key())
		})
	case types.StreamRoute:
		if asSNIRoute(r) {
			if !common.SNIRoutingForTCPRoutes {
				return fmt.Errorf("route %q listens on the shared HTTPS listener, but TCP SNI routing is disabled", r.Name())
			}
			if err := ep.sni.AddRoute(r); err != nil {
				return err
			}
			ep.streamRoutes.Add(r)
			r.Task().OnCancel("remove_sni_route", func() {
				ep.sni.DelRoute(r)
				_ = r.Stream().Close()
				ep.streamRoutes.Del(r)
			})
			return nil
		}

		err := r.ListenAndServe(r.Task().Context(), nil, nil)
		if err != nil {
			return err
		}
		ep.streamRoutes.Add(r)

		r.Task().OnCancel("remove_route", func() {
			r.Stream().Close()
			ep.streamRoutes.Del(r)
		})
	default:
		return fmt.Errorf("unknown route type: %T", r)
	}
	return nil
}

func getAddr(route types.HTTPRoute) (httpAddr, httpsAddr string) {
	if port := route.ListenURL().Port(); port == "" || port == "0" {