Add support for lastSeen property

test/conftest.py

@@ -222,7 +222,7 @@ def version_data_fixture():
         "serverVersion": "test_server_version",
         "homeId": "test_home_id",
         "minSchemaVersion": 0,
-        "maxSchemaVersion": 29,
+        "maxSchemaVersion": 30,
     }
 
 

test/model/test_node.py

@@ -1,7 +1,7 @@
 """Test the node model."""
 import json
 from copy import deepcopy
-from datetime import datetime
+from datetime import datetime, timezone
 from unittest.mock import patch
 
 import pytest
@@ -136,6 +136,26 @@ def test_from_state(client):
     )
     assert node.endpoints[0] != node.endpoints[0].index
     assert hash(node.endpoints[0]) == hash((client.driver, node.node_id, 0))
+    assert node.last_seen is None
+    event = Event(
+        "statistics updated",
+        {
+            "source": "node",
+            "event": "statistics updated",
+            "nodeId": node.node_id,
+            "statistics": {
+                "commandsTX": 1,
+                "commandsRX": 2,
+                "commandsDroppedTX": 3,
+                "commandsDroppedRX": 4,
+                "timeoutResponse": 5,
+                "rssi": 7,
+                "lastSeen": "2023-07-18T15:42:34.701Z",
+            },
+        },
+    )
+    node.receive_event(event)
+    assert node.last_seen == datetime(2023, 7, 18, 15, 42, 34, 701000, timezone.utc)
 
 
 async def test_highest_security_value(lock_schlage_be469, ring_keypad):

test/test_client.py

@@ -454,7 +454,7 @@ async def test_additional_user_agent_components(client_session, url):
             {
                 "command": "initialize",
                 "messageId": "initialize",
-                "schemaVersion": 29,
+                "schemaVersion": 30,
                 "additionalUserAgentComponents": {
                     "zwave-js-server-python": __version__,
                     "foo": "bar",

test/test_dump.py

@@ -105,7 +105,7 @@ async def test_dump_additional_user_agent_components(
         {
             "command": "initialize",
             "messageId": "initialize",
-            "schemaVersion": 29,
+            "schemaVersion": 30,
             "additionalUserAgentComponents": {
                 "zwave-js-server-python": __version__,
                 "foo": "bar",

test/test_main.py

@@ -55,7 +55,7 @@ def test_dump_state(
     assert captured.out == (
         "{'type': 'version', 'driverVersion': 'test_driver_version', "
         "'serverVersion': 'test_server_version', 'homeId': 'test_home_id', "
-        "'minSchemaVersion': 0, 'maxSchemaVersion': 29}\n"
+        "'minSchemaVersion': 0, 'maxSchemaVersion': 30}\n"
         "{'type': 'result', 'success': True, 'result': {}, 'messageId': 'initialize'}\n"
         "test_result\n"
     )

zwave_js_server/const/__init__.py

@@ -8,9 +8,9 @@
 __version__ = metadata.version(PACKAGE_NAME)
 
 # minimal server schema version we can handle
-MIN_SERVER_SCHEMA_VERSION = 29
+MIN_SERVER_SCHEMA_VERSION = 30
 # max server schema version we can handle (and our code is compatible with)
-MAX_SERVER_SCHEMA_VERSION = 29
+MAX_SERVER_SCHEMA_VERSION = 30
 
 VALUE_UNKNOWN = "unknown"
 

zwave_js_server/model/node/__init__.py

@@ -347,6 +347,13 @@ def keep_awake(self) -> bool:
         """Return whether the node is set to keep awake."""
         return self.data["keepAwake"]
 
+    @property
+    def last_seen(self) -> datetime | None:
+        """Return when the node was last seen."""
+        if last_seen := self.data.get("lastSeen"):
+            return datetime.fromisoformat(last_seen)
+        return None
+
     def update(self, data: NodeDataType) -> None:
         """Update the internal state data."""
         self.data = copy.deepcopy(data)
@@ -969,3 +976,5 @@ def handle_statistics_updated(self, event: Event) -> None:
         event.data["statistics_updated"] = self._statistics = NodeStatistics(
             self.client, statistics
         )
+        if last_seen := statistics.get("lastSeen"):
+            self.data["lastSeen"] = last_seen

zwave_js_server/model/node/data_model.py

@@ -62,3 +62,4 @@ class NodeDataType(TypedDict, total=False):
     statistics: NodeStatisticsDataType
     highestSecurityClass: int
     isControllerNode: bool
+    lastSeen: str

zwave_js_server/model/node/statistics.py

@@ -3,6 +3,7 @@
 
 from contextlib import suppress
 from dataclasses import dataclass, field
+from datetime import datetime
 from typing import TYPE_CHECKING, TypedDict
 
 from zwave_js_server.exceptions import RssiErrorReceived
@@ -27,6 +28,7 @@ class NodeStatisticsDataType(TypedDict, total=False):
     rssi: int
     lwr: RouteStatisticsDataType
     nlwr: RouteStatisticsDataType
+    lastSeen: str
 
 
 @dataclass
@@ -43,6 +45,7 @@ class NodeStatistics:
     rtt: int | None = field(init=False)
     lwr: RouteStatistics | None = field(init=False, default=None)
     nlwr: RouteStatistics | None = field(init=False, default=None)
+    last_seen: datetime | None = field(init=False, default=None)
 
     def __post_init__(self) -> None:
         """Post initialize."""
@@ -52,6 +55,8 @@ def __post_init__(self) -> None:
         self.commands_dropped_tx = self.data["commandsDroppedTX"]
         self.timeout_response = self.data["timeoutResponse"]
         self.rtt = self.data.get("rtt")
+        if last_seen := self.data.get("lastSeen"):
+            self.last_seen = datetime.fromisoformat(last_seen)
         if lwr := self.data.get("lwr"):
             with suppress(ValueError):
                 self.lwr = RouteStatistics(self.client, lwr)