131 lines
4.3 KiB
Ruby
131 lines
4.3 KiB
Ruby
# == Schema Information
|
|
#
|
|
# Table name: notifications
|
|
#
|
|
# id :bigint not null, primary key
|
|
# notification_type :integer not null
|
|
# primary_actor_type :string not null
|
|
# read_at :datetime
|
|
# secondary_actor_type :string
|
|
# created_at :datetime not null
|
|
# updated_at :datetime not null
|
|
# account_id :bigint not null
|
|
# primary_actor_id :bigint not null
|
|
# secondary_actor_id :bigint
|
|
# user_id :bigint not null
|
|
#
|
|
# Indexes
|
|
#
|
|
# index_notifications_on_account_id (account_id)
|
|
# index_notifications_on_user_id (user_id)
|
|
# uniq_primary_actor_per_account_notifications (primary_actor_type,primary_actor_id)
|
|
# uniq_secondary_actor_per_account_notifications (secondary_actor_type,secondary_actor_id)
|
|
#
|
|
|
|
class Notification < ApplicationRecord
|
|
include MessageFormatHelper
|
|
belongs_to :account
|
|
belongs_to :user
|
|
|
|
belongs_to :primary_actor, polymorphic: true
|
|
belongs_to :secondary_actor, polymorphic: true, optional: true
|
|
|
|
NOTIFICATION_TYPES = {
|
|
conversation_creation: 1,
|
|
conversation_assignment: 2,
|
|
assigned_conversation_new_message: 3,
|
|
conversation_mention: 4
|
|
}.freeze
|
|
|
|
enum notification_type: NOTIFICATION_TYPES
|
|
|
|
after_create_commit :process_notification_delivery, :dispatch_create_event
|
|
|
|
default_scope { order(id: :desc) }
|
|
|
|
PRIMARY_ACTORS = ['Conversation'].freeze
|
|
|
|
def push_event_data
|
|
# Secondary actor could be nil for cases like system assigning conversation
|
|
{
|
|
id: id,
|
|
notification_type: notification_type,
|
|
primary_actor_type: primary_actor_type,
|
|
primary_actor_id: primary_actor_id,
|
|
primary_actor: primary_actor_data,
|
|
read_at: read_at,
|
|
secondary_actor: secondary_actor&.push_event_data,
|
|
user: user&.push_event_data,
|
|
created_at: created_at.to_i,
|
|
account_id: account_id,
|
|
push_message_title: push_message_title
|
|
}
|
|
end
|
|
|
|
def primary_actor_data
|
|
if %w[assigned_conversation_new_message conversation_mention].include? notification_type
|
|
{
|
|
id: primary_actor.conversation.push_event_data[:id],
|
|
meta: primary_actor.conversation.push_event_data[:meta]
|
|
}
|
|
else
|
|
{
|
|
id: primary_actor.push_event_data[:id],
|
|
meta: primary_actor.push_event_data[:meta]
|
|
}
|
|
end
|
|
end
|
|
|
|
def fcm_push_data
|
|
{
|
|
id: id,
|
|
notification_type: notification_type,
|
|
primary_actor_id: primary_actor_id,
|
|
primary_actor_type: primary_actor_type,
|
|
primary_actor: primary_actor.push_event_data.with_indifferent_access.slice('conversation_id', 'id')
|
|
}
|
|
end
|
|
|
|
# TODO: move to a data presenter
|
|
# rubocop:disable Metrics/CyclomaticComplexity
|
|
def push_message_title
|
|
case notification_type
|
|
when 'conversation_creation'
|
|
I18n.t('notifications.notification_title.conversation_creation', display_id: primary_actor.display_id, inbox_name: primary_actor.inbox.name)
|
|
when 'conversation_assignment'
|
|
I18n.t('notifications.notification_title.conversation_assignment', display_id: primary_actor.display_id)
|
|
when 'assigned_conversation_new_message'
|
|
I18n.t(
|
|
'notifications.notification_title.assigned_conversation_new_message',
|
|
display_id: conversation.display_id,
|
|
content: primary_actor&.content&.truncate_words(10)
|
|
)
|
|
when 'conversation_mention'
|
|
"[##{conversation&.display_id}] #{transform_user_mention_content primary_actor&.content}"
|
|
else
|
|
''
|
|
end
|
|
end
|
|
# rubocop:enable Metrics/CyclomaticComplexity
|
|
|
|
def conversation
|
|
return primary_actor.conversation if %w[assigned_conversation_new_message conversation_mention].include? notification_type
|
|
|
|
primary_actor
|
|
end
|
|
|
|
private
|
|
|
|
def process_notification_delivery
|
|
Notification::PushNotificationJob.perform_later(self)
|
|
|
|
# Should we do something about the case where user subscribed to both push and email ?
|
|
# In future, we could probably add condition here to enqueue the job for 30 seconds later
|
|
# 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
|