Skip to content

Commit a584f5b

Browse files
committed
Update API Gateway
1 parent 2375c3d commit a584f5b

3 files changed

Lines changed: 15 additions & 3 deletions

File tree

custom_components/toyota_na/__init__.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,11 @@
77
from toyota_na.client import ToyotaOneClient
88

99
# Patch client code
10-
from .patch_client import get_electric_realtime_status, get_electric_status, api_request
10+
from .patch_client import get_electric_realtime_status, get_electric_status, api_request, _auth_headers
1111
ToyotaOneClient.get_electric_realtime_status = get_electric_realtime_status
1212
ToyotaOneClient.get_electric_status = get_electric_status
1313
ToyotaOneClient.api_request = api_request
14+
ToyotaOneClient._auth_headers = _auth_headers
1415

1516
# Patch base_vehicle
1617
import toyota_na.vehicle.base_vehicle

custom_components/toyota_na/manifest.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,6 @@
77
"codeowners": ["@vanstinator, @widewing"],
88
"requirements": ["toyota-na==2.1.1"],
99
"issue_tracker": "https://github.com/widewing/ha-toyota-na/issues",
10-
"version": "2.5.3",
10+
"version": "2.6.1",
1111
"iot_class": "cloud_polling"
1212
}

custom_components/toyota_na/patch_client.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,15 @@
33

44
import aiohttp
55

6-
API_GATEWAY = "https://oneapi-east.telematicsct.com/"
6+
API_GATEWAY = "https://onecdn.telematicsct.com/oneapi/"
7+
8+
async def _auth_headers(self):
9+
return {
10+
"AUTHORIZATION": "Bearer " + await self.auth.get_access_token(),
11+
"X-API-KEY": self.API_KEY,
12+
"X-GUID": await self.auth.get_guid(),
13+
"X-CHANNEL": "ONEAPP"
14+
}
715

816
async def get_electric_realtime_status(self, vin, generation="17CYPLUS"):
917
realtime_electric_status = await self.api_post(
@@ -37,6 +45,9 @@ async def api_request(self, method, endpoint, header_params=None, **kwargs):
3745
if header_params:
3846
headers.update(header_params)
3947

48+
if endpoint.startswith("/"):
49+
endpoint = endpoint[1:]
50+
4051
async with aiohttp.ClientSession() as session:
4152
async with session.request(
4253
method, urljoin(API_GATEWAY, endpoint), headers=headers, **kwargs

0 commit comments

Comments
 (0)