Graham McIntire
80f2725cd5
Non-admin users can now submit beacons but they are held in an unapproved state until an admin approves them. Only approved beacons appear in the public list; pending submissions are shown in a separate admin-only section on /beacons with Approve and Delete actions. The show page surfaces a pending badge and an admin-only Approve button when viewing an unapproved beacon. Also formats EIRP (mW) on the index page without scientific notation.
101 lines
2.5 KiB
Elixir
101 lines
2.5 KiB
Elixir
defmodule Microwaveprop.Beacons do
|
|
@moduledoc """
|
|
The Beacons context. Any authenticated user can submit a beacon,
|
|
but submissions are held as unapproved until an admin approves
|
|
them. Only approved beacons appear in the public list.
|
|
"""
|
|
|
|
import Ecto.Query, warn: false
|
|
|
|
alias Microwaveprop.Accounts.User
|
|
alias Microwaveprop.Beacons.Beacon
|
|
alias Microwaveprop.Repo
|
|
|
|
@topic "beacons"
|
|
|
|
@doc """
|
|
Subscribes to beacon change notifications. Messages:
|
|
|
|
* `{:created, %Beacon{}}`
|
|
* `{:updated, %Beacon{}}`
|
|
* `{:deleted, %Beacon{}}`
|
|
"""
|
|
def subscribe_beacons do
|
|
Phoenix.PubSub.subscribe(Microwaveprop.PubSub, @topic)
|
|
end
|
|
|
|
defp broadcast(message) do
|
|
Phoenix.PubSub.broadcast(Microwaveprop.PubSub, @topic, message)
|
|
end
|
|
|
|
@doc "Returns approved beacons ordered by frequency."
|
|
def list_beacons do
|
|
Repo.all(
|
|
from b in Beacon,
|
|
where: b.approved == true,
|
|
order_by: [asc: b.frequency_mhz, asc: b.callsign]
|
|
)
|
|
end
|
|
|
|
@doc "Returns unapproved beacons awaiting admin review."
|
|
def list_pending_beacons do
|
|
Repo.all(
|
|
from b in Beacon,
|
|
where: b.approved == false,
|
|
order_by: [asc: b.inserted_at]
|
|
)
|
|
end
|
|
|
|
@doc "Gets a single beacon. Raises if not found."
|
|
def get_beacon!(id), do: Repo.get!(Beacon, id)
|
|
|
|
@doc """
|
|
Creates a beacon. The user is recorded on the row as the creator.
|
|
"""
|
|
def create_beacon(%User{} = user, attrs) do
|
|
%Beacon{user_id: user.id}
|
|
|> Beacon.changeset(attrs)
|
|
|> Repo.insert()
|
|
|> broadcast_if_ok(:created)
|
|
end
|
|
|
|
@doc "Updates a beacon."
|
|
def update_beacon(%Beacon{} = beacon, attrs) do
|
|
beacon
|
|
|> Beacon.changeset(attrs)
|
|
|> Repo.update()
|
|
|> broadcast_if_ok(:updated)
|
|
end
|
|
|
|
@doc "Marks a beacon as approved, making it visible in the public list."
|
|
def approve_beacon(%Beacon{} = beacon) do
|
|
beacon
|
|
|> Ecto.Changeset.change(approved: true)
|
|
|> Repo.update()
|
|
|> broadcast_if_ok(:updated)
|
|
end
|
|
|
|
@doc "Deletes a beacon."
|
|
def delete_beacon(%Beacon{} = beacon) do
|
|
case Repo.delete(beacon) do
|
|
{:ok, beacon} ->
|
|
broadcast({:deleted, beacon})
|
|
{:ok, beacon}
|
|
|
|
other ->
|
|
other
|
|
end
|
|
end
|
|
|
|
@doc "Returns an `%Ecto.Changeset{}` for tracking beacon changes."
|
|
def change_beacon(%Beacon{} = beacon, attrs \\ %{}) do
|
|
Beacon.changeset(beacon, attrs)
|
|
end
|
|
|
|
defp broadcast_if_ok({:ok, beacon} = result, type) do
|
|
broadcast({type, beacon})
|
|
result
|
|
end
|
|
|
|
defp broadcast_if_ok(other, _type), do: other
|
|
end
|