rclex

defmodule Rclex.JobQueue do
  require Logger
  use GenServer, restart: :transient

  @moduledoc """
  Queue jobs, jobs in the queue are executed when jobs count reached the queue length or over.

  * queue length is changeable
    * if not specified the length to be 1

  Used by `Rclex.Timer` and `Rclex.Subscriber`.
  """

  # FIXME: below comment feature is not implemented
  # queue_lengthが-1なら外部から呼ばれるまでqueueをため続ける

  @spec start_link({target_identifier :: charlist()}) :: GenServer.on_start()
  def start_link({target_identifier}) do
    GenServer.start_link(__MODULE__, {target_identifier, 1},
      name: {:global, "#{target_identifier}/JobQueue"}
    )
  end

  @spec start_link({target_identifier :: charlist(), queue_length :: integer()}) ::
          GenServer.on_start()
  def start_link({target_identifier, queue_length}) do
    GenServer.start_link(__MODULE__, {target_identifier, queue_length},
      name: {:global, "#{target_identifier}/JobQueue"}
    )
  end

  @impl GenServer
  def init({target_identifier, queue_length}) do
    {:ok, {target_identifier, queue_length, :queue.new()}}
  end

  @impl GenServer
  def handle_cast({:push, job}, {target_identifier, queue_length, job_queue}) do
    new_job_queue = :queue.in(job, job_queue)

    if :queue.len(new_job_queue) >= queue_length do
      GenServer.cast({:global, "#{target_identifier}/JobExecutor"}, {:execute, new_job_queue})
      {:noreply, {target_identifier, queue_length, :queue.new()}}
    else
      {:noreply, {target_identifier, queue_length, new_job_queue}}
    end
  end
end