Merge pull request #17835 from skateman/generic-task-notifications

Create generic task notifications

app/models/mixins/notification_mixin.rb

@@ -0,0 +1,25 @@
+module NotificationMixin
+  extend ActiveSupport::Concern
+
+  def notify_task_start(message, user_id, subject = self)
+    notify_task_emit(:generic_task_start, message, user_id, subject)
+  end
+
+  def notify_task_finish(message, user_id, subject = self)
+    notify_task_emit(:generic_task_finish, message, user_id, subject)
+  end
+
+  def notify_task_fail(message, user_id, subject = self)
+    notify_task_emit(:generic_task_fail, message, user_id, subject)
+  end
+
+  def notify_task_update(message, user_id, subject = self)
+    notify_task_emit(:generic_task_update, message, user_id, subject)
+  end
+
+  private
+
+  def notify_task_emit(type, message, user_id, subject)
+    Notification.create(:type => type, :subject => subject, :user_id => user_id, :options => {:message => message})
+  end
+end

db/fixtures/notification_types.yml

@@ -289,3 +289,23 @@
   :expires_in: 24.hours
   :level: error
   :audience: global
+- :name: generic_task_start
+  :message: '%{message}'
+  :expires_in: 7.days
+  :level: success
+  :audience: user
+- :name: generic_task_finish
+  :message: '%{message}'
+  :expires_in: 7.days
+  :level: success
+  :audience: user
+- :name: generic_task_fail
+  :message: '%{message}'
+  :expires_in: 7.days
+  :level: error
+  :audience: user
+- :name: generic_task_update
+  :message: '%{message}'
+  :expires_in: 7.days
+  :level: success
+  :audience: user