Justin Edmund
1c1ed0dd9d
* Add Redis and Sidekiq * Rename PreviewGenerationMonitor * Update production.rb require master key * Initialize AWS at application start * Add fallbacks for credentials * Add logging * Create railway.toml
55 lines
1.6 KiB
Ruby
55 lines
1.6 KiB
Ruby
require 'sidekiq/api'
|
|
|
|
module PreviewService
|
|
class GenerationMonitor
|
|
class << self
|
|
def check_stalled_jobs
|
|
Party.where(preview_state: :queued)
|
|
.where('updated_at < ?', 10.minutes.ago)
|
|
.find_each do |party|
|
|
Rails.logger.warn("Found stalled preview generation for party #{party.id}")
|
|
|
|
# If no job is actually queued, reset the state
|
|
unless job_exists?(party)
|
|
party.update!(preview_state: :pending)
|
|
Rails.logger.info("Reset stalled party #{party.id} to pending state")
|
|
end
|
|
end
|
|
end
|
|
|
|
def retry_failed
|
|
Party.where(preview_state: :failed)
|
|
.where('updated_at < ?', 1.hour.ago)
|
|
.find_each do |party|
|
|
Rails.logger.info("Retrying failed preview generation for party #{party.id}")
|
|
GeneratePartyPreviewJob.perform_later(party.id)
|
|
end
|
|
end
|
|
|
|
def cleanup_old_previews
|
|
Party.where(preview_state: :generated)
|
|
.where('preview_generated_at < ?', 30.days.ago)
|
|
.find_each do |party|
|
|
PreviewService::Coordinator.new(party).delete_preview
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def job_exists?(party)
|
|
# Implementation depends on your job backend
|
|
# For Sidekiq:
|
|
queue = Sidekiq::Queue.new('previews')
|
|
scheduled = Sidekiq::ScheduledSet.new
|
|
retrying = Sidekiq::RetrySet.new
|
|
|
|
[queue, scheduled, retrying].any? do |set|
|
|
set.any? do |job|
|
|
job.args.first == party.id &&
|
|
job.klass == 'GeneratePartyPreviewJob'
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|