chore: bumped version to 0.0.31

Author: MODSetter

VERSION

@@ -1 +1 @@
-0.0.30
+0.0.31

surfsense_backend/alembic/env.py

@@ -5,12 +5,12 @@
 from logging.config import fileConfig
 
 import sqlalchemy as sa
-from alembic.script import ScriptDirectory
 from sqlalchemy import pool
 from sqlalchemy.engine import Connection
 from sqlalchemy.ext.asyncio import async_engine_from_config
 
 from alembic import context
+from alembic.script import ScriptDirectory
 
 # Ensure the app directory is in the Python path
 # This allows Alembic to find your models
@@ -81,9 +81,7 @@ def _fast_forward_fresh_db(connection: Connection) -> bool:
     step rather than resurrecting the replay.
     """
     for table in ("documents", "searchspaces", BOOTSTRAP_MARKER_TABLE):
-        if connection.execute(
-            sa.text("SELECT to_regclass(:t)"), {"t": table}
-        ).scalar():
+        if connection.execute(sa.text("SELECT to_regclass(:t)"), {"t": table}).scalar():
             return False
     if connection.execute(sa.text("SELECT to_regclass('alembic_version')")).scalar():
         current = connection.execute(

surfsense_backend/alembic/versions/171_add_runs_and_tool_output_spills.py

@@ -41,9 +41,7 @@ def upgrade() -> None:
         );
         """
     )
-    op.execute(
-        "CREATE INDEX IF NOT EXISTS ix_runs_workspace_id ON runs (workspace_id)"
-    )
+    op.execute("CREATE INDEX IF NOT EXISTS ix_runs_workspace_id ON runs (workspace_id)")
     op.execute("CREATE INDEX IF NOT EXISTS ix_runs_user_id ON runs (user_id)")
     op.execute("CREATE INDEX IF NOT EXISTS ix_runs_capability ON runs (capability)")
     op.execute("CREATE INDEX IF NOT EXISTS ix_runs_created_at ON runs (created_at)")

surfsense_backend/app/agents/chat/multi_agent_chat/subagents/builtins/mcp_discovery/agent.py

@@ -50,9 +50,7 @@ def _augment_allowlist_for_collision_prefixes(
             continue
         original = meta.get("mcp_original_tool_name")
         if original in trusted_names and tool.name not in trusted_names:
-            alias_rules.append(
-                Rule(permission=tool.name, pattern="*", action="allow")
-            )
+            alias_rules.append(Rule(permission=tool.name, pattern="*", action="allow"))
 
     if not alias_rules:
         return dependencies

surfsense_backend/app/agents/chat/multi_agent_chat/subagents/builtins/mcp_discovery/tools/get_connected_accounts.py

@@ -85,8 +85,7 @@ async def _impl() -> str:
                     # ``server_config`` presence == the connector produces agent
                     # tools. Native rows without it are connected for indexing
                     # only and need a reconnect via MCP.
-                    "usable_in_chat": isinstance(cfg, dict)
-                    and "server_config" in cfg,
+                    "usable_in_chat": isinstance(cfg, dict) and "server_config" in cfg,
                     "account": account_meta,
                 }
             )

surfsense_backend/app/agents/chat/multi_agent_chat/subagents/mcp_tools/index.py

@@ -83,7 +83,9 @@ def resolve_tool_name_collisions(
             or original_name,
             "mcp_collision_prefixed": True,
         }
-        resolved.append(tool.model_copy(update={"name": new_name, "metadata": new_meta}))
+        resolved.append(
+            tool.model_copy(update={"name": new_name, "metadata": new_meta})
+        )
     return resolved
 
 

surfsense_backend/app/agents/chat/multi_agent_chat/subagents/shared/run_reader.py

@@ -128,7 +128,7 @@ def _cell(value: Any) -> str:
     """Render one CSV cell: scalars as-is, nested structures as compact JSON."""
     if value is None:
         return ""
-    if isinstance(value, (dict, list)):
+    if isinstance(value, dict | list):
         return json.dumps(value, ensure_ascii=False, default=str)
     return str(value)
 
@@ -230,9 +230,7 @@ async def _read_run(
         count = min(max(1, limit), _MAX_LIMIT)
         window = lines[start : start + count]
         if not window:
-            return (
-                f"No lines at offset {start} (total {len(lines)} lines in {ref})."
-            )
+            return f"No lines at offset {start} (total {len(lines)} lines in {ref})."
         window_body = "\n".join(window)
         start_char = max(0, char_offset)
         if start_char >= len(window_body) > 0:
@@ -328,10 +326,14 @@ async def _export_run(
         records = _rows_from_body(body, rows)
         if include_pattern:
             inc = _build_matcher(include_pattern.strip())
-            records = [r for r in records if inc(" ".join(map(_cell, r.values()))) is not None]
+            records = [
+                r for r in records if inc(" ".join(map(_cell, r.values()))) is not None
+            ]
         if exclude_pattern:
             exc = _build_matcher(exclude_pattern.strip())
-            records = [r for r in records if exc(" ".join(map(_cell, r.values()))) is None]
+            records = [
+                r for r in records if exc(" ".join(map(_cell, r.values()))) is None
+            ]
         if not records:
             return (
                 f"Error: no rows to export from {ref} "
@@ -353,7 +355,9 @@ async def _export_run(
 
         preview_lines = csv_text.split("\n")[:4]
         truncated_note = (
-            f" (capped at {_EXPORT_MAX_ROWS} rows)" if row_count >= _EXPORT_MAX_ROWS else ""
+            f" (capped at {_EXPORT_MAX_ROWS} rows)"
+            if row_count >= _EXPORT_MAX_ROWS
+            else ""
         )
         return (
             f"Exported {row_count} rows{truncated_note} to {final_path} "

surfsense_backend/app/app.py

@@ -627,9 +627,13 @@ async def _sweep_stale_scraper_runs() -> None:
         async with async_session_maker() as session:
             swept = await fail_stale_running_runs(session)
         if swept:
-            logger.info("[startup] Marked %d stale running scraper run(s) as error", swept)
+            logger.info(
+                "[startup] Marked %d stale running scraper run(s) as error", swept
+            )
     except Exception:
-        logger.warning("[startup] Stale scraper-run sweep failed (non-fatal)", exc_info=True)
+        logger.warning(
+            "[startup] Stale scraper-run sweep failed (non-fatal)", exc_info=True
+        )
 
 
 @asynccontextmanager

surfsense_backend/app/capabilities/core/access/rest.py

@@ -209,7 +209,10 @@ async def _execute_async_run(
             raise
         except (SurfSenseError, HTTPException) as exc:
             await _finalize_async(
-                run_id, status="error", error=str(exc), started=started,
+                run_id,
+                status="error",
+                error=str(exc),
+                started=started,
                 progress=reporter.coarse,
             )
             _publish_finished(run_id, "error", error=str(exc))

surfsense_backend/app/capabilities/core/runs.py

@@ -291,7 +291,9 @@ async def record_spill(
         return None
 
 
-async def _maybe_cleanup(session: AsyncSession, table: str, retention_days: int) -> None:
+async def _maybe_cleanup(
+    session: AsyncSession, table: str, retention_days: int
+) -> None:
     """Delete a bounded batch of expired rows on ~1% of inserts."""
     if random.random() >= _CLEANUP_SAMPLE_RATE:
         return