2016-11-15 10:56:29 -05:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
2016-02-24 06:57:29 -05:00
|
|
|
class ProcessFeedService < BaseService
|
2016-02-20 16:53:20 -05:00
|
|
|
def call(body, account)
|
|
|
|
xml = Nokogiri::XML(body)
|
2016-11-13 13:12:40 -05:00
|
|
|
xml.encoding = 'utf-8'
|
2016-11-07 19:32:34 -05:00
|
|
|
|
2017-04-08 07:26:03 -04:00
|
|
|
update_author(body, account)
|
2016-11-07 19:32:34 -05:00
|
|
|
process_entries(xml, account)
|
2016-03-24 21:13:30 -04:00
|
|
|
end
|
2016-02-20 16:53:20 -05:00
|
|
|
|
2016-03-24 21:13:30 -04:00
|
|
|
private
|
2016-02-28 08:26:26 -05:00
|
|
|
|
2017-04-08 07:26:03 -04:00
|
|
|
def update_author(body, account)
|
2017-04-05 15:41:50 -04:00
|
|
|
RemoteProfileUpdateWorker.perform_async(account.id, body.force_encoding('UTF-8'), true)
|
2016-11-07 19:32:34 -05:00
|
|
|
end
|
2016-02-23 19:28:53 -05:00
|
|
|
|
2016-11-07 19:32:34 -05:00
|
|
|
def process_entries(xml, account)
|
2017-07-18 10:39:47 -04:00
|
|
|
xml.xpath('//xmlns:entry', xmlns: TagManager::XMLNS).reverse_each.map { |entry| process_entry(entry, account) }.compact
|
2016-11-07 19:32:34 -05:00
|
|
|
end
|
2016-03-16 05:46:15 -04:00
|
|
|
|
2017-07-18 10:39:47 -04:00
|
|
|
def process_entry(xml, account)
|
|
|
|
activity = Ostatus::Activity::General.new(xml, account)
|
|
|
|
activity.specialize&.perform if activity.status?
|
|
|
|
rescue ActiveRecord::RecordInvalid => e
|
|
|
|
Rails.logger.debug "Nothing was saved for #{id} because: #{e}"
|
|
|
|
nil
|
2016-09-19 18:39:03 -04:00
|
|
|
end
|
2016-02-20 16:53:20 -05:00
|
|
|
end
|