39 lines
1.0 KiB
Ruby
39 lines
1.0 KiB
Ruby
class ProcessInteractionService
|
|
def call(envelope, target_account)
|
|
body = salmon.unpack(envelope)
|
|
xml = Nokogiri::XML(body)
|
|
|
|
return if xml.at_xpath('//author/name').nil? || xml.at_xpath('//author/uri').nil?
|
|
|
|
username = xml.at_xpath('//author/name').content
|
|
url = xml.at_xpath('//author/uri').content
|
|
domain = Addressable::URI.parse(url).host
|
|
account = Account.find_by(username: username, domain: domain)
|
|
|
|
if account.nil?
|
|
account = follow_remote_account_service.("acct:#{username}@#{domain}")
|
|
end
|
|
|
|
if salmon.verify(envelope, account.keypair)
|
|
verb = xml.at_path('//activity:verb').content
|
|
|
|
case verb
|
|
when 'http://activitystrea.ms/schema/1.0/follow', 'follow'
|
|
account.follow!(target_account)
|
|
when 'http://activitystrea.ms/schema/1.0/unfollow', 'unfollow'
|
|
account.unfollow!(target_account)
|
|
end
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def salmon
|
|
OStatus2::Salmon.new
|
|
end
|
|
|
|
def follow_remote_account_service
|
|
FollowRemoteAccountService.new
|
|
end
|
|
end
|