Packages

quantum

1.2.1
3.5.3 3.5.2 retired 3.5.1 retired 3.5.0 3.4.0 3.3.0 3.2.0 3.1.0 3.0.2 3.0.1 3.0.0 3.0.0-rc.3 3.0.0-rc.2 3.0.0-rc.1 2.4.0 2.3.4 2.3.3 2.3.2 2.3.1 retired 2.3.0 retired 2.2.7 2.2.6 2.2.5 retired 2.2.4 retired 2.2.3 retired 2.2.2 retired 2.2.1 retired 2.2.0 retired 2.1.3 retired 2.1.2 retired 2.1.1 retired 2.1.0 retired 2.1.0-beta.1 retired 2.0.4 retired 2.0.3 retired 2.0.2 retired 2.0.1 retired 2.0.0 retired 2.0.0-beta.2 retired 2.0.0-beta.1 retired 1.9.3 retired 1.9.2 retired 1.9.1 retired 1.9.0 retired 1.8.1 retired 1.8.0 retired 1.7.1 retired 1.7.0 retired 1.6.1 retired 1.6.0 retired 1.5.0 retired 1.4.0 retired 1.3.2 retired 1.3.1 retired 1.3.0 retired 1.2.4 retired 1.2.3 retired 1.2.2 retired 1.2.1 retired 1.2.0 retired 1.1.0 retired 1.0.4 retired 1.0.3 retired 1.0.2 retired 1.0.1 retired 1.0.0 retired

Cron-like job scheduler for Elixir.

Retired package: Security issue - v1 is no longer supported
HexDocs

Current section

Files

Jump to
Readme
66 Versions
0 Dependencies
Dependants
Files
Activity
quantum lib quantum.ex
Raw

lib/quantum.ex 

defmodule Quantum do

  use GenServer

  import Process, only: [send_after: 3]



  @typedoc "A function/0 to be called when cron expression matches"

  @type fun0 :: (() -> Type)

  @typedoc "A job is defined by a cron expression and a function/0"

  @type job :: {String.t | Atom, fun0}



  @doc "Adds a new job"

  @spec add_job(String.t, fun0) :: :ok

  def add_job(spec, job) do

    GenServer.call(__MODULE__, {:add_job, spec, job})

  end



  @doc "Returns the list of currently defined jobs"

  @spec jobs :: [job]

  def jobs do

    GenServer.call(__MODULE__, :jobs)

  end



  def init(_) do

    tick

    {:ok, %{jobs: Application.get_env(:quantum, :cron, []), d: nil, h: nil, m: nil, w: nil}}

  end



  def handle_call({:add_job, spec, job}, _from, state) do

    {:reply, :ok, %{state | jobs: [{spec, job} | state.jobs]}}

  end



  def handle_call(:jobs, _from, state) do

    {:reply, state.jobs, state}

  end



  def handle_info(:tick, state) do

    {d, h, m} = tick

    if state.d != d, do: state = %{state | d: d, w: rem(:calendar.day_of_the_week(d), 7)}

    state = %{state | h: h, m: m}

    Enum.each(state.jobs, fn({e, fun}) -> execute(e, fun, state) end)

    {:noreply, state}

  end

  def handle_info(_, state), do: {:noreply, state}



  defp execute(e, fun, state) do

    Task.start(Quantum.Executor, :execute, [e, fun, state])

  end



  defp tick do

    {d, {h, m, s}} = :calendar.now_to_universal_time(:os.timestamp)

    send_after(self, :tick, (60 - s) * 1000)

    {d, h, m}

  end



end