Check domain suspensions before trying to fetch resources (#24535)
This commit is contained in:
		
							parent
							
								
									1ed0ff30d3
								
							
						
					
					
						commit
						a89b02af92
					
				@ -2,12 +2,15 @@
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
class ActivityPub::FetchRemoteStatusService < BaseService
 | 
					class ActivityPub::FetchRemoteStatusService < BaseService
 | 
				
			||||||
  include JsonLdHelper
 | 
					  include JsonLdHelper
 | 
				
			||||||
 | 
					  include DomainControlHelper
 | 
				
			||||||
  include Redisable
 | 
					  include Redisable
 | 
				
			||||||
 | 
					
 | 
				
			||||||
  DISCOVERIES_PER_REQUEST = 1000
 | 
					  DISCOVERIES_PER_REQUEST = 1000
 | 
				
			||||||
 | 
					
 | 
				
			||||||
  # Should be called when uri has already been checked for locality
 | 
					  # Should be called when uri has already been checked for locality
 | 
				
			||||||
  def call(uri, id: true, prefetched_body: nil, on_behalf_of: nil, expected_actor_uri: nil, request_id: nil)
 | 
					  def call(uri, id: true, prefetched_body: nil, on_behalf_of: nil, expected_actor_uri: nil, request_id: nil)
 | 
				
			||||||
 | 
					    return if domain_not_allowed?(uri)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    @request_id = request_id || "#{Time.now.utc.to_i}-status-#{uri}"
 | 
					    @request_id = request_id || "#{Time.now.utc.to_i}-status-#{uri}"
 | 
				
			||||||
    @json = if prefetched_body.nil?
 | 
					    @json = if prefetched_body.nil?
 | 
				
			||||||
              fetch_resource(uri, id, on_behalf_of)
 | 
					              fetch_resource(uri, id, on_behalf_of)
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user