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