HomeAssistant/midea-meiju-codec
1
0
Fork 1
mirror of https://github.com/sususweet/midea-meiju-codec.git synced 2025-12-17 09:55:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: file async read

Browse Source
This commit is contained in:
Yingqi Tang
2025-11-21 01:16:55 +00:00
parent 849280676f
commit fe1a5b315b
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
custom_components/midea_auto_cloud/core/cloud.py
View File

@@ -4,6 +4,7 @@ import datetime
import json import json
import base64 import base64
import asyncio import asyncio
import aiofiles
import requests import requests
from aiohttp import ClientSession from aiohttp import ClientSession
from secrets import token_hex from secrets import token_hex
@@ -89,12 +90,10 @@ class MideaCloud:
"accesstoken": self._access_token "accesstoken": self._access_token
}) })
response:dict = {"code": -1} response:dict = {"code": -1}
_LOGGER.debug(f"Midea cloud API header: {header}")
_LOGGER.debug(f"Midea cloud API dump_data: {dump_data}")
try: try:
r = await self._session.request(method, url, headers=header, data=dump_data, timeout=5) r = await self._session.request(method, url, headers=header, data=dump_data, timeout=5)
raw = await r.read() raw = await r.read()
_LOGGER.debug(f"Midea cloud API url: {url}, data: {data}, response: {raw}") _LOGGER.debug(f"Midea cloud API url: {url}, header: {header}, data: {data}, response: {raw}")
response = json.loads(raw) response = json.loads(raw)
except Exception as e: except Exception as e:
_LOGGER.debug(f"API request attempt failed: {e}") _LOGGER.debug(f"API request attempt failed: {e}")
@@ -467,8 +466,8 @@ class MeijuCloud(MideaCloud):
self._security.aes_decrypt_with_fixed_key(lua)) self._security.aes_decrypt_with_fixed_key(lua))
stream = stream.replace("\r\n", "\n") stream = stream.replace("\r\n", "\n")
fnm = f"{path}/{response['fileName']}" fnm = f"{path}/{response['fileName']}"
with open(fnm, "w") as fp: async with aiofiles.open(fnm, "w") as fp:
fp.write(stream) await fp.write(stream)
return fnm return fnm
@@ -629,8 +628,8 @@ class MSmartHomeCloud(MideaCloud):
self._security.aes_decrypt_with_fixed_key(lua)) self._security.aes_decrypt_with_fixed_key(lua))
stream = stream.replace("\r\n", "\n") stream = stream.replace("\r\n", "\n")
fnm = f"{path}/{response['fileName']}" fnm = f"{path}/{response['fileName']}"
with open(fnm, "w") as fp: async with aiofiles.open(fnm, "w") as fp:
fp.write(stream) await fp.write(stream)
return fnm return fnm
async def send_cloud(self, appliance_code: int, data: bytearray): async def send_cloud(self, appliance_code: int, data: bytearray):