diff options
author | Eugen Rochko <eugen@zeonfederated.com> | 2017-02-11 14:12:29 +0100 |
---|---|---|
committer | Eugen Rochko <eugen@zeonfederated.com> | 2017-02-11 14:25:01 +0100 |
commit | 00b5731ecb2c29dd5c79a233f046a9655031ec71 (patch) | |
tree | 318e297bc3393da5a303ac5665d2f6ebae80f5b0 /app/services | |
parent | e610555e10356374d1f4e0e7ca11056580ec9f3b (diff) |
After FollowService, re-fetch remote account asynchronously, do nothing
if account lock info was up to date, otherwise re-do the FollowService with now updated information
Diffstat (limited to 'app/services')
-rw-r--r-- | app/services/fetch_remote_account_service.rb | 4 | ||||
-rw-r--r-- | app/services/follow_service.rb | 2 |
2 files changed, 5 insertions, 1 deletions
diff --git a/app/services/fetch_remote_account_service.rb b/app/services/fetch_remote_account_service.rb index 3c3694a65..baefa3a86 100644 --- a/app/services/fetch_remote_account_service.rb +++ b/app/services/fetch_remote_account_service.rb @@ -22,7 +22,9 @@ class FetchRemoteAccountService < BaseService Rails.logger.debug "Going to webfinger #{username}@#{domain}" - return FollowRemoteAccountService.new.call("#{username}@#{domain}") + account = FollowRemoteAccountService.new.call("#{username}@#{domain}") + UpdateRemoteProfileService.new.call(xml, account) unless account.nil? + account rescue TypeError Rails.logger.debug "Unparseable URL given: #{url}" nil diff --git a/app/services/follow_service.rb b/app/services/follow_service.rb index 6ca834c19..ac0392d16 100644 --- a/app/services/follow_service.rb +++ b/app/services/follow_service.rb @@ -28,6 +28,7 @@ class FollowService < BaseService NotifyService.new.call(target_account, follow_request) else NotificationWorker.perform_async(stream_entry_to_xml(follow_request.stream_entry), source_account.id, target_account.id) + AfterRemoteFollowRequestWorker.perform_async(follow_request.id) end follow_request @@ -41,6 +42,7 @@ class FollowService < BaseService else subscribe_service.call(target_account) unless target_account.subscribed? NotificationWorker.perform_async(stream_entry_to_xml(follow.stream_entry), source_account.id, target_account.id) + AfterRemoteFollowWorker.perform_async(follow.id) end MergeWorker.perform_async(target_account.id, source_account.id) |