Add IP address configuration through Home Assistant UI

- Enhanced options flow to allow IP address and name changes
- Added connection testing for new IP addresses
- Fixed deprecated config_entry assignment in OptionsFlowHandler
- Added automatic integration reload when configuration changes
- IP changes are now possible through Settings > Devices & Services > Configure

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: rihokirss

custom_components/yamaha_rn301/__init__.py

@@ -18,8 +18,16 @@ def setup(hass, config):
 async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry):
     """Set up Yamaha R-N301 receiver from a config entry."""
     await hass.config_entries.async_forward_entry_setups(entry, ["media_player"])
+    
+    # Listen for config entry updates
+    entry.async_on_unload(entry.add_update_listener(update_listener))
+    
     return True
 
+async def update_listener(hass: HomeAssistant, entry: ConfigEntry):
+    """Handle config entry update."""
+    await hass.config_entries.async_reload(entry.entry_id)
+
 async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
     """Handle removal of receiver entry."""
     return await hass.config_entries.async_unload_platforms(entry, ["media_player"])

custom_components/yamaha_rn301/config_flow.py

@@ -54,7 +54,7 @@ async def async_step_user(self, user_input=None):
     @callback
     def async_get_options_flow(config_entry):
         """Return the options flow for this config entry."""
-        return OptionsFlowHandler(config_entry)
+        return OptionsFlowHandler()
 
     async def _test_connection(self, host, hass):
         """Test connection to Yamaha receiver."""
@@ -73,18 +73,54 @@ async def _test_connection(self, host, hass):
 class OptionsFlowHandler(config_entries.OptionsFlow):
     """Handle integration options flow."""
 
-    def __init__(self, config_entry):
-        """Constructor that stores the config entry."""
-        self.config_entry = config_entry
-
     async def async_step_init(self, user_input=None):
         """Initial step of the options flow."""
+        errors = {}
+        
         if user_input is not None:
-            return self.async_create_entry(title="", data=user_input)
+            # If host was changed, test the new connection
+            if CONF_HOST in user_input:
+                host = user_input[CONF_HOST]
+                if host != self.config_entry.data.get(CONF_HOST):
+                    # Test new host
+                    if not await self._test_connection(host):
+                        errors["base"] = "cannot_connect"
+                    else:
+                        # Update the config entry with new host
+                        new_data = dict(self.config_entry.data)
+                        new_data[CONF_HOST] = host
+                        # Also update name if changed
+                        if CONF_NAME in user_input:
+                            new_data[CONF_NAME] = user_input[CONF_NAME]
+                        self.hass.config_entries.async_update_entry(
+                            self.config_entry, data=new_data
+                        )
+            
+            if not errors:
+                return self.async_create_entry(title="", data={})
 
+        current_host = self.config_entry.data.get(CONF_HOST, "")
+        current_name = self.config_entry.data.get(CONF_NAME, DEFAULT_NAME)
+        
         return self.async_show_form(
             step_id="init",
             data_schema=vol.Schema({
-                vol.Optional("scan_interval", default=30): int,
-            })
+                vol.Required(CONF_HOST, default=current_host): str,
+                vol.Required(CONF_NAME, default=current_name): str,
+            }),
+            errors=errors
         )
+    
+    async def _test_connection(self, host):
+        """Test connection to Yamaha receiver."""
+        try:
+            url = f"http://{host}/YamahaRemoteControl/ctrl"
+            data = '<?xml version="1.0" encoding="utf-8"?><YAMAHA_AV cmd="GET"><Main_Zone><Basic_Status>GetParam</Basic_Status></Main_Zone></YAMAHA_AV>'
+            
+            session = async_get_clientsession(self.hass)
+            timeout = aiohttp.ClientTimeout(total=DEFAULT_TIMEOUT)
+            
+            async with session.post(url, data=data, timeout=timeout) as response:
+                return response.status == 200
+        except Exception:
+            return False