X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/47e59a35d5ed9b2cdb052894d741972324058505..4a1735427d84743f6c2f3576263fdcae397cf9e9:/services/api/app/middlewares/arvados_api_token.rb diff --git a/services/api/app/middlewares/arvados_api_token.rb b/services/api/app/middlewares/arvados_api_token.rb index 4098fd72ca..18140e57fe 100644 --- a/services/api/app/middlewares/arvados_api_token.rb +++ b/services/api/app/middlewares/arvados_api_token.rb @@ -25,6 +25,7 @@ class ArvadosApiToken reader_tokens = nil if params["remote"] && request.get? && ( request.path.start_with?('/arvados/v1/groups') || + request.path.start_with?('/arvados/v1/api_client_authorizations/current') || request.path.start_with?('/arvados/v1/users/current')) # Request from a remote API server, asking to validate a salted # token. @@ -39,18 +40,37 @@ class ArvadosApiToken # Set current_user etc. based on the primary session token if a # valid one is present. Otherwise, use the first valid token in # reader_tokens. + accepted = false auth = nil + remote_errcodes = [] + remote_errmsgs = [] [params["api_token"], params["oauth_token"], - env["HTTP_AUTHORIZATION"].andand.match(/(OAuth2|Bearer) ([-\/a-zA-Z0-9]+)/).andand[2], + env["HTTP_AUTHORIZATION"].andand.match(/(OAuth2|Bearer) ([!-~]+)/).andand[2], *reader_tokens, ].each do |supplied| next if !supplied - try_auth = ApiClientAuthorization. - validate(token: supplied, remote: remote) - if try_auth.andand.user - auth = try_auth - break + begin + try_auth = ApiClientAuthorization.validate(token: supplied, remote: remote) + rescue => e + begin + remote_errcodes.append(e.http_status) + rescue NoMethodError + # The exception is an internal validation problem, not a remote error. + next + end + begin + errors = SafeJSON.load(e.res.content)["errors"] + rescue + errors = nil + end + remote_errmsgs += errors if errors.is_a?(Array) + else + if try_auth.andand.user + auth = try_auth + accepted = supplied + break + end end end @@ -58,8 +78,27 @@ class ArvadosApiToken Thread.current[:api_client_authorization] = auth Thread.current[:api_client_uuid] = auth.andand.api_client.andand.uuid Thread.current[:api_client] = auth.andand.api_client + Thread.current[:token] = accepted Thread.current[:user] = auth.andand.user - @app.call env if @app + if auth.nil? and not remote_errcodes.empty? + # If we failed to validate any tokens because of remote validation + # errors, pass those on to the client. This code is functionally very + # similar to ApplicationController#render_error, but the implementation + # is very different because we're a Rack middleware, not in + # ActionDispatch land yet. + remote_errmsgs.prepend("failed to validate remote token") + error_content = { + error_token: "%d+%08x" % [Time.now.utc.to_i, rand(16 ** 8)], + errors: remote_errmsgs, + } + [ + remote_errcodes.max, + {"Content-Type": "application/json"}, + SafeJSON.dump(error_content).html_safe, + ] + else + @app.call env if @app + end end end