jketterl/openwebrx
1
0
Fork 0
mirror of https://github.com/jketterl/openwebrx.git synced 2026-01-06 16:50:01 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

parse event reports and extract timestamps

Browse source
This commit is contained in:
Jakob Ketterl 2023-09-12 18:58:25 +02:00
parent 97a9a4f8c9
commit 156d1adc69
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
owrx/vdl2/dumpvdl2.py
View file

@ -4,6 +4,7 @@ from owrx.aeronautical import AcarsProcessor
from owrx.map import Map
from owrx.aeronautical import AirplaneLocation, IcaoSource
from owrx.metrics import Metrics, CounterMetric
from datetime import datetime, date, time, timezone
import logging
@ -55,9 +56,12 @@ class VDL2MessageParser(AcarsProcessor):
adsc_v2 = cotp["adsc_v2"]
if "adsc_report" in adsc_v2:
adsc_report = adsc_v2["adsc_report"]
if "periodic_report" in adsc_report["data"]:
periodic_report = adsc_report["data"]["periodic_report"]
report_data = periodic_report["report_data"]
data = adsc_report["data"]
if "periodic_report" in data:
report_data = data["periodic_report"]["report_data"]
self.processReport(report_data, src)
elif "event_report" in data:
report_data = data["event_report"]["report_data"]
self.processReport(report_data, src)
except Exception:
logger.exception("error processing VDL2 data")
@ -81,7 +85,11 @@ class VDL2MessageParser(AcarsProcessor):
msg.update({
"verticalspeed": report["air_vector"]["vertical_rate"]["val"],
})
Map.getSharedInstance().updateLocation(IcaoSource(icao), AirplaneLocation(msg), "VDL2")
if "timestamp" in report:
timestamp = self.convertTimestamp(**report["timestamp"])
else:
timestamp = None
Map.getSharedInstance().updateLocation(IcaoSource(icao), AirplaneLocation(msg), "VDL2", timestamp=timestamp)
def convertLatitude(self, dir, **args) -> float:
coord = self.convertCoordinate(**args)
@ -97,3 +105,12 @@ class VDL2MessageParser(AcarsProcessor):
def convertCoordinate(self, deg, min, sec) -> float:
return deg + float(min) / 60 + float(sec) / 3600
def convertTimestamp(self, date, time):
return datetime.combine(self.convertDate(**date), self.convertTime(**time), tzinfo=timezone.utc)
def convertDate(self, year, month, day):
return date(year=year, month=month, day=day)
def convertTime(self, hour, min, sec):
return time(hour=hour, minute=min, second=sec, microsecond=0, tzinfo=timezone.utc)