mastodon/app/services/process_feed_service.rb

32 lines
877 B
Ruby
Raw Permalink Normal View History

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