qsethuk/can_sniffer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix handlers

Browse Source
This commit is contained in:
Alexander Poletaev
2026-01-29 17:14:43 +03:00
parent 5c64b01d5f
commit 0011a9b0fe
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
can_sniffer/src/handlers/flipper_handler.py
View File

@@ -81,7 +81,7 @@ class FlipperHandler(BaseHandler):
def initialize(self) -> bool: def initialize(self) -> bool:
"""Initialize the handler.""" """Initialize the handler."""
if not self._enabled: if not self.enabled:
logger.info("Flipper handler disabled") logger.info("Flipper handler disabled")
return False return False
@@ -172,11 +172,11 @@ class FlipperHandler(BaseHandler):
Returns: Returns:
True if handler is active True if handler is active
""" """
return self._initialized and self._enabled return self._initialized and self.enabled
def handle_batch(self, readings: list) -> int: def handle_batch(self, readings: list) -> int:
"""Handle batch of readings.""" """Handle batch of readings."""
if not self._initialized or not self._enabled: if not self._initialized or not self.enabled:
return 0 return 0
return len(readings) return len(readings)
@@ -211,7 +211,7 @@ class FlipperHandler(BaseHandler):
"""Get handler statistics.""" """Get handler statistics."""
stats = { stats = {
"name": self.name, "name": self.name,
"enabled": self._enabled, "enabled": self.enabled,
"initialized": self._initialized, "initialized": self._initialized,
"device": self._device, "device": self._device,
"connected": self._connected, "connected": self._connected,

6
can_sniffer/src/handlers/realtime_handler.py
View File

@@ -47,7 +47,7 @@ class RealtimeHandler(BaseHandler):
Returns: Returns:
True if state was updated True if state was updated
""" """
if not self._initialized or not self._enabled: if not self._initialized or not self.enabled:
return False return False
if not reading.is_valid: if not reading.is_valid:
@@ -72,7 +72,7 @@ class RealtimeHandler(BaseHandler):
Returns: Returns:
Number of successful updates Number of successful updates
""" """
if not self._initialized or not self._enabled: if not self._initialized or not self.enabled:
return 0 return 0
count = 0 count = 0
@@ -102,7 +102,7 @@ class RealtimeHandler(BaseHandler):
return { return {
"name": self.name, "name": self.name,
"enabled": self._enabled, "enabled": self.enabled,
"initialized": self._initialized, "initialized": self._initialized,
"updates_count": self._updates_count, "updates_count": self._updates_count,
**state_stats **state_stats

6
can_sniffer/src/handlers/storage_handler.py
View File

@@ -76,7 +76,7 @@ class StorageHandler(BaseHandler):
Returns: Returns:
True if reading was accepted True if reading was accepted
""" """
if not self._initialized or not self._enabled: if not self._initialized or not self.enabled:
return False return False
with self._batch_lock: with self._batch_lock:
@@ -103,7 +103,7 @@ class StorageHandler(BaseHandler):
Returns: Returns:
Number of readings accepted Number of readings accepted
""" """
if not self._initialized or not self._enabled: if not self._initialized or not self.enabled:
return 0 return 0
with self._batch_lock: with self._batch_lock:
@@ -172,7 +172,7 @@ class StorageHandler(BaseHandler):
return { return {
"name": self.name, "name": self.name,
"enabled": self._enabled, "enabled": self.enabled,
"initialized": self._initialized, "initialized": self._initialized,
"saved_count": self._saved_count, "saved_count": self._saved_count,
"batch_count": self._batch_count, "batch_count": self._batch_count,