2016-11-15 09:56:29 -06:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
2018-01-22 07:25:09 -06:00
|
|
|
class ResolveAccountService < BaseService
|
2016-10-12 14:07:00 -05:00
|
|
|
include OStatus2::MagicKey
|
2017-08-08 14:52:15 -05:00
|
|
|
include JsonLdHelper
|
2016-10-12 14:07:00 -05:00
|
|
|
|
2016-11-15 09:56:29 -06:00
|
|
|
DFRN_NS = 'http://purl.org/macgirvin/dfrn/1.0'
|
2016-10-12 15:55:00 -05:00
|
|
|
|
2016-02-24 05:57:29 -06:00
|
|
|
# Find or create a local account for a remote user.
|
|
|
|
# When creating, look up the user's webfinger and fetch all
|
|
|
|
# important information from their feed
|
2018-11-08 14:05:42 -06:00
|
|
|
# @param [String, Account] uri User URI in the form of username@domain
|
|
|
|
# @param [Hash] options
|
2016-02-24 05:57:29 -06:00
|
|
|
# @return [Account]
|
2018-11-08 14:05:42 -06:00
|
|
|
def call(uri, options = {})
|
|
|
|
@options = options
|
2016-03-21 12:26:47 -05:00
|
|
|
|
2018-11-08 14:05:42 -06:00
|
|
|
if uri.is_a?(Account)
|
|
|
|
@account = uri
|
|
|
|
@username = @account.username
|
|
|
|
@domain = @account.domain
|
|
|
|
|
|
|
|
return @account if @account.local? || !webfinger_update_due?
|
|
|
|
else
|
|
|
|
@username, @domain = uri.split('@')
|
2016-03-21 12:26:47 -05:00
|
|
|
|
2018-11-08 14:05:42 -06:00
|
|
|
return Account.find_local(@username) if TagManager.instance.local_domain?(@domain)
|
2017-07-19 07:44:04 -05:00
|
|
|
|
2018-11-08 14:05:42 -06:00
|
|
|
@account = Account.find_remote(@username, @domain)
|
|
|
|
|
|
|
|
return @account unless webfinger_update_due?
|
|
|
|
end
|
2016-09-19 17:39:03 -05:00
|
|
|
|
2016-11-03 10:57:44 -05:00
|
|
|
Rails.logger.debug "Looking up webfinger for #{uri}"
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
@webfinger = Goldfinger.finger("acct:#{uri}")
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
confirmed_username, confirmed_domain = @webfinger.subject.gsub(/\Aacct:/, '').split('@')
|
2016-11-03 10:57:44 -05:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
if confirmed_username.casecmp(@username).zero? && confirmed_domain.casecmp(@domain).zero?
|
|
|
|
@username = confirmed_username
|
|
|
|
@domain = confirmed_domain
|
2018-11-08 14:05:42 -06:00
|
|
|
elsif options[:redirected].nil?
|
|
|
|
return call("#{confirmed_username}@#{confirmed_domain}", options.merge(redirected: true))
|
2017-07-19 07:44:04 -05:00
|
|
|
else
|
2017-07-19 18:59:07 -05:00
|
|
|
Rails.logger.debug 'Requested and returned acct URIs do not match'
|
|
|
|
return
|
2017-04-19 10:28:35 -05:00
|
|
|
end
|
|
|
|
|
2017-07-19 18:59:07 -05:00
|
|
|
return if links_missing?
|
2017-07-19 07:44:04 -05:00
|
|
|
return Account.find_local(@username) if TagManager.instance.local_domain?(@domain)
|
2016-11-03 10:57:44 -05:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
RedisLock.acquire(lock_options) do |lock|
|
|
|
|
if lock.acquired?
|
|
|
|
@account = Account.find_remote(@username, @domain)
|
2016-11-03 10:57:44 -05:00
|
|
|
|
2017-12-08 18:24:47 -06:00
|
|
|
if activitypub_ready? || @account&.activitypub?
|
2017-08-08 14:52:15 -05:00
|
|
|
handle_activitypub
|
|
|
|
else
|
|
|
|
handle_ostatus
|
|
|
|
end
|
2018-05-16 05:29:45 -05:00
|
|
|
else
|
|
|
|
raise Mastodon::RaceConditionError
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
2017-04-14 20:16:05 -05:00
|
|
|
end
|
2016-11-03 10:57:44 -05:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
@account
|
2017-07-19 18:59:07 -05:00
|
|
|
rescue Goldfinger::Error => e
|
|
|
|
Rails.logger.debug "Webfinger query for #{uri} unsuccessful: #{e}"
|
|
|
|
nil
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
2017-01-23 10:38:38 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
private
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def links_missing?
|
2017-08-08 14:52:15 -05:00
|
|
|
!(activitypub_ready? || ostatus_ready?)
|
|
|
|
end
|
|
|
|
|
|
|
|
def ostatus_ready?
|
|
|
|
!(@webfinger.link('http://schemas.google.com/g/2010#updates-from').nil? ||
|
2017-07-19 07:44:04 -05:00
|
|
|
@webfinger.link('salmon').nil? ||
|
|
|
|
@webfinger.link('http://webfinger.net/rel/profile-page').nil? ||
|
2017-07-19 18:59:07 -05:00
|
|
|
@webfinger.link('magic-public-key').nil? ||
|
|
|
|
canonical_uri.nil? ||
|
2017-08-08 14:52:15 -05:00
|
|
|
hub_url.nil?)
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def webfinger_update_due?
|
2018-11-08 14:05:42 -06:00
|
|
|
@account.nil? || ((!@options[:skip_webfinger] || @account.ostatus?) && @account.possibly_stale?)
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
2016-02-22 11:10:30 -06:00
|
|
|
|
2017-08-08 14:52:15 -05:00
|
|
|
def activitypub_ready?
|
|
|
|
!@webfinger.link('self').nil? &&
|
2017-08-14 04:27:25 -05:00
|
|
|
['application/activity+json', 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"'].include?(@webfinger.link('self').type) &&
|
2017-09-17 04:54:23 -05:00
|
|
|
!actor_json.nil? &&
|
2017-08-14 04:27:25 -05:00
|
|
|
actor_json['inbox'].present?
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def handle_ostatus
|
|
|
|
create_account if @account.nil?
|
|
|
|
update_account
|
|
|
|
update_account_profile if update_profile?
|
|
|
|
end
|
|
|
|
|
|
|
|
def update_profile?
|
2018-11-08 14:05:42 -06:00
|
|
|
@options[:update_profile]
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def handle_activitypub
|
2017-08-14 04:27:25 -05:00
|
|
|
return if actor_json.nil?
|
2017-08-08 14:52:15 -05:00
|
|
|
|
2017-08-14 04:27:25 -05:00
|
|
|
@account = ActivityPub::ProcessAccountService.new.call(@username, @domain, actor_json)
|
2017-08-08 14:52:15 -05:00
|
|
|
rescue Oj::ParseError
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def create_account
|
|
|
|
Rails.logger.debug "Creating new remote account for #{@username}@#{@domain}"
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
@account = Account.new(username: @username, domain: @domain)
|
|
|
|
@account.suspended = true if auto_suspend?
|
|
|
|
@account.silenced = true if auto_silence?
|
|
|
|
@account.private_key = nil
|
2016-02-20 15:53:20 -06:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def update_account
|
|
|
|
@account.last_webfingered_at = Time.now.utc
|
2017-08-08 14:52:15 -05:00
|
|
|
@account.protocol = :ostatus
|
2017-07-19 07:44:04 -05:00
|
|
|
@account.remote_url = atom_url
|
|
|
|
@account.salmon_url = salmon_url
|
|
|
|
@account.url = url
|
|
|
|
@account.public_key = public_key
|
|
|
|
@account.uri = canonical_uri
|
|
|
|
@account.hub_url = hub_url
|
|
|
|
@account.save!
|
|
|
|
end
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def auto_suspend?
|
2017-11-16 19:06:26 -06:00
|
|
|
domain_block&.suspend?
|
2017-04-16 09:38:29 -05:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def auto_silence?
|
2017-11-16 19:06:26 -06:00
|
|
|
domain_block&.silence?
|
2016-02-20 15:53:20 -06:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def domain_block
|
|
|
|
return @domain_block if defined?(@domain_block)
|
|
|
|
@domain_block = DomainBlock.find_by(domain: @domain)
|
2016-10-12 15:55:00 -05:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def atom_url
|
|
|
|
@atom_url ||= @webfinger.link('http://schemas.google.com/g/2010#updates-from').href
|
|
|
|
end
|
|
|
|
|
|
|
|
def salmon_url
|
|
|
|
@salmon_url ||= @webfinger.link('salmon').href
|
|
|
|
end
|
|
|
|
|
2017-08-08 14:52:15 -05:00
|
|
|
def actor_url
|
|
|
|
@actor_url ||= @webfinger.link('self').href
|
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def url
|
|
|
|
@url ||= @webfinger.link('http://webfinger.net/rel/profile-page').href
|
|
|
|
end
|
|
|
|
|
|
|
|
def public_key
|
|
|
|
@public_key ||= magic_key_to_pem(@webfinger.link('magic-public-key').href)
|
|
|
|
end
|
|
|
|
|
|
|
|
def canonical_uri
|
|
|
|
return @canonical_uri if defined?(@canonical_uri)
|
|
|
|
|
|
|
|
author_uri = atom.at_xpath('/xmlns:feed/xmlns:author/xmlns:uri')
|
2016-10-12 15:55:00 -05:00
|
|
|
|
|
|
|
if author_uri.nil?
|
2017-07-19 07:44:04 -05:00
|
|
|
owner = atom.at_xpath('/xmlns:feed').at_xpath('./dfrn:owner', dfrn: DFRN_NS)
|
2016-10-12 15:55:00 -05:00
|
|
|
author_uri = owner.at_xpath('./xmlns:uri') unless owner.nil?
|
|
|
|
end
|
|
|
|
|
2017-07-19 18:59:07 -05:00
|
|
|
@canonical_uri = author_uri.nil? ? nil : author_uri.content
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def hub_url
|
|
|
|
return @hub_url if defined?(@hub_url)
|
|
|
|
|
2017-07-19 18:59:07 -05:00
|
|
|
hubs = atom.xpath('//xmlns:link[@rel="hub"]')
|
|
|
|
@hub_url = hubs.empty? || hubs.first['href'].nil? ? nil : hubs.first['href']
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def atom_body
|
|
|
|
return @atom_body if defined?(@atom_body)
|
|
|
|
|
2018-03-24 06:49:54 -05:00
|
|
|
@atom_body = Request.new(:get, atom_url).perform do |response|
|
|
|
|
raise Mastodon::UnexpectedResponseError, response unless response.code == 200
|
2018-03-26 07:02:10 -05:00
|
|
|
response.body_with_limit
|
2018-03-24 06:49:54 -05:00
|
|
|
end
|
2017-07-19 07:44:04 -05:00
|
|
|
end
|
|
|
|
|
2017-08-14 04:27:25 -05:00
|
|
|
def actor_json
|
|
|
|
return @actor_json if defined?(@actor_json)
|
|
|
|
|
2017-10-03 18:13:48 -05:00
|
|
|
json = fetch_resource(actor_url, false)
|
2018-05-02 05:40:24 -05:00
|
|
|
@actor_json = supported_context?(json) && equals_or_includes_any?(json['type'], ActivityPub::FetchRemoteAccountService::SUPPORTED_TYPES) ? json : nil
|
2017-08-14 04:27:25 -05:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def atom
|
|
|
|
return @atom if defined?(@atom)
|
|
|
|
@atom = Nokogiri::XML(atom_body)
|
|
|
|
end
|
|
|
|
|
|
|
|
def update_account_profile
|
|
|
|
RemoteProfileUpdateWorker.perform_async(@account.id, atom_body.force_encoding('UTF-8'), false)
|
2016-10-12 15:55:00 -05:00
|
|
|
end
|
|
|
|
|
2017-07-19 07:44:04 -05:00
|
|
|
def lock_options
|
|
|
|
{ redis: Redis.current, key: "resolve:#{@username}@#{@domain}" }
|
2016-02-28 07:26:26 -06:00
|
|
|
end
|
2016-02-20 15:53:20 -06:00
|
|
|
end
|