v2.1.16 (#44)

* groundwork for instance heartbeats

* Update __main__.py

* Update pyproject.toml

* Update __main__.py

* Update __main__.py

* Update __main__.py

* listener marking in db

* class level max hops

* min 5 -> 30

* migrate to uv

* remove final poetry

* Update README.md

* remove submodule

* node map working, but ugly

* that'll do for now

* don't traceroute everyone, just who I tell you to

* Update __main__.py

* v2.1.1

* model_validate packet

* include bell icon for alerts to trigger t1000e notification sound

* Update __main__.py

* !l command to see links

* Update __main__.py

* v2.1.3

* fix !l

* v2.1.4

* testing working again

* v2.1.5

* rework of notification messages

* v2.1.7

alert settings modifications and full implementation

* Update listener_db.py

* Update listener_db.py

* warn -> info

* Update __main__.py

* ditch the api

* Update README.md

* Update README.md

* reconnect attempts + warning

* Update __main__.py

* Update __main__.py

* v2.1.9

increment reconnect

* Update __main__.py

* alert symbols

* readability

* v2.1.11

remove message history. not useful.

* v2.1.12

notify upon new connection

* Update __main__.py

* notify using threads

* v2.1.13

listeners can all speak in unison

* Update __main__.py

* v2.1.14

ignore text messages from other listener nodes

* Update __main__.py

* v2.1.15

now checking system usage stats

* CPU interval -> None

* Update utils.py

* v2.1.16

bug fix for durations

* info -> debug

* remove some debug fluff

* Update README.md

* strip alert_context

Author: migillett

README.md

@@ -54,6 +54,7 @@ uv sync
 | `ENABLE_DEBUG`       | Sets the logger to debug mode if set to `True`.                                                   | `False`       |
 | `POSTGRES_DB` | The name of the Postgres database. | `listener_db` |
 | `POSTGRES_PASSWORD` | The password of the user to connect to the database | No default defined |
+| `ENABLE_DEBUG` | Sets the default logging level to `debug` if set to `true` | `false` |
 
 ## Docker Compose
 This repo has a [Docker Compose](docker-compose.yml) file to faster deploys. You'll also want to modify the [environment secrets](secrets_example.env) for your specific use as well. For examples on various docker deployments, see the [Docker Compose Readme](docker-examples.md)

meshtastic_listener/__main__.py

@@ -183,7 +183,7 @@ def __sanitize_packet__(self, packet: dict) -> dict:
         response = {}
         for key in packet:
             if isinstance(packet[key], bytes) or key == 'raw':
-                logging.debug(f'Dropping raw bytes from packet: {key}:{packet[key]}')
+                continue
             elif isinstance(packet[key], dict):
                 response[key] = self.__sanitize_packet__(packet[key])
             else:
@@ -399,7 +399,7 @@ def __check_node_health__(self) -> None:
                     alert_context += f'High Memory Usage: {health_check_stats.systemResources.memoryUsagePercent}%\n'
 
                 if alert_context != '':
-                    self.__notify_admins__(f'Node: {self.interface.getLongName()}\n{alert_context}', priority=True)
+                    self.__notify_admins__(f'Node: {self.interface.getLongName()}\n{alert_context.strip()}', priority=True)
 
                 self.previous_health_check = health_check_stats
 
@@ -427,7 +427,7 @@ def __handle_text_message__(self, packet: dict) -> None:
             logging.debug(f'Message received from another listener node {payload.fromId}. Ignoring to prevent loops.')
             return None
 
-        self.__print_packet_received__(logging.info, packet)
+        self.__print_packet_received__(logging.debug, packet)
 
         response = None
         if self.cmd_handler is not None:
@@ -558,7 +558,7 @@ def __handle_position__(self, packet: dict) -> None:
                 altitude=position.get('altitude'),
                 precision_bits=position.get('precisionBits')
             )
-            logging.debug(f'Updated position for node {packet["from"]}: {self.db.get_node(packet["from"])}')
+            logging.debug(f'Updated position for node {packet["from"]}')
         except ItemNotFound as e:
             logging.warning(e)
 

meshtastic_listener/listener_db/listener_db.py

@@ -81,7 +81,6 @@ def insert_node(self, node: NodeBase) -> None:
                 )
             session.execute(stmt)
             session.commit()
-        logger.debug(f'Inserted node into DB: {node.model_dump_json()}')
 
     def mark_node_as_listener(self, node_id: int, version: str) -> None:
         with self.session() as session:
@@ -565,10 +564,12 @@ def return_traceroute_success_rate(self, from_id: int, lookback_ts: int = 0) ->
                 if item.txTime is not None and item.rxTime is not None
             ]
 
+            avg = durations[0] if len(durations) == 1 else mean(durations)
+
             return TracerouteStatistics(
                 total=len(items),
                 successes=sum(1 for item in items if item.tracerouteDetails is not None),
-                avgTraceDuration=round(mean(durations), 2) if durations else 0.0
+                avgTraceDuration=round(avg, 2) if durations else 0.0
             )
 
     def select_favorite_nodes(self) -> list[Node]:

meshtastic_listener/utils.py

@@ -35,12 +35,10 @@ def system_stats() -> SystemResources:
     """
     Gather system resource usage statistics.
     """
-    cpu_usage = psutil.cpu_percent(interval=1)
-    memory = psutil.virtual_memory()
-    disk = psutil.disk_usage('/')
-    
-    return SystemResources(
-        cpuUsagePercent=round(cpu_usage, 1),
-        memoryUsagePercent=round(memory.percent, 1),
-        diskUsagePercent=round(disk.percent, 1)
+    stats = SystemResources(
+        cpuUsagePercent=round(psutil.cpu_percent(interval=None), 1),
+        memoryUsagePercent=round(psutil.virtual_memory().percent, 1),
+        diskUsagePercent=round(psutil.disk_usage('/').percent, 1)
     )
+    logger.debug(f"System Resource Statistics: {stats.model_dump()}")
+    return stats

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "meshtatic_listener"
-version = "2.1.15"
+version = "2.1.16"
 description = "A server for connecting to a Meshtastic device and responding to commands."
 authors = [{ name = "Michael Gillett", email = "51103663+migillett@users.noreply.github.com" }]
 requires-python = ">=3.10,<3.14"