# frozen_string_literal: true class ActivityPub::Activity include JsonLdHelper include Redisable SUPPORTED_TYPES = %w(Note Question).freeze CONVERTED_TYPES = %w(Image Video Article Page).freeze def initialize(json, account, **options) @json = json @account = account @object = @json['object'] @options = options end def perform raise NotImplementedError end class << self def factory(json, account, **options) @json = json klass&.new(json, account, options) end private def klass case @json['type'] when 'Create' ActivityPub::Activity::Create when 'Announce' ActivityPub::Activity::Announce when 'Delete' ActivityPub::Activity::Delete when 'Follow' ActivityPub::Activity::Follow when 'Like' ActivityPub::Activity::Like when 'Block' ActivityPub::Activity::Block when 'Update' ActivityPub::Activity::Update when 'Undo' ActivityPub::Activity::Undo when 'Accept' ActivityPub::Activity::Accept when 'Reject' ActivityPub::Activity::Reject when 'Flag' ActivityPub::Activity::Flag when 'Add' ActivityPub::Activity::Add when 'Remove' ActivityPub::Activity::Remove when 'Move' ActivityPub::Activity::Move end end end protected def status_from_uri(uri) ActivityPub::TagManager.instance.uri_to_resource(uri, Status) end def account_from_uri(uri) ActivityPub::TagManager.instance.uri_to_resource(uri, Account) end def object_uri @object_uri ||= value_or_id(@object) end def unsupported_object_type? @object.is_a?(String) || !(supported_object_type? || converted_object_type?) end def supported_object_type? equals_or_includes_any?(@object['type'], SUPPORTED_TYPES) end def converted_object_type? equals_or_includes_any?(@object['type'], CONVERTED_TYPES) end def distribute(status) crawl_links(status) return if @options[:imported] notify_about_reblog(status) if reblog_of_local_account?(status) notify_about_mentions(status) # Only continue if the status is supposed to have arrived in real-time. # Note that if @options[:override_timestamps] isn't set, the status # may have a lower snowflake id than other existing statuses, potentially # "hiding" it from paginated API calls return unless @options[:override_timestamps] || status.within_realtime_window? distribute_to_followers(status) end def reblog_of_local_account?(status) status.reblog? && status.reblog.account.local? end def notify_about_reblog(status) NotifyService.new.call(status.reblog.account, status) end def notify_about_mentions(status) status.active_mentions.includes(:account).each do |mention| next unless mention.account.local? && audience_includes?(mention.account) NotifyService.new.call(mention.account, mention) end end def crawl_links(status) return if status.spoiler_text? LinkCrawlWorker.perform_async(status.id) end def distribute_to_followers(status) ::DistributionWorker.perform_async(status.id) end def delete_arrived_first?(uri) redis.exists("delete_upon_arrival:#{@account.id}:#{uri}") end def delete_later!(uri) redis.setex("delete_upon_arrival:#{@account.id}:#{uri}", 6.hours.seconds, uri) end def status_from_object(announced_by: nil, local_only: false, existing_only: false) # If the status is already known, return it status = status_from_uri(object_uri) return status unless status.nil? || (local_only && !status.local?) return if existing_only || local_only # If the boosted toot is embedded and it is a self-boost, handle it like a Create unless unsupported_object_type? actor_id = value_or_id(first_of_value(@object['attributedTo'])) if actor_id == @account.uri return ActivityPub::Activity.factory({ 'type' => 'Create', 'actor' => actor_id, 'object' => @object }, @account, announced_by: announced_by).perform end end fetch_remote_original_status(announced_by: announced_by) end def fetch_remote_original_status(announced_by: nil) if object_uri.start_with?('http') return if ActivityPub::TagManager.instance.local_uri?(object_uri) ActivityPub::FetchRemoteStatusService.new.call(object_uri, id: true, on_behalf_of: @account.followers.local.first, announced_by: announced_by) elsif @object['url'].present? options[:id] = true ::FetchRemoteStatusService.new.call(@object['url'], announced_by: announced_by) end end def lock_or_return(key, expire_after = 7.days.seconds) yield if redis.set(key, true, nx: true, ex: expire_after) ensure redis.del(key) end def fetch? !@options[:delivery] end def followed_by_local_accounts? @account.passive_relationships.exists? end def requested_through_relay? @options[:relayed_through_account] && Relay.find_by(inbox_url: @options[:relayed_through_account].inbox_url)&.enabled? end def rejecting_unknown?(account = nil) account = @account if account.nil? DomainBlock.where(domain: account.domain, reject_unknown: true).exists? end def manual_only?(account = nil) account = @account if account.nil? DomainBlock.where(domain: account.domain, manual_only: true).exists? end def known?(account = nil) account = @account if account.nil? return true if account.known? !account.service? && account.passive_relationships.exists? end def manual_only?(account = nil) account = @account if account.nil? account.manual_only? end def blocked? uri = object_uri.start_with?('http') ? object_uri : @object['url'] return true if object_uri.nil? domain = uri.scan(/[\w\-]+\.[\w\-]+(?:\.[\w\-]+)*/).first domain.blank? ? true : DomainBlock.suspend?(domain) end def reject_payload! Rails.logger.info("Rejected #{@json['type']} activity #{@json['id']} from #{@account.uri}#{@options[:relayed_through_account] && "via #{@options[:relayed_through_account].uri}"}") nil end end