notify_service.rb 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. # frozen_string_literal: true
  2. class NotifyService < BaseService
  3. def call(recipient, activity)
  4. @recipient = recipient
  5. @activity = activity
  6. @notification = Notification.new(account: @recipient, activity: @activity)
  7. return if recipient.user.nil? || blocked?
  8. create_notification
  9. send_email if email_enabled?
  10. rescue ActiveRecord::RecordInvalid
  11. return
  12. end
  13. private
  14. def blocked_mention?
  15. FeedManager.instance.filter?(:mentions, @notification.mention.status, @recipient.id)
  16. end
  17. def blocked_favourite?
  18. false
  19. end
  20. def blocked_follow?
  21. false
  22. end
  23. def blocked_reblog?
  24. @recipient.muting_reblogs?(@notification.from_account)
  25. end
  26. def blocked_follow_request?
  27. false
  28. end
  29. def following_sender?
  30. return @following_sender if defined?(@following_sender)
  31. @following_sender = @recipient.following?(@notification.from_account) || @recipient.requested?(@notification.from_account)
  32. end
  33. def optional_non_follower?
  34. @recipient.user.settings.interactions['must_be_follower'] && !@notification.from_account.following?(@recipient)
  35. end
  36. def optional_non_following?
  37. @recipient.user.settings.interactions['must_be_following'] && !following_sender?
  38. end
  39. def direct_message?
  40. @notification.type == :mention && @notification.target_status.direct_visibility?
  41. end
  42. def response_to_recipient?
  43. @notification.target_status.in_reply_to_account_id == @recipient.id && @notification.target_status.thread&.direct_visibility?
  44. end
  45. def optional_non_following_and_direct?
  46. direct_message? &&
  47. @recipient.user.settings.interactions['must_be_following_dm'] &&
  48. !following_sender? &&
  49. !response_to_recipient?
  50. end
  51. def hellbanned?
  52. @notification.from_account.silenced? && !following_sender?
  53. end
  54. def from_self?
  55. @recipient.id == @notification.from_account.id
  56. end
  57. def domain_blocking?
  58. @recipient.domain_blocking?(@notification.from_account.domain) && !following_sender?
  59. end
  60. def blocked?
  61. blocked = @recipient.suspended? # Skip if the recipient account is suspended anyway
  62. blocked ||= from_self? # Skip for interactions with self
  63. blocked ||= domain_blocking? # Skip for domain blocked accounts
  64. blocked ||= @recipient.blocking?(@notification.from_account) # Skip for blocked accounts
  65. blocked ||= @recipient.muting_notifications?(@notification.from_account)
  66. blocked ||= hellbanned? # Hellban
  67. blocked ||= optional_non_follower? # Options
  68. blocked ||= optional_non_following? # Options
  69. blocked ||= optional_non_following_and_direct? # Options
  70. blocked ||= conversation_muted?
  71. blocked ||= send("blocked_#{@notification.type}?") # Type-dependent filters
  72. blocked
  73. end
  74. def conversation_muted?
  75. if @notification.target_status
  76. @recipient.muting_conversation?(@notification.target_status.conversation)
  77. else
  78. false
  79. end
  80. end
  81. def create_notification
  82. @notification.save!
  83. return unless @notification.browserable?
  84. Redis.current.publish("timeline:#{@recipient.id}", Oj.dump(event: :notification, payload: InlineRenderer.render(@notification, @recipient, :notification)))
  85. send_push_notifications
  86. end
  87. def send_push_notifications
  88. # HACK: Can be caused by quickly unfavouriting a status, since creating
  89. # a favourite and creating a notification are not wrapped in a transaction.
  90. return if @notification.activity.nil?
  91. sessions_with_subscriptions = @recipient.user.session_activations.where.not(web_push_subscription: nil)
  92. sessions_with_subscriptions_ids = sessions_with_subscriptions.select { |session| session.web_push_subscription.pushable? @notification }.map(&:id)
  93. WebPushNotificationWorker.push_bulk(sessions_with_subscriptions_ids) do |session_activation_id|
  94. [session_activation_id, @notification.id]
  95. end
  96. end
  97. def send_email
  98. NotificationMailer.public_send(@notification.type, @recipient, @notification).deliver_later
  99. end
  100. def email_enabled?
  101. @recipient.user.settings.notification_emails[@notification.type.to_s]
  102. end
  103. end