Merge pull request #31 from schizza/async_fix

aiohttp fix

custom_components/sws12500/__init__.py

@@ -1,4 +1,5 @@
 """The Sencor SWS 12500 Weather Station integration."""
+
 import logging
 
 import aiohttp
@@ -74,7 +75,9 @@ class WeatherDataUpdateCoordinator(DataUpdateCoordinator):
 
         if sensors := check_disabled(self.hass, remaped_items, self.config):
             translate_sensors = [
-                await translations(self.hass, DOMAIN, f"sensor.{t_key}", key="name", category="entity")
+                await translations(
+                    self.hass, DOMAIN, f"sensor.{t_key}", key="name", category="entity"
+                )
                 for t_key in sensors
             ]
             human_readable = "\n".join(translate_sensors)

custom_components/sws12500/windy_func.py

@@ -3,10 +3,9 @@
 from datetime import datetime, timedelta
 import logging
 
-import aiohttp
-
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant
+from homeassistant.helpers.aiohttp_client import async_get_clientsession
 
 from .const import (
     PURGE_DATA,
@@ -69,6 +68,9 @@ class WindyPush:
     ) -> WindyNotInserted | WindySuccess | WindyApiKeyError | None:
         """Verify answer form Windy."""
 
+        if self.log:
+            _LOGGER.info("Windy response raw response: %s", response)
+
         if "NOTICE" in response:
             raise WindyNotInserted
 
@@ -78,6 +80,9 @@ class WindyPush:
         if "Invalid API key" in response:
             raise WindyApiKeyError
 
+        if "Unauthorized" in response:
+            raise WindyApiKeyError
+
         return None
 
     async def push_data_to_windy(self, data):
@@ -116,10 +121,7 @@ class WindyPush:
 
         if self.log:
             _LOGGER.info("Dataset for windy: %s", purged_data)
-
+        session = async_get_clientsession(self.hass, verify_ssl=False)
-        async with aiohttp.ClientSession(
-            connector=aiohttp.TCPConnector(ssl=False), trust_env=True
-        ) as session:  # verify_ssl=False; intended to be False
         try:
             async with session.get(request_url, params=purged_data) as resp:
                 status = await resp.text()
@@ -143,7 +145,7 @@ class WindyPush:
                         _LOGGER.info(WINDY_SUCCESS)
                     text_for_test = WINDY_SUCCESS
 
-            except aiohttp.ClientConnectionError as ex:
+        except session.ClientError as ex:
             _LOGGER.critical("Invalid response from Windy: %s", str(ex))
             self.invalid_response_count += 1
             if self.invalid_response_count > 3:
@@ -156,6 +158,7 @@ class WindyPush:
 
         if self.log:
             _LOGGER.info("Next update: %s", str(self.next_update))
+
         if RESPONSE_FOR_TEST and text_for_test:
             return text_for_test
         return None