+ <%= case @status.state do %>
+ <% :running -> %>
+ <.icon
+ name="hero-arrow-path"
+ class="size-3.5 shrink-0 text-info motion-safe:animate-spin"
+ />
+ {@status.label}
+ <% :idle -> %>
+
+ {@status.label}
+ <% :stale -> %>
+
+ {@status.label}
+ <% :unknown -> %>
+
+ {@status.label}
+ <% end %>
+
+ """
+ end
+
@impl true
def render(assigns) do
~H"""
@@ -405,6 +453,8 @@ defmodule MicrowavepropWeb.MapLive do
+ <.pipeline_status_chip id="pipeline-status-mobile" status={@pipeline_status} />
+
{selected_label(@bands, @selected_band)}
@@ -558,6 +608,8 @@ defmodule MicrowavepropWeb.MapLive do
+ <.pipeline_status_chip id="pipeline-status-desktop" status={@pipeline_status} />
+
<%!-- Band selector --%>
diff --git a/test/microwaveprop/propagation/pipeline_status_test.exs b/test/microwaveprop/propagation/pipeline_status_test.exs
new file mode 100644
index 00000000..47397eff
--- /dev/null
+++ b/test/microwaveprop/propagation/pipeline_status_test.exs
@@ -0,0 +1,143 @@
+defmodule Microwaveprop.Propagation.PipelineStatusTest do
+ use Microwaveprop.DataCase, async: false
+
+ alias Microwaveprop.Propagation.PipelineStatus
+ alias Microwaveprop.Repo
+
+ @grid_worker "Microwaveprop.Workers.PropagationGridWorker"
+ @asos_worker "Microwaveprop.Workers.AsosAdjustmentWorker"
+
+ # Bypass Oban's normal insert pipeline (which executes inline in test)
+ # by writing directly to the Oban.Job schema. The SQL sandbox keeps
+ # Oban's executor from seeing these rows.
+ defp insert_oban_job(overrides) do
+ now = DateTime.utc_now()
+
+ defaults = %{
+ state: "available",
+ queue: "propagation",
+ worker: @grid_worker,
+ args: %{},
+ attempt: 0,
+ max_attempts: 3,
+ inserted_at: now,
+ scheduled_at: now
+ }
+
+ attrs = Map.merge(defaults, Map.new(overrides))
+ Repo.insert!(struct!(Oban.Job, attrs))
+ end
+
+ defp minutes_ago(n) do
+ DateTime.add(DateTime.utc_now(), -n * 60, :second)
+ end
+
+ describe "current/0" do
+ test "returns :unknown when no pipeline jobs have ever run" do
+ status = PipelineStatus.current()
+
+ assert status.state == :unknown
+ assert status.last_update_at == nil
+ assert is_binary(status.label)
+ end
+
+ test "returns :running with grid worker label when PropagationGridWorker is executing" do
+ insert_oban_job(%{
+ state: "executing",
+ worker: @grid_worker,
+ attempted_at: minutes_ago(5)
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :running
+ assert status.label =~ "HRRR"
+ end
+
+ test "returns :running with ASOS label when AsosAdjustmentWorker is executing" do
+ insert_oban_job(%{
+ state: "executing",
+ worker: @asos_worker,
+ attempted_at: minutes_ago(1)
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :running
+ assert status.label =~ "ASOS"
+ end
+
+ test "returns :idle with Up to date label when last grid run completed recently" do
+ completed = minutes_ago(15)
+
+ insert_oban_job(%{
+ state: "completed",
+ worker: @grid_worker,
+ attempted_at: completed,
+ completed_at: completed
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :idle
+ assert status.last_update_at
+ assert status.label =~ "Up to date"
+ end
+
+ test "returns :stale when last completed was more than 120 minutes ago" do
+ stale = minutes_ago(180)
+
+ insert_oban_job(%{
+ state: "completed",
+ worker: @grid_worker,
+ attempted_at: stale,
+ completed_at: stale
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :stale
+ assert status.label =~ "stale"
+ end
+
+ test "prefers :running over :idle when a job is executing even if a recent job completed" do
+ recent = minutes_ago(5)
+
+ insert_oban_job(%{
+ state: "completed",
+ worker: @grid_worker,
+ attempted_at: recent,
+ completed_at: recent
+ })
+
+ insert_oban_job(%{
+ state: "executing",
+ worker: @grid_worker,
+ attempted_at: minutes_ago(1)
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :running
+ end
+
+ test "ignores completed jobs from unrelated workers" do
+ # WeatherFetchWorker enriches individual QSOs — it's not part of
+ # the CONUS grid update pipeline, so its recent success should
+ # not make the map page show 'Up to date'.
+ completed = minutes_ago(5)
+
+ insert_oban_job(%{
+ state: "completed",
+ worker: "Microwaveprop.Workers.WeatherFetchWorker",
+ queue: "weather",
+ attempted_at: completed,
+ completed_at: completed
+ })
+
+ status = PipelineStatus.current()
+
+ assert status.state == :unknown
+ end
+ end
+end
diff --git a/test/microwaveprop_web/live/map_live_test.exs b/test/microwaveprop_web/live/map_live_test.exs
index 4063c6bc..2c6336f4 100644
--- a/test/microwaveprop_web/live/map_live_test.exs
+++ b/test/microwaveprop_web/live/map_live_test.exs
@@ -97,4 +97,15 @@ defmodule MicrowavepropWeb.MapLiveTest do
refute html =~ "checked"
end
end
+
+ describe "pipeline status chip" do
+ test "renders the aggregated pipeline status chip on mount", %{conn: conn} do
+ {:ok, _lv, html} = live(conn, ~p"/map")
+ # Both the mobile and desktop sidebars carry their own chip.
+ assert html =~ ~s(id="pipeline-status-mobile")
+ assert html =~ ~s(id="pipeline-status-desktop")
+ # With a clean test DB no pipeline workers have ever run.
+ assert html =~ ~s(data-pipeline-state="unknown")
+ end
+ end
end