custom_components/sws12500/__init__.py

@@ -1,5 +1,4 @@
 """The Sencor SWS 12500 Weather Station integration."""
-
 import logging
 
 import aiohttp
@@ -75,9 +74,7 @@ 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,9 +3,10 @@
 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,
@@ -68,9 +69,6 @@ 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
 
@@ -80,9 +78,6 @@ 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):
@@ -121,7 +116,10 @@ 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()
@@ -145,7 +143,7 @@ class WindyPush:
                             _LOGGER.info(WINDY_SUCCESS)
                         text_for_test = WINDY_SUCCESS
 
-        except session.ClientError as ex:
+            except aiohttp.ClientConnectionError as ex:
                 _LOGGER.critical("Invalid response from Windy: %s", str(ex))
                 self.invalid_response_count += 1
                 if self.invalid_response_count > 3:
@@ -158,7 +156,6 @@ 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