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,44 +116,46 @@ class WindyPush:
 
         if self.log:
             _LOGGER.info("Dataset for windy: %s", purged_data)
-        session = async_get_clientsession(self.hass, verify_ssl=False)
-        try:
-            async with session.get(request_url, params=purged_data) as resp:
-                status = await resp.text()
-                try:
-                    self.verify_windy_response(status)
-                except WindyNotInserted:
-                    # log despite of settings
-                    _LOGGER.error(WINDY_NOT_INSERTED)
 
-                    text_for_test = WINDY_NOT_INSERTED
+        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()
+                    try:
+                        self.verify_windy_response(status)
+                    except WindyNotInserted:
+                        # log despite of settings
+                        _LOGGER.error(WINDY_NOT_INSERTED)
 
-                except WindyApiKeyError:
-                    # log despite of settings
-                    _LOGGER.critical(WINDY_INVALID_KEY)
-                    text_for_test = WINDY_INVALID_KEY
+                        text_for_test = WINDY_NOT_INSERTED
 
+                    except WindyApiKeyError:
+                        # log despite of settings
+                        _LOGGER.critical(WINDY_INVALID_KEY)
+                        text_for_test = WINDY_INVALID_KEY
+
+                        update_options(self.hass, self.config, WINDY_ENABLED, False)
+
+                    except WindySuccess:
+                        if self.log:
+                            _LOGGER.info(WINDY_SUCCESS)
+                        text_for_test = WINDY_SUCCESS
+
+            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:
+                    _LOGGER.critical(WINDY_UNEXPECTED)
+                    text_for_test = WINDY_UNEXPECTED
                     update_options(self.hass, self.config, WINDY_ENABLED, False)
 
-                except WindySuccess:
-                    if self.log:
-                        _LOGGER.info(WINDY_SUCCESS)
-                    text_for_test = WINDY_SUCCESS
-
-        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:
-                _LOGGER.critical(WINDY_UNEXPECTED)
-                text_for_test = WINDY_UNEXPECTED
-                update_options(self.hass, self.config, WINDY_ENABLED, False)
-
-        self.last_update = datetime.now()
-        self.next_update = self.last_update + timed(minutes=5)
-
-        if self.log:
-            _LOGGER.info("Next update: %s", str(self.next_update))
+            self.last_update = datetime.now()
+            self.next_update = self.last_update + timed(minutes=5)
 
+            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