mastodon/app/services/process_interaction_service.rb

120 lines
3.6 KiB
Ruby
Raw Normal View History

2016-02-24 12:57:29 +01:00
class ProcessInteractionService < BaseService
2016-10-10 18:05:52 +02:00
ACTIVITY_NS = 'http://activitystrea.ms/spec/1.0/'.freeze
2016-02-24 12:57:29 +01:00
# Record locally the remote interaction with our user
# @param [String] envelope Salmon envelope
# @param [Account] target_account Account the Salmon was addressed to
2016-02-22 16:00:20 +01:00
def call(envelope, target_account)
body = salmon.unpack(envelope)
xml = Nokogiri::XML(body)
return unless contains_author?(xml)
2016-02-22 16:00:20 +01:00
username = xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:name').content
url = xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:uri').content
2016-02-22 16:00:20 +01:00
domain = Addressable::URI.parse(url).host
account = Account.find_by(username: username, domain: domain)
2016-10-09 14:48:43 +02:00
return if DomainBlock.blocked?(domain)
2016-02-22 16:00:20 +01:00
if account.nil?
2016-09-29 21:28:21 +02:00
account = follow_remote_account_service.call("#{username}@#{domain}")
2016-02-22 16:00:20 +01:00
end
if salmon.verify(envelope, account.keypair)
2016-09-29 21:28:21 +02:00
update_remote_profile_service.call(xml.at_xpath('/xmlns:entry/xmlns:author'), account)
case verb(xml)
when :follow
follow!(account, target_account)
when :unfollow
unfollow!(account, target_account)
when :favorite
favourite!(xml, account)
when :post
add_post!(body, account) if mentions_account?(xml, target_account)
when :share
2016-02-24 02:15:58 +01:00
add_post!(body, account) unless status(xml).nil?
when :delete
delete_post!(xml, account)
2016-02-22 16:00:20 +01:00
end
end
rescue Goldfinger::Error, HTTP::Error, OStatus2::BadSalmonError
nil
2016-02-22 16:00:20 +01:00
end
private
def contains_author?(xml)
!(xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:name').nil? || xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:uri').nil?)
end
def mentions_account?(xml, account)
xml.xpath('/xmlns:entry/xmlns:link[@rel="mentioned"]').each { |mention_link| return true if mention_link.attribute('href').value == TagManager.instance.url_for(account) }
false
end
def verb(xml)
2016-10-10 18:05:52 +02:00
xml.at_xpath('//activity:verb', activity: ACTIVITY_NS).content.gsub('http://activitystrea.ms/schema/1.0/', '').gsub('http://ostatus.org/schema/1.0/', '').to_sym
rescue
:post
end
def follow!(account, target_account)
account.follow!(target_account)
NotificationMailer.follow(target_account, account).deliver_later unless target_account.blocking?(account)
end
def unfollow!(account, target_account)
account.unfollow!(target_account)
end
def delete_post!(xml, account)
status = Status.find(activity_id(xml))
return if status.nil?
if account.id == status.account_id
2016-09-29 21:28:21 +02:00
remove_status_service.call(status)
end
end
def favourite!(xml, from_account)
current_status = status(xml)
current_status.favourites.where(account: from_account).first_or_create!(account: from_account)
NotificationMailer.favourite(current_status, from_account).deliver_later unless current_status.account.blocking?(from_account)
end
def add_post!(body, account)
2016-09-29 21:28:21 +02:00
process_feed_service.call(body, account)
end
def status(xml)
Status.find(TagManager.instance.unique_tag_to_local_id(activity_id(xml), 'Status'))
end
def activity_id(xml)
2016-10-10 18:05:52 +02:00
xml.at_xpath('//activity:object/xmlns:id', activity: ACTIVITY_NS).content
2016-02-22 19:11:07 +01:00
end
2016-02-22 16:00:20 +01:00
def salmon
2016-02-24 12:57:29 +01:00
@salmon ||= OStatus2::Salmon.new
2016-02-22 16:00:20 +01:00
end
def follow_remote_account_service
2016-02-24 12:57:29 +01:00
@follow_remote_account_service ||= FollowRemoteAccountService.new
2016-02-22 16:00:20 +01:00
end
def process_feed_service
2016-02-24 12:57:29 +01:00
@process_feed_service ||= ProcessFeedService.new
end
def update_remote_profile_service
@update_remote_profile_service ||= UpdateRemoteProfileService.new
end
def remove_status_service
@remove_status_service ||= RemoveStatusService.new
end
2016-02-22 16:00:20 +01:00
end