X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/96326e988977cd5147dcd4962d6c02bb43e7b330..a95f899d7ac84f29b3d019aa410d265bb40833e5:/apps/workbench/app/models/arvados_api_client.rb diff --git a/apps/workbench/app/models/arvados_api_client.rb b/apps/workbench/app/models/arvados_api_client.rb index 904673fe28..13d4a24c69 100644 --- a/apps/workbench/app/models/arvados_api_client.rb +++ b/apps/workbench/app/models/arvados_api_client.rb @@ -89,7 +89,13 @@ class ArvadosApiClient @api_client.ssl_config.verify_mode = OpenSSL::SSL::VERIFY_NONE else # Use system CA certificates - @api_client.ssl_config.add_trust_ca('/etc/ssl/certs') + ["/etc/ssl/certs/ca-certificates.crt", + "/etc/pki/tls/certs/ca-bundle.crt"] + .select { |ca_path| File.readable?(ca_path) } + .each { |ca_path| @api_client.ssl_config.add_trust_ca(ca_path) } + end + if Rails.configuration.api_response_compression + @api_client.transparent_gzip_decompression = true end end end @@ -101,8 +107,13 @@ class ArvadosApiClient url.sub! '/arvados/v1/../../', '/' query = { - 'api_token' => tokens[:arvados_api_token] || Thread.current[:arvados_api_token] || '', - 'reader_tokens' => (tokens[:reader_tokens] || Thread.current[:reader_tokens] || []).to_json, + 'api_token' => (tokens[:arvados_api_token] || + Thread.current[:arvados_api_token] || + ''), + 'reader_tokens' => ((tokens[:reader_tokens] || + Thread.current[:reader_tokens] || + []) + + [Rails.configuration.anonymous_user_token]).to_json, } if !data.nil? data.each do |k,v| @@ -113,25 +124,20 @@ class ArvadosApiClient elsif v == false query[k] = 0 else - query[k] = JSON.dump(v) + query[k] = Oj.dump(v, mode: :compat) end end else query["_method"] = "GET" end - # Use anonymous token for GET requests when no api_token is available - if ((query["_method"] == "GET") or (query[:_method] == "GET")) && query["api_token"].empty? - query['api_token'] = Rails.configuration.anonymous_user_token - end - if @@profiling_enabled query["_profile"] = "true" end header = {"Accept" => "application/json"} - profile_checkpoint { "Prepare request #{url} #{query[:uuid]} #{query[:where]} #{query[:filters]} #{query[:order]}" } + profile_checkpoint { "Prepare request #{query["_method"] or "POST"} #{url} #{query[:uuid]} #{query.inspect[0,256]}" } msg = @client_mtx.synchronize do begin @api_client.post(url, query, header: header) @@ -140,6 +146,12 @@ class ArvadosApiClient end end profile_checkpoint 'API transaction' + if @@profiling_enabled + if msg.headers['X-Runtime'] + Rails.logger.info "API server: #{msg.headers['X-Runtime']} runtime reported" + end + Rails.logger.info "Content-Encoding #{msg.headers['Content-Encoding'].inspect}, Content-Length #{msg.headers['Content-Length'].inspect}, actual content size #{msg.content.size}" + end begin resp = Oj.load(msg.content, :symbol_keys => true)