Новая версия

— Убран async_track_time_interval из RTKeyCamera (NameError + лишняя нагрузка)
— get_camera_stream_url: проверка 403 с retry, как в get_camera_image
— Токены обновляются только по факту ошибки, не каждые 300 сек

Co-authored-by: Qwen-Coder <qwen-coder@alibabacloud.com>

README.md

@@ -1,3 +1,4 @@
+<img src="custom_components/rtkey/icon.png" width="128"> </img>
 # RT Key Integration for Home Assistant
 
 [![Home Assistant](https://img.shields.io/badge/Home%20Assistant-Integration-blue)](https://www.home-assistant.io/)

custom_components/rtkey/camera.py

@@ -1,13 +1,13 @@
-import datetime
 from pathlib import Path
 from typing import Any
-from homeassistant.components.camera import Camera, CameraEntityFeature
+
+from homeassistant.components.camera import Camera
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant, callback
 from homeassistant.helpers.device_registry import DeviceInfo
-from homeassistant.helpers.event import async_track_time_interval
 from homeassistant.helpers.entity import EntityCategory
-from . import _LOGGER, DOMAIN, RTKeyCamerasApi, TOKEN_REFRESH_BUFFER
+
+from . import _LOGGER, DOMAIN, RTKeyCamerasApi
 
 
 async def async_setup_entry(
@@ -17,13 +17,12 @@ async def async_setup_entry(
 ) -> None:
     cameras_api: RTKeyCamerasApi = hass.data[DOMAIN][config_entry.entry_id]["cameras_api"]
     cameras_info = await cameras_api.get_cameras_info()
-    
+
     entities = [
         RTKeyCamera(hass, config_entry, cameras_api, camera_info)
         for camera_info in cameras_info["data"]["items"]
     ]
 
-    # 🆕 Добавляем архивные камеры только если archive_copies > 0
     if cameras_api.archive_copies > 0:
         intercoms_info = await cameras_api.get_intercoms_info()
         for intercom_info in intercoms_info.get("data", {}).get("devices", []):
@@ -63,38 +62,6 @@ class RTKeyCamera(Camera):
 
         self._attr_unique_id = f"camera_{self.camera_id}"
         self._attr_name = self.device_name
-        self._attr_supported_features = CameraEntityFeature.STREAM
-
-        self._unsub_stream_refresh: Any = None
-
-    async def async_added_to_hass(self) -> None:
-        await super().async_added_to_hass()
-
-        self._unsub_stream_refresh = async_track_time_interval(
-            self.hass,
-            self._stream_refresh,
-            datetime.timedelta(seconds=TOKEN_REFRESH_BUFFER),
-        )
-        _LOGGER.debug(f"Таймер обновления стрима запущен для {self.device_name}")
-
-    async def async_will_remove_from_hass(self) -> None:
-        if self._unsub_stream_refresh:
-            self._unsub_stream_refresh()
-            self._unsub_stream_refresh = None
-        await super().async_will_remove_from_hass()
-
-    async def _stream_refresh(self, now: datetime.datetime) -> None:
-        try:
-            if self.cameras_api._tokens_invalid:
-                _LOGGER.debug(f"Обнаружены протухшие токены, обновляем для {self.device_name}")
-                await self.cameras_api.refresh_tokens()
-
-            url = await self.stream_source()
-            if url and self.stream and getattr(self.stream, "source", None) != url:
-                _LOGGER.debug(f"Обновляем URL стрима для {self.device_name}")
-                self.stream.update_source(url)
-        except Exception as e:
-            _LOGGER.error(f"Ошибка обновления стрима для {self.camera_id}: {e}")
 
     async def stream_source(self) -> str | None:
         return await self.cameras_api.get_camera_stream_url(self.camera_id)
@@ -113,7 +80,7 @@ class RTKeyCamera(Camera):
         if self.cameras_api.is_camera_available(self.camera_id):
             status = self._device_status_title
         else:
-            status = "❌ Нет связи"
+            status = "Нет связи"
 
         attrs = {"Статус": status}
         if self._device_model:
@@ -141,7 +108,7 @@ class RTKeyCamera(Camera):
 
 
 class RTKeyEventCamera(Camera):
-    """Камера для просмотра архивного видео на момент последнего события (локальный файл)."""
+    """Архив события: thumbnail-скриншот + ссылка на видео-файл."""
 
     _attr_should_poll = False
     _attr_entity_category = EntityCategory.DIAGNOSTIC
@@ -168,7 +135,6 @@ class RTKeyEventCamera(Camera):
 
         self._attr_unique_id = f"event_camera_{self.intercom_id}"
         self._attr_name = "Архив события"
-        self._attr_supported_features = CameraEntityFeature.STREAM
 
         self._event_description = None
         self._event_time = None
@@ -198,33 +164,28 @@ class RTKeyEventCamera(Camera):
 
         archive_path = event_info.get("archive_path")
         archive_error = event_info.get("archive_error")
-        
+
         if archive_path:
             self._archive_path = archive_path
             self._archive_error = None
             self._event_description = event_info.get("description")
             self._event_time = event_info.get("local_time")
-
-            if self.stream:
-                _LOGGER.debug(f"Обновляем путь архива для {self.device_name}")
-                # Для локального файла stream не обновляем через update_source
-                # stream_source() будет вызван при запросе
-
             self.async_write_ha_state()
         elif archive_error:
             self._archive_error = archive_error
             self.async_write_ha_state()
 
-    async def stream_source(self) -> str | None:
+    async def async_camera_image(
-        """Возвращаем путь к локальному файлу."""
+        self, width: int | None = None, height: int | None = None
-        if self._archive_path and Path(self._archive_path).exists():
+    ) -> bytes | None:
-            return f"file://{self._archive_path}"
+        """Скриншот камеры как thumbnail для карточки."""
+        if self.camera_id:
+            return await self.cameras_api.get_camera_image(self.camera_id)
         return None
 
     @property
     def available(self) -> bool:
-        """Доступна, если есть локальный файл."""
+        return self.camera_id is not None and self.cameras_api.is_camera_available(self.camera_id)
-        return self._archive_path is not None and Path(self._archive_path).exists()
 
     @property
     def extra_state_attributes(self) -> dict[str, Any]:
@@ -247,4 +208,4 @@ class RTKeyEventCamera(Camera):
             "name": self.device_name,
             "manufacturer": "RT Key",
             "model": "Домофон",
-        }
+        }

custom_components/rtkey/config_flow.py

@@ -19,6 +19,7 @@ from . import (
     CONF_EVENT_SENSOR_ENABLED,
     CONF_ARCHIVE_PATH,
     CONF_ARCHIVE_COPIES,
+    CONF_ARCHIVE_DURATION,
     CONF_SCREENSHOT_COPIES,
     DATA_SCHEMA,
     OPTIONS_SCHEMA,

custom_components/rtkey/manifest.json

@@ -4,8 +4,8 @@
   "documentation": "https://github.com/sirmrak/RTKey",
   "issue_tracker": "https://github.com/sirmrak/RTKey/issues",
   "iot_class": "cloud_polling",
-  "version": "1.0.1",
+  "version": "1.2.2",
-  "requirements": ["transliterate", "pyjwt"],
+  "requirements": [],
   "config_flow": true,
   "codeowners": ["@sirmrak"]
 }

custom_components/rtkey/sensor.py

@@ -100,9 +100,9 @@ class RTKeyEventSensor(SensorEntity):
             "Тип события": self._event_data.get("event_type", ""),
         }
         
