* Add bell button Fix #4890 * Remove duplicate type from post-deployment migration * Fix legacy class type mappings * Improve query performance with better index * Fix validation * Remove redundant index from notifications
		
			
				
	
	
		
			48 lines
		
	
	
		
			1.3 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
			
		
		
	
	
			48 lines
		
	
	
		
			1.3 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
# 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)
 | 
						|
 | 
						|
    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
 | 
						|
end
 |