forked from peter/volvo2mqtt
Compare commits
5
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 Linus Dietz
|
016a0193e2 | ||
|
Linus Dietz
|
c3a798e397 | ||
|
Linus Dietz
|
89417696bd | ||
|
Linus Dietz
|
d55dc25647 | ||
|
Linus Dietz
|
1d193270a4 |
@@ -27,20 +27,20 @@ jobs:
|
||||
|
||||
steps:
|
||||
- name: Checkout repository
|
||||
uses: actions/checkout@v4
|
||||
uses: actions/checkout@v3
|
||||
- name: Set up QEMU
|
||||
uses: docker/setup-qemu-action@v3
|
||||
uses: docker/setup-qemu-action@v2
|
||||
- name: Set up Docker Buildx
|
||||
uses: docker/setup-buildx-action@v3
|
||||
uses: docker/setup-buildx-action@v2
|
||||
- name: Log in to the Container registry
|
||||
uses: docker/login-action@v3
|
||||
uses: docker/login-action@65b78e6e13532edd9afa3aa52ac7964289d1a9c1
|
||||
with:
|
||||
registry: ${{ env.REGISTRY }}
|
||||
username: ${{ github.actor }}
|
||||
password: ${{ secrets.GITHUB_TOKEN }}
|
||||
- name: Extract metadata (tags, labels) for Docker
|
||||
id: meta
|
||||
uses: docker/metadata-action@v5
|
||||
uses: docker/metadata-action@9ec57ed1fcdbf14dcef7dfbe97b2010124a938b7
|
||||
with:
|
||||
images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
|
||||
tags: |
|
||||
@@ -52,7 +52,7 @@ jobs:
|
||||
type=semver,pattern={{major}}
|
||||
type=sha
|
||||
- name: Build and push
|
||||
uses: docker/build-push-action@v5
|
||||
uses: docker/build-push-action@v2
|
||||
with:
|
||||
context: .
|
||||
platforms: linux/amd64,linux/arm/v7,linux/arm/v6,linux/arm/v8
|
||||
|
||||
@@ -15,8 +15,6 @@ Maybe this component works also with other Volvo cars. Please try out the native
|
||||
|
||||
Home Assistant thread can be found [here](https://community.home-assistant.io/t/volvo2mqtt-connect-your-aaos-volvo/585699).
|
||||
|
||||
<b>Important note: The Volvo api currently ONLY works in these [countries](https://developer.volvocars.com/terms-and-conditions/apis-supported-locations/)</b>
|
||||
|
||||
If you like my work:<br>
|
||||
[](https://ko-fi.com/U7U8MFXCF)
|
||||
|
||||
@@ -26,22 +24,16 @@ If you like my work:<br>
|
||||
- XC40 BEV (2022)
|
||||
- XC40 PHEV (2021)
|
||||
- V60 T8 PHEV (2023)
|
||||
- V60 T6 PHEV (2025)
|
||||
- C40 BEV (2023)
|
||||
- C40 BEV (2022)
|
||||
- C40 BEV (2024)
|
||||
- XC90 T8 PHEV (2023)
|
||||
- XC60 PHEV (2024)
|
||||
- XC60 PHEV (2023)
|
||||
- XC60 PHEV (2022)
|
||||
- XC60 B5 Mildhybrid (2023)
|
||||
- XC90 PHEV T8 (2023)
|
||||
- XC90 PHEV T8 (2024)
|
||||
- XC90 B5 Mildhybrid (2024)
|
||||
- V90 PHEV T8 (2019)*
|
||||
- V90 PHEV T6 (2024)
|
||||
- V90 B5 Mildhybrid (2023)
|
||||
- EX40 BEV (2025)
|
||||
|
||||
*only partly working
|
||||
|
||||
@@ -52,10 +44,9 @@ Please let me know if your car works with this addon so I can expand the list!<b
|
||||
- Lock/unlock car
|
||||
- Start/stop climate
|
||||
- Sensor "Battery Charge Level"
|
||||
- Sensor "Battery Capacity"
|
||||
- Sensor "Electric Range"
|
||||
- Sensor "Charging System Status"
|
||||
- Sensor "Charging Connection Status"
|
||||
- Sensor "Charging Connection Status" (partly broken since 2.10 car update)
|
||||
- Sensor "Estimated Charging Finish Time"
|
||||
- Sensor "Door Lock Status (All doors, tank lid, and engine hood)"
|
||||
- Sensor "Window Lock Status (All windows and sunroof - Thanks to @navet)"
|
||||
@@ -76,50 +67,6 @@ Please let me know if your car works with this addon so I can expand the list!<b
|
||||
|
||||
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)
|
||||
|
||||
## OTP Authentication
|
||||
|
||||
As of version <b>v1.9.0</b>, this addon uses the same OTP authentication as the Volvo app.
|
||||
The following steps are required for authentication in exactly this order:
|
||||
|
||||
1. Setup volvo2Mqtt, either via Docker, or via HA addon (take a look at the "Setup" section below)
|
||||
2. Fill in your settings and start volvo2Mqtt
|
||||
3. Your log will show the following lines <br>
|
||||
```Waiting for otp code... Please check your mailbox and post your otp code to the following mqtt topic "volvoAAOS2mqtt/otp_code". Retry 0/15```<br>
|
||||
```Waiting for otp code... Please check your mailbox and post your otp code to the following mqtt topic "volvoAAOS2mqtt/otp_code". Retry 1/15```<br>
|
||||
```etc ...```
|
||||
4. Now, open your mailbox and copy your OTP Code
|
||||
5. Open HomeAssistant and search for the entity ID ```text.volvo_otp```
|
||||
6. Paste your OTP into the text entity and **<ins>press Enter</ins>**<br>
|
||||
6a. (optional) If your OTP cannot be safed, try to paste your OTP code via MQTT to the following topic: `volvoAAOS2mqtt/otp_code` <p>
|
||||
<details>
|
||||
<summary>OTP Post Script</summary>
|
||||
<div>
|
||||
<p>
|
||||
1. Safe the following script in your script section <br>
|
||||
2. Go to https://yourHAUrl/developer-tools/service<br>
|
||||
3. Search for "Post Volvo OTP"<br>
|
||||
4. Tick "OTP" and fill in your OTP<br>
|
||||
5. Run this service<br>
|
||||
</div>
|
||||
|
||||
alias: Post Volvo OTP
|
||||
sequence:
|
||||
- service: mqtt.publish
|
||||
metadata: {}
|
||||
data:
|
||||
topic: volvoAAOS2mqtt/otp_code
|
||||
payload: "{{ otp }}"
|
||||
mode: single
|
||||
fields:
|
||||
otp:
|
||||
selector:
|
||||
text: null
|
||||
name: OTP
|
||||
description: Volvo OTP
|
||||
|
||||
</details>
|
||||
8. If everything has worked, your addon is now authenticated. In the future, OTP authentication only needs to be done when updating, not when restarting the container.
|
||||
|
||||
## Setup
|
||||
<b>Docker:</b>
|
||||
|
||||
@@ -153,6 +100,7 @@ Here is what every option means:
|
||||
| `TZ` | `string` | | **required** | Container timezone eg "Europe/Berlin" from [here](https://docs.diladele.com/docker/timezones.html)|
|
||||
|
||||
|
||||
|
||||
[aarch64-shield]: https://img.shields.io/badge/aarch64-yes-green.svg
|
||||
[amd64-shield]: https://img.shields.io/badge/amd64-yes-green.svg
|
||||
[armhf-shield]: https://img.shields.io/badge/armhf-yes-green.svg
|
||||
@@ -160,6 +108,6 @@ Here is what every option means:
|
||||
[i386-shield]: https://img.shields.io/badge/i386-yes-green.svg
|
||||
[releases]: https://github.com/Dielee/volvo2mqtt/releases
|
||||
[releases-shield]: https://img.shields.io/github/release/Dielee/volvo2mqtt.svg
|
||||
[maintenance-shield]: https://img.shields.io/maintenance/yes/2024.svg
|
||||
[maintenance-shield]: https://img.shields.io/maintenance/yes/2023.svg
|
||||
[commits-shield]: https://img.shields.io/github/commit-activity/y/Dielee/volvo2mqtt.svg
|
||||
[commits]: https://github.com/Dielee/volvo2mqtt/commits/main
|
||||
|
||||
+2
-3
@@ -1,6 +1,5 @@
|
||||
requests~=2.32.0
|
||||
requests~=2.29.0
|
||||
dynaconf~=3.1.12
|
||||
paho-mqtt~=1.6.1
|
||||
Babel~=2.12.1
|
||||
pytz~=2023.3
|
||||
google_play_scraper~=1.2.6
|
||||
pytz~=2023.3
|
||||
+2
-101
@@ -1,107 +1,8 @@
|
||||
## v1.9.7
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Fix EX30 battery state #230
|
||||
|
||||
## v1.9.6
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Fixed interior and exterior Images #219
|
||||
- Take care of broken token files #220
|
||||
|
||||
## v1.9.5
|
||||
### 🚀 Features:
|
||||
|
||||
- Added "retain" states to survive HA reboot
|
||||
|
||||
## v1.9.4
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Fix backend state API url
|
||||
|
||||
## v1.9.3
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Ignore retained OTP messages #193
|
||||
|
||||
## v1.9.2
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Try to fix OTP Input
|
||||
- Fix `SyntaxWarning: invalid escape sequence '\d'` #196
|
||||
|
||||
## v1.9.1
|
||||
### 🚀 Features:
|
||||
|
||||
- The token file now survives an HA addon update/restart
|
||||
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Extend OTP retry time to 120 seconds
|
||||
|
||||
## v1.9.0
|
||||
### ⚠️ Breaking change
|
||||
### 🚀 Features:
|
||||
|
||||
- Add "Battery Capacity" sensor. Thanks to @gurtjun!
|
||||
- OTP Auth
|
||||
This addon uses the same OTP authentication as the Volvo app, now.
|
||||
The following steps are required for authentication in exactly this order:
|
||||
|
||||
1. Setup volvo2Mqtt, either via Docker, or via HA addon (take a look at the "Setup" section)
|
||||
2. Fill in your settings and start volvo2Mqtt
|
||||
3. Your log will show the following lines
|
||||
Waiting for otp code... Please check your mailbox and post your otp code to the following mqtt topic "volvoAAOS2mqtt/otp_code". Retry 0/15
|
||||
Waiting for otp code... Please check your mailbox and post your otp code to the following mqtt topic "volvoAAOS2mqtt/otp_code". Retry 1/15
|
||||
etc ...
|
||||
4. Now, open your mailbox and copy your OTP Code
|
||||
5. Open HomeAssistant and search for the entity ID text.volvo_otp
|
||||
6. Paste your OTP into the text entity and press Enter
|
||||
7. If everything has worked, your addon is now authenticated. In the future, OTP authentication only needs to be done when updating, not when restarting the container.
|
||||
|
||||
|
||||
## v1.8.27
|
||||
### 🚀 Features:
|
||||
|
||||
- Add state caching for "diagnostics" endpoint
|
||||
|
||||
## v1.8.26
|
||||
### 🚀 Features:
|
||||
|
||||
- Add option to disable updates #160 (Set the update interval to -1)
|
||||
|
||||
## v1.8.25
|
||||
### 🚀 Features:
|
||||
|
||||
- Fix INTERNAL_SERVER_ERROR #165
|
||||
|
||||
## v1.8.24
|
||||
### 🚀 Features:
|
||||
|
||||
- Add option for dynamic interval settings #160
|
||||
- Add warnings endpoint #151
|
||||
|
||||
## v1.8.23
|
||||
### 🚀 Features:
|
||||
|
||||
- Add new charging system states #152
|
||||
|
||||
## v1.8.22
|
||||
### 🚀 Features:
|
||||
|
||||
- Change units to HA default #148
|
||||
|
||||
## v1.8.21
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Try to fix addon build #146
|
||||
|
||||
## v1.8.20
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
- Fix Addon crash if icon state is `UNKOWN`
|
||||
- Add `UNSPECIFIED` state for windows
|
||||
|
||||
- Add check for supported commands
|
||||
- Add Engine start/stop and Engine runtime minutes for supported cars
|
||||
|
||||
## v1.8.19
|
||||
### 🐛 Bug Fixes:
|
||||
|
||||
+2
-5
@@ -1,9 +1,6 @@
|
||||
ARG BUILD_FROM
|
||||
FROM $BUILD_FROM
|
||||
|
||||
# Add community packets
|
||||
RUN echo -e "https://nl.alpinelinux.org/alpine/latest-stable/main\nhttps://nl.alpinelinux.org/alpine/latest-stable/community" > /etc/apk/repositories
|
||||
|
||||
# Install requirements for add-on
|
||||
RUN apk add --no-cache python3 bash py3-pip
|
||||
|
||||
@@ -14,11 +11,11 @@ WORKDIR /volvoAAOS2mqtt
|
||||
RUN wget --no-cache https://raw.githubusercontent.com/Dielee/volvo2mqtt/main/requirements.txt
|
||||
|
||||
# install dependencies
|
||||
RUN pip install -r requirements.txt --break-system-packages
|
||||
RUN pip install -r requirements.txt
|
||||
|
||||
# copy the content of the local src directory to the working directory
|
||||
COPY / .
|
||||
RUN chmod a+x /volvoAAOS2mqtt/run.sh
|
||||
|
||||
# command to run on container start
|
||||
CMD [ "/volvoAAOS2mqtt/run.sh" ]
|
||||
CMD [ "/volvoAAOS2mqtt/run.sh" ]
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
name: "Volvo2Mqtt"
|
||||
description: "Volvo AAOS MQTT bridge"
|
||||
version: "1.9.6"
|
||||
version: "1.9.0"
|
||||
slug: "volvo2mqtt"
|
||||
init: false
|
||||
url: "https://github.com/Dielee/volvo2mqtt"
|
||||
|
||||
+46
-59
@@ -1,9 +1,8 @@
|
||||
from config import settings
|
||||
|
||||
VERSION = "v1.9.7"
|
||||
VERSION = "v1.9.0"
|
||||
|
||||
OAUTH_TOKEN_URL = "https://volvoid.eu.volvocars.com/as/token.oauth2"
|
||||
OAUTH_AUTH_URL = "https://volvoid.eu.volvocars.com/as/authorization.oauth2"
|
||||
OAUTH_URL = "https://volvoid.eu.volvocars.com/as/token.oauth2"
|
||||
VEHICLES_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles"
|
||||
VEHICLE_DETAILS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}"
|
||||
WINDOWS_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/windows"
|
||||
@@ -21,49 +20,40 @@ FUEL_BATTERY_STATE_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicle
|
||||
STATISTICS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/statistics"
|
||||
ENGINE_DIAGNOSTICS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/engine"
|
||||
VEHICLE_DIAGNOSTICS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/diagnostics"
|
||||
WARNINGS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/warnings"
|
||||
API_BACKEND_STATUS = "https://public-developer-portal-bff.weu-prod.ecpaz.volvocars.biz/api/v1/backend-status"
|
||||
|
||||
LENGTH_KILOMETERS = "km"
|
||||
SPEED_KILOMETERS_PER_HOUR = "km/h"
|
||||
TIME_MINUTES = "min"
|
||||
LENGTH_MILES = "mi"
|
||||
SPEED_MILES_PER_HOUR = "mph"
|
||||
VOLUME_LITERS = "L"
|
||||
ENERGY_KILO_WATT_HOUR = "kWh"
|
||||
TIME_HOURS = "h"
|
||||
TIME_MONTHS = "m"
|
||||
API_BACKEND_STATUS_URL = "https://oip-dev-bff.euwest1.production.volvo.care/api/v1/backend-status"
|
||||
SUPPORTED_COMMANDS_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands"
|
||||
ENGINE_START_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/engine-start"
|
||||
ENGINE_STOP_URL = "https://api.volvocars.com/connected-vehicle/v2/vehicles/{0}/commands/engine-stop"
|
||||
|
||||
units = {
|
||||
"en_GB": {
|
||||
"divider": 1.60934,
|
||||
"electric_range": {"unit": LENGTH_MILES},
|
||||
"odometer": {"unit": LENGTH_MILES},
|
||||
"average_speed": {"unit": SPEED_MILES_PER_HOUR},
|
||||
"distance_to_empty": {"unit": LENGTH_MILES},
|
||||
"distance_to_service": {"unit": LENGTH_MILES}
|
||||
"electric_range": {"unit": "mi"},
|
||||
"odometer": {"unit": "mi"},
|
||||
"average_speed": {"unit": "mph"},
|
||||
"distance_to_empty": {"unit": "mi"},
|
||||
"distance_to_service": {"unit": "mi"}
|
||||
},
|
||||
"en_US": {
|
||||
"divider": 1.60934,
|
||||
"electric_range": {"unit": LENGTH_MILES},
|
||||
"odometer": {"unit": LENGTH_MILES},
|
||||
"average_speed": {"unit": SPEED_MILES_PER_HOUR},
|
||||
"distance_to_empty": {"unit": LENGTH_MILES},
|
||||
"distance_to_service": {"unit": LENGTH_MILES}
|
||||
"electric_range": {"unit": "mi"},
|
||||
"odometer": {"unit": "mi"},
|
||||
"average_speed": {"unit": "mph"},
|
||||
"distance_to_empty": {"unit": "mi"},
|
||||
"distance_to_service": {"unit": "mi"}
|
||||
}
|
||||
}
|
||||
|
||||
availability_topic = "volvoAAOS2mqtt/availability"
|
||||
|
||||
charging_system_states = {"CHARGING_SYSTEM_CHARGING": "Charging", "CHARGING_SYSTEM_IDLE": "Idle",
|
||||
"CHARGING_SYSTEM_FAULT": "Fault", "CHARGING_SYSTEM_UNSPECIFIED": "Unspecified",
|
||||
"CHARGING_SYSTEM_DONE": "Done", "CHARGING_SYSTEM_SCHEDULED": "Scheduled"}
|
||||
"CHARGING_SYSTEM_FAULT": "Fault", "CHARGING_SYSTEM_UNSPECIFIED": "Unspecified"}
|
||||
|
||||
charging_connection_states = {"CONNECTION_STATUS_DISCONNECTED": "Disconnected", "CONNECTION_STATUS_UNSPECIFIED": "Unspecified",
|
||||
"CONNECTION_STATUS_CONNECTED_DC": "Connected DC", "CONNECTION_STATUS_CONNECTED_AC": "Connected AC",
|
||||
"CONNECTION_STATUS_FAULT": "Fault"}
|
||||
|
||||
window_states = {"CLOSED": "OFF", "OPEN": "ON", "UNSPECIFIED": "UNKNOWN", "AJAR": "ON"}
|
||||
window_states = {"CLOSED": "OFF", "OPEN": "ON", "AJAR": "ON"}
|
||||
door_states = {"CLOSED": "OFF", "OPEN": "ON", "UNSPECIFIED": "UNKNOWN", "AJAR": "ON"}
|
||||
engine_states = {"RUNNING": "ON", "STOPPED": "OFF", "true": "ON", "false": "OFF"}
|
||||
|
||||
@@ -75,30 +65,29 @@ icon_states = {
|
||||
"door_rear_right": {"ON": "car-door", "OFF": "car-door-lock"},
|
||||
"engine_state": {"ON": "engine-outline", "OFF": "engine-off-outline"},
|
||||
"battery_charge_level": [
|
||||
{"from": float('inf'), "to": 100, "icon": "battery"},
|
||||
{"from": 100, "to": 90, "icon": "battery-90"},
|
||||
{"from": 90, "to": 80, "icon": "battery-80"},
|
||||
{"from": 80, "to": 70, "icon": "battery-70"},
|
||||
{"from": 70, "to": 60, "icon": "battery-60"},
|
||||
{"from": 60, "to": 50, "icon": "battery-50"},
|
||||
{"from": 50, "to": 40, "icon": "battery-40"},
|
||||
{"from": 40, "to": 30, "icon": "battery-30"},
|
||||
{"from": 30, "to": 20, "icon": "battery-20"},
|
||||
{"from": 20, "to": 10, "icon": "battery-10"},
|
||||
{"from": 10, "to": 0, "icon": "battery-alert-variant-outline"},
|
||||
{"from": 100, "to": 100, "icon": "battery"},
|
||||
{"from": 99, "to": 90, "icon": "battery-90"},
|
||||
{"from": 89, "to": 80, "icon": "battery-80"},
|
||||
{"from": 79, "to": 70, "icon": "battery-70"},
|
||||
{"from": 69, "to": 60, "icon": "battery-60"},
|
||||
{"from": 59, "to": 50, "icon": "battery-50"},
|
||||
{"from": 49, "to": 40, "icon": "battery-40"},
|
||||
{"from": 39, "to": 30, "icon": "battery-30"},
|
||||
{"from": 29, "to": 20, "icon": "battery-20"},
|
||||
{"from": 19, "to": 10, "icon": "battery-10"},
|
||||
{"from": 9, "to": 0, "icon": "battery-alert-variant-outline"},
|
||||
]
|
||||
}
|
||||
|
||||
supported_entities = [
|
||||
{"name": "Battery Charge Level", "domain": "sensor", "device_class": "battery", "id": "battery_charge_level", "unit": "%", "icon": "car-battery", "url": RECHARGE_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Battery Charge Level", "domain": "sensor", "device_class": "battery", "id": "battery_charge_level", "unit": "%", "icon": "car-battery", "url": FUEL_BATTERY_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Battery Capacity", "domain": "sensor", "device_class": "energy_storage", "id": "battery_capacity", "unit": ENERGY_KILO_WATT_HOUR, "icon": "car-battery", "url": VEHICLE_DETAILS_URL, "state_class": "measurement"},
|
||||
{"name": "Electric Range", "domain": "sensor", "id": "electric_range", "unit": LENGTH_KILOMETERS if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["electric_range"]["unit"], "icon": "map-marker-distance", "url": RECHARGE_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Estimated Charging Time", "domain": "sensor", "id": "estimated_charging_time", "unit": TIME_MINUTES, "icon": "timer-sync-outline", "url": RECHARGE_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Electric Range", "domain": "sensor", "id": "electric_range", "unit": "km" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["electric_range"]["unit"], "icon": "map-marker-distance", "url": RECHARGE_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Estimated Charging Time", "domain": "sensor", "id": "estimated_charging_time", "unit": "minutes", "icon": "timer-sync-outline", "url": RECHARGE_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Charging System Status", "domain": "sensor", "id": "charging_system_status", "icon": "ev-station", "url": RECHARGE_STATE_URL},
|
||||
{"name": "Charging Connection Status", "domain": "sensor", "id": "charging_connection_status", "icon": "ev-plug-ccs2", "url": RECHARGE_STATE_URL},
|
||||
{"name": "Estimated Charging Finish Time", "domain": "sensor", "id": "estimated_charging_finish_time", "icon": "timer-sync-outline", "url": RECHARGE_STATE_URL},
|
||||
{"name": "Odometer", "domain": "sensor", "id": "odometer", "unit": LENGTH_KILOMETERS if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["odometer"]["unit"], "icon": "counter", "url": ODOMETER_STATE_URL, "state_class":"total_increasing"},
|
||||
{"name": "Odometer", "domain": "sensor", "id": "odometer", "unit": "km" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["odometer"]["unit"], "icon": "counter", "url": ODOMETER_STATE_URL, "state_class":"total_increasing"},
|
||||
{"name": "Last Data Update", "domain": "sensor", "id": "last_data_update", "icon": "timer", "url": ""},
|
||||
{"name": "Active schedules", "domain": "sensor", "id": "active_schedules", "icon": "timer", "url": ""},
|
||||
{"name": "Window Front Left", "domain": "binary_sensor", "device_class": "window", "id": "window_front_left", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||
@@ -113,31 +102,29 @@ supported_entities = [
|
||||
{"name": "Engine Hood", "domain": "binary_sensor", "device_class": "door", "id": "engine_hood", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||
{"name": "Tank Lid", "domain": "binary_sensor", "device_class": "door", "id": "tank_lid", "icon": "car-door-lock", "url": LOCK_STATE_URL},
|
||||
{"name": "Sunroof", "domain": "binary_sensor", "device_class": "door", "id": "sunroof", "icon": "car-door-lock", "url": WINDOWS_STATE_URL},
|
||||
{"name": "Air Conditioning", "domain": "switch", "id": "climate_status", "icon": "air-conditioner"},
|
||||
{"name": "Lock state", "domain": "lock", "id": "lock_status", "icon": "lock", "url": LOCK_STATE_URL},
|
||||
{"name": "Air Conditioning", "domain": "switch", "id": "climate_status", "icon": "air-conditioner", "commands": ["CLIMATIZATION_START", "CLIMATIZATION_STOP"]},
|
||||
{"name": "Engine State", "domain": "switch", "id": "engine_state", "icon": "engine", "url": ENGINE_STATE_URL ,"commands": ["ENGINE_START", "ENGINE_STOP"]},
|
||||
{"name": "Leave in", "domain": "number", "id": "engine_runtime", "unit": "minutes", "icon": "timer-sand", "commands": ["ENGINE_START", "ENGINE_STOP"], "min": 1, "max": 15, "mode": "box"},
|
||||
{"name": "Engine State", "domain": "binary_sensor", "device_class": "running", "id": "engine_state", "icon": "engine", "url": ENGINE_STATE_URL},
|
||||
{"name": "Lock state", "domain": "lock", "id": "lock_status", "icon": "lock", "url": LOCK_STATE_URL, "commands": ["LOCK", "UNLOCK"]},
|
||||
{"name": "Force Update Data", "domain": "button", "id": "update_data", "icon": "update", "url": ""},
|
||||
{"name": "Location", "domain": "device_tracker", "id": "location", "icon": "map-marker-radius", "url": LOCATION_STATE_URL},
|
||||
{"name": "Tire Front Left", "domain": "sensor", "id": "tyre_front_left", "icon": "car-tire-alert", "url": TYRE_STATE_URL},
|
||||
{"name": "Tire Front Right", "domain": "sensor", "id": "tyre_front_right", "icon": "car-tire-alert", "url": TYRE_STATE_URL},
|
||||
{"name": "Tire Rear Left", "domain": "sensor", "id": "tyre_rear_left", "icon": "car-tire-alert", "url": TYRE_STATE_URL},
|
||||
{"name": "Tire Rear Right", "domain": "sensor", "id": "tyre_rear_right", "icon": "car-tire-alert", "url": TYRE_STATE_URL},
|
||||
{"name": "Engine State", "domain": "binary_sensor", "device_class": "running", "id": "engine_state", "icon": "engine", "url": ENGINE_STATE_URL},
|
||||
{"name": "Fuel Level", "domain": "sensor", "id": "fuel_level", "unit": VOLUME_LITERS, "icon": "fuel", "url": FUEL_BATTERY_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Average Fuel Consumption", "domain": "sensor", "id": "average_fuel_consumption", "unit": VOLUME_LITERS, "icon": "fuel", "url": STATISTICS_URL},
|
||||
{"name": "Average Energy Consumption", "domain": "sensor", "id": "average_energy_consumption", "unit": ENERGY_KILO_WATT_HOUR, "icon": "car-electric", "url": STATISTICS_URL},
|
||||
{"name": "Distance to Empty Tank", "domain": "sensor", "id": "distance_to_empty_tank", "unit": LENGTH_KILOMETERS if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_empty"]["unit"], "icon": "map-marker-distance", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Distance to Empty Battery", "domain": "sensor", "id": "distance_to_empty_battery", "unit": LENGTH_KILOMETERS if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_empty"]["unit"], "icon": "map-marker-distance", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Average Speed", "domain": "sensor", "id": "average_speed", "unit": SPEED_KILOMETERS_PER_HOUR if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["average_speed"]["unit"], "icon": "speedometer", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Hours to Service", "domain": "sensor", "id": "hours_to_service", "unit": TIME_HOURS, "icon": "wrench-clock", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Distance to Service", "domain": "sensor", "id": "km_to_service", "unit": LENGTH_KILOMETERS if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_service"]["unit"], "icon": "wrench-clock", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Fuel Level", "domain": "sensor", "id": "fuel_level", "unit": "liters", "icon": "fuel", "url": FUEL_BATTERY_STATE_URL, "state_class": "measurement"},
|
||||
{"name": "Average Fuel Consumption", "domain": "sensor", "id": "average_fuel_consumption", "unit": "liters", "icon": "fuel", "url": STATISTICS_URL},
|
||||
{"name": "Average Energy Consumption", "domain": "sensor", "id": "average_energy_consumption", "unit": "kwh", "icon": "car-electric", "url": STATISTICS_URL},
|
||||
{"name": "Distance to Empty Tank", "domain": "sensor", "id": "distance_to_empty_tank", "unit": "km" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_empty"]["unit"], "icon": "map-marker-distance", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Distance to Empty Battery", "domain": "sensor", "id": "distance_to_empty_battery", "unit": "km" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_empty"]["unit"], "icon": "map-marker-distance", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Average Speed", "domain": "sensor", "id": "average_speed", "unit": "km/h" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["average_speed"]["unit"], "icon": "speedometer", "url": STATISTICS_URL, "state_class": "measurement"},
|
||||
{"name": "Hours to Service", "domain": "sensor", "id": "hours_to_service", "unit": "hour", "icon": "wrench-clock", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Distance to Service", "domain": "sensor", "id": "km_to_service", "unit": "km" if not units.get(settings["babelLocale"]) else units[settings["babelLocale"]]["distance_to_service"]["unit"], "icon": "wrench-clock", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Time to Service", "domain": "sensor", "id": "time_to_service", "icon": "wrench-clock", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Service warning status", "domain": "sensor", "id": "service_warning_status", "icon": "alert-outline", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "Washer Fluid Level warning", "domain": "sensor", "id": "washer_fluid_warning", "icon": "alert-outline", "url": VEHICLE_DIAGNOSTICS_URL},
|
||||
{"name": "API Backend status", "domain": "sensor", "id": "api_backend_status", "icon": "alert"},
|
||||
{"name": "Update Interval", "domain": "number", "id": "update_interval", "unit": "seconds", "icon": "timer", "min": -1, "max": 600, "mode": "box"},
|
||||
{"name": "Warnings", "domain": "sensor", "id": "warnings", "icon": "alert", "url": WARNINGS_URL}
|
||||
{"name": "API Backend status", "domain": "sensor", "id": "api_backend_status", "icon": "alert"}
|
||||
]
|
||||
|
||||
old_entity_ids = ["months_to_service", "service_warning_trigger", "distance_to_empty"]
|
||||
otp_max_loops = 24
|
||||
otp_mqtt_topic = "volvoAAOS2mqtt/otp_code"
|
||||
+67
-139
@@ -5,13 +5,12 @@ import json
|
||||
import volvo
|
||||
import util
|
||||
import os
|
||||
import requests
|
||||
from threading import Thread, Timer
|
||||
from datetime import datetime
|
||||
from babel.dates import format_datetime
|
||||
from config import settings
|
||||
from const import CLIMATE_START_URL, CLIMATE_STOP_URL, CAR_LOCK_URL, \
|
||||
CAR_UNLOCK_URL, availability_topic, icon_states, old_entity_ids, otp_mqtt_topic
|
||||
CAR_UNLOCK_URL, ENGINE_START_URL, ENGINE_STOP_URL, availability_topic, icon_states, old_entity_ids
|
||||
|
||||
mqtt_client: mqtt.Client
|
||||
subscribed_topics = []
|
||||
@@ -21,7 +20,8 @@ climate_timer = {}
|
||||
engine_status = {}
|
||||
devices = {}
|
||||
active_schedules = {}
|
||||
otp_code = None
|
||||
engine_runtime = 1
|
||||
|
||||
|
||||
def connect():
|
||||
client = mqtt.Client("volvoAAOS2mqtt") if os.environ.get("IS_HA_ADDON") \
|
||||
@@ -38,7 +38,6 @@ def connect():
|
||||
port = settings["mqtt"]["port"]
|
||||
client.connect(settings["mqtt"]["broker"], port)
|
||||
client.loop_start()
|
||||
client.subscribe("volvoAAOS2mqtt/otp_code")
|
||||
client.on_message = on_message
|
||||
client.on_disconnect = on_disconnect
|
||||
client.on_connect = on_connect
|
||||
@@ -47,52 +46,17 @@ def connect():
|
||||
mqtt_client = client
|
||||
|
||||
|
||||
def create_otp_input():
|
||||
state_topic = otp_mqtt_topic + "/state"
|
||||
config = {
|
||||
"name": "Volvo OTP",
|
||||
"object_id": f"volvo_otp",
|
||||
"schema": "state",
|
||||
"command_topic": otp_mqtt_topic,
|
||||
"state_topic": state_topic,
|
||||
"unique_id": "volvoAAOS2mqtt_otp",
|
||||
"pattern": r"\d{6}",
|
||||
"icon": "mdi:two-factor-authentication",
|
||||
"mode": "text"
|
||||
}
|
||||
|
||||
mqtt_client.publish(
|
||||
"homeassistant/text/volvoAAOS2mqtt/volvo_otp/config",
|
||||
json.dumps(config),
|
||||
retain=True
|
||||
)
|
||||
|
||||
mqtt_client.publish(
|
||||
state_topic,
|
||||
"000000",
|
||||
retain=True
|
||||
)
|
||||
|
||||
def set_otp_state():
|
||||
mqtt_client.publish(
|
||||
otp_mqtt_topic + "/state",
|
||||
otp_code,
|
||||
retain=True
|
||||
)
|
||||
|
||||
|
||||
def send_car_images(vin, data, device):
|
||||
if util.keys_exists(data, "images"):
|
||||
for entity in [{"name": "Exterior Image", "id": "exterior_image"},
|
||||
{"name": "Interior Image", "id": "interior_image"}]:
|
||||
image_topic = f"homeassistant/image/{vin}_{entity['id']}/image_topic"
|
||||
url_topic = f"homeassistant/image/{vin}_{entity['id']}/image_url"
|
||||
config = {
|
||||
"name": entity["name"],
|
||||
"object_id": f"volvo_{vin}_{entity['id']}",
|
||||
"schema": "state",
|
||||
"icon": "mdi:image-area",
|
||||
"content_type": "image/png",
|
||||
"image_topic": image_topic,
|
||||
"url_topic": url_topic,
|
||||
"device": device,
|
||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{entity['id']}",
|
||||
"availability_topic": availability_topic
|
||||
@@ -104,41 +68,19 @@ def send_car_images(vin, data, device):
|
||||
retain=True
|
||||
)
|
||||
|
||||
headers = {"User-Agent": "(Windows NT 10.0; Win64; x64)",
|
||||
"sec-ch-ua-platform": "\"Windows\"", "sec-fetch-dest": "document", "Accept-Encoding": "gzip, deflate, br, zstd",
|
||||
"sec-fetch-mode": "navigate", "sec-fetch-site": "none", "sec-fetch-user": "?1", "upgrade-insecure-requests": "1"}
|
||||
|
||||
# Post exterior image
|
||||
if entity["id"] == "exterior_image":
|
||||
if not os.path.exists("exterior_image.png"):
|
||||
response = requests.get(data["images"]["exteriorImageUrl"], headers=headers)
|
||||
if response.status_code == 200:
|
||||
with open("exterior_image.png", 'wb') as image:
|
||||
image.write(response.content)
|
||||
|
||||
if os.path.exists("exterior_image.png"):
|
||||
ext_image = open("exterior_image.png", mode="rb").read()
|
||||
mqtt_client.publish(
|
||||
image_topic,
|
||||
ext_image,
|
||||
retain=True
|
||||
)
|
||||
mqtt_client.publish(
|
||||
url_topic,
|
||||
data["images"]["exteriorImageUrl"],
|
||||
retain=True
|
||||
)
|
||||
|
||||
if entity["id"] == "interior_image":
|
||||
# Post interior Image
|
||||
if not os.path.exists("interior_image.png"):
|
||||
response = requests.get(data["images"]["internalImageUrl"], headers=headers)
|
||||
if response.status_code == 200:
|
||||
with open("interior_image.png", 'wb') as image:
|
||||
image.write(response.content)
|
||||
|
||||
if os.path.exists("interior_image.png"):
|
||||
int_image = open("interior_image.png", mode="rb").read()
|
||||
mqtt_client.publish(
|
||||
image_topic,
|
||||
int_image,
|
||||
retain=True
|
||||
)
|
||||
mqtt_client.publish(
|
||||
url_topic,
|
||||
data["images"]["internalImageUrl"],
|
||||
retain=True
|
||||
)
|
||||
|
||||
|
||||
def on_connect(client, userdata, flags, rc):
|
||||
@@ -153,22 +95,13 @@ def on_disconnect(client, userdata, rc):
|
||||
|
||||
|
||||
def on_message(client, userdata, msg):
|
||||
payload = msg.payload.decode("UTF-8")
|
||||
if msg.topic == otp_mqtt_topic:
|
||||
if msg.retain == 0:
|
||||
global otp_code
|
||||
otp_code = payload
|
||||
set_otp_state()
|
||||
else:
|
||||
logging.warning("Found retained OTP, this can't work! Please clean retained messages!")
|
||||
try:
|
||||
vin = msg.topic.split('/')[2].split('_')[0]
|
||||
except IndexError:
|
||||
logging.error("Error - Cannot get vin from MQTT topic!")
|
||||
return None
|
||||
else:
|
||||
try:
|
||||
vin = msg.topic.split('/')[2].split('_')[0]
|
||||
except IndexError:
|
||||
logging.error("Error - Cannot get vin from MQTT topic!")
|
||||
return None
|
||||
|
||||
payload = msg.payload.decode("UTF-8")
|
||||
if "climate_status" in msg.topic:
|
||||
if payload == "ON":
|
||||
start_climate(vin)
|
||||
@@ -182,13 +115,15 @@ def on_message(client, userdata, msg):
|
||||
elif "update_data" in msg.topic:
|
||||
if payload == "PRESS":
|
||||
update_car_data(True)
|
||||
elif "update_interval" in msg.topic:
|
||||
update_interval = int(payload)
|
||||
if update_interval >= 60 or update_interval == -1:
|
||||
settings.update({"updateInterval": int(update_interval)})
|
||||
else:
|
||||
logging.warning("Interval " + str(update_interval) + " seconds is to low. Doing nothing!")
|
||||
update_car_data()
|
||||
elif "engine_runtime" in msg.topic:
|
||||
global engine_runtime
|
||||
engine_runtime = int(payload)
|
||||
logging.debug("Updated engine runtime to " + str(engine_runtime) + " minutes!")
|
||||
elif "engine_state" in msg.topic:
|
||||
if payload == "ON":
|
||||
start_engine(vin)
|
||||
elif payload == "OFF":
|
||||
stop_engine(vin)
|
||||
elif "schedule" in msg.topic:
|
||||
try:
|
||||
d = json.loads(payload)
|
||||
@@ -286,18 +221,31 @@ def start_climate(vin):
|
||||
update_car_data()
|
||||
|
||||
|
||||
def start_engine(vin):
|
||||
body = {"runtimeMinutes": engine_runtime}
|
||||
# Start the api call in another thread for HA performance
|
||||
Thread(target=volvo.api_call, args=(ENGINE_START_URL, "POST", vin, None, None, None, body)).start()
|
||||
|
||||
# Set and update switch status
|
||||
update_car_data(False, {"entity_id": "engine_state", "vin": vin, "state": "ON"})
|
||||
|
||||
|
||||
def stop_engine(vin):
|
||||
# Start the api call in another thread for HA performance
|
||||
Thread(target=volvo.api_call, args=(ENGINE_STOP_URL, "POST", vin)).start()
|
||||
|
||||
# Set and update switch status
|
||||
update_car_data(False, {"entity_id": "engine_state", "vin": vin, "state": "OFF"})
|
||||
|
||||
|
||||
def update_loop():
|
||||
create_ha_devices()
|
||||
while True:
|
||||
if settings["updateInterval"] > 0:
|
||||
logging.info("Sending mqtt update...")
|
||||
send_heartbeat()
|
||||
update_car_data()
|
||||
logging.info("Mqtt update done. Next run in " + str(settings["updateInterval"]) + " seconds.")
|
||||
time.sleep(settings["updateInterval"])
|
||||
else:
|
||||
logging.info("Data update is disabled, doing nothing for 30 seconds")
|
||||
time.sleep(30)
|
||||
logging.info("Sending mqtt update...")
|
||||
send_heartbeat()
|
||||
update_car_data()
|
||||
logging.info("Mqtt update done. Next run in " + str(settings["updateInterval"]) + " seconds.")
|
||||
time.sleep(settings["updateInterval"])
|
||||
|
||||
|
||||
def update_car_data(force_update=False, overwrite={}):
|
||||
@@ -305,7 +253,7 @@ def update_car_data(force_update=False, overwrite={}):
|
||||
last_data_update = format_datetime(datetime.now(util.TZ), format="medium", locale=settings["babelLocale"])
|
||||
for vin in volvo.vins:
|
||||
for entity in volvo.supported_endpoints[vin]:
|
||||
if entity["domain"] in ["button"]:
|
||||
if entity["domain"] in ["button", "number"]:
|
||||
continue
|
||||
|
||||
ov_entity_id = ""
|
||||
@@ -322,8 +270,6 @@ def update_car_data(force_update=False, overwrite={}):
|
||||
state = last_data_update
|
||||
elif entity["id"] == "active_schedules":
|
||||
state = active_schedules[vin]
|
||||
elif entity["id"] == "update_interval":
|
||||
state = settings["updateInterval"]
|
||||
elif entity["id"] == "api_backend_status":
|
||||
if force_update:
|
||||
state = volvo.get_backend_status()
|
||||
@@ -337,45 +283,29 @@ def update_car_data(force_update=False, overwrite={}):
|
||||
|
||||
if entity["domain"] == "device_tracker" or entity["id"] == "active_schedules":
|
||||
topic = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/attributes"
|
||||
elif entity["id"] == "warnings":
|
||||
mqtt_client.publish(
|
||||
f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/attributes",
|
||||
json.dumps(state),
|
||||
retain=True
|
||||
)
|
||||
if state:
|
||||
state = sum(value == "FAILURE" for value in state.values())
|
||||
else:
|
||||
state = 0
|
||||
|
||||
topic = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/state"
|
||||
else:
|
||||
topic = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/state"
|
||||
|
||||
if state or state == 0:
|
||||
mqtt_client.publish(
|
||||
topic,
|
||||
json.dumps(state) if isinstance(state, dict) or isinstance(state, list) else state,
|
||||
retain=True
|
||||
json.dumps(state) if isinstance(state, dict) or isinstance(state, list) else state
|
||||
)
|
||||
update_ha_device(entity, vin, state)
|
||||
|
||||
|
||||
def update_ha_device(entity, vin, state):
|
||||
icon_config = icon_states.get(entity["id"])
|
||||
try:
|
||||
if icon_config and state:
|
||||
logging.debug("Entity " + entity["id"] + " state " + str(state))
|
||||
if isinstance(state, float):
|
||||
icon = util.get_icon_between(icon_config, state)
|
||||
elif state.replace(".", "").isnumeric():
|
||||
state = float(state)
|
||||
icon = util.get_icon_between(icon_config, state)
|
||||
else:
|
||||
icon = icon_config[state]
|
||||
if icon_config and state:
|
||||
logging.debug("Entity " + entity["id"] + " state " + str(state))
|
||||
if isinstance(state, float):
|
||||
icon = util.get_icon_between(icon_config, state)
|
||||
elif state.replace(".", "").isnumeric():
|
||||
state = float(state)
|
||||
icon = util.get_icon_between(icon_config, state)
|
||||
else:
|
||||
return None
|
||||
except:
|
||||
icon = icon_config[state]
|
||||
else:
|
||||
return None
|
||||
|
||||
logging.debug("Updating icon to " + icon + " for " + entity["id"])
|
||||
@@ -430,7 +360,6 @@ def create_ha_devices():
|
||||
"unique_id": f"volvoAAOS2mqtt_{vin}_{entity['id']}",
|
||||
"availability_topic": availability_topic
|
||||
}
|
||||
|
||||
if entity.get("device_class"):
|
||||
config["device_class"] = entity["device_class"]
|
||||
|
||||
@@ -440,11 +369,9 @@ def create_ha_devices():
|
||||
if entity.get("state_class"):
|
||||
config["state_class"] = entity["state_class"]
|
||||
|
||||
if (entity.get("domain") == "device_tracker" or entity.get("id") == "active_schedules"
|
||||
or entity.get("id") == "warnings"):
|
||||
if entity.get("domain") == "device_tracker" or entity.get("id") == "active_schedules":
|
||||
config["json_attributes_topic"] = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/attributes"
|
||||
|
||||
if entity.get("domain") in ["switch", "lock", "button", "number"]:
|
||||
elif entity.get("domain") in ["switch", "lock", "button", "number"]:
|
||||
command_topic = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/command"
|
||||
config["command_topic"] = command_topic
|
||||
subscribed_topics.append(command_topic)
|
||||
@@ -454,6 +381,7 @@ def create_ha_devices():
|
||||
config["min"] = entity["min"]
|
||||
config["max"] = entity["max"]
|
||||
config["mode"] = entity["mode"]
|
||||
|
||||
elif entity.get("domain") == "image":
|
||||
config["url_topic"] = f"homeassistant/{entity['domain']}/{vin}_{entity['id']}/image_url"
|
||||
|
||||
@@ -467,11 +395,11 @@ def create_ha_devices():
|
||||
|
||||
|
||||
def send_heartbeat():
|
||||
mqtt_client.publish(availability_topic, "online", retain=True)
|
||||
mqtt_client.publish(availability_topic, "online")
|
||||
|
||||
|
||||
def send_offline():
|
||||
mqtt_client.publish(availability_topic, "offline", retain=True)
|
||||
mqtt_client.publish(availability_topic, "offline")
|
||||
|
||||
|
||||
def delete_old_entities():
|
||||
|
||||
+4
-29
@@ -4,8 +4,6 @@ import os
|
||||
import re
|
||||
import sys
|
||||
import config
|
||||
import json
|
||||
from google_play_scraper import app
|
||||
from logging import handlers
|
||||
from datetime import datetime
|
||||
from const import units
|
||||
@@ -30,34 +28,11 @@ class SensitiveDataFilter(logging.Filter):
|
||||
record.msg = re.sub(pattern, "<REDACTED>", record.msg)
|
||||
return True
|
||||
|
||||
def get_volvo_app_version():
|
||||
result = app(
|
||||
'se.volvo.vcc',
|
||||
lang='en',
|
||||
country='us'
|
||||
)
|
||||
|
||||
if "version" in result:
|
||||
return result["version"]
|
||||
else:
|
||||
return "5.37.0"
|
||||
|
||||
def get_token_path():
|
||||
token_path = ".token"
|
||||
if os.environ.get("IS_HA_ADDON"):
|
||||
check_existing_folder("/addons/volvo2mqtt/token/")
|
||||
token_path = "/addons/volvo2mqtt/token/.token"
|
||||
|
||||
return token_path
|
||||
|
||||
def save_to_json(data, token_path):
|
||||
with open(token_path, 'w', encoding='utf-8') as f:
|
||||
json.dump(data, f, ensure_ascii=False, indent=4)
|
||||
|
||||
def get_icon_between(icon_list, state):
|
||||
icon = None
|
||||
for s in icon_list:
|
||||
if s["to"] <= state < s["from"]:
|
||||
if s["to"] <= state <= s["from"]:
|
||||
icon = s["icon"]
|
||||
return icon
|
||||
|
||||
@@ -65,7 +40,7 @@ def get_icon_between(icon_list, state):
|
||||
def setup_logging():
|
||||
log_location = "volvo2mqtt.log"
|
||||
if os.environ.get("IS_HA_ADDON"):
|
||||
check_existing_folder("/addons/volvo2mqtt/log/")
|
||||
check_existing_folder()
|
||||
log_location = "/addons/volvo2mqtt/log/volvo2mqtt.log"
|
||||
|
||||
logging.Formatter.converter = lambda *args: datetime.now(tz=TZ).timetuple()
|
||||
@@ -98,8 +73,8 @@ def setup_logging():
|
||||
logger.setLevel(logging.ERROR)
|
||||
|
||||
|
||||
def check_existing_folder(path):
|
||||
Path(path).mkdir(parents=True, exist_ok=True)
|
||||
def check_existing_folder():
|
||||
Path("/addons/volvo2mqtt/log/").mkdir(parents=True, exist_ok=True)
|
||||
|
||||
|
||||
def keys_exists(element, *keys):
|
||||
|
||||
+75
-162
@@ -5,17 +5,16 @@ import mqtt
|
||||
import util
|
||||
import time
|
||||
import re
|
||||
import os.path
|
||||
from threading import current_thread, Thread
|
||||
from datetime import datetime, timedelta
|
||||
from config import settings
|
||||
from babel.dates import format_datetime
|
||||
from json import JSONDecodeError
|
||||
from const import charging_system_states, charging_connection_states, door_states, window_states, \
|
||||
OAUTH_AUTH_URL, OAUTH_TOKEN_URL, VEHICLES_URL, VEHICLE_DETAILS_URL, RECHARGE_STATE_URL, CLIMATE_START_URL, \
|
||||
OAUTH_URL, VEHICLES_URL, VEHICLE_DETAILS_URL, RECHARGE_STATE_URL, CLIMATE_START_URL, \
|
||||
WINDOWS_STATE_URL, LOCK_STATE_URL, TYRE_STATE_URL, supported_entities, FUEL_BATTERY_STATE_URL, \
|
||||
STATISTICS_URL, ENGINE_DIAGNOSTICS_URL, VEHICLE_DIAGNOSTICS_URL, API_BACKEND_STATUS, WARNINGS_URL, engine_states, \
|
||||
otp_max_loops
|
||||
STATISTICS_URL, ENGINE_DIAGNOSTICS_URL, API_BACKEND_STATUS_URL, SUPPORTED_COMMANDS_URL, \
|
||||
ENGINE_STATE_URL, engine_states
|
||||
|
||||
session = requests.Session()
|
||||
session.headers = {
|
||||
@@ -30,144 +29,42 @@ vins = []
|
||||
supported_endpoints = {}
|
||||
cached_requests = {}
|
||||
vcc_api_keys = []
|
||||
supported_commands = []
|
||||
backend_status = ""
|
||||
|
||||
|
||||
def authorize(renew_tokenfile=False):
|
||||
global refresh_token
|
||||
|
||||
token_path = util.get_token_path()
|
||||
if os.path.isfile(token_path) and not renew_tokenfile:
|
||||
logging.info("Using login from token file")
|
||||
f = open(token_path)
|
||||
try:
|
||||
data = json.load(f)
|
||||
refresh_token = data["refresh_token"]
|
||||
refresh_auth()
|
||||
except ValueError:
|
||||
logging.warning("Detected corrupted token file, restarting auth process")
|
||||
authorize(True)
|
||||
else:
|
||||
logging.info("Starting login with OTP")
|
||||
auth_session = requests.session()
|
||||
auth_session.headers = {
|
||||
"authorization": "Basic aDRZZjBiOlU4WWtTYlZsNnh3c2c1WVFxWmZyZ1ZtSWFEcGhPc3kxUENhVXNpY1F0bzNUUjVrd2FKc2U0QVpkZ2ZJZmNMeXc=",
|
||||
"User-Agent": "vca-android/" + util.get_volvo_app_version(),
|
||||
"Accept-Encoding": "gzip",
|
||||
"Content-Type": "application/json; charset=utf-8"
|
||||
}
|
||||
|
||||
url_params = ("?client_id=h4Yf0b"
|
||||
"&response_type=code"
|
||||
"&acr_values=urn:volvoid:aal:bronze:2sv"
|
||||
"&response_mode=pi.flow"
|
||||
"&scope=openid email profile care_by_volvo:financial_information:invoice:read care_by_volvo:financial_information:payment_method care_by_volvo:subscription:read customer:attributes customer:attributes:write order:attributes vehicle:attributes tsp_customer_api:all conve:brake_status conve:climatization_start_stop conve:command_accessibility conve:commands conve:diagnostics_engine_status conve:diagnostics_workshop conve:doors_status conve:engine_status conve:environment conve:fuel_status conve:honk_flash conve:lock conve:lock_status conve:navigation conve:odometer_status conve:trip_statistics conve:tyre_status conve:unlock conve:vehicle_relation conve:warnings conve:windows_status energy:battery_charge_level energy:charging_connection_status energy:charging_system_status energy:electric_range energy:estimated_charging_time energy:recharge_status vehicle:attributes")
|
||||
|
||||
auth = auth_session.get(OAUTH_AUTH_URL + url_params)
|
||||
if auth.status_code == 200:
|
||||
response = auth.json()
|
||||
auth_state = response["status"]
|
||||
|
||||
if auth_state == "USERNAME_PASSWORD_REQUIRED":
|
||||
auth_session.headers.update({"x-xsrf-header": "PingFederate"})
|
||||
response = check_username_password(auth_session, response)
|
||||
auth_state = response["status"]
|
||||
|
||||
if auth_state == "OTP_REQUIRED":
|
||||
response = send_otp(auth_session, response)
|
||||
response = continue_auth(auth_session, response)
|
||||
token_data = get_token(auth_session, response)
|
||||
else:
|
||||
raise Exception("Unkown auth state " + auth_state)
|
||||
elif auth_state == "OTP_REQUIRED":
|
||||
response = send_otp(auth_session, response)
|
||||
response = continue_auth(auth_session, response)
|
||||
token_data = get_token(auth_session, response)
|
||||
elif auth_state == "OTP_VERIFIED":
|
||||
response = continue_auth(auth_session, response)
|
||||
token_data = get_token(auth_session, response)
|
||||
elif auth_state == "COMPLETED":
|
||||
token_data = get_token(auth_session, response)
|
||||
else:
|
||||
raise Exception("Unkown auth state " + auth_state)
|
||||
|
||||
session.headers.update({"authorization": "Bearer " + token_data["access_token"]})
|
||||
|
||||
global token_expires_at
|
||||
token_expires_at = datetime.now(util.TZ) + timedelta(seconds=(token_data["expires_in"] - 30))
|
||||
refresh_token = token_data["refresh_token"]
|
||||
|
||||
util.save_to_json(token_data, token_path)
|
||||
else:
|
||||
message = auth.json()
|
||||
raise Exception(message["details"][0]["userMessage"])
|
||||
|
||||
get_vcc_api_keys()
|
||||
get_vehicles()
|
||||
check_supported_endpoints()
|
||||
Thread(target=backend_status_loop).start()
|
||||
|
||||
def continue_auth(auth_session, data):
|
||||
next_url = data["_links"]["continueAuthentication"]["href"] + "?action=continueAuthentication"
|
||||
auth = auth_session.get(next_url)
|
||||
def authorize():
|
||||
headers = {
|
||||
"authorization": "Basic aDRZZjBiOlU4WWtTYlZsNnh3c2c1WVFxWmZyZ1ZtSWFEcGhPc3kxUENhVXNpY1F0bzNUUjVrd2FKc2U0QVpkZ2ZJZmNMeXc=",
|
||||
"content-type": "application/x-www-form-urlencoded",
|
||||
"accept": "application/json"
|
||||
}
|
||||
|
||||
body = {
|
||||
"username": settings.volvoData["username"],
|
||||
"password": settings.volvoData["password"],
|
||||
"grant_type": "password",
|
||||
"scope": "openid email profile care_by_volvo:financial_information:invoice:read care_by_volvo:financial_information:payment_method care_by_volvo:subscription:read customer:attributes customer:attributes:write order:attributes vehicle:attributes tsp_customer_api:all conve:brake_status conve:climatization_start_stop conve:command_accessibility conve:commands conve:diagnostics_engine_status conve:diagnostics_workshop conve:doors_status conve:engine_status conve:environment conve:fuel_status conve:honk_flash conve:lock conve:lock_status conve:navigation conve:odometer_status conve:trip_statistics conve:tyre_status conve:unlock conve:vehicle_relation conve:warnings conve:windows_status energy:battery_charge_level energy:charging_connection_status energy:charging_system_status energy:electric_range energy:estimated_charging_time energy:recharge_status vehicle:attributes"
|
||||
}
|
||||
auth = requests.post(OAUTH_URL, data=body, headers=headers)
|
||||
if auth.status_code == 200:
|
||||
return auth.json()
|
||||
data = auth.json()
|
||||
session.headers.update({"authorization": "Bearer " + data["access_token"]})
|
||||
|
||||
global token_expires_at, refresh_token
|
||||
token_expires_at = datetime.now(util.TZ) + timedelta(seconds=(data["expires_in"] - 30))
|
||||
refresh_token = data["refresh_token"]
|
||||
|
||||
get_vcc_api_keys()
|
||||
get_vehicles()
|
||||
get_supported_commands()
|
||||
check_supported_endpoints()
|
||||
Thread(target=backend_status_loop).start()
|
||||
else:
|
||||
message = auth.json()
|
||||
raise Exception(message["details"][0]["userMessage"])
|
||||
|
||||
|
||||
def get_token(auth_session, data):
|
||||
auth_session.headers.update({"content-type": "application/x-www-form-urlencoded"})
|
||||
body = {"code": data["authorizeResponse"]["code"], "grant_type": "authorization_code"}
|
||||
token_auth = auth_session.post(OAUTH_TOKEN_URL, data=body)
|
||||
|
||||
if token_auth.status_code == 200:
|
||||
return token_auth.json()
|
||||
else:
|
||||
message = token_auth.json()
|
||||
raise Exception(message["error_description"])
|
||||
|
||||
|
||||
def check_username_password(auth_session, data):
|
||||
next_url = data["_links"]["checkUsernamePassword"]["href"] + "?action=checkUsernamePassword"
|
||||
body = {"username": settings.volvoData["username"],
|
||||
"password": settings.volvoData["password"]}
|
||||
auth = auth_session.post(next_url, data=json.dumps(body))
|
||||
|
||||
if auth.status_code == 200:
|
||||
return auth.json()
|
||||
else:
|
||||
message = auth.json()
|
||||
raise Exception(message["details"][0]["userMessage"])
|
||||
|
||||
|
||||
def send_otp(auth_session, data):
|
||||
mqtt.create_otp_input()
|
||||
next_url = data["_links"]["checkOtp"]["href"] + "?action=checkOtp"
|
||||
body = {"otp": ""}
|
||||
|
||||
for i in range(otp_max_loops):
|
||||
if mqtt.otp_code:
|
||||
body["otp"] = mqtt.otp_code
|
||||
break
|
||||
|
||||
logging.info("Waiting for otp code... Please check your mailbox and post your otp code to the following "
|
||||
"mqtt topic \"volvoAAOS2mqtt/otp_code\". Retry " + str(i) + "/" + str(otp_max_loops))
|
||||
time.sleep(5)
|
||||
|
||||
if not mqtt.otp_code:
|
||||
raise Exception ("No OTP found, exting...")
|
||||
|
||||
auth = auth_session.post(next_url, data=json.dumps(body))
|
||||
if auth.status_code == 200:
|
||||
return auth.json()
|
||||
else:
|
||||
message = auth.json()
|
||||
raise Exception(message["details"][0]["userMessage"])
|
||||
|
||||
|
||||
def refresh_auth():
|
||||
logging.info("Refreshing credentials")
|
||||
global refresh_token
|
||||
@@ -183,22 +80,31 @@ def refresh_auth():
|
||||
}
|
||||
|
||||
try:
|
||||
auth = requests.post(OAUTH_TOKEN_URL, data=body, headers=headers)
|
||||
auth = requests.post(OAUTH_URL, data=body, headers=headers)
|
||||
except requests.exceptions.RequestException as e:
|
||||
logging.error("Error refreshing credentials data: " + str(e))
|
||||
return None
|
||||
|
||||
if auth.status_code == 200:
|
||||
token_path = util.get_token_path()
|
||||
data = auth.json()
|
||||
util.save_to_json(data, token_path)
|
||||
session.headers.update({"authorization": "Bearer " + data["access_token"]})
|
||||
|
||||
global token_expires_at
|
||||
token_expires_at = datetime.now(util.TZ) + timedelta(seconds=(data["expires_in"] - 30))
|
||||
refresh_token = data["refresh_token"]
|
||||
else:
|
||||
authorize(renew_tokenfile=True)
|
||||
|
||||
|
||||
def get_supported_commands():
|
||||
global supported_commands
|
||||
for vin in vins:
|
||||
commands = session.get(SUPPORTED_COMMANDS_URL.format(vin))
|
||||
data = commands.json()
|
||||
if commands.status_code == 200:
|
||||
for command in data["data"]:
|
||||
supported_commands.append(command["command"])
|
||||
else:
|
||||
logging.error("Error getting supported commands: " + str(commands.status_code) + ". " + str(data["error"].get("message")))
|
||||
logging.debug("Supported commands: " + str(supported_commands))
|
||||
|
||||
|
||||
def get_vehicles():
|
||||
@@ -213,9 +119,8 @@ def get_vehicles():
|
||||
else:
|
||||
raise Exception("No vehicle in account " + settings.volvoData["username"] + " found.")
|
||||
else:
|
||||
error = vehicles.json()
|
||||
raise Exception(
|
||||
"Error getting vehicles: " + str(vehicles.status_code) + ". " + str(error["error"].get("message")))
|
||||
"Error getting vehicles: " + str(vehicles.status_code) + ". " + str(data["error"].get("message")))
|
||||
else:
|
||||
if isinstance(settings.volvoData["vin"], list):
|
||||
# If setting is a list, copy
|
||||
@@ -359,16 +264,38 @@ def check_supported_endpoints():
|
||||
# If battery charge level could be found in recharge-api, skip the second battery charge sensor
|
||||
continue
|
||||
|
||||
if entity.get('url'):
|
||||
state = api_call(entity["url"], "GET", vin, entity["id"])
|
||||
if entity["id"] == "engine_state" and entity["url"] == ENGINE_STATE_URL \
|
||||
and any("engine_state" in d["id"] for d in supported_endpoints[vin]):
|
||||
# If engine state is supported with commands, skip engine state sensor, as switch
|
||||
# represents the actual engine state
|
||||
continue
|
||||
|
||||
if entity["domain"] in ["switch", "lock", "number"]:
|
||||
state = check_supported_command(entity["commands"])
|
||||
else:
|
||||
state = ""
|
||||
if entity.get('url'):
|
||||
state = api_call(entity["url"], "GET", vin, entity["id"])
|
||||
else:
|
||||
state = ""
|
||||
|
||||
if state is not None:
|
||||
logging.info("Success! " + entity["name"] + " is supported by your vehicle.")
|
||||
logging.info("Success! " + entity["name"] + " (" + entity["domain"] + ") is supported by your vehicle.")
|
||||
supported_endpoints[vin].append(entity)
|
||||
else:
|
||||
logging.info("Failed, " + entity["name"] + " is unfortunately not supported by your vehicle.")
|
||||
logging.info("Failed, " + entity["name"] + " (" + entity["domain"] + ") is unfortunately not supported by your vehicle.")
|
||||
|
||||
|
||||
def check_supported_command(entity_commands):
|
||||
commands_supported = True
|
||||
for entity_command in entity_commands:
|
||||
if entity_command not in supported_commands:
|
||||
commands_supported = False
|
||||
break
|
||||
|
||||
if commands_supported:
|
||||
return ""
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
def initialize_scheduler(vins):
|
||||
@@ -436,7 +363,7 @@ def backend_status_loop():
|
||||
|
||||
def get_backend_status():
|
||||
global backend_status
|
||||
response = session.get(API_BACKEND_STATUS, timeout=15)
|
||||
response = session.get(API_BACKEND_STATUS_URL, timeout=15)
|
||||
try:
|
||||
data = response.json()
|
||||
if util.keys_exists(data, "message"):
|
||||
@@ -452,12 +379,12 @@ def get_backend_status():
|
||||
return backend_status
|
||||
|
||||
|
||||
def api_call(url, method, vin, sensor_id=None, force_update=False, key_change=False):
|
||||
def api_call(url, method, vin, sensor_id=None, force_update=False, key_change=False, body=None):
|
||||
if datetime.now(util.TZ) >= token_expires_at:
|
||||
refresh_auth()
|
||||
|
||||
if url in [RECHARGE_STATE_URL, WINDOWS_STATE_URL, LOCK_STATE_URL, TYRE_STATE_URL,
|
||||
STATISTICS_URL, ENGINE_DIAGNOSTICS_URL, VEHICLE_DIAGNOSTICS_URL, FUEL_BATTERY_STATE_URL, WARNINGS_URL]:
|
||||
STATISTICS_URL, ENGINE_DIAGNOSTICS_URL, FUEL_BATTERY_STATE_URL]:
|
||||
# Minimize API calls for endpoints with multiple values
|
||||
response = cached_request(url, method, vin, force_update, key_change)
|
||||
if response is None:
|
||||
@@ -473,7 +400,7 @@ def api_call(url, method, vin, sensor_id=None, force_update=False, key_change=Fa
|
||||
elif method == "POST":
|
||||
logging.debug("Starting " + method + " call against " + url)
|
||||
try:
|
||||
response = session.post(url.format(vin), timeout=20)
|
||||
response = session.post(url.format(vin), data=json.dumps(body), timeout=20)
|
||||
except requests.exceptions.RequestException as e:
|
||||
logging.error("Error getting data: " + str(e))
|
||||
return None
|
||||
@@ -554,8 +481,6 @@ def parse_api_data(data, sensor_id=None):
|
||||
|
||||
if sensor_id == "battery_charge_level":
|
||||
return data["batteryChargeLevel"]["value"] if util.keys_exists(data, "batteryChargeLevel") else None
|
||||
elif sensor_id == "battery_capacity":
|
||||
return data["batteryCapacityKWH"] if util.keys_exists(data, "batteryCapacityKWH") else None
|
||||
elif sensor_id == "electric_range":
|
||||
return util.convert_metric_values(data["electricRange"]["value"]) \
|
||||
if util.keys_exists(data, "electricRange") else None
|
||||
@@ -708,17 +633,5 @@ def parse_api_data(data, sensor_id=None):
|
||||
return data["averageEnergyConsumption"]["value"] if util.keys_exists(data, "averageEnergyConsumption") else None
|
||||
elif sensor_id == "washer_fluid_warning":
|
||||
return data["washerFluidLevelWarning"]["value"] if util.keys_exists(data, "washerFluidLevelWarning") else None
|
||||
elif sensor_id == "warnings":
|
||||
warnings = 0
|
||||
cleaned_data = {}
|
||||
for key, dicts in data.items():
|
||||
contains_data = sum(value == "NO_WARNING" or value == "FAILURE" for value in dicts.values())
|
||||
if contains_data:
|
||||
warnings = warnings + 1
|
||||
cleaned_data[key] = dicts["value"]
|
||||
|
||||
return cleaned_data if warnings > 0 else None
|
||||
else:
|
||||
return None
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user