reblog_service.rb 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. # frozen_string_literal: true
  2. class ReblogService < BaseService
  3. include Authorization
  4. include StreamEntryRenderer
  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. # @return [Status]
  9. def call(account, reblogged_status)
  10. reblogged_status = reblogged_status.reblog if reblogged_status.reblog?
  11. authorize_with account, reblogged_status, :reblog?
  12. reblog = account.statuses.find_by(reblog: reblogged_status)
  13. return reblog unless reblog.nil?
  14. reblog = account.statuses.create!(reblog: reblogged_status, text: '')
  15. DistributionWorker.perform_async(reblog.id)
  16. Pubsubhubbub::DistributionWorker.perform_async(reblog.stream_entry.id)
  17. ActivityPub::DistributionWorker.perform_async(reblog.id)
  18. create_notification(reblog)
  19. reblog
  20. end
  21. private
  22. def create_notification(reblog)
  23. reblogged_status = reblog.reblog
  24. if reblogged_status.account.local?
  25. NotifyService.new.call(reblogged_status.account, reblog)
  26. elsif reblogged_status.account.ostatus?
  27. NotificationWorker.perform_async(stream_entry_to_xml(reblog.stream_entry), reblog.account_id, reblogged_status.account_id)
  28. elsif reblogged_status.account.activitypub? && !reblogged_status.account.following?(reblog.account)
  29. ActivityPub::DeliveryWorker.perform_async(build_json(reblog), reblog.account_id, reblogged_status.account.inbox_url)
  30. end
  31. end
  32. def build_json(reblog)
  33. Oj.dump(ActivityPub::LinkedDataSignature.new(ActiveModelSerializers::SerializableResource.new(
  34. reblog,
  35. serializer: ActivityPub::ActivitySerializer,
  36. adapter: ActivityPub::Adapter
  37. ).as_json).sign!(reblog.account))
  38. end
  39. end