Merge branch 'master' into origin-2608-websocket-event-bus-alt2
[arvados.git] / services / api / app / models / arvados_model.rb
index dbb807c0b6b4005193babfef0a93481f1f75ef56..c87a909e0643b932e2340264416f38b70e0e992c 100644 (file)
@@ -79,14 +79,44 @@ class ArvadosModel < ActiveRecord::Base
     sanitized_uuid_list = uuid_list.
       collect { |uuid| sanitize(uuid) }.join(', ')
     or_references_me = ''
-    if self == Link and user
+
+    if self == User
+      or_row_is_me = "OR (#{table_name}.uuid=#{sanitize user.uuid})"
+    end
+
+    if self == Link
       or_references_me = "OR (#{table_name}.link_class in (#{sanitize 'permission'}, #{sanitize 'resources'}) AND #{sanitize user.uuid} IN (#{table_name}.head_uuid, #{table_name}.tail_uuid))"
     end
-    joins("LEFT JOIN links permissions ON permissions.head_uuid in (#{table_name}.owner_uuid, #{table_name}.uuid) AND permissions.tail_uuid in (#{sanitized_uuid_list}) AND permissions.link_class='permission'").
-      where("?=? OR #{table_name}.owner_uuid in (?) OR #{table_name}.uuid=? OR permissions.head_uuid IS NOT NULL #{or_references_me}",
-            true, user.is_admin,
-            uuid_list,
-            user.uuid)
+
+    if self == Log
+      or_object_uuid = ", #{table_name}.object_uuid"
+      or_object_owner = "OR (#{table_name}.object_owner_uuid in (#{sanitized_uuid_list}))"
+    end
+
+    # Link head points to this row, or to the owner of this row (the thing to be read)
+    # (or the object described by this row, for logs table only)
+    # Link tail originates from this user, or a group that is readable by this
+    # user (the identity with authorization to read)
+    # Link is any permission link ('write' and 'manage' implicitly include 'read')
+    # The existence of such a link is tested in the where clause as permissions.head_uuid IS NOT NULL.
+    # or
+    # User is admin
+    # or
+    # This row is owned by this user, or owned by a group readable by this user
+    # or
+    # This is the users table
+    # This row uuid is equal this user uuid
+    # or
+    # This is the links table
+    # This row is a permission link
+    # The current user is referenced in either the head or tail of the link
+    # or
+    # This is the logs table
+    # This object described by this row is owned by this user, or owned by a group readable by this user
+
+    joins("LEFT JOIN links permissions ON permissions.head_uuid in (#{table_name}.owner_uuid, #{table_name}.uuid #{or_object_uuid}) AND permissions.tail_uuid in (#{sanitized_uuid_list}) AND permissions.link_class='permission'").
+      where("permissions.head_uuid IS NOT NULL OR ?=? OR #{table_name}.owner_uuid in (?) #{or_row_is_me} #{or_references_me} #{or_object_owner}",
+            user.is_admin, true, uuid_list).uniq
   end
 
   def logged_attributes
@@ -154,7 +184,7 @@ class ArvadosModel < ActiveRecord::Base
   end
 
   def update_modified_by_fields
-    self.created_at ||= Time.now
+    self.updated_at = Time.now
     self.owner_uuid ||= current_default_owner if self.respond_to? :owner_uuid=
     self.modified_at = Time.now
     self.modified_by_user_uuid = current_user ? current_user.uuid : nil
@@ -185,6 +215,10 @@ class ArvadosModel < ActiveRecord::Base
     %w(modified_by_client_uuid)
   end
 
+  def skip_uuid_existence_check
+    []
+  end
+
   def normalize_collection_uuids
     foreign_key_attributes.each do |attr|
       attr_value = send attr
@@ -223,11 +257,18 @@ class ArvadosModel < ActiveRecord::Base
 
     foreign_key_attributes.each do |attr|
       if new_record? or send (attr + "_changed?")
+        next if skip_uuid_existence_check.include? attr
         attr_value = send attr
-        r = ArvadosModel::resource_class_for_uuid attr_value if attr_value
-        r = r.readable_by(current_user) if r and not skip_uuid_read_permission_check.include? attr
-        if r and r.where(uuid: attr_value).count == 0 and not specials.include? attr_value
-          errors.add(attr, "'#{attr_value}' not found")
+        next if specials.include? attr_value
+        if attr_value
+          if (r = ArvadosModel::resource_class_for_uuid attr_value)
+            unless skip_uuid_read_permission_check.include? attr
+              r = r.readable_by(current_user)
+            end
+            if r.where(uuid: attr_value).count == 0
+              errors.add(attr, "'#{attr_value}' not found")
+            end
+          end
         end
       end
     end
@@ -284,6 +325,7 @@ class ArvadosModel < ActiveRecord::Base
     log = Log.new(event_type: event_type).fill_object(self)
     yield log
     log.save!
+    connection.execute "NOTIFY logs, '#{log.id}'"
     log_start_state
   end