Instantly upgrade account to ActivityPub if we receive ActivityPub payload (#4766)
This commit is contained in:
		| @ -26,8 +26,12 @@ class ActivityPub::InboxesController < Api::BaseController | ||||
|   end | ||||
|  | ||||
|   def upgrade_account | ||||
|     return unless signed_request_account.subscribed? | ||||
|     Pubsubhubbub::UnsubscribeWorker.perform_async(signed_request_account.id) | ||||
|     if signed_request_account.ostatus? | ||||
|       signed_request_account.update(last_webfingered_at: nil) | ||||
|       ResolveRemoteAccountWorker.perform_async(signed_request_account.acct) | ||||
|     end | ||||
|  | ||||
|     Pubsubhubbub::UnsubscribeWorker.perform_async(signed_request_account.id) if signed_request_account.subscribed? | ||||
|   end | ||||
|  | ||||
|   def process_payload | ||||
|  | ||||
							
								
								
									
										11
									
								
								app/workers/resolve_remote_account_worker.rb
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										11
									
								
								app/workers/resolve_remote_account_worker.rb
									
									
									
									
									
										Normal file
									
								
							| @ -0,0 +1,11 @@ | ||||
| # frozen_string_literal: true | ||||
|  | ||||
| class ResolveRemoteAccountWorker | ||||
|   include Sidekiq::Worker | ||||
|  | ||||
|   sidekiq_options queue: 'pull', unique: :until_executed | ||||
|  | ||||
|   def perform(uri) | ||||
|     ResolveRemoteAccountService.new.call(uri) | ||||
|   end | ||||
| end | ||||
		Reference in New Issue
	
	Block a user