48 lines
1,017 B
Elixir
48 lines
1,017 B
Elixir
defmodule MorseServer do
|
|
use GenServer
|
|
use Application
|
|
|
|
@impl true
|
|
def start(_type, _args) do
|
|
start_link()
|
|
end
|
|
|
|
def start_link do
|
|
GenServer.start_link(__MODULE__, {nil, 0}, name: __MODULE__)
|
|
end
|
|
|
|
def start_morse do
|
|
GenServer.call(__MODULE__, :start)
|
|
end
|
|
|
|
def update_progress(progress) do
|
|
GenServer.cast(__MODULE__, {:progress, progress})
|
|
end
|
|
|
|
@impl true
|
|
def init(state) do
|
|
{:ok, state}
|
|
end
|
|
|
|
@impl true
|
|
def handle_call(:start, _from, {pid, _progress} = state) do
|
|
cond do
|
|
pid == nil or not Process.alive?(pid) ->
|
|
pid = spawn(&MorseSignaler.signal/0)
|
|
{:reply, :ok, {pid, 0}}
|
|
|
|
true ->
|
|
{:reply, {:error, :already_started}, state}
|
|
end
|
|
end
|
|
|
|
@impl true
|
|
def handle_cast({:progress, new_progress}, {pid, _progress}) do
|
|
broadcast_progress(new_progress)
|
|
{:noreply, {pid, new_progress}}
|
|
end
|
|
|
|
defp broadcast_progress(progress) do
|
|
UiWeb.Endpoint.broadcast("morse:progress", "update", %{value: progress})
|
|
end
|
|
end
|