Merge pull request #248 from akrherz/pirep_afos

feat: add fake_afos support for PIREP

Author: akrherz

pqact.d/pqact_afos.conf

@@ -44,6 +44,9 @@ IDS|DDPLUS	^UR.... (KNHC|KWBC)
 # G-AIRMET (XML) for NTSB
 IDS|DDPLUS	^LW(G|H|I)E.. KKCI
 	PIPE	pywwa-parse-fake-afos-dump
+# PIREPs
+WMO ^UB
+	PIPE	pywwa-parse-fake-afos-dump
 
 IDS|DDPLUS	^CDUS27
 	PIPE	pywwa-parse-dsm2afos

src/pywwa/workflows/fake_afos_dump.py

@@ -45,6 +45,8 @@ def compute_afos(textprod):
     ttaaii = textprod.wmo
     if ttaaii[:4] == "NOXX":
         afos = f"ADM{textprod.source[1:]}"
+    elif ttaaii.startswith("UB"):
+        afos = "PIREP"
     elif ttaaii in GMET:
         afos = GMET[ttaaii]
     elif MIS.match(ttaaii):

tests/workflows/test_fake_afos_dump.py

@@ -5,11 +5,20 @@
 
 # Local
 import pywwa
+from pyiem.nws.products.pirep import Pirep
 from pyiem.util import utc
 from pywwa.testing import get_example_file
 from pywwa.workflows import fake_afos_dump
 
 
+def test_fake_pirep():
+    """Test fake PIREP."""
+    tp = Pirep(get_example_file("PIREP.txt"), utcnow=utc(2024, 7, 9, 0, 0))
+    assert tp.afos is None
+    fake_afos_dump.compute_afos(tp)
+    assert tp.afos == "PIREP"
+
+
 @pytest.mark.parametrize("database", ["afos"])
 def test_processor(cursor):
     """Test basic parsing."""