Merge branch 'main' into fix/sse-reconnect

Replace the infinite fixed-delay retry loop with exponential backoff
(1s, 2s, 4s, ... capped at 60s) and a max retry limit of 10.

Changes to SiloEventListener:
- Expand connection_status signal to (status, retry_count, error_message)
- Add exponential backoff: min(BASE_DELAY * 2^retries, MAX_DELAY)
- Add terminal "gave_up" state after MAX_RETRIES exhausted
- Capture and forward error messages from failed connection attempts

Changes to SiloAuthDockWidget._on_sse_status:
- Show retry count: "Reconnecting (3/10)..."
- Show "Disconnected" (red) on gave_up state
- Log each attempt to FreeCAD console (PrintWarning/PrintError)
- Set tooltip with last error message on the status label

Closes #2

freecad/InitGui.py

@@ -47,6 +47,8 @@ class SiloWorkbench(FreeCADGui.Workbench):
             "Separator",
             "Silo_Settings",
             "Silo_Auth",
+            "Silo_StartPanel",
+            "Silo_Diag",
         ]
 
         self.appendMenu("Silo", self.menu_commands)
@@ -54,6 +56,7 @@ class SiloWorkbench(FreeCADGui.Workbench):
     def Activated(self):
         """Called when workbench is activated."""
         FreeCAD.Console.PrintMessage("Kindred Silo workbench activated\n")
+        FreeCADGui.runCommand("Silo_StartPanel", 0)
 
     def Deactivated(self):
         pass

freecad/silo_commands.py

@@ -3,6 +3,7 @@
 import json
 import os
 import re
+import socket
 import urllib.error
 import urllib.parse
 import urllib.request
@@ -2365,13 +2366,13 @@ class SiloEventListener(QtCore.QThread):
     item_updated = QtCore.Signal(str)  # part_number
     revision_created = QtCore.Signal(str, int)  # part_number, revision
     connection_status = QtCore.Signal(
-        str
-    )  # "connected" / "disconnected" / "unsupported"
+        str, int, str
+    )  # (status, retry_count, error_message)
     server_mode_changed = QtCore.Signal(str)  # "normal" / "read-only" / "degraded"
 
-    _MAX_FAST_RETRIES = 3
-    _FAST_RETRY_SECS = 5
-    _SLOW_RETRY_SECS = 30
+    _MAX_RETRIES = 10
+    _BASE_DELAY = 1  # seconds, doubles each retry
+    _MAX_DELAY = 60  # seconds, backoff cap
 
     def __init__(self, parent=None):
         super().__init__(parent)
@@ -2394,6 +2395,7 @@ class SiloEventListener(QtCore.QThread):
 
     def run(self):
         retries = 0
+        last_error = ""
         while not self._stop_flag:
             try:
                 self._listen()
@@ -2401,21 +2403,24 @@ class SiloEventListener(QtCore.QThread):
                 if self._stop_flag:
                     return
                 retries += 1
+                last_error = "connection closed"
             except _SSEUnsupported:
-                self.connection_status.emit("unsupported")
+                self.connection_status.emit("unsupported", 0, "")
                 return
-            except Exception:
+            except Exception as exc:
                 retries += 1
+                last_error = str(exc) or "unknown error"
 
-            self.connection_status.emit("disconnected")
+            if retries > self._MAX_RETRIES:
+                self.connection_status.emit("gave_up", retries - 1, last_error)
+                return
 
-            if retries <= self._MAX_FAST_RETRIES:
-                delay = self._FAST_RETRY_SECS
-            else:
-                delay = self._SLOW_RETRY_SECS
+            self.connection_status.emit("disconnected", retries, last_error)
+
+            delay = min(self._BASE_DELAY * (2 ** (retries - 1)), self._MAX_DELAY)
 
             # Interruptible sleep
-            for _ in range(delay):
+            for _ in range(int(delay)):
                 if self._stop_flag:
                     return
                 self.msleep(1000)
@@ -2439,7 +2444,7 @@ class SiloEventListener(QtCore.QThread):
         except urllib.error.URLError:
             raise
 
