mirror of
https://github.com/zvx-echo6/meshai.git
synced 2026-08-26 17:31:34 +00:00
2e1fb325f7
- Move all application source (meshai/, dashboard-frontend/, tests/, config/, docs/, Dockerfile, etc.) into work/ directory - Add Node.js multi-stage build to Dockerfile for frontend compilation; remove compiled static assets from git tracking - Fix satpass missing time windows: consolidation was splitting wire on newline and only putting line 1 in event.title, dropping the time window line that the composer uses for precomposed broadcasts - Fix satpass burst flooding: stagger consolidation timers (+60s per pending pass) so Central batch publishes don't blast the mesh - Update CI workflow build context to work/ - Anchor lib/ and data/ gitignore patterns to repo root to prevent false matches on nested directories - Add dashboard-frontend/node_modules/ to .dockerignore Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
268 lines
10 KiB
Python
268 lines
10 KiB
Python
"""Tests for tombstone broadcast path fix.
|
|
|
|
Validates:
|
|
T1: tombstone yields _severity_override="immediate" + commit handles
|
|
T2: closure wire dispatches when New was broadcast >=10min earlier
|
|
T3: build_env_summary excludes tombstoned and 100%-contained fires
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import time
|
|
|
|
import pytest
|
|
|
|
from meshai.central.wfigs_handler import handle_wfigs
|
|
from meshai.notifications.env_reporter import EnvReporter
|
|
from meshai.persistence import get_db
|
|
|
|
|
|
@pytest.fixture
|
|
def reporter():
|
|
return EnvReporter()
|
|
|
|
|
|
def _seed_fire(conn, *, irwin_id, name, acres, contained=None,
|
|
last_broadcast_at=None, last_event_at=None,
|
|
tombstoned_at=None, county="Ada", state="ID"):
|
|
now = int(time.time())
|
|
conn.execute(
|
|
"INSERT OR REPLACE INTO fires(irwin_id, incident_name, incident_type, "
|
|
"current_acres, current_contained_pct, lat, lon, county, state, "
|
|
"declared_at, last_event_at, last_broadcast_at, tombstoned_at) "
|
|
"VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)",
|
|
(irwin_id, name, "WF", acres, contained, 43.6, -116.2,
|
|
county, state, now, last_event_at or now,
|
|
last_broadcast_at, tombstoned_at),
|
|
)
|
|
|
|
|
|
class TestTombstoneSeverityAndCommitHandles:
|
|
"""T1: tombstone branch sets immediate severity and attaches commit handles."""
|
|
|
|
def test_severity_is_immediate(self):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="FIRE-001", name="Test Fire",
|
|
acres=500, contained=80,
|
|
last_broadcast_at=now - 3600)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "FIRE-001"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is not None, "tombstone should produce wire for previously-broadcast fire"
|
|
assert data.get("_severity_override") == "immediate", (
|
|
f"expected immediate, got {data.get('_severity_override')}")
|
|
|
|
def test_commit_handles_attached(self):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="FIRE-002", name="Handled Fire",
|
|
acres=1000, contained=95,
|
|
last_broadcast_at=now - 7200)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "FIRE-002"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is not None
|
|
assert "_on_broadcast_committed" in data, "commit callback missing"
|
|
assert "_broadcast_audit" in data, "broadcast audit descriptor missing"
|
|
assert "_cooldown_suffix" in data, "cooldown suffix missing"
|
|
assert data["_cooldown_suffix"] == "FIRE-002"
|
|
|
|
def test_dedup_suffix_is_closed(self):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="FIRE-003", name="Dedup Fire",
|
|
acres=200, contained=100,
|
|
last_broadcast_at=now - 600)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "FIRE-003"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is not None
|
|
assert data.get("_dedup_suffix") == "closed", (
|
|
f"expected 'closed', got {data.get('_dedup_suffix')}")
|
|
|
|
def test_commit_callback_flips_handled(self):
|
|
"""The commit callback should flip event_log.handled to 1."""
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="FIRE-004", name="Callback Fire",
|
|
acres=300, contained=50,
|
|
last_broadcast_at=now - 1800)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "FIRE-004"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is not None
|
|
assert "_on_broadcast_committed" in data
|
|
|
|
# Before commit: event_log row should have handled=0
|
|
row_before = conn.execute(
|
|
"SELECT id, handled FROM event_log WHERE event_id_external='FIRE-004' "
|
|
"ORDER BY id DESC LIMIT 1"
|
|
).fetchone()
|
|
assert row_before is not None, "event_log row should exist"
|
|
assert row_before["handled"] == 0, "should be unhandled before commit"
|
|
|
|
# Fire the commit callback
|
|
data["_on_broadcast_committed"](float(now))
|
|
|
|
# After commit: handled should be 1
|
|
row_after = conn.execute(
|
|
"SELECT handled FROM event_log WHERE id=?",
|
|
(row_before["id"],)
|
|
).fetchone()
|
|
assert row_after["handled"] == 1, "should be handled=1 after commit callback"
|
|
|
|
|
|
class TestTombstoneAfterNewBroadcast:
|
|
"""T2: closure dispatches when a New broadcast went out earlier."""
|
|
|
|
def test_closure_wire_after_prior_broadcast(self):
|
|
"""Fire that was broadcast 10 min ago gets a closure wire on tombstone."""
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="IA-1", name="IA 1",
|
|
acres=0.1, contained=None,
|
|
last_broadcast_at=now - 600, # 10 min ago
|
|
last_event_at=now - 600)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "IA-1"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is not None, "tombstone should produce wire"
|
|
assert "✅" in wire, "closure wire should contain checkmark"
|
|
assert "IA 1" in wire, "closure wire should name the fire"
|
|
assert data["category"] == "wildfire_closed"
|
|
assert data["_severity_override"] == "immediate"
|
|
assert callable(data.get("_on_broadcast_committed"))
|
|
|
|
def test_no_wire_when_never_broadcast(self):
|
|
"""Fire that was never broadcast should NOT get a closure wire."""
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="SILENT-1", name="Silent Fire",
|
|
acres=5, contained=None,
|
|
last_broadcast_at=None, # never broadcast
|
|
last_event_at=now - 600)
|
|
|
|
data = {}
|
|
wire = handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "SILENT-1"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data=data,
|
|
now=now,
|
|
)
|
|
assert wire is None, "no closure wire for never-broadcast fire"
|
|
|
|
def test_tombstoned_at_stamped(self):
|
|
"""Tombstone should stamp tombstoned_at on the fires row."""
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
_seed_fire(conn, irwin_id="STAMP-1", name="Stamp Fire",
|
|
acres=10, contained=50,
|
|
last_broadcast_at=now - 3600)
|
|
|
|
handle_wfigs(
|
|
normalized={"_kind": "wfigs_tombstone", "irwin_id": "STAMP-1"},
|
|
envelope={"data": {"category": "wildfire", "severity": "immediate"}},
|
|
subject="wfigs.tombstone",
|
|
data={},
|
|
now=now,
|
|
)
|
|
row = conn.execute(
|
|
"SELECT tombstoned_at FROM fires WHERE irwin_id='STAMP-1'"
|
|
).fetchone()
|
|
assert row is not None
|
|
assert row["tombstoned_at"] == now
|
|
|
|
|
|
class TestEnvSummaryExcludesContainedTombstoned:
|
|
"""T3: build_env_summary fire count excludes tombstoned and 100%-contained."""
|
|
|
|
def test_summary_excludes_tombstoned(self, reporter):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
# Active fire
|
|
_seed_fire(conn, irwin_id="ACTIVE-1", name="Active Fire",
|
|
acres=500, contained=20,
|
|
last_event_at=now - 3600)
|
|
# Tombstoned fire
|
|
_seed_fire(conn, irwin_id="DEAD-1", name="Dead Fire",
|
|
acres=1000, contained=100,
|
|
last_event_at=now - 7200,
|
|
tombstoned_at=now - 3600)
|
|
text = reporter.build_env_summary(now=now)
|
|
assert "Active fires (WFIGS, last 7d): 1" in text, (
|
|
f"should count 1 active fire, got: {text}")
|
|
|
|
def test_summary_excludes_100_contained(self, reporter):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
# Active fire, 50% contained
|
|
_seed_fire(conn, irwin_id="HALF-1", name="Half Contained",
|
|
acres=300, contained=50,
|
|
last_event_at=now - 3600)
|
|
# 100% contained, NOT tombstoned
|
|
_seed_fire(conn, irwin_id="FULL-1", name="Fully Contained",
|
|
acres=800, contained=100,
|
|
last_event_at=now - 7200)
|
|
text = reporter.build_env_summary(now=now)
|
|
assert "Active fires (WFIGS, last 7d): 1" in text, (
|
|
f"should count 1 active fire, got: {text}")
|
|
|
|
def test_summary_includes_null_containment(self, reporter):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
# Two fires with NULL containment
|
|
_seed_fire(conn, irwin_id="NULL-1", name="No Containment 1",
|
|
acres=10, contained=None,
|
|
last_event_at=now - 3600)
|
|
_seed_fire(conn, irwin_id="NULL-2", name="No Containment 2",
|
|
acres=20, contained=None,
|
|
last_event_at=now - 7200)
|
|
text = reporter.build_env_summary(now=now)
|
|
assert "Active fires (WFIGS, last 7d): 2" in text, (
|
|
f"should count 2 active fires, got: {text}")
|
|
|
|
def test_summary_empty_when_all_excluded(self, reporter):
|
|
conn = get_db()
|
|
now = int(time.time())
|
|
# Only tombstoned and 100%-contained fires
|
|
_seed_fire(conn, irwin_id="EX-1", name="Ex 1",
|
|
acres=100, contained=100,
|
|
last_event_at=now - 3600,
|
|
tombstoned_at=now - 1800)
|
|
_seed_fire(conn, irwin_id="EX-2", name="Ex 2",
|
|
acres=200, contained=100,
|
|
last_event_at=now - 7200)
|
|
text = reporter.build_env_summary(now=now)
|
|
assert "Active fires" not in text, (
|
|
f"should not mention fires when all excluded, got: {text}")
|