Compare commits
No commits in common. "main" and "v0.9.5" have entirely different histories.
@ -8,7 +8,6 @@ from typing import Any
|
||||
from pybotvac.exceptions import NeatoException, NeatoRobotException
|
||||
from pybotvac.robot import Robot
|
||||
from pybotvac.vorwerk import Vorwerk
|
||||
from pybotvac.session import PasswordlessSession
|
||||
import voluptuous as vol
|
||||
|
||||
from homeassistant.components.vacuum import (
|
||||
@ -25,7 +24,6 @@ import homeassistant.helpers.config_validation as cv
|
||||
from homeassistant.helpers.entity import DeviceInfo
|
||||
from homeassistant.helpers.typing import ConfigType, HomeAssistantType
|
||||
from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
|
||||
from homeassistant.const import CONF_TOKEN
|
||||
|
||||
from .const import (
|
||||
ACTION,
|
||||
@ -99,7 +97,6 @@ async def async_setup_entry(hass: HomeAssistantType, entry: ConfigEntry) -> bool
|
||||
{
|
||||
VORWERK_ROBOT_API: r,
|
||||
VORWERK_ROBOT_COORDINATOR: _create_coordinator(hass, r),
|
||||
CONF_TOKEN: entry.data[CONF_TOKEN]
|
||||
}
|
||||
for r in robot_states
|
||||
]
|
||||
|
1
const.py
1
const.py
@ -23,7 +23,6 @@ MIN_TIME_BETWEEN_UPDATES = timedelta(minutes=1)
|
||||
ATTR_NAVIGATION = "navigation"
|
||||
ATTR_CATEGORY = "category"
|
||||
ATTR_ZONE = "zone"
|
||||
ATTR_MAP = "map"
|
||||
|
||||
ROBOT_STATE_INVALID = 0
|
||||
ROBOT_STATE_IDLE = 1
|
||||
|
@ -2,17 +2,16 @@
|
||||
"domain": "vorwerk",
|
||||
"name": "Vorwerk Kobold",
|
||||
"config_flow": true,
|
||||
"documentation": "https://github.com/trunneml/homeassistant-vorwerk",
|
||||
"documentation": "https://www.home-assistant.io/integrations/vorwerk",
|
||||
"requirements": [
|
||||
"pybotvac==0.0.23"
|
||||
"pybotvac==0.0.20"
|
||||
],
|
||||
"codeowners": [
|
||||
"@trunneml",
|
||||
"@fuempel"
|
||||
"@trunneml"
|
||||
],
|
||||
"dependencies": [
|
||||
"http"
|
||||
],
|
||||
"iot_class": "cloud_polling",
|
||||
"version": "0.10.0"
|
||||
"version": "0.9.5"
|
||||
}
|
@ -1,5 +0,0 @@
|
||||
{
|
||||
"name": "Eriks homeassistant-vorwerk addon",
|
||||
"url": "https://git.sfs.ddnss.org/SFS/homeassistant-vorwerk",
|
||||
"maintainer": "Erik Foris <erikfor@outlook.de"
|
||||
}
|
@ -16,6 +16,3 @@ custom_cleaning:
|
||||
zone:
|
||||
description: Only supported on the VR300. Name of the zone to clean. Defaults to no zone i.e. complete house cleanup.
|
||||
example: "Kitchen"
|
||||
map:
|
||||
description: Only supported on the VR300. Name of the map for the zone to clean. Defaults to no zone i.e. complete house cleanup.
|
||||
example: "Ground Floor"
|
@ -6,14 +6,14 @@
|
||||
"data": {
|
||||
"email": "E-Mailaddresse"
|
||||
},
|
||||
"description": "Um einen Authentifizierungscode per E-Mail zu erhalten, gib die E-Mailadresse deines Vorwerk-Accounts ein."
|
||||
"description": "Um einen Authentifizierungscode per E-Mail zu erhalten, gib die E-Mailadresse deines Vorwerk-Accounts ein.\n\nSiehe [Vorwerk-Dokumentation]({docs_url})."
|
||||
},
|
||||
"code": {
|
||||
"title": "Vorwerk Account Info",
|
||||
"data": {
|
||||
"code": "Code"
|
||||
},
|
||||
"description": "Gib den per E-Mail erhaltenen Code ein."
|
||||
"description": "Gib den per E-Mail erhaltenen Code ein.\n\nSee [Vorwerk documentation]({docs_url})."
|
||||
}
|
||||
},
|
||||
"error": {
|
||||
|
@ -6,14 +6,14 @@
|
||||
"data": {
|
||||
"email": "Email"
|
||||
},
|
||||
"description": "To recieve an authentication code, enter the email address of your vorwerk account."
|
||||
"description": "To recieve an authentication code, enter the email address of your vorwerk account.\n\nSee [Vorwerk documentation]({docs_url})."
|
||||
},
|
||||
"code": {
|
||||
"title": "Vorwerk Account Info",
|
||||
"data": {
|
||||
"code": "Code"
|
||||
},
|
||||
"description": "Enter the code you received by email."
|
||||
"description": "Enter the code you received by email.\n\nSee [Vorwerk documentation]({docs_url})."
|
||||
}
|
||||
},
|
||||
"error": {
|
||||
|
83
vacuum.py
83
vacuum.py
@ -5,8 +5,6 @@ import logging
|
||||
from typing import Any
|
||||
|
||||
from pybotvac import Robot
|
||||
from pybotvac.session import PasswordlessSession
|
||||
from pybotvac.account import Account
|
||||
from pybotvac.exceptions import NeatoRobotException
|
||||
import voluptuous as vol
|
||||
|
||||
@ -26,7 +24,7 @@ from homeassistant.components.vacuum import (
|
||||
SUPPORT_STOP,
|
||||
StateVacuumEntity,
|
||||
)
|
||||
from homeassistant.const import ATTR_MODE, CONF_TOKEN
|
||||
from homeassistant.const import ATTR_MODE
|
||||
from homeassistant.helpers import config_validation as cv, entity_platform
|
||||
from homeassistant.helpers.entity import DeviceInfo
|
||||
from homeassistant.helpers.update_coordinator import (
|
||||
@ -38,12 +36,10 @@ from .const import (
|
||||
ATTR_CATEGORY,
|
||||
ATTR_NAVIGATION,
|
||||
ATTR_ZONE,
|
||||
ATTR_MAP,
|
||||
VORWERK_DOMAIN,
|
||||
VORWERK_ROBOT_API,
|
||||
VORWERK_ROBOT_COORDINATOR,
|
||||
VORWERK_ROBOTS,
|
||||
VORWERK_CLIENT_ID,
|
||||
)
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
@ -68,7 +64,7 @@ async def async_setup_entry(hass, entry, async_add_entities):
|
||||
async_add_entities(
|
||||
[
|
||||
VorwerkConnectedVacuum(
|
||||
robot[VORWERK_ROBOT_API], robot[VORWERK_ROBOT_COORDINATOR], robot[CONF_TOKEN]
|
||||
robot[VORWERK_ROBOT_API], robot[VORWERK_ROBOT_COORDINATOR]
|
||||
)
|
||||
for robot in hass.data[VORWERK_DOMAIN][entry.entry_id][VORWERK_ROBOTS]
|
||||
],
|
||||
@ -85,7 +81,6 @@ async def async_setup_entry(hass, entry, async_add_entities):
|
||||
vol.Optional(ATTR_NAVIGATION, default=1): cv.positive_int,
|
||||
vol.Optional(ATTR_CATEGORY, default=4): cv.positive_int,
|
||||
vol.Optional(ATTR_ZONE): cv.string,
|
||||
vol.Optional(ATTR_MAP): cv.string,
|
||||
},
|
||||
"vorwerk_custom_cleaning",
|
||||
)
|
||||
@ -95,7 +90,7 @@ class VorwerkConnectedVacuum(CoordinatorEntity, StateVacuumEntity):
|
||||
"""Representation of a Vorwerk Connected Vacuum."""
|
||||
|
||||
def __init__(
|
||||
self, robot_state: VorwerkState, coordinator: DataUpdateCoordinator[Any], token
|
||||
self, robot_state: VorwerkState, coordinator: DataUpdateCoordinator[Any]
|
||||
) -> None:
|
||||
"""Initialize the Vorwerk Connected Vacuum."""
|
||||
super().__init__(coordinator)
|
||||
@ -104,7 +99,7 @@ class VorwerkConnectedVacuum(CoordinatorEntity, StateVacuumEntity):
|
||||
|
||||
self._name = f"{self.robot.name}"
|
||||
self._robot_serial = self.robot.serial
|
||||
self._token = token
|
||||
self._robot_boundaries: list[str] = []
|
||||
|
||||
@property
|
||||
def name(self) -> str:
|
||||
@ -161,7 +156,7 @@ class VorwerkConnectedVacuum(CoordinatorEntity, StateVacuumEntity):
|
||||
if not self._state:
|
||||
return
|
||||
try:
|
||||
if self._state.state == STATE_IDLE or self._state.state == STATE_DOCKED:
|
||||
if self._state.state == STATE_IDLE:
|
||||
self.robot.start_cleaning()
|
||||
elif self._state.state == STATE_PAUSED:
|
||||
self.robot.resume_cleaning()
|
||||
@ -182,7 +177,7 @@ class VorwerkConnectedVacuum(CoordinatorEntity, StateVacuumEntity):
|
||||
def return_to_base(self, **kwargs: Any) -> None:
|
||||
"""Set the vacuum cleaner to return to the dock."""
|
||||
try:
|
||||
if self._state.state == STATE_CLEANING:
|
||||
if self._state.state == STATE_CLEANING or self._state.state == STATE_DOCKED:
|
||||
self.robot.pause_cleaning()
|
||||
self.robot.send_to_base()
|
||||
except NeatoRobotException as ex:
|
||||
@ -218,67 +213,23 @@ class VorwerkConnectedVacuum(CoordinatorEntity, StateVacuumEntity):
|
||||
)
|
||||
|
||||
def vorwerk_custom_cleaning(
|
||||
self, mode: str, navigation: str, category: str, zone: str, map: str | None = None
|
||||
self, mode: str, navigation: str, category: str, zone: str | None = None
|
||||
) -> None:
|
||||
"""Zone cleaning service call."""
|
||||
_LOGGER.debug("vorwerk_custom_cleaning called for %s / %s with token %s", map, zone, self._token)
|
||||
|
||||
# create Vorwerk API session + account object and populate the robot list
|
||||
# (this necessary to update pybotvac internal states)
|
||||
session = PasswordlessSession(client_id=VORWERK_CLIENT_ID, token=self._token)
|
||||
account = Account(session)
|
||||
robots = account.robots
|
||||
|
||||
_LOGGER.debug(" Robot list = %s", robots)
|
||||
|
||||
map_id = None
|
||||
boundary_id = None
|
||||
|
||||
if map is not None:
|
||||
# search map
|
||||
maps = account.persistent_maps[self._robot_serial]
|
||||
|
||||
_LOGGER.debug(" Persistent map list = %s", maps)
|
||||
|
||||
map_obj = None
|
||||
available_maps = []
|
||||
for m in maps:
|
||||
available_maps.append(m['name'])
|
||||
if map in m['name']:
|
||||
map_obj = m
|
||||
|
||||
if map_obj is None:
|
||||
_LOGGER.error("Map '%s' was not found for the robot '%s', list of valid maps: %s", map, self.entity_id, available_maps)
|
||||
if zone is not None:
|
||||
for boundary in self._robot_boundaries:
|
||||
if zone in boundary["name"]:
|
||||
boundary_id = boundary["id"]
|
||||
if boundary_id is None:
|
||||
_LOGGER.error(
|
||||
"Zone '%s' was not found for the robot '%s'", zone, self.entity_id
|
||||
)
|
||||
return
|
||||
|
||||
map_id = map_obj['id']
|
||||
_LOGGER.debug(" Found map %s = ID %s", map, map_id)
|
||||
|
||||
if zone is not None:
|
||||
# search zone = boundary ID
|
||||
boundaries = self.robot.get_map_boundaries(map_id).json()
|
||||
|
||||
_LOGGER.debug(" Boundary list = %s", boundaries)
|
||||
|
||||
boundary_obj = None
|
||||
available_zones = []
|
||||
for b in boundaries['data']['boundaries']:
|
||||
available_zones.append(b['name'])
|
||||
if zone in b['name']:
|
||||
boundary_obj = b
|
||||
|
||||
if boundary_obj is None:
|
||||
_LOGGER.error("Zone '%s' was not found for the robot '%s' on map '%s', list of valid zones: %s", zone, self.entity_id, map, available_zones)
|
||||
return
|
||||
|
||||
boundary_id = boundary_obj['id']
|
||||
_LOGGER.debug(" Found baundary / zone %s = ID %s", zone, boundary_id)
|
||||
|
||||
# start cleaning now
|
||||
_LOGGER.info("Start cleaning zone '%s' on map '%s' with robot %s", zone, map, self.entity_id)
|
||||
_LOGGER.info("Start cleaning zone '%s' with robot %s", zone, self.entity_id)
|
||||
|
||||
try:
|
||||
self.robot.start_cleaning(mode, navigation, category, boundary_id, map_id)
|
||||
self.robot.start_cleaning(mode, navigation, category, boundary_id)
|
||||
except NeatoRobotException as ex:
|
||||
_LOGGER.error(
|
||||
"Vorwerk vacuum connection error for '%s': %s", self.entity_id, ex
|
||||
|
Loading…
Reference in New Issue
Block a user