03d59340da
* Fix Sidekiq warnings about JSON serialization This occurs on every symbol argument we pass, and every symbol key in hashes, because Sidekiq expects strings instead. See https://github.com/mperham/sidekiq/pull/5071 We do not need to change how workers parse their arguments because this has not changed and we were already converting to symbols adequately or using `with_indifferent_access`. * Set Sidekiq to raise on unsafe arguments in test mode In order to more easily catch issues that would produce warnings in production code.
75 lines
1.6 KiB
Ruby
75 lines
1.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class FeedInsertWorker
|
|
include Sidekiq::Worker
|
|
|
|
def perform(status_id, id, type = 'home', options = {})
|
|
@type = type.to_sym
|
|
@status = Status.find(status_id)
|
|
@options = options.symbolize_keys
|
|
|
|
case @type
|
|
when :home
|
|
@follower = Account.find(id)
|
|
when :list
|
|
@list = List.find(id)
|
|
@follower = @list.account
|
|
end
|
|
|
|
check_and_insert
|
|
rescue ActiveRecord::RecordNotFound
|
|
true
|
|
end
|
|
|
|
private
|
|
|
|
def check_and_insert
|
|
if feed_filtered?
|
|
perform_unpush if update?
|
|
else
|
|
perform_push
|
|
perform_notify if notify?
|
|
end
|
|
end
|
|
|
|
def feed_filtered?
|
|
case @type
|
|
when :home
|
|
FeedManager.instance.filter?(:home, @status, @follower)
|
|
when :list
|
|
FeedManager.instance.filter?(:list, @status, @list)
|
|
end
|
|
end
|
|
|
|
def notify?
|
|
return false if @type != :home || @status.reblog? || (@status.reply? && @status.in_reply_to_account_id != @status.account_id)
|
|
|
|
Follow.find_by(account: @follower, target_account: @status.account)&.notify?
|
|
end
|
|
|
|
def perform_push
|
|
case @type
|
|
when :home
|
|
FeedManager.instance.push_to_home(@follower, @status, update: update?)
|
|
when :list
|
|
FeedManager.instance.push_to_list(@list, @status, update: update?)
|
|
end
|
|
end
|
|
|
|
def perform_unpush
|
|
case @type
|
|
when :home
|
|
FeedManager.instance.unpush_from_home(@follower, @status, update: true)
|
|
when :list
|
|
FeedManager.instance.unpush_from_list(@list, @status, update: true)
|
|
end
|
|
end
|
|
|
|
def perform_notify
|
|
NotifyService.new.call(@follower, :status, @status)
|
|
end
|
|
|
|
def update?
|
|
@options[:update]
|
|
end
|
|
end
|