Fix: リレーブロック中のサーバーからブーストが届く問題

app/lib/activitypub/activity/announce.rb

@@ -6,6 +6,7 @@ class ActivityPub::Activity::Announce < ActivityPub::Activity
   def perform
     return reject_payload! if delete_arrived_first?(@json['id']) || !related_to_local_activity?
     return reject_payload! if @object.nil?
+    return reject_payload! if reject_relay?
 
     with_redis_lock("announce:#{value_or_id(@object)}") do
       original_status = status_from_object
@@ -88,4 +89,8 @@ def requested_through_relay?
   def reblog_of_local_status?
     status_from_uri(object_uri)&.account&.local?
   end
+
+  def reject_relay?
+    requested_through_relay? && DomainBlock.reject_relay?(@account.domain)
+  end
 end

spec/lib/activitypub/activity/announce_spec.rb

@@ -143,6 +143,21 @@
       end
     end
 
+    context 'without rejecting relay received from no-relay' do
+      let(:object_json) do
+        ActivityPub::TagManager.instance.uri_for(status)
+      end
+
+      before do
+        Fabricate(:domain_block, domain: sender.domain, reject_relay: true)
+        subject.perform
+      end
+
+      it 'creates a reblog' do
+        expect(sender.reblogged?(status)).to be true
+      end
+    end
+
     context 'when the sender is relayed' do
       subject { described_class.new(json, sender, relayed_through_actor: relay_account) }
 
@@ -167,6 +182,18 @@
         end
       end
 
+      context 'with rejecting relay' do
+        before do
+          Fabricate(:domain_block, domain: sender.domain, reject_relay: true)
+          relay.update(state: :accepted)
+          subject.perform
+        end
+
+        it 'does not reblog' do
+          expect(sender.statuses.count).to eq 0
+        end
+      end
+
       context 'when the relay is disabled' do
         before do
           subject.perform