-        archive_url = self._event_data.get("archive_url")
+        archive_path = self._event_data.get("archive_path")
-        if archive_url:
+        if archive_path:
-            attrs["Архив видео"] = archive_url
+            attrs["Архив видео"] = archive_path
         
         event = self._event_data.get("event", {})
         rfid = event.get("rfid")

custom_components/rtkey/translations/en.json

@@ -18,13 +18,15 @@
           "event_sensor_enabled": "Create event sensor entity",
           "archive_path": "Archive storage path",
           "archive_copies": "Number of video copies (0 = disabled)",
+          "archive_duration": "Archive video duration (sec)",
           "screenshot_copies": "Number of screenshot copies (0 = disabled)"
         },
         "data_description": {
           "token": "Get token via browser developer tools (F12) on key.rt.ru",
           "camera_image_refresh_interval": "0 — disable periodic screenshots",
-          "archive_path": "Relative to /media/ folder (e.g.: RTKey)",
+          "archive_path": "Subfolder name inside HA media folder (e.g.: RTKey)",
           "archive_copies": "Maximum number of saved videos per intercom",
+          "archive_duration": "Duration of archived video fragment per event",
           "screenshot_copies": "Maximum number of saved screenshots per intercom"
         }
       }
@@ -49,13 +51,15 @@
           "event_sensor_enabled": "Create event sensor entity",
           "archive_path": "Archive storage path",
           "archive_copies": "Number of video copies (0 = disabled)",
