reblog_service.rb 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  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 = begin
  18. if reblogged_status.hidden?
  19. reblogged_status.visibility
  20. else
  21. options[:visibility] || account.user&.setting_default_privacy
  22. end
  23. end
  24. reblog = account.statuses.create!(reblog: reblogged_status, text: '', visibility: visibility, rate_limit: options[:with_rate_limit])
  25. DistributionWorker.perform_async(reblog.id)
  26. ActivityPub::DistributionWorker.perform_async(reblog.id)
  27. create_notification(reblog)
  28. bump_potential_friendship(account, reblog)
  29. reblog
  30. end
  31. private
  32. def create_notification(reblog)
  33. reblogged_status = reblog.reblog
  34. if reblogged_status.account.local?
  35. LocalNotificationWorker.perform_async(reblogged_status.account_id, reblog.id, reblog.class.name)
  36. elsif reblogged_status.account.activitypub? && !reblogged_status.account.following?(reblog.account)
  37. ActivityPub::DeliveryWorker.perform_async(build_json(reblog), reblog.account_id, reblogged_status.account.inbox_url)
  38. end
  39. end
  40. def bump_potential_friendship(account, reblog)
  41. ActivityTracker.increment('activity:interactions')
  42. return if account.following?(reblog.reblog.account_id)
  43. PotentialFriendshipTracker.record(account.id, reblog.reblog.account_id, :reblog)
  44. end
  45. def build_json(reblog)
  46. Oj.dump(serialize_payload(ActivityPub::ActivityPresenter.from_status(reblog), ActivityPub::ActivitySerializer, signer: reblog.account))
  47. end
  48. end