feat: Notification action cable event (#4154)

app/listeners/action_cable_listener.rb

@@ -1,6 +1,12 @@
 class ActionCableListener < BaseListener
   include Events::Types
 
+  def notification_created(event)
+    notification, account = extract_notification_and_account(event)
+    tokens = [event.data[:notification].user.pubsub_token]
+    broadcast(account, tokens, NOTIFICATION_CREATED, notification.push_event_data)
+  end
+
   def message_created(event)
     message, account = extract_message_and_account(event)
     conversation = message.conversation

app/listeners/base_listener.rb

@@ -6,6 +6,11 @@ class BaseListener
     [conversation, conversation.account]
   end
 
+  def extract_notification_and_account(event)
+    notification = event.data[:notification]
+    [notification, notification.account]
+  end
+
   def extract_message_and_account(event)
     message = event.data[:message]
     [message, message.account]

app/models/notification.rb

@@ -39,7 +39,8 @@ class Notification < ApplicationRecord
 
   enum notification_type: NOTIFICATION_TYPES
 
-  after_create_commit :process_notification_delivery
+  after_create_commit :process_notification_delivery, :dispatch_create_event
+
   default_scope { order(id: :desc) }
 
   PRIMARY_ACTORS = ['Conversation'].freeze
@@ -108,4 +109,8 @@ class Notification < ApplicationRecord
     # when push enabled and then check in email job whether notification has been read already.
     Notification::EmailNotificationJob.perform_later(self)
   end
+
+  def dispatch_create_event
+    Rails.configuration.dispatcher.dispatch(NOTIFICATION_CREATED, Time.zone.now, notification: self)
+  end
 end