chore: release 2.10.44 — WebSocket resilience, ingress UI (Codex, Antigravity), changelog

Author: Coolver

CHANGELOG.md

@@ -2,6 +2,20 @@
 
 All notable changes to this project will be documented in this file.
 
+## [2.10.44] - 2026-04-17
+
+**Thanks:** [Chris Lennon](https://github.com/chrislennon) for the Home Assistant WebSocket resilience work shipped in [PR #38](https://github.com/Coolver/home-assistant-vibecode-agent/pull/38). [SpryNM](https://github.com/sprynm) for practical feedback that improved the **Codex** setup steps in the ingress UI (aligned with [OpenAI’s Codex MCP guide](https://developers.openai.com/codex/mcp/)).
+
+### Steadier connection when Home Assistant restarts or the network blips
+
+If Home Assistant restarted, the watchdog kicked in, or the network dropped for a moment, the agent could leave a lot of work waiting a long time for answers that would never come—so you saw long stretches of timeout noise even after things were fine again. It also sometimes gave up waiting for the link to come back a little too eagerly. This release smooths that out: work in flight is cleared promptly when the link drops, reconnects pause briefly instead of hammering the server, the agent waits longer for a healthy connection before reporting “not connected,” and very large registry exports get more headroom on busy but healthy systems.
+
+### Setup panel (ingress UI)
+
+- **Codex:** Explains that the shared config file may not exist yet; adds a one-line `codex mcp add …` option with a copy button; points to official MCP documentation.
+- **Antigravity (Gemini):** New tab (after Cursor) with install notes, config path under `.gemini`, and merge guidance.
+- **Tabs:** Claude Code stays the default first tab; Cursor second; Antigravity follows Cursor.
+
 ## [2.10.42] - 2026-04-10
 
 **Release prepared with thanks to:** [@ctaylor86](https://github.com/ctaylor86), [@johny-mnemonic](https://github.com/johny-mnemonic), and [@wilsto](https://github.com/wilsto).

Dockerfile

@@ -1,8 +1,8 @@
 ARG BUILD_FROM
 FROM ${BUILD_FROM}
 
-# Version: 2.3.12 - Force rebuild for repository parsing fix
-# Build timestamp: 2025-11-09 15:25:00 UTC
+# Version: 2.10.44 - WebSocket disconnect / reconnect resilience (see CHANGELOG)
+# Build timestamp: 2026-04-17
 # Install system dependencies
 RUN apk add --no-cache \
     git \

README.md

@@ -1,6 +1,6 @@
 # HA Vibecode Agent - Home Assistant Add-on
 
-[![Version](https://img.shields.io/badge/version-2.10.43-blue.svg)](https://github.com/Coolver/home-assistant-vibecode-agent)
+[![Version](https://img.shields.io/badge/version-2.10.44-blue.svg)](https://github.com/Coolver/home-assistant-vibecode-agent)
 [![License](https://img.shields.io/badge/license-MIT-green.svg)](LICENSE)
 [![MCP Package](https://img.shields.io/npm/v/@coolver/home-assistant-mcp?label=MCP%20Package)](https://www.npmjs.com/package/@coolver/home-assistant-mcp)
 

app/ingress_panel.py

@@ -68,6 +68,21 @@ def generate_ingress_html(api_key: str, agent_version: str) -> str:
   }}
 }}'''
 
+    # Google Antigravity (Gemini) — same mcpServers JSON; stored under ~/.gemini/antigravity/mcp_config.json
+    # See https://antigravity.google/docs/mcp
+    antigravity_json_config = f'''{{
+  "mcpServers": {{
+    "home-assistant": {{
+      "command": "npx",
+      "args": ["-y", "@coolver/home-assistant-mcp@latest"],
+      "env": {{
+        "HA_AGENT_URL": "http://homeassistant.local:8099",
+        "HA_AGENT_KEY": "{api_key}"
+      }}
+    }}
+  }}
+}}'''
+    
     # Load Jinja2 template
     template_path = Path(__file__).parent / 'templates' / 'ingress_panel.html'
     template_content = template_path.read_text(encoding='utf-8')
@@ -80,7 +95,8 @@ def generate_ingress_html(api_key: str, agent_version: str) -> str:
         cursor_json_config=cursor_json_config,
         claude_json_config=claude_json_config,
         vscode_json_config=vscode_json_config,
-        vscode_codex_toml_config=vscode_codex_toml_config
+        vscode_codex_toml_config=vscode_codex_toml_config,
+        antigravity_json_config=antigravity_json_config,
     )
 
     return html

app/main.py

@@ -26,7 +26,7 @@
 logger = setup_logger('ha_cursor_agent', LOG_LEVEL)
 
 # Agent version
-AGENT_VERSION = "2.10.43"
+AGENT_VERSION = "2.10.44"
 
 # FastAPI app
 app = FastAPI(

app/services/ha_websocket.py

@@ -53,6 +53,17 @@ def is_connected(self) -> bool:
         """Check if WebSocket is connected"""
         return self._connected and self.ws is not None and not self.ws.closed
 
+    def _fail_pending_requests_on_disconnect(self) -> None:
+        """Fail in-flight request futures immediately when the socket is gone."""
+        if not self.pending_requests:
+            return
+        err = ConnectionError("WebSocket disconnected")
+        pending = list(self.pending_requests.items())
+        self.pending_requests.clear()
+        for _msg_id, future in pending:
+            if not future.done():
+                future.set_exception(err)
+    
     async def start(self):
         """Start WebSocket client in background"""
         if self._running:
@@ -114,59 +125,51 @@ async def _connect_and_listen(self):
         if self.session is None or self.session.closed:
             self.session = aiohttp.ClientSession()
 
-        async with self.session.ws_connect(self.url) as ws:
-            self.ws = ws
-            
-            # Step 1: Receive auth_required
-            msg = await ws.receive_json()
-            if msg.get('type') != 'auth_required':
-                raise Exception(f"Expected auth_required, got: {msg.get('type')}")
-            
-            logger.debug("Received auth_required, sending auth...")
-            
-            # Step 2: Send auth
-            await ws.send_json({
-                'type': 'auth',
-                'access_token': self.token
-            })
-            
-            # Step 3: Receive auth_ok or auth_invalid
-            auth_response = await ws.receive_json()
-            if auth_response.get('type') == 'auth_invalid':
-                raise Exception(f"Authentication failed: {auth_response.get('message')}")
-            
-            if auth_response.get('type') != 'auth_ok':
-                raise Exception(f"Unexpected auth response: {auth_response}")
-            
-            logger.info("✅ WebSocket connected and authenticated")
-            self._connected = True
-            self._reconnect_delay = 1  # Reset backoff on successful connect
-            
-            # Step 4: Listen for messages
-            async for msg in ws:
-                if msg.type == aiohttp.WSMsgType.TEXT:
-                    try:
-                        data = json.loads(msg.data)
-                        await self._handle_message(data)
-                    except json.JSONDecodeError as e:
-                        logger.error(f"Failed to parse WebSocket message: {e}")
+        try:
+            async with self.session.ws_connect(self.url) as ws:
+                self.ws = ws
 
-                elif msg.type == aiohttp.WSMsgType.CLOSED:
-                    logger.warning("WebSocket closed by server")
-                    break
+                # Step 1: Receive auth_required
+                msg = await ws.receive_json()
+                if msg.get('type') != 'auth_required':
+                    raise Exception(f"Expected auth_required, got: {msg.get('type')}")
 
-                elif msg.type == aiohttp.WSMsgType.ERROR:
-                    logger.error(f"WebSocket error: {ws.exception()}")
-                    break
-
-            # Fail all in-flight requests immediately instead of letting them
-            # wait 30s for a response that will never arrive
-            for msg_id, future in list(self.pending_requests.items()):
-                if not future.done():
-                    future.set_exception(ConnectionError("WebSocket disconnected"))
-            self.pending_requests.clear()
-
+                logger.debug("Received auth_required, sending auth...")
+                
+                await ws.send_json({
+                    'type': 'auth',
+                    'access_token': self.token
+                })
+                
+                auth_response = await ws.receive_json()
+                if auth_response.get('type') == 'auth_invalid':
+                    raise Exception(f"Authentication failed: {auth_response.get('message')}")
+                
+                if auth_response.get('type') != 'auth_ok':
+                    raise Exception(f"Unexpected auth response: {auth_response}")
+                
+                logger.info("✅ WebSocket connected and authenticated")
+                self._connected = True
+                self._reconnect_delay = 1  # Reset backoff on successful connect
+                
+                async for msg in ws:
+                    if msg.type == aiohttp.WSMsgType.TEXT:
+                        try:
+                            data = json.loads(msg.data)
+                            await self._handle_message(data)
+                        except json.JSONDecodeError as e:
+                            logger.error(f"Failed to parse WebSocket message: {e}")
+                    
+                    elif msg.type == aiohttp.WSMsgType.CLOSED:
+                        logger.warning("WebSocket closed by server")
+                        break
+                    
+                    elif msg.type == aiohttp.WSMsgType.ERROR:
+                        logger.error(f"WebSocket error: {ws.exception()}")
+                        break
+        finally:
             self._connected = False
+            self._fail_pending_requests_on_disconnect()
 
     async def _handle_message(self, data: dict):
         """Handle incoming WebSocket message"""