-        self.connection_status.emit("connected")
+        self.connection_status.emit("connected", 0, "")
 
         event_type = ""
         data_buf = ""
@@ -2705,13 +2710,28 @@ class SiloAuthDockWidget:
                 self._event_listener.stop()
             self._sse_label.setText("")
 
-    def _on_sse_status(self, status):
+    def _on_sse_status(self, status, retry, error):
         if status == "connected":
             self._sse_label.setText("Listening")
             self._sse_label.setStyleSheet("font-size: 11px; color: #4CAF50;")
+            self._sse_label.setToolTip("")
+            FreeCAD.Console.PrintMessage("Silo: SSE connected\n")
         elif status == "disconnected":
-            self._sse_label.setText("Reconnecting...")
+            self._sse_label.setText(
+                f"Reconnecting ({retry}/{SiloEventListener._MAX_RETRIES})..."
+            )
             self._sse_label.setStyleSheet("font-size: 11px; color: #FF9800;")
+            self._sse_label.setToolTip(error or "Connection lost")
+            FreeCAD.Console.PrintWarning(
+                f"Silo: SSE reconnecting ({retry}/{SiloEventListener._MAX_RETRIES}): {error}\n"
+            )
+        elif status == "gave_up":
+            self._sse_label.setText("Disconnected")
+            self._sse_label.setStyleSheet("font-size: 11px; color: #F44336;")
+            self._sse_label.setToolTip(error or "Max retries reached")
+            FreeCAD.Console.PrintError(
+                f"Silo: SSE gave up after {retry} retries: {error}\n"
+            )
         elif status == "unsupported":
             self._sse_label.setText("Not available")
             self._sse_label.setStyleSheet("font-size: 11px; color: #888;")
@@ -2940,6 +2960,390 @@ class Silo_Auth:
         return True
 
 
