# frozen_string_literal: true class FavouriteService < BaseService include Authorization include Payloadable # Favourite a status and notify remote user # @param [Account] account # @param [Status] status # @return [Favourite] def call(account, status) authorize_with account, status, :favourite? favourite = Favourite.find_by(account: account, status: status) return favourite unless favourite.nil? favourite = Favourite.create!(account: account, status: status) curate!(status) unless status.curated? || !status.published? create_notification(favourite) bump_potential_friendship(account, status) favourite end private def create_notification(favourite) status = favourite.status if status.account.local? NotifyService.new.call(status.account, :favourite, favourite) elsif status.account.activitypub? ActivityPub::DeliveryWorker.perform_async(build_json(favourite), favourite.account_id, status.account.inbox_url) end end def bump_potential_friendship(account, status) ActivityTracker.increment('activity:interactions') return if account.following?(status.account_id) PotentialFriendshipTracker.record(account.id, status.account_id, :favourite) end def build_json(favourite) Oj.dump(serialize_payload(favourite, ActivityPub::LikeSerializer)) end def curate!(status) status.curate! DistributionWorker.perform_async(status.id) end end