This repository has been archived on 2024-07-22. You can view files and clone it, but cannot push or open issues or pull requests.
2019-01-05 03:43:28 -08:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
|
|
class PublishScheduledStatusWorker
|
|
|
|
|
include Sidekiq::Worker
|
|
|
|
|
|
2020-03-31 12:59:03 -07:00
|
|
|
sidekiq_options lock: :until_executed
|
2019-01-20 03:57:05 -08:00
|
|
|
|
2019-01-05 03:43:28 -08:00
|
|
|
def perform(scheduled_status_id)
|
|
|
|
|
scheduled_status = ScheduledStatus.find(scheduled_status_id)
|
|
|
|
|
scheduled_status.destroy!
|
|
|
|
|
|
|
|
|
|
PostStatusService.new.call(
|
|
|
|
|
scheduled_status.account,
|
|
|
|
|
options_with_objects(scheduled_status.params.with_indifferent_access)
|
|
|
|
|
)
|
|
|
|
|
rescue ActiveRecord::RecordNotFound, ActiveRecord::RecordInvalid
|
|
|
|
|
true
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def options_with_objects(options)
|
|
|
|
|
options.tap do |options_hash|
|
|
|
|
|
options_hash[:application] = Doorkeeper::Application.find(options_hash.delete(:application_id)) if options[:application_id]
|
2019-01-06 03:03:27 -08:00
|
|
|
options_hash[:thread] = Status.find(options_hash.delete(:in_reply_to_id)) if options_hash[:in_reply_to_id]
|
2019-01-05 03:43:28 -08:00
|
|
|
end
|
|
|
|
|
end
|
|
|
|
|
end
|
