reblog_service.rb 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. # frozen_string_literal: true
  2. class ReblogService < BaseService
  3. include Authorization
  4. include Payloadable
  5. # Reblog a status and notify its remote author
  6. # @param [Account] account Account to reblog from
  7. # @param [Status] reblogged_status Status to be reblogged
  8. # @param [Hash] options
  9. # @option [String] :visibility
  10. # @option [Boolean] :with_rate_limit
  11. # @return [Status]
  12. def call(account, reblogged_status, options = {})
  13. reblogged_status = reblogged_status.reblog if reblogged_status.reblog?
  14. authorize_with account, reblogged_status, :reblog?
  15. reblog = account.statuses.find_by(reblog: reblogged_status)
  16. return reblog unless reblog.nil?
  17. visibility = if reblogged_status.hidden?
  18. reblogged_status.visibility
  19. else
  20. options[:visibility] || account.user&.setting_default_privacy
  21. end
  22. reblog = account.statuses.create!(reblog: reblogged_status, text: '', visibility: visibility, rate_limit: options[:with_rate_limit])
  23. Trends.register!(reblog)
  24. DistributionWorker.perform_async(reblog.id)
  25. ActivityPub::DistributionWorker.perform_async(reblog.id)
  26. create_notification(reblog)
  27. bump_potential_friendship(account, reblog)
  28. reblog
  29. end
  30. private
  31. def create_notification(reblog)
  32. reblogged_status = reblog.reblog
  33. if reblogged_status.account.local?
  34. LocalNotificationWorker.perform_async(reblogged_status.account_id, reblog.id, reblog.class.name, 'reblog')
  35. elsif reblogged_status.account.activitypub? && !reblogged_status.account.following?(reblog.account)
  36. ActivityPub::DeliveryWorker.perform_async(build_json(reblog), reblog.account_id, reblogged_status.account.inbox_url)
  37. end
  38. end
  39. def bump_potential_friendship(account, reblog)
  40. ActivityTracker.increment('activity:interactions')
  41. return if account.following?(reblog.reblog.account_id)
  42. PotentialFriendshipTracker.record(account.id, reblog.reblog.account_id, :reblog)
  43. end
  44. def build_json(reblog)
  45. Oj.dump(serialize_payload(ActivityPub::ActivityPresenter.from_status(reblog), ActivityPub::ActivitySerializer, signer: reblog.account))
  46. end
  47. end