Fix get_config to send get_config command

Fixes the HomeAssistantClient.get_config method so it actually sends
"get_config" rather than "get_states".

Author: barneysowood

hass_client/client.py

@@ -132,7 +132,9 @@ def handle_message(message: Message):
             else:
                 self._loop.call_soon(cb_func, message["event"])
 
-        return await self.subscribe(handle_message, "subscribe_events", event_type=event_type)
+        return await self.subscribe(
+            handle_message, "subscribe_events", event_type=event_type
+        )
 
     async def subscribe_entities(
         self, cb_func: Callable[[EntityStateEvent], None], entity_ids: list[str]
@@ -155,7 +157,9 @@ def handle_message(message: Message):
             else:
                 self._loop.call_soon(cb_func, message["event"])
 
-        return await self.subscribe(handle_message, "subscribe_entities", entity_ids=entity_ids)
+        return await self.subscribe(
+            handle_message, "subscribe_entities", entity_ids=entity_ids
+        )
 
     async def call_service(
         self,
@@ -189,7 +193,7 @@ async def get_states(self) -> list[State]:
 
     async def get_config(self) -> list[Config]:
         """Get dump of the current config in Home Assistant."""
-        return await self.send_command("get_states")
+        return await self.send_command("get_config")
 
     async def get_services(self) -> dict[str, dict[str, Any]]:
         """Get dump of the current services in Home Assistant."""
@@ -209,9 +213,13 @@ async def get_entity_registry(self) -> list[Entity]:
 
     async def get_entity_registry_entry(self, entity_id: str) -> Entity:
         """Get single entry from Entity Registry."""
-        return await self.send_command("config/entity_registry/get", entity_id=entity_id)
+        return await self.send_command(
+            "config/entity_registry/get", entity_id=entity_id
+        )
 
-    async def send_command(self, command: str, **kwargs: dict[str, Any]) -> CommandResultData:
+    async def send_command(
+        self, command: str, **kwargs: dict[str, Any]
+    ) -> CommandResultData:
         """Send a command to the HA websocket and return response."""
         future: asyncio.Future[CommandResultData] = self._loop.create_future()
         if "message_id" in kwargs:
@@ -260,7 +268,9 @@ def remove_listener():
             if "subscribe" not in message_base["command"]:
                 return
             unsub_command = message_base["command"].replace("subscribe", "unsubscribe")
-            asyncio.create_task(self.send_command_no_wait(unsub_command, subscription=message_id))
+            asyncio.create_task(
+                self.send_command_no_wait(unsub_command, subscription=message_id)
+            )
 
         return remove_listener
 
@@ -292,7 +302,9 @@ async def connect(self, ssl: SSLContext | bool | Fingerprint | None = True) -> N
             auth_result: AuthResultMessage = await self._client.receive_json()
             if auth_result["type"] != "auth_ok":
                 await self._client.close()
-                raise AuthenticationFailed(auth_result.get("message", "Authentication failed"))
+                raise AuthenticationFailed(
+                    auth_result.get("message", "Authentication failed")
+                )
         except (
             client_exceptions.WSServerHandshakeError,
             client_exceptions.ClientError,
@@ -370,7 +382,9 @@ def _handle_incoming_message(self, msg: Message) -> None:
             future = self._result_futures.get(msg["id"])
 
             if future is None:
-                LOGGER.debug("Received result for unknown message with ID: %s", msg["id"])
+                LOGGER.debug(
+                    "Received result for unknown message with ID: %s", msg["id"]
+                )
                 return
 
             if msg["success"]: