forked from peter/volvo2mqtt
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1d07644a9c | ||
|
|
e0152fa82d | ||
|
|
e1e31776c2 | ||
|
|
43f5bbaadf | ||
|
|
dd6e4f8cb7 | ||
|
|
17e29e44fc | ||
|
|
93494eaa43 | ||
|
|
5555ddc5cc | ||
|
|
5ea045f1cf | ||
|
|
6a01f70637 | ||
|
|
2c52f0ad58 | ||
|
|
d5e02b4a3e | ||
|
|
fbe05f6aa2 | ||
|
|
385a500dab | ||
|
|
54c459ff39 | ||
|
|
931a2f1523 | ||
|
|
22d421f5aa | ||
|
|
18d17cff58 | ||
|
|
c09dd42e76 | ||
|
|
563e5508ae |
+3
-1
@@ -1 +1,3 @@
|
|||||||
.idea
|
.idea
|
||||||
|
venv
|
||||||
|
src/settings.dev.json
|
||||||
@@ -7,7 +7,9 @@ Maybe this component works also with other Volvo cars. Please try out the native
|
|||||||
- XC40 BEV (2023)
|
- XC40 BEV (2023)
|
||||||
- V60 T8 PHEV (2023)
|
- V60 T8 PHEV (2023)
|
||||||
- C40 PHEV (2023)
|
- C40 PHEV (2023)
|
||||||
|
- C40 PHEV (2022)
|
||||||
- XC90 T8 PHEV (2023)
|
- XC90 T8 PHEV (2023)
|
||||||
|
- XC60 PHEV (2023)
|
||||||
|
|
||||||
Please let me know if your car works with this addon so I can expand the list!
|
Please let me know if your car works with this addon so I can expand the list!
|
||||||
|
|
||||||
@@ -23,14 +25,14 @@ Please let me know if your car works with this addon so I can expand the list!
|
|||||||
NOTE: Energy status currently available only for cars in the Europe / Middle East / Africa regions. [source](https://developer.volvocars.com/apis/energy/v1/overview/#availability)
|
NOTE: Energy status currently available only for cars in the Europe / Middle East / Africa regions. [source](https://developer.volvocars.com/apis/energy/v1/overview/#availability)
|
||||||
|
|
||||||
## Setup
|
## Setup
|
||||||
Docker:
|
<b>Docker:</b>
|
||||||
|
|
||||||
Just install this addon with the following command.
|
Just install this addon with the following command.
|
||||||
Please note to fill in your settings inside the environment variables.
|
Please note to fill in your settings inside the environment variables.
|
||||||
|
|
||||||
`docker run --pull=always -e CONF_updateInterval=300 -e CONF_babelLocale='de' -e CONF_mqtt='@json {"broker": "", "username": "", "password": ""}' -e CONF_volvoData='@json {"username": "", "password": "", "vin": "", "vccapikey": ""}' -e TZ='Europe/Berlin' --name volvo2mqtt ghcr.io/dielee/volvo2mqtt:latest`
|
`docker run --pull=always -e CONF_updateInterval=300 -e CONF_babelLocale='de' -e CONF_mqtt='@json {"broker": "", "username": "", "password": ""}' -e CONF_volvoData='@json {"username": "", "password": "", "vin": "", "vccapikey": ""}' -e TZ='Europe/Berlin' --name volvo2mqtt ghcr.io/dielee/volvo2mqtt:latest`
|
||||||
|
|
||||||
HA Add-On<br>
|
<b>HA Add-On:</b><br>
|
||||||
|
|
||||||
[](https://my.home-assistant.io/redirect/supervisor_add_addon_repository/?repository_url=https%3A%2F%2Fgithub.com%2FDielee%2Fvolvo2mqtt)
|
[](https://my.home-assistant.io/redirect/supervisor_add_addon_repository/?repository_url=https%3A%2F%2Fgithub.com%2FDielee%2Fvolvo2mqtt)
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -2,5 +2,5 @@ from dynaconf import Dynaconf
|
|||||||
|
|
||||||
settings = Dynaconf(
|
settings = Dynaconf(
|
||||||
envvar_prefix="CONF",
|
envvar_prefix="CONF",
|
||||||
settings_files=["settings.json", "/data/options.json"],
|
settings_files=["settings.json", "/data/options.json", "settings.dev.json"],
|
||||||
)
|
)
|
||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
name: "Volvo2Mqtt"
|
name: "Volvo2Mqtt"
|
||||||
description: "Volvo AAOS MQTT bridge"
|
description: "Volvo AAOS MQTT bridge"
|
||||||
version: "1.1.0"
|
version: "1.2.1"
|
||||||
slug: "volvo2mqtt"
|
slug: "volvo2mqtt"
|
||||||
init: false
|
init: false
|
||||||
url: "https://github.com/Dielee/volvo2mqtt"
|
url: "https://github.com/Dielee/volvo2mqtt"
|
||||||
|
|||||||
+32
-12
@@ -1,26 +1,42 @@
|
|||||||
VERSION = "v1.1.0"
|
from config import settings
|
||||||
|
|
||||||
|
VERSION = "v1.2.1"
|
||||||
|
|
||||||
OAUTH_URL = "https://volvoid.eu.volvocars.com/as/token.oauth2"
|
OAUTH_URL = "https://volvoid.eu.volvocars.com/as/token.oauth2"
|
||||||
VEHICLES_URL = "https://api.volvocars.com/connected-vehicle/v1/vehicles"
|
VEHICLES_URL = "https://api.volvocars.com/connected-vehicle/v1/vehicles"
|
||||||
VEHICLE_DETAILS_URL = "https://api.volvocars.com/connected-vehicle/v1/vehicles/{0}"
|
VEHICLE_DETAILS_URL = "https://api.volvocars.com/connected-vehicle/v1/vehicles/{0}"
|
||||||
WINDOW_STATUS_URL = "https://api.volvocars.com/connected-vehicle/v1/vehicles/{0}/windows"
|
WINDOWS_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/windows"
|
||||||
CLIMATE_START_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/climatization-start"
|
CLIMATE_START_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/climatization-start"
|
||||||
CLIMATE_STOP_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/climatization-stop"
|
CLIMATE_STOP_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/climatization-stop"
|
||||||
CAR_LOCK_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/doors"
|
LOCK_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/doors"
|
||||||
CAR_LOCK_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/lock"
|
CAR_LOCK_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/lock"
|
||||||
CAR_UNLOCK_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/unlock"
|
CAR_UNLOCK_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/unlock"
|
||||||
RECHARGE_STATUS_URL = "https://api.volvocars.com/energy/v1/vehicles/{0}/recharge-status"
|
RECHARGE_STATE_URL = "https://api.volvocars.com/energy/v1/vehicles/{0}/recharge-status"
|
||||||
|
ODOMETER_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/odometer"
|
||||||
|
LOCATION_STATE_URL = "https://api.volvocars.com/location/v1/vehicles/{0}/location"
|
||||||
|
|
||||||
charging_system_states = {"CHARGING_SYSTEM_CHARGING": "Charging", "CHARGING_SYSTEM_IDLE": "Idle",
|
charging_system_states = {"CHARGING_SYSTEM_CHARGING": "Charging", "CHARGING_SYSTEM_IDLE": "Idle",
|
||||||
"CHARGING_SYSTEM_FAULT": "Fault", "CHARGING_SYSTEM_UNSPECIFIED": "Unspecified"}
|
"CHARGING_SYSTEM_FAULT": "Fault", "CHARGING_SYSTEM_UNSPECIFIED": "Unspecified"}
|
||||||
|
|
||||||
supported_sensors = [
|
supported_sensors = [
|
||||||
{"name": "Battery Charge Level", "id": "battery_charge_level", "unit": "%", "icon": "car-battery", "url": RECHARGE_STATUS_URL},
|
{"name": "Battery Charge Level", "id": "battery_charge_level", "unit": "%", "icon": "car-battery", "url": RECHARGE_STATE_URL},
|
||||||
{"name": "Electric Range", "id": "electric_range", "unit": "km", "icon": "map-marker-distance", "url": RECHARGE_STATUS_URL},
|
{"name": "Electric Range", "id": "electric_range", "unit": "km" if settings["babelLocale"] != "en_US" else "mi", "icon": "map-marker-distance", "url": RECHARGE_STATE_URL},
|
||||||
{"name": "Estimated Charging Time", "id": "estimated_charging_time", "unit": "minutes", "icon": "timer-sync-outline", "url": RECHARGE_STATUS_URL},
|
{"name": "Estimated Charging Time", "id": "estimated_charging_time", "unit": "minutes", "icon": "timer-sync-outline", "url": RECHARGE_STATE_URL},
|
||||||
{"name": "Charging System Status", "id": "charging_system_status", "icon": "ev-plug-ccs2", "url": RECHARGE_STATUS_URL},
|
{"name": "Charging System Status", "id": "charging_system_status", "icon": "ev-plug-ccs2", "url": RECHARGE_STATE_URL},
|
||||||
{"name": "Estimated Charging Finish Time", "id": "estimated_charging_finish_time", "icon": "timer-sync-outline", "url": RECHARGE_STATUS_URL},
|
{"name": "Estimated Charging Finish Time", "id": "estimated_charging_finish_time", "icon": "timer-sync-outline", "url": RECHARGE_STATE_URL},
|
||||||
{"name": "Last Data Update", "id": "last_data_update", "icon": "timer", "url": ""}
|
{"name": "Odometer", "id": "odometer", "unit": "km" if settings["babelLocale"] != "en_US" else "mi", "icon": "counter", "url": ODOMETER_STATE_URL},
|
||||||
|
{"name": "Last Data Update", "id": "last_data_update", "icon": "timer", "url": ""},
|
||||||
|
{"name": "Window Front Left", "id": "window_front_left", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||||
|
{"name": "Window Front Right", "id": "window_front_right", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||||
|
{"name": "Window Rear Left", "id": "window_rear_left", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||||
|
{"name": "Window Rear Right", "id": "window_rear_right", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||||
|
{"name": "Door Front Left", "id": "door_front_left", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Door Front Right", "id": "door_front_right", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Door Rear Left", "id": "door_rear_left", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Door Rear Right", "id": "door_rear_right", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Tailgate", "id": "tailgate", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Engine Hood", "id": "engine_hood", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||||
|
{"name": "Tank Lid", "id": "tank_lid", "icon": "car-door-lock", "url": LOCK_STATE_URL}
|
||||||
]
|
]
|
||||||
|
|
||||||
supported_switches = [
|
supported_switches = [
|
||||||
@@ -28,9 +44,13 @@ supported_switches = [
|
|||||||
]
|
]
|
||||||
|
|
||||||
supported_locks = [
|
supported_locks = [
|
||||||
{"name": "Lock state", "id": "lock_status", "icon": "lock", "url": CAR_LOCK_STATE_URL}
|
{"name": "Lock state", "id": "lock_status", "icon": "lock", "url": LOCK_STATE_URL}
|
||||||
]
|
]
|
||||||
|
|
||||||
supported_buttons = [
|
supported_buttons = [
|
||||||
{"name": "Update Data", "id": "update_data", "icon": "update", "url": ""}
|
{"name": "Force Update Data", "id": "update_data", "icon": "update", "url": ""}
|
||||||
|
]
|
||||||
|
|
||||||
|
supported_device_trackers = [
|
||||||
|
{"name": "Location", "id": "location", "icon": "map-marker-radius", "url": LOCATION_STATE_URL}
|
||||||
]
|
]
|
||||||
+50
-40
@@ -2,18 +2,21 @@ import time
|
|||||||
import paho.mqtt.client as mqtt
|
import paho.mqtt.client as mqtt
|
||||||
import json
|
import json
|
||||||
import volvo
|
import volvo
|
||||||
import threading
|
from threading import Thread, Timer
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from babel.dates import format_datetime
|
from babel.dates import format_datetime
|
||||||
from config import settings
|
from config import settings
|
||||||
from const import VEHICLE_DETAILS_URL, CLIMATE_START_URL, CLIMATE_STOP_URL, CAR_LOCK_URL, \
|
from const import CLIMATE_START_URL, CLIMATE_STOP_URL, CAR_LOCK_URL, \
|
||||||
CAR_UNLOCK_URL, supported_sensors, supported_buttons, supported_switches, supported_locks
|
CAR_UNLOCK_URL, supported_sensors, supported_buttons, supported_switches, \
|
||||||
|
supported_locks, supported_device_trackers
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
mqtt_client: mqtt.Client
|
mqtt_client: mqtt.Client
|
||||||
subscribed_topics = []
|
subscribed_topics = []
|
||||||
assumed_climate_state = {}
|
assumed_climate_state = {}
|
||||||
last_data_update = None
|
last_data_update = None
|
||||||
|
climate_timer: Timer
|
||||||
|
|
||||||
|
|
||||||
def connect():
|
def connect():
|
||||||
@@ -45,18 +48,22 @@ def on_message(client, userdata, msg):
|
|||||||
vin = msg.topic.split('/')[2].split('_')[0]
|
vin = msg.topic.split('/')[2].split('_')[0]
|
||||||
payload = msg.payload.decode("UTF-8")
|
payload = msg.payload.decode("UTF-8")
|
||||||
if "climate_status" in msg.topic:
|
if "climate_status" in msg.topic:
|
||||||
global assumed_climate_state
|
global assumed_climate_state, climate_timer
|
||||||
if payload == "ON":
|
if payload == "ON":
|
||||||
api_thread = threading.Thread(target=volvo.api_call, args=(CLIMATE_START_URL, "POST", vin))
|
api_thread = Thread(target=volvo.api_call, args=(CLIMATE_START_URL, "POST", vin))
|
||||||
api_thread.start()
|
api_thread.start()
|
||||||
assumed_climate_state[vin] = "ON"
|
assumed_climate_state[vin] = "ON"
|
||||||
# Starting timer to disable climate after 30 mins
|
# Starting timer to disable climate after 30 mins
|
||||||
threading.Timer(30 * 60, volvo.disable_climate, (vin, )).start()
|
climate_timer = Timer(1 * 60, volvo.disable_climate, (vin, ))
|
||||||
|
climate_timer.start()
|
||||||
update_car_data()
|
update_car_data()
|
||||||
elif payload == "OFF":
|
elif payload == "OFF":
|
||||||
api_thread = threading.Thread(target=volvo.api_call, args=(CLIMATE_STOP_URL, "POST", vin))
|
api_thread = Thread(target=volvo.api_call, args=(CLIMATE_STOP_URL, "POST", vin))
|
||||||
api_thread.start()
|
api_thread.start()
|
||||||
assumed_climate_state[vin] = "OFF"
|
assumed_climate_state[vin] = "OFF"
|
||||||
|
# Stop timer if active
|
||||||
|
if climate_timer.is_alive():
|
||||||
|
climate_timer.cancel()
|
||||||
update_car_data()
|
update_car_data()
|
||||||
elif "lock_status" in msg.topic:
|
elif "lock_status" in msg.topic:
|
||||||
if payload == "LOCK":
|
if payload == "LOCK":
|
||||||
@@ -67,7 +74,7 @@ def on_message(client, userdata, msg):
|
|||||||
update_car_data()
|
update_car_data()
|
||||||
elif "update_data" in msg.topic:
|
elif "update_data" in msg.topic:
|
||||||
if payload == "PRESS":
|
if payload == "PRESS":
|
||||||
update_car_data()
|
update_car_data(True)
|
||||||
|
|
||||||
|
|
||||||
def update_loop():
|
def update_loop():
|
||||||
@@ -79,12 +86,19 @@ def update_loop():
|
|||||||
time.sleep(settings["updateInterval"])
|
time.sleep(settings["updateInterval"])
|
||||||
|
|
||||||
|
|
||||||
def update_car_data():
|
def update_car_data(force_update=False):
|
||||||
global last_data_update
|
global last_data_update
|
||||||
last_data_update = format_datetime(datetime.now(), format="medium", locale=settings["babelLocale"])
|
last_data_update = format_datetime(datetime.now(), format="medium", locale=settings["babelLocale"])
|
||||||
for vin in volvo.vins:
|
for vin in volvo.vins:
|
||||||
|
for device_tracker in supported_device_trackers:
|
||||||
|
state = volvo.api_call(device_tracker["url"], "GET", vin, device_tracker["id"], force_update)
|
||||||
|
mqtt_client.publish(
|
||||||
|
f"homeassistant/device_tracker/{vin}_{device_tracker['id']}/attributes",
|
||||||
|
json.dumps(state)
|
||||||
|
)
|
||||||
|
|
||||||
for lock in supported_locks:
|
for lock in supported_locks:
|
||||||
state = volvo.api_call(lock["url"], "GET", vin, lock["id"])
|
state = volvo.api_call(lock["url"], "GET", vin, lock["id"], force_update)
|
||||||
mqtt_client.publish(
|
mqtt_client.publish(
|
||||||
f"homeassistant/lock/{vin}_{lock['id']}/state",
|
f"homeassistant/lock/{vin}_{lock['id']}/state",
|
||||||
state
|
state
|
||||||
@@ -105,7 +119,7 @@ def update_car_data():
|
|||||||
if sensor["id"] == "last_data_update":
|
if sensor["id"] == "last_data_update":
|
||||||
state = last_data_update
|
state = last_data_update
|
||||||
else:
|
else:
|
||||||
state = volvo.api_call(sensor["url"], "GET", vin, sensor["id"])
|
state = volvo.api_call(sensor["url"], "GET", vin, sensor["id"], force_update)
|
||||||
mqtt_client.publish(
|
mqtt_client.publish(
|
||||||
f"homeassistant/sensor/{vin}_{sensor['id']}/state",
|
f"homeassistant/sensor/{vin}_{sensor['id']}/state",
|
||||||
state
|
state
|
||||||
@@ -114,23 +128,34 @@ def update_car_data():
|
|||||||
|
|
||||||
def create_ha_devices():
|
def create_ha_devices():
|
||||||
for vin in volvo.vins:
|
for vin in volvo.vins:
|
||||||
car_details = volvo.api_call(VEHICLE_DETAILS_URL, "GET", vin)
|
device = volvo.get_vehicle_details(vin)
|
||||||
|
|
||||||
|
for device_tracker in supported_device_trackers:
|
||||||
|
config = {
|
||||||
|
"name": device_tracker['name'],
|
||||||
|
"object_id": f"volvo_{vin}_{device_tracker['id']}",
|
||||||
|
"schema": "state",
|
||||||
|
"icon": f"mdi:{device_tracker['icon']}",
|
||||||
|
"state_topic": f"homeassistant/device_tracker/{vin}_{device_tracker['id']}/state",
|
||||||
|
"device": device,
|
||||||
|
"unique_id": f"volvoAAOS2mqtt_{vin}_{device_tracker['id']}",
|
||||||
|
"json_attributes_topic": f"homeassistant/device_tracker/{vin}_{device_tracker['id']}/attributes"
|
||||||
|
}
|
||||||
|
mqtt_client.publish(
|
||||||
|
f"homeassistant/device_tracker/volvoAAOS2mqtt/{vin}_{device_tracker['id']}/config",
|
||||||
|
json.dumps(config),
|
||||||
|
)
|
||||||
|
|
||||||
for button in supported_buttons:
|
for button in supported_buttons:
|
||||||
command_topic = f"homeassistant/button/{vin}_{button['id']}/command"
|
command_topic = f"homeassistant/button/{vin}_{button['id']}/command"
|
||||||
config = {
|
config = {
|
||||||
"name": button['name'],
|
"name": button['name'],
|
||||||
"object_id": button['id'],
|
"object_id": f"volvo_{vin}_{button['id']}",
|
||||||
"schema": "state",
|
"schema": "state",
|
||||||
"icon": f"mdi:{button['icon']}",
|
"icon": f"mdi:{button['icon']}",
|
||||||
"state_topic": f"homeassistant/button/{vin}_{button['id']}/state",
|
"state_topic": f"homeassistant/button/{vin}_{button['id']}/state",
|
||||||
"command_topic": command_topic,
|
"command_topic": command_topic,
|
||||||
"device": {
|
"device": device,
|
||||||
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
|
||||||
"manufacturer": "Volvo",
|
|
||||||
"model": car_details['descriptions']['model'],
|
|
||||||
"name": f"{car_details['descriptions']['model']} ({car_details['modelYear']}) - {vin}",
|
|
||||||
},
|
|
||||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{button['id']}",
|
"unique_id": f"volvoAAOS2mqtt_{vin}_{button['id']}",
|
||||||
}
|
}
|
||||||
mqtt_client.publish(
|
mqtt_client.publish(
|
||||||
@@ -144,18 +169,13 @@ def create_ha_devices():
|
|||||||
command_topic = f"homeassistant/lock/{vin}_{lock['id']}/command"
|
command_topic = f"homeassistant/lock/{vin}_{lock['id']}/command"
|
||||||
config = {
|
config = {
|
||||||
"name": lock['name'],
|
"name": lock['name'],
|
||||||
"object_id": lock['id'],
|
"object_id": f"volvo_{vin}_{lock['id']}",
|
||||||
"schema": "state",
|
"schema": "state",
|
||||||
"icon": f"mdi:{lock['icon']}",
|
"icon": f"mdi:{lock['icon']}",
|
||||||
"state_topic": f"homeassistant/lock/{vin}_{lock['id']}/state",
|
"state_topic": f"homeassistant/lock/{vin}_{lock['id']}/state",
|
||||||
"command_topic": command_topic,
|
"command_topic": command_topic,
|
||||||
"optimistic": False,
|
"optimistic": False,
|
||||||
"device": {
|
"device": device,
|
||||||
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
|
||||||
"manufacturer": "Volvo",
|
|
||||||
"model": car_details['descriptions']['model'],
|
|
||||||
"name": f"{car_details['descriptions']['model']} ({car_details['modelYear']}) - {vin}",
|
|
||||||
},
|
|
||||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{lock['id']}",
|
"unique_id": f"volvoAAOS2mqtt_{vin}_{lock['id']}",
|
||||||
}
|
}
|
||||||
mqtt_client.publish(
|
mqtt_client.publish(
|
||||||
@@ -169,18 +189,13 @@ def create_ha_devices():
|
|||||||
command_topic = f"homeassistant/switch/{vin}_{switch['id']}/command"
|
command_topic = f"homeassistant/switch/{vin}_{switch['id']}/command"
|
||||||
config = {
|
config = {
|
||||||
"name": switch['name'],
|
"name": switch['name'],
|
||||||
"object_id": switch['id'],
|
"object_id": f"volvo_{vin}_{switch['id']}",
|
||||||
"schema": "state",
|
"schema": "state",
|
||||||
"icon": f"mdi:{switch['icon']}",
|
"icon": f"mdi:{switch['icon']}",
|
||||||
"state_topic": f"homeassistant/switch/{vin}_{switch['id']}/state",
|
"state_topic": f"homeassistant/switch/{vin}_{switch['id']}/state",
|
||||||
"command_topic": command_topic,
|
"command_topic": command_topic,
|
||||||
"optimistic": False,
|
"optimistic": False,
|
||||||
"device": {
|
"device": device,
|
||||||
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
|
||||||
"manufacturer": "Volvo",
|
|
||||||
"model": car_details['descriptions']['model'],
|
|
||||||
"name": f"{car_details['descriptions']['model']} ({car_details['modelYear']}) - {vin}",
|
|
||||||
},
|
|
||||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{switch['id']}",
|
"unique_id": f"volvoAAOS2mqtt_{vin}_{switch['id']}",
|
||||||
}
|
}
|
||||||
mqtt_client.publish(
|
mqtt_client.publish(
|
||||||
@@ -193,16 +208,11 @@ def create_ha_devices():
|
|||||||
for sensor in supported_sensors:
|
for sensor in supported_sensors:
|
||||||
config = {
|
config = {
|
||||||
"name": sensor['name'],
|
"name": sensor['name'],
|
||||||
"object_id": sensor['id'],
|
"object_id": f"volvo_{vin}_{sensor['id']}",
|
||||||
"schema": "state",
|
"schema": "state",
|
||||||
"icon": f"mdi:{sensor['icon']}",
|
"icon": f"mdi:{sensor['icon']}",
|
||||||
"state_topic": f"homeassistant/sensor/{vin}_{sensor['id']}/state",
|
"state_topic": f"homeassistant/sensor/{vin}_{sensor['id']}/state",
|
||||||
"device": {
|
"device": device,
|
||||||
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
|
||||||
"manufacturer": "Volvo",
|
|
||||||
"model": car_details['descriptions']['model'],
|
|
||||||
"name": f"{car_details['descriptions']['model']} ({car_details['modelYear']}) - {vin}",
|
|
||||||
},
|
|
||||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{sensor['id']}",
|
"unique_id": f"volvoAAOS2mqtt_{vin}_{sensor['id']}",
|
||||||
}
|
}
|
||||||
if "unit" in sensor:
|
if "unit" in sensor:
|
||||||
|
|||||||
@@ -0,0 +1,16 @@
|
|||||||
|
configuration:
|
||||||
|
updateInterval:
|
||||||
|
name: Update intervall
|
||||||
|
description: Time to wait between data pulls
|
||||||
|
babelLocale:
|
||||||
|
name: Babel locale
|
||||||
|
description: Select your country code or take a look at the GitHub repo for more infos!
|
||||||
|
debug:
|
||||||
|
name: API debug mode
|
||||||
|
description: Enable Volvo API debug, normaly this can stay off
|
||||||
|
mqtt:
|
||||||
|
name: MQTT Broker settings
|
||||||
|
description: Broker is your mqtt broker IP eg "192.168.0.1". Mqtt username and password are optional.
|
||||||
|
volvoData:
|
||||||
|
name: Volvo APP credentials
|
||||||
|
description: You have to enter your Volvo app credentials. The username is normally your email, and the password is the password you use for your Volvo app. The vin can stay empty. The Add-On will use any vin inside your Volvo account. VCCAPI key is required and comes from your Volvo developer account. Take a look at the GitHub repo for more information!
|
||||||
+152
-39
@@ -4,7 +4,8 @@ import mqtt
|
|||||||
from config import settings
|
from config import settings
|
||||||
from babel.dates import format_datetime
|
from babel.dates import format_datetime
|
||||||
from const import charging_system_states, CLIMATE_START_URL, \
|
from const import charging_system_states, CLIMATE_START_URL, \
|
||||||
OAUTH_URL, VEHICLES_URL, VEHICLE_DETAILS_URL, RECHARGE_STATUS_URL
|
OAUTH_URL, VEHICLES_URL, VEHICLE_DETAILS_URL, RECHARGE_STATE_URL, \
|
||||||
|
WINDOWS_STATE_URL, LOCK_STATE_URL
|
||||||
|
|
||||||
session = requests.Session()
|
session = requests.Session()
|
||||||
session.headers = {
|
session.headers = {
|
||||||
@@ -16,8 +17,12 @@ session.headers = {
|
|||||||
token_expires_at: datetime
|
token_expires_at: datetime
|
||||||
refresh_token = None
|
refresh_token = None
|
||||||
vins = []
|
vins = []
|
||||||
recharge_response = {}
|
recharge_cached_api_response = {}
|
||||||
recharge_last_update = {}
|
recharge_api_last_update = {}
|
||||||
|
window_cached_api_response = {}
|
||||||
|
window_api_last_update = {}
|
||||||
|
door_cached_api_response = {}
|
||||||
|
door_api_last_update = {}
|
||||||
|
|
||||||
|
|
||||||
def authorize():
|
def authorize():
|
||||||
@@ -99,6 +104,34 @@ def get_vehicles():
|
|||||||
print("Vin: " + str(vins) + " found!")
|
print("Vin: " + str(vins) + " found!")
|
||||||
|
|
||||||
|
|
||||||
|
def get_vehicle_details(vin):
|
||||||
|
response = session.get(VEHICLE_DETAILS_URL.format(vin), timeout=15)
|
||||||
|
if response.status_code == 200:
|
||||||
|
data = response.json()["data"]
|
||||||
|
if "debug" in settings:
|
||||||
|
if settings["debug"]:
|
||||||
|
print(response.text)
|
||||||
|
device = {
|
||||||
|
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
||||||
|
"manufacturer": "Volvo",
|
||||||
|
"model": data['descriptions']['model'],
|
||||||
|
"name": f"{data['descriptions']['model']} ({data['modelYear']}) - {vin}",
|
||||||
|
}
|
||||||
|
elif response.status_code == 500 and not settings.volvoData["vin"]:
|
||||||
|
# Workaround for some cars that are not returning vehicle details
|
||||||
|
device = {
|
||||||
|
"identifiers": [f"volvoAAOS2mqtt_{vin}"],
|
||||||
|
"manufacturer": "Volvo",
|
||||||
|
"model": vin,
|
||||||
|
"name": f"Volvo - {vin}",
|
||||||
|
}
|
||||||
|
else:
|
||||||
|
raise Exception("Getting vehicle details failed. Status Code: " + str(response.status_code) +
|
||||||
|
". Error: " + response.text)
|
||||||
|
|
||||||
|
return device
|
||||||
|
|
||||||
|
|
||||||
def initialize_climate(vins):
|
def initialize_climate(vins):
|
||||||
for vin in vins:
|
for vin in vins:
|
||||||
mqtt.assumed_climate_state[vin] = "OFF"
|
mqtt.assumed_climate_state[vin] = "OFF"
|
||||||
@@ -110,30 +143,20 @@ def disable_climate(vin):
|
|||||||
mqtt.update_car_data()
|
mqtt.update_car_data()
|
||||||
|
|
||||||
|
|
||||||
def api_call(url, method, vin, sensor_id=None):
|
def api_call(url, method, vin, sensor_id=None, force_update=False):
|
||||||
global token_expires_at
|
global token_expires_at
|
||||||
if datetime.now() >= token_expires_at:
|
if datetime.now() >= token_expires_at:
|
||||||
refresh_auth()
|
refresh_auth()
|
||||||
|
|
||||||
global recharge_response, recharge_last_update
|
if url == RECHARGE_STATE_URL:
|
||||||
if url == RECHARGE_STATUS_URL:
|
# Minimize API calls for recharge state
|
||||||
# Minimize API calls for recharge API
|
response = pull_recharge_api(url, method, vin, force_update)
|
||||||
if not vin in recharge_response:
|
elif url == WINDOWS_STATE_URL:
|
||||||
# No API Data for vin cached, get fresh data from API
|
# Minimize API calls for window state
|
||||||
print("Starting " + method + " call against " + url)
|
response = pull_window_api(url, method, vin, force_update)
|
||||||
response = session.get(url.format(vin), timeout=15)
|
elif url == LOCK_STATE_URL:
|
||||||
recharge_response[vin] = response
|
# Minimize API calls for door state
|
||||||
recharge_last_update[vin] = datetime.now()
|
response = pull_door_api(url, method, vin, force_update)
|
||||||
else:
|
|
||||||
if (datetime.now() - recharge_last_update[vin]).total_seconds() >= settings["updateInterval"]:
|
|
||||||
# Old Data in Cache, updating
|
|
||||||
print("Starting " + method + " call against " + url)
|
|
||||||
response = session.get(url.format(vin), timeout=15)
|
|
||||||
recharge_response[vin] = response
|
|
||||||
recharge_last_update[vin] = datetime.now()
|
|
||||||
else:
|
|
||||||
# Data is up do date, returning cached data
|
|
||||||
response = recharge_response[vin]
|
|
||||||
elif method == "GET":
|
elif method == "GET":
|
||||||
print("Starting " + method + " call against " + url)
|
print("Starting " + method + " call against " + url)
|
||||||
response = session.get(url.format(vin), timeout=15)
|
response = session.get(url.format(vin), timeout=15)
|
||||||
@@ -157,25 +180,85 @@ def api_call(url, method, vin, sensor_id=None):
|
|||||||
else:
|
else:
|
||||||
print("API Call failed. Status Code: " + str(response.status_code) + ". Error: " + response.text)
|
print("API Call failed. Status Code: " + str(response.status_code) + ". Error: " + response.text)
|
||||||
return ""
|
return ""
|
||||||
return parse_api_data(url, data, sensor_id)
|
state = parse_api_data(data, sensor_id)
|
||||||
|
if not state:
|
||||||
|
return ""
|
||||||
|
else:
|
||||||
|
return state
|
||||||
|
|
||||||
|
|
||||||
def parse_api_data(url, data, sensor_id=None):
|
|
||||||
if url == VEHICLE_DETAILS_URL:
|
def pull_door_api(url, method, vin, force_update=False):
|
||||||
return data["data"]
|
global door_cached_api_response, door_api_last_update
|
||||||
elif sensor_id == "battery_charge_level":
|
if not vin in door_cached_api_response or force_update:
|
||||||
if "batteryChargeLevel" in data["data"]:
|
# No API Data for vin cached, get fresh data from API
|
||||||
return data["data"]["batteryChargeLevel"]["value"]
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
door_cached_api_response[vin] = response
|
||||||
|
door_api_last_update[vin] = datetime.now()
|
||||||
|
else:
|
||||||
|
if (datetime.now() - door_api_last_update[vin]).total_seconds() >= settings["updateInterval"]:
|
||||||
|
# Old Data in Cache, updating
|
||||||
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
door_cached_api_response[vin] = response
|
||||||
|
door_api_last_update[vin] = datetime.now()
|
||||||
else:
|
else:
|
||||||
return ""
|
# Data is up do date, returning cached data
|
||||||
|
response = door_cached_api_response[vin]
|
||||||
|
return response
|
||||||
|
|
||||||
|
|
||||||
|
def pull_window_api(url, method, vin, force_update=False):
|
||||||
|
global window_cached_api_response, window_api_last_update
|
||||||
|
if not vin in window_cached_api_response or force_update:
|
||||||
|
# No API Data for vin cached, get fresh data from API
|
||||||
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
window_cached_api_response[vin] = response
|
||||||
|
window_api_last_update[vin] = datetime.now()
|
||||||
|
else:
|
||||||
|
if (datetime.now() - window_api_last_update[vin]).total_seconds() >= settings["updateInterval"]:
|
||||||
|
# Old Data in Cache, updating
|
||||||
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
window_cached_api_response[vin] = response
|
||||||
|
window_api_last_update[vin] = datetime.now()
|
||||||
|
else:
|
||||||
|
# Data is up do date, returning cached data
|
||||||
|
response = window_cached_api_response[vin]
|
||||||
|
return response
|
||||||
|
|
||||||
|
|
||||||
|
def pull_recharge_api(url, method, vin, force_update=False):
|
||||||
|
global recharge_cached_api_response, recharge_api_last_update
|
||||||
|
if not vin in recharge_cached_api_response or force_update:
|
||||||
|
# No API Data for vin cached, get fresh data from API
|
||||||
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
recharge_cached_api_response[vin] = response
|
||||||
|
recharge_api_last_update[vin] = datetime.now()
|
||||||
|
else:
|
||||||
|
if (datetime.now() - recharge_api_last_update[vin]).total_seconds() >= settings["updateInterval"]:
|
||||||
|
# Old Data in Cache, updating
|
||||||
|
print("Starting " + method + " call against " + url)
|
||||||
|
response = session.get(url.format(vin), timeout=15)
|
||||||
|
recharge_cached_api_response[vin] = response
|
||||||
|
recharge_api_last_update[vin] = datetime.now()
|
||||||
|
else:
|
||||||
|
# Data is up do date, returning cached data
|
||||||
|
response = recharge_cached_api_response[vin]
|
||||||
|
return response
|
||||||
|
|
||||||
|
|
||||||
|
def parse_api_data(data, sensor_id=None):
|
||||||
|
if sensor_id == "battery_charge_level":
|
||||||
|
return data["data"].get("batteryChargeLevel").get("value")
|
||||||
elif sensor_id == "electric_range":
|
elif sensor_id == "electric_range":
|
||||||
if "electricRange" in data["data"]:
|
return data["data"].get("electricRange").get("value")
|
||||||
return data["data"]["electricRange"]["value"]
|
|
||||||
else:
|
|
||||||
return ""
|
|
||||||
elif sensor_id == "charging_system_status":
|
elif sensor_id == "charging_system_status":
|
||||||
if "chargingSystemStatus" in data["data"]:
|
if "chargingSystemStatus" in data["data"]:
|
||||||
return charging_system_states[data["data"]["chargingSystemStatus"]["value"]]
|
return charging_system_states[data["data"].get("chargingSystemStatus").get("value")]
|
||||||
else:
|
else:
|
||||||
return ""
|
return ""
|
||||||
elif sensor_id == "estimated_charging_time":
|
elif sensor_id == "estimated_charging_time":
|
||||||
@@ -189,9 +272,9 @@ def parse_api_data(url, data, sensor_id=None):
|
|||||||
return ""
|
return ""
|
||||||
elif sensor_id == "estimated_charging_finish_time":
|
elif sensor_id == "estimated_charging_finish_time":
|
||||||
if "chargingSystemStatus" in data["data"]:
|
if "chargingSystemStatus" in data["data"]:
|
||||||
charging_system_state = charging_system_states[data["data"]["chargingSystemStatus"]["value"]]
|
charging_system_state = charging_system_states[data["data"].get("chargingSystemStatus").get("value")]
|
||||||
if charging_system_state == "Charging":
|
if charging_system_state == "Charging":
|
||||||
charging_time = int(data["data"]["estimatedChargingTime"]["value"])
|
charging_time = int(data["data"].get("estimatedChargingTime").get("value"))
|
||||||
charging_finished = datetime.now() + timedelta(minutes=charging_time)
|
charging_finished = datetime.now() + timedelta(minutes=charging_time)
|
||||||
return format_datetime(charging_finished, format="medium", locale=settings["babelLocale"])
|
return format_datetime(charging_finished, format="medium", locale=settings["babelLocale"])
|
||||||
else:
|
else:
|
||||||
@@ -199,6 +282,36 @@ def parse_api_data(url, data, sensor_id=None):
|
|||||||
else:
|
else:
|
||||||
return None
|
return None
|
||||||
elif sensor_id == "lock_status":
|
elif sensor_id == "lock_status":
|
||||||
return data["data"]["carLocked"]["value"]
|
return data["data"].get("carLocked").get("value")
|
||||||
|
elif sensor_id == "odometer":
|
||||||
|
return data["data"].get("odometer").get("value")
|
||||||
|
elif sensor_id == "window_front_left":
|
||||||
|
return data["data"].get("frontLeftWindowOpen").get("value")
|
||||||
|
elif sensor_id == "window_front_right":
|
||||||
|
return data["data"].get("frontRightWindowOpen").get("value")
|
||||||
|
elif sensor_id == "window_rear_left":
|
||||||
|
return data["data"].get("rearLeftWindowOpen").get("value")
|
||||||
|
elif sensor_id == "window_rear_right":
|
||||||
|
return data["data"].get("rearRightWindowOpen").get("value")
|
||||||
|
elif sensor_id == "door_front_left":
|
||||||
|
return data["data"].get("frontLeftDoorOpen").get("value")
|
||||||
|
elif sensor_id == "door_front_right":
|
||||||
|
return data["data"].get("frontRightDoorOpen").get("value")
|
||||||
|
elif sensor_id == "door_rear_left":
|
||||||
|
return data["data"].get("rearLeftDoorOpen").get("value")
|
||||||
|
elif sensor_id == "door_rear_right":
|
||||||
|
return data["data"].get("rearRightDoorOpen").get("value")
|
||||||
|
elif sensor_id == "tailgate":
|
||||||
|
return data["data"].get("tailGateOpen").get("value")
|
||||||
|
elif sensor_id == "engine_hood":
|
||||||
|
return data["data"].get("hoodOpen").get("value")
|
||||||
|
elif sensor_id == "tank_lid":
|
||||||
|
return data["data"].get("tankLidOpen").get("value")
|
||||||
|
elif sensor_id == "location":
|
||||||
|
coordinates = {}
|
||||||
|
if "geometry" in data["data"]:
|
||||||
|
raw_data = data["data"].get("geometry").get("coordinates")
|
||||||
|
coordinates = {"longitude": raw_data[0], "latitude": raw_data[1], "gps_accuracy": 1}
|
||||||
|
return coordinates
|
||||||
else:
|
else:
|
||||||
return ""
|
return ""
|
||||||
|
|||||||
Reference in New Issue
Block a user