1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798 |
- 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
- def call(envelope, target_account)
- body = salmon.unpack(envelope)
- xml = Nokogiri::XML(body)
- return unless contains_author?(xml)
- username = xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:name').content
- url = xml.at_xpath('/xmlns:entry/xmlns:author/xmlns:uri').content
- domain = Addressable::URI.parse(url).host
- account = Account.find_by(username: username, domain: domain)
- if account.nil?
- account = follow_remote_account_service.("#{username}@#{domain}", false)
- return if account.nil?
- end
- if salmon.verify(envelope, account.keypair)
- update_remote_profile_service.(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
- add_post!(body, account) unless status(xml).nil?
- end
- end
- 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 == url_for_target(account) }
- false
- end
- def verb(xml)
- xml.at_xpath('//activity:verb').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
- end
- def unfollow!(account, target_account)
- account.unfollow!(target_account)
- 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
- end
- def add_post!(body, account)
- process_feed_service.(body, account)
- end
- def status(xml)
- Status.find(unique_tag_to_local_id(activity_id(xml), 'Status'))
- end
- def activity_id(xml)
- xml.at_xpath('//activity:object/xmlns:id').content
- end
- def salmon
- @salmon ||= OStatus2::Salmon.new
- end
- def follow_remote_account_service
- @follow_remote_account_service ||= FollowRemoteAccountService.new
- end
- def process_feed_service
- @process_feed_service ||= ProcessFeedService.new
- end
- def update_remote_profile_service
- @update_remote_profile_service ||= UpdateRemoteProfileService.new
- end
- end
|