2016-02-24 06:57:29 -05:00
|
|
|
class ProcessInteractionService < BaseService
|
|
|
|
# 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 10:00:20 -05:00
|
|
|
def call(envelope, target_account)
|
|
|
|
body = salmon.unpack(envelope)
|
|
|
|
xml = Nokogiri::XML(body)
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
return unless contains_author?(xml)
|
2016-02-22 10:00:20 -05:00
|
|
|
|
2016-02-23 16:17:07 -05: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 10:00:20 -05:00
|
|
|
domain = Addressable::URI.parse(url).host
|
|
|
|
account = Account.find_by(username: username, domain: domain)
|
|
|
|
|
2016-10-09 08:48:43 -04:00
|
|
|
return if DomainBlock.blocked?(domain)
|
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
if account.nil?
|
2016-09-29 15:28:21 -04:00
|
|
|
account = follow_remote_account_service.call("#{username}@#{domain}")
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
if salmon.verify(envelope, account.keypair)
|
2016-09-29 15:28:21 -04:00
|
|
|
update_remote_profile_service.call(xml.at_xpath('/xmlns:entry/xmlns:author'), account)
|
2016-02-28 08:26:26 -05:00
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
case verb(xml)
|
2016-02-23 16:17:07 -05:00
|
|
|
when :follow
|
2016-02-23 18:57:47 -05:00
|
|
|
follow!(account, target_account)
|
2016-02-23 16:17:07 -05:00
|
|
|
when :unfollow
|
2016-02-23 18:57:47 -05:00
|
|
|
unfollow!(account, target_account)
|
2016-02-23 16:17:07 -05:00
|
|
|
when :favorite
|
2016-02-23 18:57:47 -05:00
|
|
|
favourite!(xml, account)
|
2016-02-23 16:17:07 -05:00
|
|
|
when :post
|
2016-02-23 18:57:47 -05:00
|
|
|
add_post!(body, account) if mentions_account?(xml, target_account)
|
2016-02-23 16:17:07 -05:00
|
|
|
when :share
|
2016-02-23 20:15:58 -05:00
|
|
|
add_post!(body, account) unless status(xml).nil?
|
2016-09-04 08:43:00 -04:00
|
|
|
when :delete
|
|
|
|
delete_post!(xml, account)
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
end
|
2016-10-06 08:46:34 -04:00
|
|
|
rescue Goldfinger::Error, HTTP::Error, OStatus2::BadSalmonError
|
2016-09-17 11:07:45 -04:00
|
|
|
nil
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
2016-02-23 16:17:07 -05:00
|
|
|
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
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def mentions_account?(xml, account)
|
2016-09-09 14:04:34 -04:00
|
|
|
xml.xpath('/xmlns:entry/xmlns:link[@rel="mentioned"]').each { |mention_link| return true if mention_link.attribute('href').value == TagManager.instance.url_for(account) }
|
2016-02-23 18:57:47 -05:00
|
|
|
false
|
2016-02-23 16:17:07 -05:00
|
|
|
end
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def verb(xml)
|
2016-03-16 16:14:39 -04:00
|
|
|
xml.at_xpath('//activity:verb').content.gsub('http://activitystrea.ms/schema/1.0/', '').gsub('http://ostatus.org/schema/1.0/', '').to_sym
|
2016-02-23 19:28:53 -05:00
|
|
|
rescue
|
|
|
|
:post
|
2016-02-23 16:17:07 -05:00
|
|
|
end
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def follow!(account, target_account)
|
|
|
|
account.follow!(target_account)
|
2016-10-03 12:49:52 -04:00
|
|
|
NotificationMailer.follow(target_account, account).deliver_later unless target_account.blocking?(account)
|
2016-02-23 18:57:47 -05:00
|
|
|
end
|
2016-02-23 16:17:07 -05:00
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def unfollow!(account, target_account)
|
|
|
|
account.unfollow!(target_account)
|
|
|
|
end
|
|
|
|
|
2016-09-04 08:43:00 -04:00
|
|
|
def delete_post!(xml, account)
|
|
|
|
status = Status.find(activity_id(xml))
|
|
|
|
|
|
|
|
return if status.nil?
|
|
|
|
|
|
|
|
if account.id == status.account_id
|
2016-09-29 15:28:21 -04:00
|
|
|
remove_status_service.call(status)
|
2016-09-04 08:43:00 -04:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def favourite!(xml, from_account)
|
2016-03-19 14:20:07 -04:00
|
|
|
current_status = status(xml)
|
|
|
|
current_status.favourites.where(account: from_account).first_or_create!(account: from_account)
|
2016-10-03 12:49:52 -04:00
|
|
|
NotificationMailer.favourite(current_status, from_account).deliver_later unless current_status.account.blocking?(from_account)
|
2016-02-23 18:57:47 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def add_post!(body, account)
|
2016-09-29 15:28:21 -04:00
|
|
|
process_feed_service.call(body, account)
|
2016-02-23 16:17:07 -05:00
|
|
|
end
|
|
|
|
|
2016-02-23 18:57:47 -05:00
|
|
|
def status(xml)
|
2016-09-09 14:04:34 -04:00
|
|
|
Status.find(TagManager.instance.unique_tag_to_local_id(activity_id(xml), 'Status'))
|
2016-02-23 18:57:47 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def activity_id(xml)
|
2016-03-25 20:34:12 -04:00
|
|
|
xml.at_xpath('//activity:object/xmlns:id').content
|
2016-02-22 13:11:07 -05:00
|
|
|
end
|
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
def salmon
|
2016-02-24 06:57:29 -05:00
|
|
|
@salmon ||= OStatus2::Salmon.new
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def follow_remote_account_service
|
2016-02-24 06:57:29 -05:00
|
|
|
@follow_remote_account_service ||= FollowRemoteAccountService.new
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
2016-02-23 18:57:47 -05:00
|
|
|
|
|
|
|
def process_feed_service
|
2016-02-24 06:57:29 -05:00
|
|
|
@process_feed_service ||= ProcessFeedService.new
|
2016-02-23 18:57:47 -05:00
|
|
|
end
|
2016-02-28 08:26:26 -05:00
|
|
|
|
|
|
|
def update_remote_profile_service
|
|
|
|
@update_remote_profile_service ||= UpdateRemoteProfileService.new
|
|
|
|
end
|
2016-09-19 18:39:03 -04:00
|
|
|
|
|
|
|
def remove_status_service
|
|
|
|
@remove_status_service ||= RemoveStatusService.new
|
|
|
|
end
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|