Add antenna and bio-searchability support

app/services/activitypub/process_account_service.rb

@@ -78,6 +78,7 @@ class ActivityPub::ProcessAccountService < BaseService
     @account.suspension_origin = :local if auto_suspend?
     @account.silenced_at       = domain_block.created_at if auto_silence?
     @account.searchability     = :private  # not null
+    @account.dissubscribable   = false     # not null
     @account.save
   end
 
@@ -115,6 +116,7 @@ class ActivityPub::ProcessAccountService < BaseService
     @account.also_known_as           = as_array(@json['alsoKnownAs'] || []).map { |item| value_or_id(item) }
     @account.discoverable            = @json['discoverable'] || false
     @account.searchability           = searchability_from_audience
+    @account.dissubscribable         = !subscribable(@account.note)
   end
 
   def set_fetchable_key!
@@ -249,6 +251,20 @@ class ActivityPub::ProcessAccountService < BaseService
     end
   end
 
+  def subscribable_by
+    return nil if @json['subscribableBy'].nil?
+
+    @subscribable_by = as_array(@json['subscribableBy']).map { |x| value_or_id(x) }
+  end
+
+  def subscribable(note)
+    if subscribable_by.nil?
+      !note.include?('[subscribable:no]')
+    else
+      subscribable_by.any? { |uri| ActivityPub::TagManager.instance.public_collection?(uri) }
+    end
+  end
+
   def property_values
     return unless @json['attachment'].is_a?(Array)
 

app/services/delete_account_service.rb

@@ -8,6 +8,7 @@ class DeleteAccountService < BaseService
     account_pins
     active_relationships
     aliases
+    antennas
     block_relationships
     blocked_by_relationships
     conversation_mutes

app/services/fan_out_on_write_service.rb

@@ -49,6 +49,7 @@ class FanOutOnWriteService < BaseService
     when :public, :unlisted, :public_unlisted, :private
       deliver_to_all_followers!
       deliver_to_lists!
+      deliver_to_antennas! if [:public, :public_unlisted].include?(@status.visibility.to_sym) && !@status.account.dissubscribable
     when :limited
       deliver_to_mentioned_followers!
     else
@@ -115,6 +116,34 @@ class FanOutOnWriteService < BaseService
     end
   end
 
+  def deliver_to_antennas!
+    lists = []
+    antennas = Antenna.availables
+    antennas = antennas.left_joins(:antenna_accounts).where(any_accounts: true).or(Antenna.availables.left_joins(:antenna_accounts)                                                       .where(antenna_accounts: { exclude: false, account: @status.account }))
+    antennas = antennas.left_joins(:antenna_domains) .where(any_domains: true) .or(Antenna.availables.left_joins(:antenna_accounts).left_joins(:antenna_domains)                          .where(antenna_domains:  { exclude: false, name: @status.account.domain }))
+    antennas = antennas.left_joins(:antenna_tags)    .where(any_tags: true)    .or(Antenna.availables.left_joins(:antenna_accounts).left_joins(:antenna_domains).left_joins(:antenna_tags).where(antenna_tags:     { exclude: false, tag: @status.tags }))
+    antennas = antennas.where(account: @status.account.followers) if @status.visibility.to_sym == :unlisted
+    antennas.in_batches do |ans|
+      ans.each do |antenna|
+        next if !antenna.enabled?
+        next if antenna.keywords.any? && !([nil, :public].include?(@status.searchability&.to_sym))
+        next if antenna.keywords.any? && !antenna.keywords.any? { |keyword| @status.text.include?(keyword) }
+        next if antenna.exclude_keywords.any? && antenna.exclude_keywords.any? { |keyword| @status.text.include?(keyword) }
+        next if antenna.antenna_accounts.where(exclude: true, account: @status.account).any?
+        next if antenna.antenna_domains.where(exclude: true, name: @status.account.domain).any?
+        next if antenna.antenna_tags.where(exclude: true, tag: @status.tags).any?
+        lists << antenna.list
+      end
+    end
+    lists = lists.uniq
+
+    if lists.any?
+      FeedInsertWorker.push_bulk(lists) do |list|
+        [@status.id, list.id, 'list', { 'update' => update? }]
+      end
+    end
+  end
+
   def deliver_to_mentioned_followers!
     @status.mentions.joins(:account).merge(@account.followers_for_local_distribution).select(:id, :account_id).reorder(nil).find_in_batches do |mentions|
       FeedInsertWorker.push_bulk(mentions) do |mention|