gen_queue_verk

defmodule GenQueue.Adapters.VerkMock do
  @moduledoc """
  An adapter for `GenQueue` to enable mock functionaility with `Verk`.
  """

  use GenQueue.Adapter

  alias GenQueue.Adapters.Verk, as: VerkAdapter

  def start_link(_gen_queue, _opts) do
    :ignore
  end

  @doc """
  Push a job that will be returned to the current (or globally set) processes
  mailbox. Please see `GenQueue.Test` for further details.

  ## Parameters:
    * `gen_queue` - Any GenQueue module
    * `job` - Any valid job format
    * `opts` - A keyword list of job options

  ## Options
    * `:queue` - The queue to push the job to. Defaults to "default".
    * `:delay` - Either a `DateTime` or millseconds-based integer.

  ## Returns:
    * `{:ok, {module, args, opts}}` if the operation was successful
    * `{:error, reason}` if there was an error
  """
  def handle_push(gen_queue, module, opts) when is_atom(module) do
    do_return(gen_queue, module, [], VerkAdapter.build_opts_map(opts))
  end

  def handle_push(gen_queue, {module}, opts) do
    do_return(gen_queue, module, [], VerkAdapter.build_opts_map(opts))
  end

  def handle_push(gen_queue, {module, args}, opts) when is_list(args) do
    do_return(gen_queue, module, args, VerkAdapter.build_opts_map(opts))
  end

  def handle_push(gen_queue, {module, arg}, opts) do
    do_return(gen_queue, module, [arg], VerkAdapter.build_opts_map(opts))
  end

  @doc false
  def handle_pop(_gen_queue, _opts) do
    {:error, :not_implemented}
  end

  @doc false
  def handle_flush(_gen_queue, _opts) do
    {:error, :not_implemented}
  end

  @doc false
  def handle_length(_gen_queue, _opts) do
    {:error, :not_implemented}
  end

  defp do_return(gen_queue, module, args, opts) do
    job = {module, args, Map.put(opts, :jid, generate_jid())}
    GenQueue.Test.send_item(gen_queue, job)
    {:ok, job}
  end

  defp generate_jid do
    <<part1::32, part2::32>> = :crypto.strong_rand_bytes(8)
   "#{part1}#{part2}"
  end
end