X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a14150968c57cffebb79d6ef85e1944111bc1257..e9f7d73dc0d84ee7127b8f83a4955521e8091708:/lib/controller/railsproxy/railsproxy.go diff --git a/lib/controller/railsproxy/railsproxy.go b/lib/controller/railsproxy/railsproxy.go index 576e603eed..515dd5df0f 100644 --- a/lib/controller/railsproxy/railsproxy.go +++ b/lib/controller/railsproxy/railsproxy.go @@ -7,19 +7,15 @@ package railsproxy import ( - "context" - "errors" "fmt" "net/url" "strings" - "git.curoverse.com/arvados.git/lib/controller/rpc" - "git.curoverse.com/arvados.git/sdk/go/arvados" - "git.curoverse.com/arvados.git/sdk/go/auth" + "git.arvados.org/arvados.git/lib/controller/rpc" + "git.arvados.org/arvados.git/sdk/go/arvados" ) -// For now, FindRailsAPI always uses the rails API running on this -// node. +// FindRailsAPI always uses the rails API running on this node, for now. func FindRailsAPI(cluster *arvados.Cluster) (*url.URL, bool, error) { var best *url.URL for target := range cluster.Services.RailsAPI.InternalURLs { @@ -40,13 +36,5 @@ func NewConn(cluster *arvados.Cluster) *rpc.Conn { if err != nil { panic(err) } - return rpc.NewConn(cluster.ClusterID, url, insecure, provideIncomingToken) -} - -func provideIncomingToken(ctx context.Context) ([]string, error) { - incoming, ok := auth.FromContext(ctx) - if !ok { - return nil, errors.New("no token provided") - } - return incoming.Tokens, nil + return rpc.NewConn(cluster.ClusterID, url, insecure, rpc.PassthroughTokenProvider) }