Add files via upload

config/custom_components/neerslag/__init__.py

@@ -0,0 +1,81 @@
+"""The Neerslag Sensor (Buienalarm / Buienradar) integration."""
+import asyncio
+from .load_frontend import setup_view
+import logging
+
+from homeassistant.config_entries import ConfigEntry
+from homeassistant.core import HomeAssistant
+
+from .const import DOMAIN
+
+# TODO List the platforms that you want to support.
+# For your initial PR, limit it to 1 platform.
+PLATFORMS = ["sensor"]
+
+_LOGGER = logging.getLogger(__name__)
+
+
+async def options_update_listener(hass: HomeAssistant, config_entry: ConfigEntry):
+    """Handle options update."""
+
+    _LOGGER.info("----------------This is being executed-------options_update_listener----------------")
+    # await hass.config_entries.async_remove(config_entry.entry_id)
+    # rr = hass.config_entries.async_entries(DOMAIN)
+    # hass.config_entries.async_update_entry(config_entry, data=config_entry.options)
+    # await hass.config_entries.async_reload(config_entry.entry_id)
+    hass.config_entries.async_update_entry(config_entry, data=config_entry.options)
+
+
+async def async_setup(hass: HomeAssistant, config_entry: dict):
+    """Set up the Neerslag Sensor (Buienalarm / Buienradar) component."""
+    hass.data.setdefault(DOMAIN, {})
+    setup_view(hass)
+
+    return True
+
+
+async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry):
+    """Set up Neerslag Sensor (Buienalarm / Buienradar) from a config entry."""
+
+    # hass.states.async_set("neerslag_sensor.useBuienalarm", ConfigEntry.)
+
+    # TODO Store an API object for your platforms to access
+    # hass.data[DOMAIN][entry.entry_id] = MyApi(...)
+    hass.data[DOMAIN][config_entry.entry_id] = {}
+
+    hass_data = dict(config_entry.data)
+    # Registers update listener to update config entry when options are updated.
+    unsub_options_update_listener = config_entry.add_update_listener(options_update_listener)
+    # Store a reference to the unsubscribe function to cleanup if an entry is unloaded.
+    hass_data["unsub_options_update_listener"] = unsub_options_update_listener
+    hass.data[DOMAIN][config_entry.entry_id] = hass_data
+
+    for platform in PLATFORMS:
+        hass.async_create_task(
+            hass.config_entries.async_forward_entry_setup(config_entry, platform)
+        )
+
+    return True
+
+
+async def async_unload_entry(hass: HomeAssistant, config_entry: ConfigEntry):
+    # Remove options_update_listener.
+
+    _LOGGER.info("REMOVE ><<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<")
+
+    """Unload a config entry."""
+    unload_ok = all(
+        await asyncio.gather(
+            *[
+                hass.config_entries.async_forward_entry_unload(config_entry, platform)
+                for platform in PLATFORMS
+            ]
+        )
+    )
+
+    hass.data[DOMAIN][config_entry.entry_id]["unsub_options_update_listener"]()
+
+    if unload_ok:
+        hass.data[DOMAIN].pop(config_entry.entry_id)
+
+    return unload_ok

config/custom_components/neerslag/config_flow.py

