announce.rb 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. # frozen_string_literal: true
  2. class ActivityPub::Activity::Announce < ActivityPub::Activity
  3. def perform
  4. original_status = status_from_uri(object_uri)
  5. original_status ||= fetch_remote_original_status
  6. return if original_status.nil? || delete_arrived_first?(@json['id']) || !announceable?(original_status)
  7. status = Status.find_by(account: @account, reblog: original_status)
  8. return status unless status.nil?
  9. status = Status.create!(
  10. account: @account,
  11. reblog: original_status,
  12. uri: @json['id'],
  13. created_at: @json['published'],
  14. override_timestamps: @options[:override_timestamps],
  15. visibility: visibility_from_audience
  16. )
  17. distribute(status)
  18. status
  19. end
  20. private
  21. def visibility_from_audience
  22. if equals_or_includes?(@json['to'], ActivityPub::TagManager::COLLECTIONS[:public])
  23. :public
  24. elsif equals_or_includes?(@json['cc'], ActivityPub::TagManager::COLLECTIONS[:public])
  25. :unlisted
  26. elsif equals_or_includes?(@json['to'], @account.followers_url)
  27. :private
  28. else
  29. :direct
  30. end
  31. end
  32. def announceable?(status)
  33. status.account_id == @account.id || status.public_visibility? || status.unlisted_visibility?
  34. end
  35. end