prop/lib/microwaveprop_web/controllers/api/v1/me_controller.ex
Graham McIntire 0704253af8
fix(security,test): viewer-aware profile queries + create_contact ordering + valkey test isolation
- /u/:callsign profile no longer leaks private contacts or pending beacons;
  Radio.list_contacts_for_user/2 and Beacons.list_beacons_for_user/2 now
  filter by viewer (owner/admin see everything, others see only public).
- Radio.create_contact/2 places user_id on the struct before
  submission_changeset so validate_user_or_email/1 accepts authenticated
  submissions that omit submitter_email.
- valkey_test.exs runs async: false; its setup mutates global Application
  env and Process registry, which otherwise crashed concurrent ConnCase
  GridCache.clear/0 calls (Mox.UnexpectedCallError on SCAN).
2026-05-12 08:49:08 -05:00

102 lines
3.1 KiB
Elixir

defmodule MicrowavepropWeb.Api.V1.MeController do
@moduledoc """
Endpoints scoped to the authenticated user's own profile, contacts,
beacons, beacon monitors, and API tokens.
"""
use Phoenix.Controller, formats: [:json]
alias Microwaveprop.Accounts
alias Microwaveprop.BeaconMonitors
alias Microwaveprop.Beacons
alias Microwaveprop.Radio
alias MicrowavepropWeb.Api.ErrorJSON
alias MicrowavepropWeb.Api.V1.BeaconJSON
alias MicrowavepropWeb.Api.V1.BeaconMonitorJSON
alias MicrowavepropWeb.Api.V1.ContactJSON
alias MicrowavepropWeb.Api.V1.TokenJSON
alias MicrowavepropWeb.Api.V1.UserJSON
plug :accepts, ["json"]
action_fallback MicrowavepropWeb.Api.FallbackController
## Profile -----------------------------------------------------------
def show(conn, _params) do
user = conn.assigns.current_api_user
json(conn, UserJSON.me(user))
end
def update(conn, params) do
user = conn.assigns.current_api_user
attrs = Map.take(params, ["home_grid", "home_lat", "home_lon", "home_elevation_m"])
case Accounts.update_user_home_qth(user, attrs) do
{:ok, updated} -> json(conn, UserJSON.me(updated))
{:error, changeset} -> ErrorJSON.send_changeset(conn, changeset)
end
end
## My contacts -------------------------------------------------------
def contacts(conn, _params) do
user = conn.assigns.current_api_user
contacts = Radio.list_contacts_for_user(user, user)
json(conn, ContactJSON.index(%{contacts: contacts, viewer: user}))
end
## My beacons --------------------------------------------------------
def beacons(conn, _params) do
user = conn.assigns.current_api_user
beacons = Beacons.list_beacons_for_user(user, user)
json(conn, BeaconJSON.index(%{beacons: beacons}))
end
## API tokens --------------------------------------------------------
def list_tokens(conn, _params) do
user = conn.assigns.current_api_user
tokens = Accounts.list_api_tokens(user)
json(conn, TokenJSON.index(%{tokens: tokens}))
end
def revoke_token(conn, %{"id" => id}) do
user = conn.assigns.current_api_user
with {:ok, token} <- Accounts.revoke_api_token(user, id) do
json(conn, TokenJSON.show(%{token: token}))
end
end
## Beacon monitors ---------------------------------------------------
def list_monitors(conn, _params) do
user = conn.assigns.current_api_user
monitors = BeaconMonitors.list_monitors_for_user(user)
json(conn, BeaconMonitorJSON.index(%{monitors: monitors}))
end
def create_monitor(conn, params) do
user = conn.assigns.current_api_user
attrs = Map.take(params, ["name"])
case BeaconMonitors.create_monitor(user, attrs) do
{:ok, monitor} ->
conn
|> put_status(:created)
|> json(BeaconMonitorJSON.show(%{monitor: monitor}))
{:error, changeset} ->
ErrorJSON.send_changeset(conn, changeset)
end
end
def delete_monitor(conn, %{"id" => id}) do
user = conn.assigns.current_api_user
with {:ok, _monitor} <- BeaconMonitors.delete_monitor(user, id) do
send_resp(conn, 204, "")
end
end
end