16 lines
393 B
Elixir
16 lines
393 B
Elixir
|
defmodule ShootingEventPhx.Events do
|
||
|
|
@moduledoc false
|
||
|
|
@topic "state_updates"
|
||
|
|
|
||
|
|
def topic, do: @topic
|
||
|
|
|
||
|
|
def subscribe do
|
||
|
|
Phoenix.PubSub.subscribe(ShootingEventPhx.PubSub, @topic)
|
||
|
|
end
|
||
|
|
|
||
|
|
def broadcast do
|
||
|
|
payload = {:state, DateTime.utc_now() |> DateTime.truncate(:second) |> DateTime.to_iso8601()}
|
||
|
|
Phoenix.PubSub.broadcast(ShootingEventPhx.PubSub, @topic, payload)
|
||
|
|
end
|
||
|
|
end
|