module SidekiqUniqueJobs::Orphans::ReaperResurrector

def current_timestamp
  Time.now.to_i
end

def drift_reaper_interval
  reaper_interval + (reaper_interval * DRIFT_FACTOR).to_i
end

def logging_context
  if logger_context_hash?
    { "uniquejobs" => "reaper-resurrector" }
  else
    "uniquejobs=reaper-resurrector"
  end
end

def orphans_manager
  SidekiqUniqueJobs::Orphans::Manager
end

def reaper
  SidekiqUniqueJobs.config.reaper
end

def reaper_disabled?
  !reaper_enabled?
end

def reaper_enabled?
  REAPERS.include?(reaper)
end

def reaper_interval
  SidekiqUniqueJobs.config.reaper_interval
end

def reaper_registered?
  redis do |conn|
    conn.get(UNIQUE_REAPER).to_i + drift_reaper_interval > current_timestamp
  end
end

def reaper_resurrector_interval
  SidekiqUniqueJobs.config.reaper_resurrector_interval
end

def restart_if_dead
  return if reaper_registered?
  log_info("Reaper is considered dead. Starting new reaper instance")
  orphans_manager.start
end

def resurrector_disabled?
  !resurrector_enabled?
end

def resurrector_enabled?
  SidekiqUniqueJobs.config.reaper_resurrector_enabled
end

def run_task
  log_info("Starting Reaper Resurrector")
  task.execute
  task
end

def start
  return if resurrector_disabled?
  return if reaper_disabled?
  with_logging_context do
    run_task
  end
end

def task
  SidekiqUniqueJobs::TimerTask.new(timer_task_options) do
    with_logging_context do
      restart_if_dead
    end
  end
end

def timer_task_options
  { run_now: false,
    execution_interval: reaper_resurrector_interval }
end