fix(zeo): address review — narrow exceptions, tighten try/except scope, document _dps_cache

except Exception → except RoborockException (aligns with Bundle's silent fallback to 0)
try/except only wraps decode_rpc_response — cache updates and notify must propagate
query_values docstring explains cache population and consumer semantics

Author: NOisi-X

roborock/devices/traits/a01/__init__.py

@@ -209,11 +209,16 @@ async def _discover_features(self) -> None:
         start pushing its full state — equivalent to how V1's
         ``discover_features()`` uses ``device_features.refresh()`` to
         initiate the push cycle.
+
+        Only devices that support the FeatureBits DP will respond;
+        older or unsupported devices return nothing. 
+        A failed query defaults to 0 — all feature-gated DPs are 
+        disabled and the device operates in basic mode.
         """
         try:
             result = await self.query_values([RoborockZeoProtocol.FEATURE_BITS])
             self._feature_bits = result.get(RoborockZeoProtocol.FEATURE_BITS, 0)
-        except Exception:
+        except RoborockException:
             self._feature_bits = 0
 
     def supports(self, feature: ZeoFeatureBits) -> bool:
@@ -232,10 +237,11 @@ def _on_dps_message(self, message: RoborockMessage) -> None:
             return
         try:
             decoded = decode_rpc_response(message)
-            self._dps_cache.update(decoded)
-            self._notify_update()
         except RoborockException:
-            _LOGGER.debug("Failed to decode push message, skipping: %s", message, exc_info=True)
+            _LOGGER.debug("Dropped malformed push message", exc_info=True)
+            return
+        self._dps_cache.update(decoded)
+        self._notify_update()
 
     async def query_values(self, protocols: list[RoborockZeoProtocol]) -> dict[RoborockZeoProtocol, Any]:
         """Query the device for the values of the given protocols."""