@@ -0,0 +1,144 @@
+"""Config flow for Neerslag Sensor (Buienalarm / Buienradar) integration."""
+import logging
+from typing import Optional
+
+import voluptuous as vol
+from homeassistant.core import callback
+
+from homeassistant import config_entries, core, exceptions
+
+from .const import DOMAIN  # pylint:disable=unused-import
+
+_LOGGER = logging.getLogger(__name__)
+
+# TODO adjust the data schema to the data that you need
+STEP_USER_DATA_SCHEMA = vol.Schema({vol.Optional("buienalarm", default=False): bool,
+                                    vol.Optional("buienalarmLatitude", description={"suggested_value": "55.000"}): str,
+                                    vol.Optional("buienalarmLongitude", description={"suggested_value": "5.000"}): str,
+                                    vol.Optional("buienradar", default=False): bool,
+                                    vol.Optional("buienradarLatitude", description={"suggested_value": "55.00"}): str,
+                                    vol.Optional("buienradarLongitude", description={"suggested_value": "5.00"}): str,
+                                    vol.Optional("NeerslagSensorUseHAforLocation", default=True): bool
+                                    })
+
+
+async def validate_input(hass: core.HomeAssistant, data):
+    """Validate the user input allows us to connect.
+
+    Data has the keys from STEP_USER_DATA_SCHEMA with values provided by the user.
+    """
+    # TODO validate the data can be used to set up a connection.
+
+    # If your PyPI package is not built with async, pass your methods
+    # to the executor:
+    # await hass.async_add_executor_job(
+    #     your_validate_func, data["username"], data["password"]
+    # )
+
+    # hub = PlaceholderHub(data["host"])
+
+    # if not await hub.authenticate(data["username"], data["password"]):
+    #     raise InvalidAuth
+
+    # If you cannot connect:
+    # throw CannotConnect
+    # If the authentication is wrong:
+    # InvalidAuth
+
+    # Return info that you want to store in the config entry.
+    return {"title": "Neerslag"}
+
+
+class ConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
+    """Handle a config flow for Neerslag Sensor (Buienalarm / Buienradar)."""
+
+    VERSION = 1
+    # TODO pick one of the available connection classes in homeassistant/config_entries.py
+    CONNECTION_CLASS = config_entries.CONN_CLASS_UNKNOWN
+
+    async def async_step_user(self, user_input=None):
+        """Handle the initial step."""
+
+        if self._async_current_entries():
+            return self.async_abort(reason="single_instance_allowed")
+        if self.hass.data.get(DOMAIN):
+            return self.async_abort(reason="single_instance_allowed")
+
+        if user_input is None:
+            return self.async_show_form(
+                step_id="user", data_schema=STEP_USER_DATA_SCHEMA
+            )
+
+        errors = {}
+
+        try:
+            # info = await validate_input(self.hass, user_input)
+            title = "Neerslag App"
+            data = user_input
+            # _LOGGER.info("Dit wordt nu uitgevoerd...........")
+            # _LOGGER.info(data)
+
+        except CannotConnect:
+            errors["base"] = "cannot_connect"
+        except InvalidAuth:
+            errors["base"] = "invalid_auth"
+        except Exception:  # pylint: disable=broad-except
+            _LOGGER.exception("Unexpected exception")
+            errors["base"] = "unknown"
+        else:
+            return self.async_create_entry(title=title, data=data)
+
+        return self.async_show_form(
+            step_id="user", data_schema=STEP_USER_DATA_SCHEMA, errors=errors
+        )
+
+    @staticmethod
+    @callback
+    def async_get_options_flow(config_entry):
+        """Get the options flow for this handler."""
+        return OptionsFlowHandler(config_entry)
+
+
+class OptionsFlowHandler(config_entries.OptionsFlow):
+
+    def __init__(self, config_entry: config_entries.ConfigEntry) -> None:
+        self.config_entry = config_entry
+
+    async def async_step_init(self, user_input=None):
+
+        # _LOGGER.info("HIER>>>")
+        # _LOGGER.info(self.config_entry.data.get("buienalarmLatitude"))
+        # _LOGGER.info(self.config_entry.data.get("buienalarm"))
+        # _LOGGER.info(self.config_entry.data.get("NeerslagSensorUseHAforLocation"))
+        testtest = vol.Schema({vol.Optional("buienalarm", default=self.config_entry.data.get("buienalarm")): bool,
+                               vol.Optional("buienalarmLatitude", default=self.config_entry.data.get("buienalarmLatitude")): str,
+                               vol.Optional("buienalarmLongitude", default=self.config_entry.data.get("buienalarmLongitude")): str,
+                               vol.Optional("buienradar", default=self.config_entry.data.get("buienradar")): bool,
+                               vol.Optional("buienradarLatitude", default=self.config_entry.data.get("buienradarLatitude")): str,
+                               vol.Optional("buienradarLongitude", default=self.config_entry.data.get("buienradarLongitude")): str,
+                               vol.Optional("NeerslagSensorUseHAforLocation", default=self.config_entry.data.get("NeerslagSensorUseHAforLocation")): bool
+                               })
+
+        # _LOGGER.info("----->>>>---------------")
+        # _LOGGER.info(self.config_entry.options)
+        # _LOGGER.info(self.config_entry.data)
+        # _LOGGER.info("------<<<<--------------")
+        """Manage the options."""
+        if user_input is not None:
+            # _LOGGER.info(user_input)
+            # _LOGGER.info("<><><><><><><><><><>")
+            # self.config_entry.data = user_input
+            return self.async_create_entry(title="", data=user_input)
+
+        return self.async_show_form(
+            step_id="init",
+            data_schema=testtest,
+        )
+
+
+class CannotConnect(exceptions.HomeAssistantError):
+    """Error to indicate we cannot connect."""
+
+
+class InvalidAuth(exceptions.HomeAssistantError):
+    """Error to indicate there is invalid auth."""

config/custom_components/neerslag/const.py

@@ -0,0 +1,7 @@
+"""Constants for the Neerslag Sensor (Buienalarm / Buienradar) integration."""
+
+DOMAIN = "neerslag"
+
+
+FRONTEND_SCRIPT_URL = "/neerslag-card.js"
+DATA_EXTRA_MODULE_URL = 'frontend_extra_module_url'