fix: Publish ptReal to device topic instead of account topic

- Publish commands to GD/{device_id} topic instead of account subscription topic
- Include device ID and SKU in the ptReal payload for proper targeting
- Handle non-state messages gracefully (ignore command responses)

This fixes the disconnection that occurred after every publish when
sending to the account topic we were subscribed to.

Author: Tom Lasswell

custom_components/govee/api/mqtt.py

@@ -314,7 +314,7 @@ async def _connection_loop(self) -> None:
     async def _handle_message(self, message: Any) -> None:
         """Handle incoming AWS IoT MQTT message.
 
-        Message format from PCAP analysis:
+        Message format from PCAP analysis (state updates):
         {
             "device": "XX:XX:XX:XX:XX:XX:XX:XX",
             "sku": "H6072",
@@ -325,18 +325,30 @@ async def _handle_message(self, message: Any) -> None:
                 "colorTemInKelvin": 0
             }
         }
+
+        Command responses and other messages are silently ignored.
         """
         try:
             raw_payload = message.payload
             payload_str = raw_payload.decode() if isinstance(raw_payload, bytes) else str(raw_payload)
 
             data = json.loads(payload_str)
 
+            # Ignore command messages (our own publishes or responses)
+            if "msg" in data:
+                _LOGGER.debug("Ignoring command/response message")
+                return
+
             device_id = data.get("device")
             state = data.get("state", {})
 
+            # Only process messages with device ID and state
             if not device_id:
-                _LOGGER.debug("AWS IoT message missing device ID")
+                _LOGGER.debug("AWS IoT message missing device ID, ignoring")
+                return
+
+            if not state:
+                _LOGGER.debug("AWS IoT message missing state for %s, ignoring", device_id)
                 return
 
             _LOGGER.debug(
@@ -377,27 +389,30 @@ async def async_publish_ptreal(
             _LOGGER.warning("Cannot publish ptReal: MQTT not connected")
             return False
 
-        # Build ptReal payload
+        # Build ptReal payload with device targeting
         payload = {
             "msg": {
                 "cmd": "ptReal",
                 "data": {
                     "command": [ble_packet_base64],
+                    "device": device_id,
+                    "sku": sku,
                 },
                 "cmdVersion": 0,
                 "transaction": f"v_{int(time.time() * 1000)}",
                 "type": 1,
             }
         }
 
-        # Publish to account topic (same as subscription topic)
-        topic = self._credentials.account_topic
+        # Build device-specific topic for commands
+        # Format: GD/{device_id} for device commands (vs GA/{account} for account-level)
+        device_topic = f"GD/{device_id}"
 
         try:
-            await self._client.publish(topic, json.dumps(payload))
+            await self._client.publish(device_topic, json.dumps(payload))
             _LOGGER.debug(
                 "Published ptReal to %s for device %s (sku=%s)",
-                topic[:30] + "...",
+                device_topic,
                 device_id,
                 sku,
             )