X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/317952f20cb0d979d35b66bc735d02c2ea69050e..5a3b04f7177afe202ab4f8776b5ca2567b4fdabe:/services/api/app/models/arvados_model.rb diff --git a/services/api/app/models/arvados_model.rb b/services/api/app/models/arvados_model.rb index 52fe56d5a2..1138bd2b9b 100644 --- a/services/api/app/models/arvados_model.rb +++ b/services/api/app/models/arvados_model.rb @@ -21,6 +21,7 @@ class ArvadosModel < ActiveRecord::Base after_update :log_update after_destroy :log_destroy after_find :convert_serialized_symbols_to_strings + before_validation :normalize_collection_uuids validate :ensure_serialized_attribute_type validate :ensure_valid_uuids @@ -67,16 +68,47 @@ class ArvadosModel < ActiveRecord::Base self.columns.select { |col| col.name == attr.to_s }.first end - # Return nil if current user is not allowed to see the list of - # writers. Otherwise, return a list of user_ and group_uuids with - # write permission. (If not returning nil, current_user is always in - # the list because can_manage permission is needed to see the list - # of writers.) + def self.attributes_required_columns + # This method returns a hash. Each key is the name of an API attribute, + # and it's mapped to a list of database columns that must be fetched + # to generate that attribute. + # This implementation generates a simple map of attributes to + # matching column names. Subclasses can override this method + # to specify that method-backed API attributes need to fetch + # specific columns from the database. + all_columns = columns.map(&:name) + api_column_map = Hash.new { |hash, key| hash[key] = [] } + methods.grep(/^api_accessible_\w+$/).each do |method_name| + next if method_name == :api_accessible_attributes + send(method_name).each_pair do |api_attr_name, col_name| + col_name = col_name.to_s + if all_columns.include?(col_name) + api_column_map[api_attr_name.to_s] |= [col_name] + end + end + end + api_column_map + end + + # If current user can manage the object, return an array of uuids of + # users and groups that have permission to write the object. The + # first two elements are always [self.owner_uuid, current user's + # uuid]. + # + # If current user can write but not manage the object, return + # [self.owner_uuid, current user's uuid]. + # + # If current user cannot write this object, just return + # [self.owner_uuid]. def writable_by unless (owner_uuid == current_user.uuid or current_user.is_admin or - current_user.groups_i_can(:manage).index(owner_uuid)) - return nil + (current_user.groups_i_can(:manage) & [uuid, owner_uuid]).any?) + if current_user.groups_i_can(:write).index(uuid) + return [owner_uuid, current_user.uuid] + else + return [owner_uuid] + end end [owner_uuid, current_user.uuid] + permissions.collect do |p| if ['can_write', 'can_manage'].index p.name @@ -101,61 +133,65 @@ class ArvadosModel < ActiveRecord::Base end # Check if any of the users are admin. If so, we're done. - if users_list.select { |u| u.is_admin }.empty? + if users_list.select { |u| u.is_admin }.any? + return self + end + + # Collect the uuids for each user and any groups readable by each user. + user_uuids = users_list.map { |u| u.uuid } + uuid_list = user_uuids + users_list.flat_map { |u| u.groups_i_can(:read) } + sql_conds = [] + sql_params = [] + sql_table = kwargs.fetch(:table_name, table_name) + or_object_uuid = '' + + # This row is owned by a member of users_list, or owned by a group + # readable by a member of users_list + # or + # This row uuid is the uuid of a member of users_list + # or + # A permission link exists ('write' and 'manage' implicitly include + # 'read') from a member of users_list, or a group readable by users_list, + # to this row, or to the owner of this row (see join() below). + sql_conds += ["#{sql_table}.uuid in (?)"] + sql_params += [user_uuids] + + if uuid_list.any? + sql_conds += ["#{sql_table}.owner_uuid in (?)"] + sql_params += [uuid_list] - # Collect the uuids for each user and any groups readable by each user. - user_uuids = users_list.map { |u| u.uuid } - uuid_list = user_uuids + users_list.flat_map { |u| u.groups_i_can(:read) } sanitized_uuid_list = uuid_list. collect { |uuid| sanitize(uuid) }.join(', ') - sql_conds = [] - sql_params = [] - sql_table = kwargs.fetch(:table_name, table_name) - or_object_uuid = '' - - # This row is owned by a member of users_list, or owned by a group - # readable by a member of users_list - # or - # This row uuid is the uuid of a member of users_list - # or - # A permission link exists ('write' and 'manage' implicitly include - # 'read') from a member of users_list, or a group readable by users_list, - # to this row, or to the owner of this row (see join() below). permitted_uuids = "(SELECT head_uuid FROM links WHERE link_class='permission' AND tail_uuid IN (#{sanitized_uuid_list}))" + sql_conds += ["#{sql_table}.uuid IN #{permitted_uuids}"] + end - sql_conds += ["#{sql_table}.owner_uuid in (?)", - "#{sql_table}.uuid in (?)", - "#{sql_table}.uuid IN #{permitted_uuids}"] - sql_params += [uuid_list, user_uuids] - - if sql_table == "links" and users_list.any? - # This row is a 'permission' or 'resources' link class - # The uuid for a member of users_list is referenced in either the head - # or tail of the link - sql_conds += ["(#{sql_table}.link_class in (#{sanitize 'permission'}, #{sanitize 'resources'}) AND (#{sql_table}.head_uuid IN (?) OR #{sql_table}.tail_uuid IN (?)))"] - sql_params += [user_uuids, user_uuids] - end - - if sql_table == "logs" and users_list.any? - # Link head points to the object described by this row - sql_conds += ["#{sql_table}.object_uuid IN #{permitted_uuids}"] + if sql_table == "links" and users_list.any? + # This row is a 'permission' or 'resources' link class + # The uuid for a member of users_list is referenced in either the head + # or tail of the link + sql_conds += ["(#{sql_table}.link_class in (#{sanitize 'permission'}, #{sanitize 'resources'}) AND (#{sql_table}.head_uuid IN (?) OR #{sql_table}.tail_uuid IN (?)))"] + sql_params += [user_uuids, user_uuids] + end - # This object described by this row is owned by this user, or owned by a group readable by this user - sql_conds += ["#{sql_table}.object_owner_uuid in (?)"] - sql_params += [uuid_list] - end + if sql_table == "logs" and users_list.any? + # Link head points to the object described by this row + sql_conds += ["#{sql_table}.object_uuid IN #{permitted_uuids}"] - # Link head points to this row, or to the owner of this row (the thing to be read) - # - # Link tail originates from this user, or a group that is readable by this - # user (the identity with authorization to read) - # - # Link class is 'permission' ('write' and 'manage' implicitly include 'read') - where(sql_conds.join(' OR '), *sql_params) - else - # At least one user is admin, so don't bother to apply any restrictions. - self + # This object described by this row is owned by this user, or owned by a group readable by this user + sql_conds += ["#{sql_table}.object_owner_uuid in (?)"] + sql_params += [uuid_list] end + + # Link head points to this row, or to the owner of this row (the + # thing to be read) + # + # Link tail originates from this user, or a group that is readable + # by this user (the identity with authorization to read) + # + # Link class is 'permission' ('write' and 'manage' implicitly + # include 'read') + where(sql_conds.join(' OR '), *sql_params) end def logged_attributes @@ -210,9 +246,14 @@ class ArvadosModel < ActiveRecord::Base self.owner_uuid ||= current_user.uuid end + if self.owner_uuid.nil? + errors.add :owner_uuid, "cannot be nil" + raise PermissionDeniedError + end + rsc_class = ArvadosModel::resource_class_for_uuid owner_uuid unless rsc_class == User or rsc_class == Group - errors.add :owner_uuid, "can only be set to User or Group" + errors.add :owner_uuid, "must be set to User or Group" raise PermissionDeniedError end @@ -373,6 +414,20 @@ class ArvadosModel < ActiveRecord::Base [] end + def normalize_collection_uuids + foreign_key_attributes.each do |attr| + attr_value = send attr + if attr_value.is_a? String and + attr_value.match /^[0-9a-f]{32,}(\+[@\w]+)*$/ + begin + send "#{attr}=", Collection.normalize_uuid(attr_value) + rescue + # TODO: abort instead of silently accepting unnormalizable value? + end + end + end + end + @@prefixes_hash = nil def self.uuid_prefixes unless @@prefixes_hash