* ActivityPub migration procedure Once one account is detected as going from OStatus to ActivityPub, invalidate WebFinger cache for other accounts from the same domain * Unsubscribe from PuSH updates once we receive an ActivityPub payload * Re-subscribe to PuSH unless already unsubscribed, regardless of protocol
		
			
				
	
	
		
			34 lines
		
	
	
		
			883 B
		
	
	
	
		
			Ruby
		
	
	
	
	
	
			
		
		
	
	
			34 lines
		
	
	
		
			883 B
		
	
	
	
		
			Ruby
		
	
	
	
	
	
| # frozen_string_literal: true
 | |
| 
 | |
| class UnsubscribeService < BaseService
 | |
|   def call(account)
 | |
|     return if account.hub_url.blank?
 | |
| 
 | |
|     @account  = account
 | |
|     @response = build_request.perform
 | |
| 
 | |
|     Rails.logger.debug "PuSH unsubscribe for #{@account.acct} failed: #{@response.status}" unless @response.status.success?
 | |
| 
 | |
|     @account.secret = ''
 | |
|     @account.subscription_expires_at = nil
 | |
|     @account.save!
 | |
|   rescue HTTP::Error, OpenSSL::SSL::SSLError
 | |
|     Rails.logger.debug "PuSH subscription request for #{@account.acct} could not be made due to HTTP or SSL error"
 | |
|   end
 | |
| 
 | |
|   private
 | |
| 
 | |
|   def build_request
 | |
|     Request.new(:post, @account.hub_url, form: subscription_params)
 | |
|   end
 | |
| 
 | |
|   def subscription_params
 | |
|     {
 | |
|       'hub.topic': @account.remote_url,
 | |
|       'hub.mode': 'unsubscribe',
 | |
|       'hub.callback': api_subscription_url(@account.id),
 | |
|       'hub.verify': 'async',
 | |
|     }
 | |
|   end
 | |
| end
 |