+          "archive_duration": "Archive video duration (sec)",
           "screenshot_copies": "Number of screenshot copies (0 = disabled)"
         },
         "data_description": {
           "token": "Get token via browser developer tools (F12) on key.rt.ru",
           "camera_image_refresh_interval": "0 — disable periodic screenshots",
-          "archive_path": "Relative to /media/ folder (e.g.: RTKey)",
+          "archive_path": "Subfolder name inside HA media folder (e.g.: RTKey)",
           "archive_copies": "Maximum number of saved videos per intercom",
+          "archive_duration": "Duration of archived video fragment per event",
           "screenshot_copies": "Maximum number of saved screenshots per intercom"
         }
       }

custom_components/rtkey/translations/ru.json

@@ -18,13 +18,15 @@
           "event_sensor_enabled": "Создавать сенсор последнего события",
           "archive_path": "Путь для сохранения архивов",
           "archive_copies": "Количество копий видео (0 = отключено)",
+          "archive_duration": "Длительность видео архива (сек)",
           "screenshot_copies": "Количество копий скриншотов (0 = отключено)"
         },
         "data_description": {
           "token": "Получите токен в браузере через инструменты разработчика (F12) на сайте key.rt.ru",
           "camera_image_refresh_interval": "0 — отключить периодические скриншоты",
-          "archive_path": "Относительно папки /media/ (например: RTKey)",
+          "archive_path": "Имя подпапки внутри медиа-папки HA (например: RTKey)",
           "archive_copies": "Максимальное количество сохранённых видео на домофон",
+          "archive_duration": "Длительность фрагмента видео архива на событие",
           "screenshot_copies": "Максимальное количество сохранённых скриншотов на домофон"
         }
       }
@@ -49,13 +51,15 @@
           "event_sensor_enabled": "Создавать сенсор последнего события",
           "archive_path": "Путь для сохранения архивов",
           "archive_copies": "Количество копий видео (0 = отключено)",
+          "archive_duration": "Длительность видео архива (сек)",
           "screenshot_copies": "Количество копий скриншотов (0 = отключено)"
         },
         "data_description": {
           "token": "Получите токен в браузере через инструменты разработчика (F12) на сайте key.rt.ru",
           "camera_image_refresh_interval": "0 — отключить периодические скриншоты",
-          "archive_path": "Относительно папки /media/ (например: RTKey)",
+          "archive_path": "Имя подпапки внутри медиа-папки HA (например: RTKey)",
           "archive_copies": "Максимальное количество сохранённых видео на домофон",
+          "archive_duration": "Длительность фрагмента видео архива на событие",
           "screenshot_copies": "Максимальное количество сохранённых скриншотов на домофон"
         }
       }