mirror of
https://github.com/jcwimer/wrestlingApp
synced 2026-03-25 01:14:43 +00:00
35 lines
1.1 KiB
Ruby
35 lines
1.1 KiB
Ruby
class AdvanceWrestlerJob < ApplicationJob
|
|
queue_as :default
|
|
# associations are not available here so we had to pass tournament_id when creating the job
|
|
limits_concurrency to: 1, key: ->(_wrestler, _match, tournament_id) { "tournament:#{tournament_id}" }
|
|
|
|
def perform(wrestler, match, tournament_id)
|
|
# Get tournament from wrestler
|
|
tournament = wrestler.tournament
|
|
|
|
# Create job status record
|
|
job_name = "Advancing wrestler #{wrestler.name}"
|
|
job_status = TournamentJobStatus.create!(
|
|
tournament: tournament,
|
|
job_name: job_name,
|
|
status: "Running",
|
|
details: "Match ID: #{match&.bout_number || 'No match'} Wrestler Name #{wrestler&.name || 'No Wrestler'}"
|
|
)
|
|
|
|
begin
|
|
# Execute the job
|
|
service = AdvanceWrestler.new(wrestler, match)
|
|
service.advance_raw
|
|
|
|
# Remove the job status record on success
|
|
TournamentJobStatus.complete_job(tournament.id, job_name)
|
|
rescue => e
|
|
# Update status to errored
|
|
job_status.update(status: "Errored", details: "Error: #{e.message}")
|
|
|
|
# Re-raise the error for SolidQueue to handle
|
|
raise e
|
|
end
|
|
end
|
|
end
|