diff options
Diffstat (limited to 'app')
| -rw-r--r-- | app/services/process_feed_service.rb | 5 | ||||
| -rw-r--r-- | app/services/update_remote_profile_service.rb | 23 | ||||
| -rw-r--r-- | app/workers/remote_profile_update_worker.rb | 9 |
3 files changed, 22 insertions, 15 deletions
diff --git a/app/services/process_feed_service.rb b/app/services/process_feed_service.rb index cf2f7a826..a2def4535 100644 --- a/app/services/process_feed_service.rb +++ b/app/services/process_feed_service.rb @@ -5,14 +5,13 @@ class ProcessFeedService < BaseService xml = Nokogiri::XML(body) xml.encoding = 'utf-8' - update_author(body, xml, account) + update_author(body, account) process_entries(xml, account) end private - def update_author(body, xml, account) - return if xml.at_xpath('/xmlns:feed', xmlns: TagManager::XMLNS).nil? + def update_author(body, account) RemoteProfileUpdateWorker.perform_async(account.id, body.force_encoding('UTF-8'), true) end diff --git a/app/services/update_remote_profile_service.rb b/app/services/update_remote_profile_service.rb index 74baa1cc5..8f0d5d4b3 100644 --- a/app/services/update_remote_profile_service.rb +++ b/app/services/update_remote_profile_service.rb @@ -1,7 +1,12 @@ # frozen_string_literal: true class UpdateRemoteProfileService < BaseService - def call(xml, account, resubscribe = false) + def call(body, account, resubscribe = false) + xml = Nokogiri::XML(body) + xml.encoding = 'utf-8' + + xml = xml.at_xpath('/xmlns:feed', xmlns: TagManager::XMLNS) || xml.at_xpath('/xmlns:entry', xmlns: TagManager::XMLNS) + return if xml.nil? author_xml = xml.at_xpath('./xmlns:author', xmlns: TagManager::XMLNS) || xml.at_xpath('./dfrn:owner', dfrn: TagManager::DFRN_XMLNS) @@ -12,9 +17,9 @@ class UpdateRemoteProfileService < BaseService account.note = author_xml.at_xpath('./poco:note', poco: TagManager::POCO_XMLNS).content unless author_xml.at_xpath('./poco:note', poco: TagManager::POCO_XMLNS).nil? account.locked = author_xml.at_xpath('./mastodon:scope', mastodon: TagManager::MTDN_XMLNS)&.content == 'private' - unless account.suspended? || DomainBlock.find_by(domain: account.domain)&.reject_media? - account.avatar_remote_url = author_xml.at_xpath('./xmlns:link[@rel="avatar"]', xmlns: TagManager::XMLNS)['href'] unless author_xml.at_xpath('./xmlns:link[@rel="avatar"]', xmlns: TagManager::XMLNS).nil? || author_xml.at_xpath('./xmlns:link[@rel="avatar"]', xmlns: TagManager::XMLNS)['href'].blank? - account.header_remote_url = author_xml.at_xpath('./xmlns:link[@rel="header"]', xmlns: TagManager::XMLNS)['href'] unless author_xml.at_xpath('./xmlns:link[@rel="header"]', xmlns: TagManager::XMLNS).nil? || author_xml.at_xpath('./xmlns:link[@rel="header"]', xmlns: TagManager::XMLNS)['href'].blank? + if !account.suspended? && !DomainBlock.find_by(domain: account.domain)&.reject_media? + account.avatar_remote_url = link_href_from_xml(author_xml, 'avatar') if link_has_href?(author_xml, 'avatar') + account.header_remote_url = link_href_from_xml(author_xml, 'header') if link_has_href?(author_xml, 'header') end end @@ -25,4 +30,14 @@ class UpdateRemoteProfileService < BaseService SubscribeService.new.call(account) if resubscribe && (account.hub_url != old_hub_url) end + + private + + def link_href_from_xml(xml, type) + xml.at_xpath('./xmlns:link[@rel="' + type + '"]', xmlns: TagManager::XMLNS)['href'] + end + + def link_has_href?(xml, type) + !(xml.at_xpath('./xmlns:link[@rel="' + type + '"]', xmlns: TagManager::XMLNS).nil? || xml.at_xpath('./xmlns:link[@rel="' + type + '"]', xmlns: TagManager::XMLNS)['href'].blank?) + end end diff --git a/app/workers/remote_profile_update_worker.rb b/app/workers/remote_profile_update_worker.rb index b91dc3466..03585ad2d 100644 --- a/app/workers/remote_profile_update_worker.rb +++ b/app/workers/remote_profile_update_worker.rb @@ -6,14 +6,7 @@ class RemoteProfileUpdateWorker sidekiq_options queue: 'pull' def perform(account_id, body, resubscribe) - account = Account.find(account_id) - - xml = Nokogiri::XML(body) - xml.encoding = 'utf-8' - - author_container = xml.at_xpath('/xmlns:feed', xmlns: TagManager::XMLNS) || xml.at_xpath('/xmlns:entry', xmlns: TagManager::XMLNS) - - UpdateRemoteProfileService.new.call(author_container, account, resubscribe) + UpdateRemoteProfileService.new.call(body, Account.find(account_id), resubscribe) rescue ActiveRecord::RecordNotFound true end |