X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/8fc29fafb91cf64ce4ededbdd85ef9507c51f216..514fb685c9d835441e0911d9b9499952b6787095:/lib/controller/handler.go diff --git a/lib/controller/handler.go b/lib/controller/handler.go index 2c3ce1d4f2..f925233ba3 100644 --- a/lib/controller/handler.go +++ b/lib/controller/handler.go @@ -15,6 +15,9 @@ import ( "sync" "time" + "git.curoverse.com/arvados.git/lib/controller/federation" + "git.curoverse.com/arvados.git/lib/controller/railsproxy" + "git.curoverse.com/arvados.git/lib/controller/router" "git.curoverse.com/arvados.git/sdk/go/arvados" "git.curoverse.com/arvados.git/sdk/go/health" "git.curoverse.com/arvados.git/sdk/go/httpserver" @@ -60,7 +63,7 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, req *http.Request) { func (h *Handler) CheckHealth() error { h.setupOnce.Do(h.setup) - _, _, err := findRailsAPI(h.Cluster) + _, _, err := railsproxy.FindRailsAPI(h.Cluster) return err } @@ -73,6 +76,16 @@ func (h *Handler) setup() { Prefix: "/_health/", Routes: health.Routes{"ping": func() error { _, err := h.db(&http.Request{}); return err }}, }) + + rtr := router.New(federation.New(h.Cluster)) + mux.Handle("/arvados/v1/config", rtr) + + if h.Cluster.EnableBetaController14287 { + mux.Handle("/arvados/v1/collections", rtr) + mux.Handle("/arvados/v1/collections/", rtr) + mux.Handle("/login", rtr) + } + hs := http.NotFoundHandler() hs = prepend(hs, h.proxyRailsAPI) hs = h.setupProxyRemoteCluster(hs) @@ -126,7 +139,7 @@ func prepend(next http.Handler, middleware middlewareFunc) http.Handler { } func (h *Handler) localClusterRequest(req *http.Request) (*http.Response, error) { - urlOut, insecure, err := findRailsAPI(h.Cluster) + urlOut, insecure, err := railsproxy.FindRailsAPI(h.Cluster) if err != nil { return nil, err }