Packages

kitto

0.0.2
0.9.1 0.9.0 0.8.0 0.7.0 0.6.0 0.6.0-rc0 0.5.2 0.5.1 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.3 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Framework for creating interactive dashboards

HexDocs

Current section

Files

Jump to
Readme
24 Versions
3 Dependencies
Dependants
Files
Activity
kitto lib notifier.ex
Raw

lib/notifier.ex 

defmodule Kitto.Notifier do

  def start_link, do: Agent.start_link(fn -> [] end, name: :notifier)



  def broadcast!(topic, data) do

    connections |> Enum.each(fn (conn) ->

      if !Process.alive?(conn), do: delete(conn)



      send conn, {:broadcast, {topic, data |> Map.merge(updated_at)}}

    end)

  end



  def register(conn) do

    notifier |> Agent.update(fn (connections) -> connections ++ [conn] end)



    conn

  end



  def delete(conn), do: notifier |> Agent.update(&(&1 |> List.delete(conn)))

  def connections, do: notifier |> Agent.get(&(&1))



  defp notifier, do: Process.whereis(:notifier)

  defp updated_at, do: %{updated_at: :os.system_time(:seconds)}

end