about summary refs log blame commit diff
path: root/app/services/process_feed_service.rb
blob: 30a9dd85ebcb176abc9b7bd2df31603f1546556a (plain) (tree)
1
2
3
4
5
6
7
8
9
                             
                                      
                                    
                      
                             
                          
 
                                
                                 
     
 
         
 
                                  
                                                                                           
     
 
                                   
                                                                                                                                    
     
 
                                 
                                                                     
                                                    
                                                                           
       
     
   
# frozen_string_literal: true

class ProcessFeedService < BaseService
  def call(body, account, **options)
    @options = options

    xml = Nokogiri::XML(body)
    xml.encoding = 'utf-8'

    update_author(body, account)
    process_entries(xml, account)
  end

  private

  def update_author(body, account)
    RemoteProfileUpdateWorker.perform_async(account.id, body.force_encoding('UTF-8'), true)
  end

  def process_entries(xml, account)
    xml.xpath('//xmlns:entry', xmlns: OStatus::TagManager::XMLNS).reverse_each.map { |entry| process_entry(entry, account) }.compact
  end

  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
end