X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e2bfcb8bc5f030828754215aff1955f5ab4bd45a..0f644e242ef37c911ad3dc25aca8135c339de349:/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..87d88fe4f5 100644 --- a/services/api/app/controllers/arvados/v1/collections_controller.rb +++ b/services/api/app/controllers/arvados/v1/collections_controller.rb @@ -1,10 +1,22 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 + require "arvados/keep" class Arvados::V1::CollectionsController < ApplicationController - def self.limit_index_columns_read - ["manifest_text"] + include DbCurrentTime + + 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 if resource_attrs[:uuid] and (loc = Keep::Locator.parse(resource_attrs[:uuid])) resource_attrs[:portable_data_hash] = loc.to_s @@ -13,6 +25,13 @@ class Arvados::V1::CollectionsController < ApplicationController super end + def find_objects_for_index + if params[:include_trash] || ['destroy', 'trash', 'untrash'].include?(action_name) + @objects = Collection.unscoped.readable_by(*@read_users) + end + super + end + def find_object_by_uuid if loc = Keep::Locator.parse(params[:id]) loc.strip_hints! @@ -23,20 +42,56 @@ class Arvados::V1::CollectionsController < ApplicationController 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 destroy + if !@object.is_trashed + @object.update_attributes!(trash_at: db_current_time) + end + earliest_delete = (@object.trash_at + + Rails.configuration.blob_signature_ttl.seconds) + if @object.delete_at > earliest_delete + @object.update_attributes!(delete_at: earliest_delete) + end + show + end + + def trash + if !@object.is_trashed + @object.update_attributes!(trash_at: db_current_time) + end + show + end + + def untrash + if @object.is_trashed + @object.trash_at = nil + + if params[:ensure_unique_name] + @object.save_with_unique_name! + else + @object.save! + end + else + raise InvalidStateTransitionError + end + show + end + def find_collections(visited, sp, &b) case sp when ArvadosModel @@ -125,9 +180,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 +237,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