X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e2bfcb8bc5f030828754215aff1955f5ab4bd45a..710399e0355ff8ed016a9d3c830730af2e228ad5:/services/api/app/controllers/arvados/v1/collections_controller.rb diff --git a/services/api/app/controllers/arvados/v1/collections_controller.rb b/services/api/app/controllers/arvados/v1/collections_controller.rb index e96fa58dff..6e77c12a1d 100644 --- a/services/api/app/controllers/arvados/v1/collections_controller.rb +++ b/services/api/app/controllers/arvados/v1/collections_controller.rb @@ -1,8 +1,21 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 + require "arvados/keep" +require "trashable" class Arvados::V1::CollectionsController < ApplicationController - def self.limit_index_columns_read - ["manifest_text"] + include DbCurrentTime + include TrashableController + + def self._index_requires_parameters + (super rescue {}). + merge({ + include_trash: { + type: 'boolean', required: false, description: "Include collections whose is_trashed attribute is true." + }, + }) end def create @@ -13,30 +26,52 @@ class Arvados::V1::CollectionsController < ApplicationController super end + def find_objects_for_index + if params[:include_trash] || ['destroy', 'trash', 'untrash'].include?(action_name) + @objects = Collection.readable_by(*@read_users, {include_trash: true}) + end + super + end + def find_object_by_uuid if loc = Keep::Locator.parse(params[:id]) loc.strip_hints! - if c = Collection.readable_by(*@read_users).where({ portable_data_hash: loc.to_s }).limit(1).first + + # It matters which Collection object we pick because we use it to get signed_manifest_text, + # the value of which is affected by the value of trash_at. + # + # From postgres doc: "By default, null values sort as if larger than any non-null + # value; that is, NULLS FIRST is the default for DESC order, and + # NULLS LAST otherwise." + # + # "trash_at desc" sorts null first, then latest to earliest, so + # it will select the Collection object with the longest + # available lifetime. + + if c = Collection.readable_by(*@read_users).where({ portable_data_hash: loc.to_s }).order("trash_at desc").limit(1).first @object = { uuid: c.portable_data_hash, portable_data_hash: c.portable_data_hash, manifest_text: c.signed_manifest_text, } end + true else super end - true end def show if @object.is_a? Collection + # Omit unsigned_manifest_text + @select ||= model_class.selectable_attributes - ["unsigned_manifest_text"] super else send_json @object end end + def find_collections(visited, sp, &b) case sp when ArvadosModel @@ -125,9 +160,9 @@ class Arvados::V1::CollectionsController < ApplicationController visited[uuid] = job.as_api_response if direction == :search_up # Follow upstream collections referenced in the script parameters - find_collections(visited, job) do |hash, uuid| + find_collections(visited, job) do |hash, col_uuid| search_edges(visited, hash, :search_up) if hash - search_edges(visited, uuid, :search_up) if uuid + search_edges(visited, col_uuid, :search_up) if col_uuid end elsif direction == :search_down # Follow downstream job output @@ -182,10 +217,10 @@ class Arvados::V1::CollectionsController < ApplicationController protected def load_limit_offset_order_params *args + super if action_name == 'index' # Omit manifest_text and unsigned_manifest_text from index results unless expressly selected. - @select ||= model_class.selectable_attributes - ["manifest_text","unsigned_manifest_text"] + @select ||= model_class.selectable_attributes - ["manifest_text", "unsigned_manifest_text"] end - super end end