♻️ refactor misc.py to make record_read_data async

- Modified `record_read_data` to be an async function
- Updated calls to `record_read_data` in `misc_settime` to use `await`
- This change is part of a larger effort to improve the async support in the ZHA Toolkit

Author: mdeweerd

custom_components/zha_toolkit/misc.py

@@ -290,7 +290,7 @@ async def misc_settime(
                 u.dict_to_jsonable(read_resp[0]),
                 read_resp[1],
             )
-            u.record_read_data(read_resp, cluster, params, listener)
+            await u.record_read_data(read_resp, cluster, params, listener)
 
         EPOCH2000_TIMESTAMP = 946684800
         utctime_towrite = utcnow().timestamp() - EPOCH2000_TIMESTAMP
@@ -312,7 +312,7 @@ async def misc_settime(
                 u.dict_to_jsonable(read_resp[0]),
                 read_resp[1],
             )
-            u.record_read_data(read_resp, cluster, params, listener)
+            await u.record_read_data(read_resp, cluster, params, listener)
 
         event_data["success"] = True
     except DeliveryError as e:

custom_components/zha_toolkit/utils.py

@@ -39,16 +39,20 @@
 
 # pylint: disable=too-many-lines
 
+
 async def get_ha_version() -> str:
     """Get HA Version"""
     return await asyncio.to_thread(version, "homeassistant")
 
+
 HA_VERSION = asyncio.run(get_ha_version())
 
+
 async def get_zigpy_version() -> str:
     """Get zigpy Version"""
     return await asyncio.to_thread(version, "zigpy")
 
+
 ZIGPY_VERSION = asyncio.run(get_zigpy_version())
 
 if parse_version(HA_VERSION) < parse_version("2023.4"):
@@ -634,7 +638,9 @@ async def append_to_csvfile(
 
     import csv
 
-    async with aiofiles.open(file_name, "w" if overwrite else "a", encoding="utf_8") as out:
+    async with aiofiles.open(
+        file_name, "w" if overwrite else "a", encoding="utf_8"
+    ) as out:
         writer = csv.writer(out)
         await writer.writerow(fields)
 
@@ -644,7 +650,7 @@ async def append_to_csvfile(
         LOGGER.debug(f"Appended {desc} to '{file_name}'")
 
 
-def record_read_data(
+async def record_read_data(
     read_resp, cluster: zigpy.zcl.Cluster, params, listener=None
 ):
     """Record result from attr_write to CSV file if configured"""