123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 |
- # frozen_string_literal: true
- class FetchRemoteResourceService < BaseService
- include JsonLdHelper
- attr_reader :url
- def call(url)
- @url = url
- return process_local_url if local_url?
- process_url unless fetched_atom_feed.nil?
- end
- private
- def process_url
- case type
- when 'Person'
- FetchRemoteAccountService.new.call(atom_url, body, protocol)
- when 'Note'
- FetchRemoteStatusService.new.call(atom_url, body, protocol)
- end
- end
- def fetched_atom_feed
- @_fetched_atom_feed ||= FetchAtomService.new.call(url)
- end
- def atom_url
- fetched_atom_feed.first
- end
- def body
- fetched_atom_feed.second
- end
- def protocol
- fetched_atom_feed.third
- end
- def type
- return json_data['type'] if protocol == :activitypub
- case xml_root
- when 'feed'
- 'Person'
- when 'entry'
- 'Note'
- end
- end
- def json_data
- @_json_data ||= body_to_json(body)
- end
- def xml_root
- xml_data.root.name
- end
- def xml_data
- @_xml_data ||= Nokogiri::XML(body, nil, 'utf-8')
- end
- def local_url?
- TagManager.instance.local_url?(@url)
- end
- def process_local_url
- recognized_params = Rails.application.routes.recognize_path(@url)
- return unless recognized_params[:action] == 'show'
- if recognized_params[:controller] == 'stream_entries'
- status = StreamEntry.find_by(id: recognized_params[:id])&.status
- check_local_status(status)
- elsif recognized_params[:controller] == 'statuses'
- status = Status.find_by(id: recognized_params[:id])
- check_local_status(status)
- elsif recognized_params[:controller] == 'accounts'
- Account.find_local(recognized_params[:username])
- end
- end
- def check_local_status(status)
- return if status.nil?
- status if status.public_visibility? || status.unlisted_visibility?
- end
- end
|