diff --git a/meshview/models.py b/meshview/models.py index 7302eca..b6a2ffb 100644 --- a/meshview/models.py +++ b/meshview/models.py @@ -72,6 +72,7 @@ class PacketSeen(Base): rx_time: Mapped[int] = mapped_column(BigInteger, primary_key=True) hop_limit: Mapped[int] = mapped_column(nullable=True) hop_start: Mapped[int] = mapped_column(nullable=True) + relay_node: Mapped[int] = mapped_column(BigInteger, nullable=True) channel: Mapped[str] = mapped_column(nullable=True) rx_snr: Mapped[float] = mapped_column(nullable=True) rx_rssi: Mapped[int] = mapped_column(nullable=True) diff --git a/meshview/mqtt_store.py b/meshview/mqtt_store.py index 7ec7ad2..341e0f6 100644 --- a/meshview/mqtt_store.py +++ b/meshview/mqtt_store.py @@ -157,6 +157,7 @@ async def process_envelope(topic, env): rx_rssi=env.packet.rx_rssi, hop_limit=env.packet.hop_limit, hop_start=env.packet.hop_start, + relay_node=env.packet.relay_node if env.packet.relay_node else None, topic=topic, import_time_us=now_us, )