+
+ {format_data_timestamp(@selected_time)}
+
+
<.pipeline_status_chip
id="pipeline-status-desktop"
status={@pipeline_status}
diff --git a/test/microwaveprop/workers/propagation_grid_worker_test.exs b/test/microwaveprop/workers/propagation_grid_worker_test.exs
new file mode 100644
index 00000000..885be7d8
--- /dev/null
+++ b/test/microwaveprop/workers/propagation_grid_worker_test.exs
@@ -0,0 +1,56 @@
+defmodule Microwaveprop.Workers.PropagationGridWorkerTest do
+ @moduledoc """
+ Tests the chain-orchestration behavior of PropagationGridWorker.
+
+ The worker processes forecast hours f00–f18 across the CONUS grid,
+ but a single full sweep takes ~2 hours of wall time — longer than a
+ typical pod restart window. To survive deploys, the worker processes
+ ONE forecast hour per `perform/1` call and enqueues the next hour as
+ a fresh Oban job. The tests here cover the dispatch + chain logic
+ without mocking the full HRRR / scoring stack.
+ """
+ use Microwaveprop.DataCase, async: false
+ use Oban.Testing, repo: Microwaveprop.Repo
+
+ alias Microwaveprop.Workers.PropagationGridWorker
+
+ describe "perform/1 — chain seeding (empty args)" do
+ test "enqueues a single fh=0 chain step with a normalized run_time" do
+ Oban.Testing.with_testing_mode(:manual, fn ->
+ assert :ok = PropagationGridWorker.perform(%Oban.Job{args: %{}})
+
+ [child] = all_enqueued(worker: PropagationGridWorker)
+ assert child.args["forecast_hour"] == 0
+ assert is_binary(child.args["run_time"])
+
+ {:ok, run_time, _} = DateTime.from_iso8601(child.args["run_time"])
+ assert run_time.minute == 0
+ assert run_time.second == 0
+ assert DateTime.before?(run_time, DateTime.utc_now())
+ end)
+ end
+ end
+
+ describe "enqueue_next_step/2" do
+ test "enqueues fh+1 when fh < max" do
+ run_time = ~U[2026-04-14 16:00:00Z]
+
+ Oban.Testing.with_testing_mode(:manual, fn ->
+ assert {:ok, _} = PropagationGridWorker.enqueue_next_step(run_time, 0)
+
+ [child] = all_enqueued(worker: PropagationGridWorker)
+ assert child.args["forecast_hour"] == 1
+ assert child.args["run_time"] == DateTime.to_iso8601(run_time)
+ end)
+ end
+
+ test "does not enqueue anything after the final forecast hour" do
+ run_time = ~U[2026-04-14 16:00:00Z]
+
+ Oban.Testing.with_testing_mode(:manual, fn ->
+ assert :final = PropagationGridWorker.enqueue_next_step(run_time, 18)
+ assert [] = all_enqueued(worker: PropagationGridWorker)
+ end)
+ end
+ end
+end
diff --git a/test/microwaveprop_web/live/map_live_test.exs b/test/microwaveprop_web/live/map_live_test.exs
index 63a03e29..c0de8c94 100644
--- a/test/microwaveprop_web/live/map_live_test.exs
+++ b/test/microwaveprop_web/live/map_live_test.exs
@@ -98,6 +98,41 @@ defmodule MicrowavepropWeb.MapLiveTest do
end
end
+ describe "data timestamp indicator" do
+ test "renders a 'Data from …' line on both mobile and desktop sidebars", %{conn: conn} do
+ {:ok, _lv, html} = live(conn, ~p"/map")
+ assert html =~ ~s(id="data-timestamp-mobile")
+ assert html =~ ~s(id="data-timestamp-desktop")
+ # Clean test DB has no scores; the indicator falls back to "No data".
+ assert html =~ "No data"
+ end
+ end
+
+ describe "format_data_timestamp/1" do
+ alias MicrowavepropWeb.MapLive
+
+ test "returns 'No data' for nil" do
+ assert MapLive.format_data_timestamp(nil) == "No data"
+ end
+
+ test "renders the valid_time and a 'now' suffix when within ±30 minutes" do
+ now = DateTime.utc_now()
+ label = MapLive.format_data_timestamp(now)
+ assert label =~ "UTC"
+ assert label =~ "now"
+ end
+
+ test "renders a '+Nh' suffix when the valid_time is in the future" do
+ future = DateTime.add(DateTime.utc_now(), 3 * 3600, :second)
+ assert MapLive.format_data_timestamp(future) =~ "+3h"
+ end
+
+ test "renders a 'Nh ago' suffix when the valid_time is in the past" do
+ past = DateTime.add(DateTime.utc_now(), -4 * 3600, :second)
+ assert MapLive.format_data_timestamp(past) =~ "4h ago"
+ 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")