+# ---------------------------------------------------------------------------
+# Start panel
+# ---------------------------------------------------------------------------
+
+
+class SiloStartPanel:
+    """Content widget for the Silo Start Panel dock."""
+
+    def __init__(self):
+        from PySide import QtCore, QtGui
+
+        self.widget = QtGui.QWidget()
+        self._build_ui()
+        self._refresh()
+
+        self._timer = QtCore.QTimer(self.widget)
+        self._timer.timeout.connect(self._refresh)
+        self._timer.start(60000)  # Refresh every 60 seconds
+
+    def _build_ui(self):
+        from PySide import QtCore, QtGui
+
+        layout = QtGui.QVBoxLayout(self.widget)
+        layout.setContentsMargins(8, 8, 8, 8)
+        layout.setSpacing(6)
+
+        # Connection status badge
+        status_row = QtGui.QHBoxLayout()
+        status_row.setSpacing(6)
+        self._conn_dot = QtGui.QLabel("\u2b24")
+        self._conn_dot.setFixedWidth(16)
+        self._conn_dot.setAlignment(QtCore.Qt.AlignCenter)
+        self._conn_label = QtGui.QLabel("Checking...")
+        self._conn_label.setStyleSheet("font-weight: bold;")
+        status_row.addWidget(self._conn_dot)
+        status_row.addWidget(self._conn_label)
+        status_row.addStretch()
+        layout.addLayout(status_row)
+
+        layout.addSpacing(8)
+
+        # My Checkouts section
+        checkout_header = QtGui.QLabel("My Checkouts")
+        checkout_header.setStyleSheet("font-weight: bold; font-size: 12px;")
+        layout.addWidget(checkout_header)
+
+        self._checkout_list = QtGui.QListWidget()
+        self._checkout_list.setMaximumHeight(160)
+        self._checkout_list.setAlternatingRowColors(True)
+        self._checkout_list.itemDoubleClicked.connect(self._on_checkout_clicked)
+        layout.addWidget(self._checkout_list)
+
+        layout.addSpacing(8)
+
+        # Recent Silo Activity section
+        activity_header = QtGui.QLabel("Recent Silo Activity")
+        activity_header.setStyleSheet("font-weight: bold; font-size: 12px;")
+        layout.addWidget(activity_header)
+
+        self._activity_list = QtGui.QListWidget()
+        self._activity_list.setMaximumHeight(200)
+        self._activity_list.setAlternatingRowColors(True)
+        self._activity_list.itemDoubleClicked.connect(self._on_activity_clicked)
+        layout.addWidget(self._activity_list)
+
+        layout.addSpacing(8)
+
+        # Local Recent Files section
+        local_header = QtGui.QLabel("Local Recent Files")
+        local_header.setStyleSheet("font-weight: bold; font-size: 12px;")
+        layout.addWidget(local_header)
+
+        self._local_list = QtGui.QListWidget()
+        self._local_list.setMaximumHeight(160)
+        self._local_list.setAlternatingRowColors(True)
+        self._local_list.itemDoubleClicked.connect(self._on_local_clicked)
+        layout.addWidget(self._local_list)
+
+        layout.addStretch()
+
+    def _refresh(self):
+        self._refresh_connection()
+        self._refresh_checkouts()
+        self._refresh_activity()
+        self._refresh_local()
+
+    def _refresh_connection(self):
+        try:
+            reachable, _ = _client.check_connection()
+        except Exception:
+            reachable = False
+
+        if reachable:
+            api_url = _get_api_url()
+            parsed = urllib.parse.urlparse(api_url)
+            hostname = parsed.hostname or api_url
+            self._conn_dot.setStyleSheet("color: #4CAF50; font-size: 10px;")
+            self._conn_label.setText(f"Connected to {hostname}")
+        else:
+            self._conn_dot.setStyleSheet("color: #888; font-size: 10px;")
+            self._conn_label.setText("Disconnected")
+
+    def _refresh_checkouts(self):
+        self._checkout_list.clear()
+        try:
+            local_files = search_local_files()
+            for item in local_files[:15]:
+                pn = item.get("part_number", "")
+                desc = item.get("description", "")
+                modified = (item.get("modified") or "")[:10]
+                label = f"{pn}  {desc}"
+                if modified:
+                    label += f"  ({modified})"
+                list_item = self._checkout_list.addItem(label)
+        except Exception:
+            self._checkout_list.addItem("(Unable to scan local files)")
+
+        if self._checkout_list.count() == 0:
+            self._checkout_list.addItem("(No local checkouts)")
+
+    def _refresh_activity(self):
+        self._activity_list.clear()
+        try:
+            reachable, _ = _client.check_connection()
+        except Exception:
+            reachable = False
+
+        if not reachable:
+            self._activity_list.addItem("(Not connected)")
+            return
+
+        try:
+            items = _client.list_items()
+            if isinstance(items, list):
+                # Collect local part numbers for badge comparison
+                local_pns = set()
+                try:
+                    for lf in search_local_files():
+                        local_pns.add(lf.get("part_number", ""))
+                except Exception:
+                    pass
+
+                for item in items[:10]:
+                    pn = item.get("part_number", "")
+                    desc = item.get("description", "")
+                    updated = (item.get("updated_at") or "")[:10]
+                    badge = "\u2713 " if pn in local_pns else ""
+                    label = f"{badge}{pn}  {desc}"
+                    if updated:
+                        label += f"  ({updated})"
+                    self._activity_list.addItem(label)
+
+            if self._activity_list.count() == 0:
+                self._activity_list.addItem("(No items in database)")
+        except Exception:
+            self._activity_list.addItem("(Unable to fetch activity)")
+
+    def _refresh_local(self):
+        from PySide import QtGui
+
+        self._local_list.clear()
+        try:
+            param = FreeCAD.ParamGet("User parameter:BaseApp/RecentFiles")
+            count = param.GetInt("RecentFiles", 0)
+            for i in range(min(count, 10)):
+                path = param.GetString(f"MRU{i}", "")
+                if path:
+                    name = Path(path).name
+                    item = QtGui.QListWidgetItem(name)
+                    item.setToolTip(path)
+                    item.setData(256, path)  # Qt.UserRole = 256
+                    self._local_list.addItem(item)
+        except Exception:
+            pass
+
+        if self._local_list.count() == 0:
+            self._local_list.addItem("(No recent files)")
+
+    def _on_checkout_clicked(self, item):
+        """Open a local checkout file."""
+        text = item.text()
+        if text.startswith("("):
+            return
+        pn = text.split()[0] if text else ""
+        if not pn:
+            return
+        local_path = find_file_by_part_number(pn)
+        if local_path and local_path.exists():
+            FreeCAD.openDocument(str(local_path))
+
+    def _on_activity_clicked(self, item):
+        """Open/checkout a remote item."""
+        text = item.text()
+        if text.startswith("("):
+            return
+        # Strip badge if present
+        text = text.lstrip("\u2713 ")
+        pn = text.split()[0] if text else ""
+        if not pn:
+            return
+        local_path = find_file_by_part_number(pn)
+        if local_path and local_path.exists():
+            FreeCAD.openDocument(str(local_path))
+        else:
+            _sync.open_item(pn)
+
+    def _on_local_clicked(self, item):
+        """Open a local recent file."""
+        path = item.data(256)  # Qt.UserRole
+        if path and Path(path).exists():
+            FreeCAD.openDocument(path)
+
+
+class Silo_StartPanel:
+    """Show the Silo Start Panel."""
+
+    def GetResources(self):
+        return {
+            "MenuText": "Start Panel",
+            "ToolTip": "Show Silo start panel with checkouts and recent activity",
+            "Pixmap": _icon("open"),
+        }
+
+    def Activated(self):
+        from PySide import QtCore, QtGui
+
+        mw = FreeCADGui.getMainWindow()
+        if mw is None:
+            return
+
+        # Reuse existing panel if it exists
+        panel = mw.findChild(QtGui.QDockWidget, "SiloStartPanel")
+        if panel:
+            panel.show()
+            panel.raise_()
+            return
+
+        # Create new dock widget
+        content = SiloStartPanel()
+        dock = QtGui.QDockWidget("Silo", mw)
+        dock.setObjectName("SiloStartPanel")
+        dock.setWidget(content.widget)
+        dock.setAllowedAreas(
+            QtCore.Qt.LeftDockWidgetArea | QtCore.Qt.RightDockWidgetArea
+        )
+        mw.addDockWidget(QtCore.Qt.LeftDockWidgetArea, dock)
+
+    def IsActive(self):
+        return True
+
+
+class _DiagWorker(QtCore.QThread):
+    """Background worker that runs connectivity diagnostics."""
+
+    result = QtCore.Signal(str, bool, str)  # (test_name, passed, detail)
+    finished_all = QtCore.Signal()
+    _HTTP_TIMEOUT = 10
+    _DNS_TIMEOUT = 5
+
+    def run(self):
+        api_url = _get_api_url()
+        base_url = api_url.rstrip("/")
+        if base_url.endswith("/api"):
+            base_url = base_url[:-4]
+        self._test_dns(base_url)
+        self._test_http("Health", f"{base_url}/health", auth=False)
+        self._test_http("Ready", f"{base_url}/ready", auth=False)
+        self._test_http("Auth", f"{api_url.rstrip('/')}/auth/me", auth=True)
+        self._test_sse(api_url)
+        self.finished_all.emit()
+
+    def _test_dns(self, base_url):
+        parsed = urllib.parse.urlparse(base_url)
+        hostname = parsed.hostname
+        if not hostname:
+            self.result.emit("DNS", False, "no hostname in URL")
+            return
+        try:
+            addrs = socket.getaddrinfo(
+                hostname, None, socket.AF_UNSPEC, socket.SOCK_STREAM
+            )
+            first_ip = addrs[0][4][0] if addrs else "?"
+            self.result.emit("DNS", True, f"{hostname} -> {first_ip}")
+        except socket.gaierror as e:
+            self.result.emit("DNS", False, f"{hostname}: {e}")
+        except Exception as e:
+            self.result.emit("DNS", False, str(e))
+
+    def _test_http(self, name, url, auth=False):
+        try:
+            headers = {}
+            if auth:
+                headers.update(_get_auth_headers())
+            req = urllib.request.Request(url, headers=headers, method="GET")
+            resp = urllib.request.urlopen(
+                req, context=_get_ssl_context(), timeout=self._HTTP_TIMEOUT
+            )
+            code = resp.getcode()
+            body = resp.read(4096).decode("utf-8", errors="replace").strip()
+            detail = f"HTTP {code}"
+            try:
+                data = json.loads(body)
+                if isinstance(data, dict):
+                    parts = []
+                    for key in ("status", "username", "role"):
+                        if key in data:
+                            parts.append(f"{key}={data[key]}")
+                    if parts:
+                        detail += f" ({', '.join(parts)})"
+            except (json.JSONDecodeError, ValueError):
+                if len(body) <= 80:
+                    detail += f" {body}"
+            self.result.emit(name, code < 400, detail)
+        except urllib.error.HTTPError as e:
+            self.result.emit(name, False, f"HTTP {e.code} {e.reason}")
+        except urllib.error.URLError as e:
+            self.result.emit(name, False, str(e.reason))
+        except Exception as e:
+            self.result.emit(name, False, str(e))
+
+    def _test_sse(self, api_url):
+        url = f"{api_url.rstrip('/')}/events"
+        try:
+            headers = {"Accept": "text/event-stream"}
+            headers.update(_get_auth_headers())
+            req = urllib.request.Request(url, headers=headers, method="GET")
+            resp = urllib.request.urlopen(
+                req, context=_get_ssl_context(), timeout=self._HTTP_TIMEOUT
+            )
+            content_type = resp.headers.get("Content-Type", "")
+            code = resp.getcode()
+            resp.close()
+            if "text/event-stream" in content_type:
+                self.result.emit("SSE", True, f"HTTP {code} event-stream")
+            else:
+                self.result.emit("SSE", True, f"HTTP {code} (type: {content_type})")
+        except urllib.error.HTTPError as e:
+            if e.code in (404, 501):
+                self.result.emit("SSE", False, f"HTTP {e.code} (not supported)")
+            else:
+                self.result.emit("SSE", False, f"HTTP {e.code} {e.reason}")
+        except urllib.error.URLError as e:
+            self.result.emit("SSE", False, str(e.reason))
+        except Exception as e:
+            self.result.emit("SSE", False, str(e))
+
+
+class Silo_Diag:
+    """Command to run connection diagnostics."""
+
+    _worker = None
+
+    def GetResources(self):
+        return {
+            "MenuText": "Diagnostics",
+            "ToolTip": "Test DNS, health, readiness, auth, and SSE connectivity",
+            "Pixmap": _icon("info"),
+        }
+
+    def Activated(self):
+        if self._worker is not None and self._worker.isRunning():
+            FreeCAD.Console.PrintWarning("Silo: diagnostics already running\n")
+            return
+        api_url = _get_api_url()
+        FreeCAD.Console.PrintMessage(f"--- Silo Diagnostics ({api_url}) ---\n")
+        self._worker = _DiagWorker()
+        self._worker.result.connect(self._on_result)
+        self._worker.finished_all.connect(self._on_finished)
+        self._worker.start()
+
+    def _on_result(self, name, passed, detail):
+        if passed:
+            FreeCAD.Console.PrintMessage(f"  PASS  {name}: {detail}\n")
+        else:
+            FreeCAD.Console.PrintError(f"  FAIL  {name}: {detail}\n")
+
+    def _on_finished(self):
+        FreeCAD.Console.PrintMessage("--- Diagnostics complete ---\n")
+        self._worker = None
+
+    def IsActive(self):
+        return True
+
+
 # Register commands
 FreeCADGui.addCommand("Silo_Open", Silo_Open())
 FreeCADGui.addCommand("Silo_New", Silo_New())
@@ -2955,3 +3359,5 @@ FreeCADGui.addCommand("Silo_SetStatus", Silo_SetStatus())
 FreeCADGui.addCommand("Silo_Settings", Silo_Settings())
 
 FreeCADGui.addCommand("Silo_Auth", Silo_Auth())
+FreeCADGui.addCommand("Silo_StartPanel", Silo_StartPanel())
+FreeCADGui.addCommand("Silo_Diag", Silo_Diag())