X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/aea4b0cd7553dfb27c3e6c448fcad349284d6cf4..c005c5ab76492b844e84d1c66f75797bd98d0996:/apps/workbench/app/controllers/collections_controller.rb diff --git a/apps/workbench/app/controllers/collections_controller.rb b/apps/workbench/app/controllers/collections_controller.rb index 9179848a4d..010cd220e7 100644 --- a/apps/workbench/app/controllers/collections_controller.rb +++ b/apps/workbench/app/controllers/collections_controller.rb @@ -1,10 +1,11 @@ class CollectionsController < ApplicationController - skip_around_filter(:thread_with_mandatory_api_token, + skip_around_filter(:require_thread_api_token, only: [:show_file, :show_file_links]) skip_before_filter(:find_object_by_uuid, only: [:provenance, :show_file, :show_file_links]) # We depend on show_file to display the user agreement: - skip_before_filter :check_user_agreements, only: [:show_file] + skip_before_filter :check_user_agreements, only: :show_file + skip_before_filter :check_user_profile, only: :show_file RELATION_LIMIT = 5 @@ -43,24 +44,30 @@ class CollectionsController < ApplicationController end def choose - params[:limit] ||= 40 + # Find collections using default find_objects logic, then search for name + # links, and preload any other links connected to the collections that are + # found. + # Name links will be obsolete when issue #3036 is merged, + # at which point this entire custom #choose function can probably be + # eliminated. - filter = [['link_class','=','name'], - ['head_uuid','is_a','arvados#collection']] + params[:limit] ||= 40 - if params[:project_uuid] and !params[:project_uuid].empty? - filter << ['tail_uuid', '=', params[:project_uuid]] - end + find_objects_for_index + @collections = @objects - @objects = Link.filter(filter) + @filters += [['link_class','=','name'], + ['head_uuid','is_a','arvados#collection']] + @objects = Link find_objects_for_index - @next_page_href = (next_page_offset and - url_for(offset: next_page_offset, partial: true)) + @name_links = @objects @objects = Collection. filter([['uuid','in',@name_links.collect(&:head_uuid)]]) + + preload_links_for_objects (@collections.to_a + @objects.to_a) super end @@ -118,7 +125,7 @@ class CollectionsController < ApplicationController def show_file_links Thread.current[:reader_tokens] = [params[:reader_token]] - find_object_by_uuid + return if false.equal?(find_object_by_uuid) render layout: false end @@ -165,12 +172,20 @@ class CollectionsController < ApplicationController Job.limit(RELATION_LIMIT).where(conds) .results.sort_by { |j| j.finished_at || j.created_at } end - @output_of = jobs_with.call(output: @object.uuid) - @log_of = jobs_with.call(log: @object.uuid) + @output_of = jobs_with.call(output: @object.portable_data_hash) + @log_of = jobs_with.call(log: @object.portable_data_hash) @project_links = Link.limit(RELATION_LIMIT).order("modified_at DESC") .where(head_uuid: @object.uuid, link_class: 'name').results project_hash = Group.where(uuid: @project_links.map(&:tail_uuid)).to_hash @projects = project_hash.values + + if @object.uuid.match /[0-9a-f]{32}/ + @same_pdh = Collection.filter([["portable_data_hash", "=", @object.portable_data_hash]]) + owners = @same_pdh.map {|s| s.owner_uuid}.to_a + preload_objects_for_dataclass Group, owners + preload_objects_for_dataclass User, owners + end + @permissions = Link.limit(RELATION_LIMIT).order("modified_at DESC") .where(head_uuid: @object.uuid, link_class: 'permission', name: 'can_read').results @@ -238,18 +253,14 @@ class CollectionsController < ApplicationController # error we encounter, and return nil. most_specific_error = [401] token_list.each do |api_token| - using_specific_api_token(api_token) do - begin + begin + using_specific_api_token(api_token) do yield return api_token - rescue ArvadosApiClient::NotLoggedInException => error - status = 401 - rescue => error - status = (error.message =~ /\[API: (\d+)\]$/) ? $1.to_i : nil - raise unless [401, 403, 404].include?(status) end - if status >= most_specific_error.first - most_specific_error = [status, error] + rescue ArvadosApiClient::ApiError => error + if error.api_status >= most_specific_error.first + most_specific_error = [error.api_status, error] end end end