notify_service.rb 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. # frozen_string_literal: true
  2. class NotifyService < BaseService
  3. include Redisable
  4. def call(recipient, type, activity)
  5. @recipient = recipient
  6. @activity = activity
  7. @notification = Notification.new(account: @recipient, type: type, activity: @activity)
  8. return if recipient.user.nil? || blocked?
  9. @notification.save!
  10. # It's possible the underlying activity has been deleted
  11. # between the save call and now
  12. return if @notification.activity.nil?
  13. push_notification!
  14. push_to_conversation! if direct_message?
  15. send_email! if email_needed?
  16. rescue ActiveRecord::RecordInvalid
  17. nil
  18. end
  19. private
  20. def blocked_mention?
  21. FeedManager.instance.filter?(:mentions, @notification.mention.status, @recipient)
  22. end
  23. def following_sender?
  24. return @following_sender if defined?(@following_sender)
  25. @following_sender = @recipient.following?(@notification.from_account) || @recipient.requested?(@notification.from_account)
  26. end
  27. def optional_non_follower?
  28. @recipient.user.settings.interactions['must_be_follower'] && !@notification.from_account.following?(@recipient)
  29. end
  30. def optional_non_following?
  31. @recipient.user.settings.interactions['must_be_following'] && !following_sender?
  32. end
  33. def message?
  34. @notification.type == :mention
  35. end
  36. def direct_message?
  37. message? && @notification.target_status.direct_visibility?
  38. end
  39. # Returns true if the sender has been mentioned by the recipient up the thread
  40. def response_to_recipient?
  41. return false if @notification.target_status.in_reply_to_id.nil?
  42. # Using an SQL CTE to avoid unneeded back-and-forth with SQL server in case of long threads
  43. !Status.count_by_sql([<<-SQL.squish, id: @notification.target_status.in_reply_to_id, recipient_id: @recipient.id, sender_id: @notification.from_account.id, depth_limit: 100]).zero?
  44. WITH RECURSIVE ancestors(id, in_reply_to_id, mention_id, path, depth) AS (
  45. SELECT s.id, s.in_reply_to_id, m.id, ARRAY[s.id], 0
  46. FROM statuses s
  47. LEFT JOIN mentions m ON m.silent = FALSE AND m.account_id = :sender_id AND m.status_id = s.id
  48. WHERE s.id = :id
  49. UNION ALL
  50. SELECT s.id, s.in_reply_to_id, m.id, st.path || s.id, st.depth + 1
  51. FROM ancestors st
  52. JOIN statuses s ON s.id = st.in_reply_to_id
  53. LEFT JOIN mentions m ON m.silent = FALSE AND m.account_id = :sender_id AND m.status_id = s.id
  54. WHERE st.mention_id IS NULL AND NOT s.id = ANY(path) AND st.depth < :depth_limit
  55. )
  56. SELECT COUNT(*)
  57. FROM ancestors st
  58. JOIN statuses s ON s.id = st.id
  59. WHERE st.mention_id IS NOT NULL AND s.visibility = 3
  60. SQL
  61. end
  62. def from_staff?
  63. @notification.from_account.local? && @notification.from_account.user.present? && @notification.from_account.user_role&.overrides?(@recipient.user_role)
  64. end
  65. def optional_non_following_and_direct?
  66. direct_message? &&
  67. @recipient.user.settings.interactions['must_be_following_dm'] &&
  68. !following_sender? &&
  69. !response_to_recipient?
  70. end
  71. def hellbanned?
  72. @notification.from_account.silenced? && !following_sender?
  73. end
  74. def from_self?
  75. @recipient.id == @notification.from_account.id
  76. end
  77. def domain_blocking?
  78. @recipient.domain_blocking?(@notification.from_account.domain) && !following_sender?
  79. end
  80. def blocked?
  81. blocked = @recipient.suspended?
  82. blocked ||= from_self? && @notification.type != :poll
  83. return blocked if message? && from_staff?
  84. blocked ||= domain_blocking?
  85. blocked ||= @recipient.blocking?(@notification.from_account)
  86. blocked ||= @recipient.muting_notifications?(@notification.from_account)
  87. blocked ||= hellbanned?
  88. blocked ||= optional_non_follower?
  89. blocked ||= optional_non_following?
  90. blocked ||= optional_non_following_and_direct?
  91. blocked ||= conversation_muted?
  92. blocked ||= blocked_mention? if @notification.type == :mention
  93. blocked
  94. end
  95. def conversation_muted?
  96. if @notification.target_status
  97. @recipient.muting_conversation?(@notification.target_status.conversation)
  98. else
  99. false
  100. end
  101. end
  102. def push_notification!
  103. push_to_streaming_api! if subscribed_to_streaming_api?
  104. push_to_web_push_subscriptions!
  105. end
  106. def push_to_streaming_api!
  107. redis.publish("timeline:#{@recipient.id}:notifications", Oj.dump(event: :notification, payload: InlineRenderer.render(@notification, @recipient, :notification)))
  108. end
  109. def subscribed_to_streaming_api?
  110. redis.exists?("subscribed:timeline:#{@recipient.id}") || redis.exists?("subscribed:timeline:#{@recipient.id}:notifications")
  111. end
  112. def push_to_conversation!
  113. AccountConversation.add_status(@recipient, @notification.target_status)
  114. end
  115. def push_to_web_push_subscriptions!
  116. ::Web::PushNotificationWorker.push_bulk(web_push_subscriptions.select { |subscription| subscription.pushable?(@notification) }) { |subscription| [subscription.id, @notification.id] }
  117. end
  118. def web_push_subscriptions
  119. @web_push_subscriptions ||= ::Web::PushSubscription.where(user_id: @recipient.user.id).to_a
  120. end
  121. def subscribed_to_web_push?
  122. web_push_subscriptions.any?
  123. end
  124. def send_email!
  125. NotificationMailer.public_send(@notification.type, @recipient, @notification).deliver_later(wait: 2.minutes) if NotificationMailer.respond_to?(@notification.type)
  126. end
  127. def email_needed?
  128. (!recipient_online? || always_send_emails?) && send_email_for_notification_type?
  129. end
  130. def recipient_online?
  131. subscribed_to_streaming_api? || subscribed_to_web_push?
  132. end
  133. def always_send_emails?
  134. @recipient.user.settings.always_send_emails
  135. end
  136. def send_email_for_notification_type?
  137. @recipient.user.settings.notification_emails[@notification.type.to_s]
  138. end
  139. end