49 lines
1.5 KiB
Ruby
49 lines
1.5 KiB
Ruby
|
class Messages::MentionService
|
||
|
|
pattr_initialize [:message!]
|
||
|
|
|
||
|
|
def perform
|
||
|
|
return unless valid_mention_message?(message)
|
||
|
|
|
||
|
|
validated_mentioned_ids = filter_mentioned_ids_by_inbox
|
||
|
|
return if validated_mentioned_ids.blank?
|
||
|
|
|
||
|
|
Conversations::UserMentionJob.perform_later(validated_mentioned_ids, message.conversation.id, message.account.id)
|
||
|
|
generate_notifications_for_mentions(validated_mentioned_ids)
|
||
|
|
add_mentioned_users_as_participants(validated_mentioned_ids)
|
||
|
|
end
|
||
|
|
|
||
|
|
private
|
||
|
|
|
||
|
|
def valid_mention_message?(message)
|
||
|
|
message.private? && message.content.present? && mentioned_ids.present?
|
||
|
|
end
|
||
|
|
|
||
|
|
def mentioned_ids
|
||
|
|
@mentioned_ids ||= message.content.scan(%r{\(mention://(user|team)/(\d+)/(.+?)\)}).map(&:second).uniq
|
||
|
|
end
|
||
|
|
|
||
|
|
def filter_mentioned_ids_by_inbox
|
||
|
|
inbox = message.inbox
|
||
|
|
valid_mentionable_ids = inbox.account.administrators.map(&:id) + inbox.members.map(&:id)
|
||
|
|
# Intersection of ids
|
||
|
|
mentioned_ids & valid_mentionable_ids.uniq.map(&:to_s)
|
||
|
|
end
|
||
|
|
|
||
|
|
def generate_notifications_for_mentions(validated_mentioned_ids)
|
||
|
|
validated_mentioned_ids.each do |user_id|
|
||
|
|
NotificationBuilder.new(
|
||
|
|
notification_type: 'conversation_mention',
|
||
|
|
user: User.find(user_id),
|
||
|
|
account: message.account,
|
||
|
|
primary_actor: message
|
||
|
|
).perform
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def add_mentioned_users_as_participants(validated_mentioned_ids)
|
||
|
|
validated_mentioned_ids.each do |user_id|
|
||
|
|
message.conversation.conversation_participants.find_or_create_by!(user_id: user_id)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|