X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0df5f0feeced5bff0adfb806dae2d3811257827f..797885e26f85f04123bcba751addcd415ed3db2e:/services/api/app/models/collection.rb diff --git a/services/api/app/models/collection.rb b/services/api/app/models/collection.rb index 590228b1af..775ebdb494 100644 --- a/services/api/app/models/collection.rb +++ b/services/api/app/models/collection.rb @@ -33,7 +33,7 @@ class Collection < ArvadosModel validate :past_versions_cannot_be_updated, on: :update after_validation :set_file_count_and_total_size before_save :set_file_names - around_update :manage_versioning + around_update :manage_versioning, unless: :is_past_version? api_accessible :user, extend: :common do |t| t.add :name @@ -125,7 +125,7 @@ class Collection < ArvadosModel # Signature provided, but verify_signature did not like it. logger.warn "Invalid signature on locator #{tok}" raise ArvadosModel::PermissionDeniedError - elsif Rails.configuration.permit_create_collection_with_unsigned_manifest + elsif !Rails.configuration.Collections.BlobSigning # No signature provided, but we are running in insecure mode. logger.debug "Missing signature on locator #{tok} ignored" elsif Blob.new(tok).empty? @@ -281,8 +281,11 @@ class Collection < ArvadosModel sync_past_versions if syncable_updates.any? if snapshot snapshot.attributes = self.syncable_updates - snapshot.manifest_text = snapshot.signed_manifest_text - snapshot.save + leave_modified_by_user_alone do + act_as_system_user do + snapshot.save + end + end end end end @@ -304,7 +307,7 @@ class Collection < ArvadosModel updates = self.syncable_updates Collection.where('current_version_uuid = ? AND uuid != ?', self.uuid_was, self.uuid_was).each do |c| c.attributes = updates - # Use a different validation context to skip the 'old_versions_cannot_be_updated' + # Use a different validation context to skip the 'past_versions_cannot_be_updated' # validator, as on this case it is legal to update some fields. leave_modified_by_user_alone do leave_modified_at_alone do @@ -322,10 +325,18 @@ class Collection < ArvadosModel ['uuid', 'owner_uuid', 'delete_at', 'trash_at', 'is_trashed', 'replication_desired', 'storage_classes_desired'] end + def is_past_version? + # Check for the '_was' values just in case the update operation + # includes a change on current_version_uuid or uuid. + !(new_record? || self.current_version_uuid_was == self.uuid_was) + end + def should_preserve_version? - return false unless (Rails.configuration.collection_versioning && versionable_updates?(self.changes.keys)) + return false unless (Rails.configuration.Collections.CollectionVersioning && versionable_updates?(self.changes.keys)) + + return false if self.is_trashed - idle_threshold = Rails.configuration.preserve_version_if_idle + idle_threshold = Rails.configuration.Collections.PreserveVersionIfIdle if !self.preserve_version_was && (idle_threshold < 0 || (idle_threshold > 0 && self.modified_at_was > db_current_time-idle_threshold.seconds)) @@ -371,7 +382,7 @@ class Collection < ArvadosModel return manifest_text else token = Thread.current[:token] - exp = [db_current_time.to_i + Rails.configuration.blob_signature_ttl, + exp = [db_current_time.to_i + Rails.configuration.Collections.BlobSigningTTL.to_i, trash_at].compact.map(&:to_i).min self.class.sign_manifest manifest_text, token, exp end @@ -379,7 +390,7 @@ class Collection < ArvadosModel def self.sign_manifest manifest, token, exp=nil if exp.nil? - exp = db_current_time.to_i + Rails.configuration.blob_signature_ttl + exp = db_current_time.to_i + Rails.configuration.Collections.BlobSigningTTL.to_i end signing_opts = { api_token: token, @@ -489,7 +500,7 @@ class Collection < ArvadosModel # # If filter_compatible_format is true (the default), only return image # collections which are support by the installation as indicated by - # Rails.configuration.docker_image_formats. Will follow + # Rails.configuration.Containers.SupportedDockerImageFormats. Will follow # 'docker_image_migration' links if search_term resolves to an incompatible # image, but an equivalent compatible image is available. def self.find_all_for_docker_image(search_term, search_tag=nil, readers=nil, filter_compatible_format: true) @@ -500,15 +511,17 @@ class Collection < ArvadosModel joins("JOIN collections ON links.head_uuid = collections.uuid"). order("links.created_at DESC") - if (Rails.configuration.docker_image_formats.include? 'v1' and - Rails.configuration.docker_image_formats.include? 'v2') or filter_compatible_format == false + docker_image_formats = Rails.configuration.Containers.SupportedDockerImageFormats + + if (docker_image_formats.include? 'v1' and + docker_image_formats.include? 'v2') or filter_compatible_format == false pattern = /^(sha256:)?[0-9A-Fa-f]{64}\.tar$/ - elsif Rails.configuration.docker_image_formats.include? 'v2' + elsif docker_image_formats.include? 'v2' pattern = /^(sha256:)[0-9A-Fa-f]{64}\.tar$/ - elsif Rails.configuration.docker_image_formats.include? 'v1' + elsif docker_image_formats.include? 'v1' pattern = /^[0-9A-Fa-f]{64}\.tar$/ else - raise "Unrecognized configuration for docker_image_formats #{Rails.configuration.docker_image_formats}" + raise "Unrecognized configuration for docker_image_formats #{docker_image_formats}" end # If the search term is a Collection locator that contains one file @@ -516,7 +529,9 @@ class Collection < ArvadosModel if loc = Keep::Locator.parse(search_term) loc.strip_hints! coll_match = readable_by(*readers).where(portable_data_hash: loc.to_s).limit(1) - if coll_match.any? or Rails.configuration.remote_hosts.length == 0 + rc = Rails.configuration.RemoteClusters.select{ |k| + k != :"*" && k != Rails.configuration.ClusterID} + if coll_match.any? or rc.length == 0 return get_compatible_images(readers, pattern, coll_match) else # Allow bare pdh that doesn't exist in the local database so @@ -646,9 +661,7 @@ class Collection < ArvadosModel end def past_versions_cannot_be_updated - # We check for the '_was' values just in case the update operation - # includes a change on current_version_uuid or uuid. - if current_version_uuid_was != uuid_was + if is_past_version? errors.add(:base, "past versions cannot be updated") false end @@ -656,7 +669,7 @@ class Collection < ArvadosModel def versioning_metadata_updates valid = true - if (current_version_uuid_was == uuid_was) && current_version_uuid_changed? + if !is_past_version? && current_version_uuid_changed? errors.add(:current_version_uuid, "cannot be updated") valid = false end