services/api/app/middlewares/arvados_api_token.rb

   1 # Copyright (C) The Arvados Authors. All rights reserved.
   2 #
   3 # SPDX-License-Identifier: AGPL-3.0
   4
   5 # Perform api_token checking very early in the request process.  We want to do
   6 # this in the Rack stack instead of in ApplicationController because
   7 # websockets needs access to authentication but doesn't use any of the rails
   8 # active dispatch infrastructure.
   9 class ArvadosApiToken
  10
  11   # Create a new ArvadosApiToken handler
  12   # +app+  The next layer of the Rack stack.
  13   def initialize(app = nil, options = nil)
  14     @app = app.respond_to?(:call) ? app : nil
  15   end
  16
  17   def call env
  18     request = Rack::Request.new(env)
  19     params = request.params
  20     remote_ip = env["action_dispatch.remote_ip"]
  21
  22     Thread.current[:request_starttime] = Time.now
  23
  24     remote = false
  25     reader_tokens = nil
  26     if params["remote"] && request.get? && (
  27          request.path.start_with?('/arvados/v1/groups') ||
  28          request.path.start_with?('/arvados/v1/users/current'))
  29       # Request from a remote API server, asking to validate a salted
  30       # token.
  31       remote = params["remote"]
  32     elsif request.get? || params["_method"] == 'GET'
  33       reader_tokens = params["reader_tokens"]
  34       if reader_tokens.is_a? String
  35         reader_tokens = SafeJSON.load(reader_tokens)
  36       end
  37     end
  38
  39     # Set current_user etc. based on the primary session token if a
  40     # valid one is present. Otherwise, use the first valid token in
  41     # reader_tokens.
  42     auth = nil
  43     [params["api_token"],
  44      params["oauth_token"],
  45      env["HTTP_AUTHORIZATION"].andand.match(/(OAuth2|Bearer) ([-\/a-zA-Z0-9]+)/).andand[2],
  46      *reader_tokens,
  47     ].each do |supplied|
  48       next if !supplied
  49       try_auth = ApiClientAuthorization.
  50                  validate(token: supplied, remote: remote)
  51       if try_auth.andand.user
  52         auth = try_auth
  53         break
  54       end
  55     end
  56
  57     Thread.current[:api_client_ip_address] = remote_ip
  58     Thread.current[:api_client_authorization] = auth
  59     Thread.current[:api_client_uuid] = auth.andand.api_client.andand.uuid
  60     Thread.current[:api_client] = auth.andand.api_client
  61     Thread.current[:user] = auth.andand.user
  62
  63     @app.call env if @app
  64   end
  65 end