fix: restore pre-commit hooks and fix all backend lint/test failures

Removed bd (beads) tool that had overwritten git hooks. Installed
pre-commit framework with 6 hooks: backend format/lint/test and
frontend prettier/lint/test. Fixed 100+ ruff lint errors (F401, F403,
F405, F811, F821, E501), configured ruff in pyproject.toml, and
resolved all 17 test failures (auth mocking, langchain API compat,
conditional enum guards).

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: ryaneggz

.pre-commit-config.yaml

@@ -8,6 +8,20 @@ repos:
             files: ^backend/
             pass_filenames: false
             always_run: false
+          - id: backend-lint
+            name: Backend Lint
+            entry: bash -c 'cd backend && make lint'
+            language: system
+            files: ^backend/
+            pass_filenames: false
+            always_run: false
+          - id: backend-test
+            name: Backend Test
+            entry: bash -c 'cd backend && make test ENV_FILE=~/.env/orchestra/.env.backend.test'
+            language: system
+            files: ^backend/
+            pass_filenames: false
+            always_run: false
           - id: frontend-prettier
             name: Frontend Prettier
             entry: npx prettier --write
@@ -22,3 +36,10 @@ repos:
             files: ^frontend/
             pass_filenames: false
             always_run: false
+          - id: frontend-test
+            name: Frontend Test
+            entry: bash -c 'cd frontend && npm run test'
+            language: system
+            files: ^frontend/
+            pass_filenames: false
+            always_run: false

Makefile

@@ -1,4 +1,4 @@
-.PHONY: update-submodules ralph archive
+.PHONY: update-submodules ralph archive setup
 
 ENV ?= dev
 MAX_ITERATIONS ?= 200
@@ -18,6 +18,10 @@ update-submodules:
 
 	@echo "🏁 Done."
 
+# Install pre-commit hooks
+setup:
+	pre-commit install
+
 # Run the Ralph autonomous agent loop using Claude Code
 ralph:
 	bash .ralph/ralph.sh $(MAX_ITERATIONS)

backend/Makefile

@@ -1,4 +1,4 @@
-.PHONY: dev claude build run tag seeds test format
+.PHONY: dev claude build run tag seeds test format lint
 
 ENV_FILE ?= $(HOME)/.env/orchestra/.env.backend
 
@@ -23,6 +23,9 @@ seeds.user:
 format:
 	uvx ruff format
 
+lint:
+	uvx ruff check
+
 test:
 	@set -a && . $(ENV_FILE) && set +a && uv run pytest
 

backend/main.py

@@ -58,7 +58,7 @@
 async def lifespan(app: FastAPI):
     # Startup
     print("Starting up...")
-    print(f"Environment Settings:")
+    print("Environment Settings:")
     print(f"APP_VERSION: {APP_VERSION}")
     print(f"LOG_LEVEL: {LOG_LEVEL}")
     print(f"HOST: {HOST}")
@@ -100,7 +100,7 @@ async def lifespan(app: FastAPI):
         "This is a simple API for building chatbots with LangGraph. "
         "It allows you to create new threads, query existing threads, "
         "and get the history of a thread.\n Check out the repo on "
-        f"<a href='https://github.com/ruska-ai/orchestra'>Github</a>"
+        "<a href='https://github.com/ruska-ai/orchestra'>Github</a>"
     ),
     contact={"name": "Ryan Eggleston", "email": "reggleston@ruska.ai"},
     debug=True,

backend/migrations/env.py

@@ -39,9 +39,7 @@ async def ensure_database_exists(db_uri: str) -> None:
 
     # Connect to the default 'postgres' database to create the target db
     # Convert to asyncpg format for async engine
-    postgres_uri = f"{base_uri}/postgres".replace(
-        "postgresql://", "postgresql+asyncpg://"
-    )
+    postgres_uri = f"{base_uri}/postgres".replace("postgresql://", "postgresql+asyncpg://")
 
     try:
         engine = create_async_engine(

backend/pyproject.toml

@@ -76,6 +76,21 @@ dev = [
     "respx>=0.22.0"
 ]
 
+[tool.ruff]
+line-length = 120
+
+[tool.ruff.lint]
+select = ["E", "F"]
+
+[tool.ruff.lint.per-file-ignores]
+"main.py" = ["E402"]
+"migrations/env.py" = ["E402"]
+"src/constants/llm.py" = ["E402"]
+"src/tools/code.py" = ["E402"]
+"src/utils/logger.py" = ["E402"]
+"src/services/checkpoint.py" = ["E402"]
+"src/constants/mock.py" = ["E501"]
+
 [tool.pytest.ini_options]
 pythonpath = ["."]
 asyncio_default_fixture_loop_scope = "session"

backend/seeds/user_seeder.py

@@ -34,9 +34,7 @@
 async def seed_admin():
     async with AsyncSessionLocal() as db:
         try:
-            result = await db.execute(
-                select(User).filter(User.email == "admin@example.com")
-            )
+            result = await db.execute(select(User).filter(User.email == "admin@example.com"))
             admin = result.scalar_one_or_none()
             if admin:
                 print("Admin exists, skipping seeding")
@@ -58,9 +56,7 @@ async def seed_admin():
 async def seed_user():
     async with AsyncSessionLocal() as db:
         try:
-            result = await db.execute(
-                select(User).filter(User.email == "user@example.com")
-            )
+            result = await db.execute(select(User).filter(User.email == "user@example.com"))
             user = result.scalar_one_or_none()
             if user:
                 print("User exists, skipping seeding")

backend/src/agents/__init__.py

@@ -8,7 +8,6 @@
 from langchain_core.language_models import BaseChatModel
 from langchain_core.tools import BaseTool
 from langgraph.checkpoint.base import BaseCheckpointSaver
-from langchain.agents import create_agent
 from langgraph.store.base import BaseStore
 from langchain_core.messages import BaseMessage
 from langgraph.graph.state import CompiledStateGraph
@@ -56,11 +55,7 @@ def memory_to_xml(memory):
             items.append(f"<{key}>{value}</{key}>")
         return f"<memory>{''.join(items)}</memory>"
 
-    formatted_memories = (
-        "\n".join(memory_to_xml(memory) for memory in memories)
-        if memories
-        else "No memories found."
-    )
+    formatted_memories = "\n".join(memory_to_xml(memory) for memory in memories) if memories else "No memories found."
 
     return (
         "You have the following general memories "
@@ -173,9 +168,7 @@ async def init_tools(
         tools_list = tools_list + await mcp_client.get_tools()
     if user_id:
         for tool in tools:
-            items = await service_context.tool_service.tool_repo.search(
-                filter={"name": tool}
-            )
+            items = await service_context.tool_service.tool_repo.search(filter={"name": tool})
             if items:
                 structured_tool = items[0]
                 tool_metadata = {structured_tool.name: structured_tool.metadata}
@@ -187,21 +180,15 @@ async def init_tools(
     return tools_list
 
 
-async def init_subagents(
-    subagents: list[Assistant], service_context: ServiceContext
-) -> list[SubAgent]:
+async def init_subagents(subagents: list[Assistant], service_context: ServiceContext) -> list[SubAgent]:
     result = []
     for subagent in subagents:
-        system_prompt = subagent.system_prompt or init_system_prompt(
-            DEFAULT_SYSTEM_PROMPT, {}, subagent.instructions
-        )
+        system_prompt = subagent.system_prompt or init_system_prompt(DEFAULT_SYSTEM_PROMPT, {}, subagent.instructions)
         subagent_dict = {
             "name": subagent.slug,
             "description": subagent.description,
             "system_prompt": system_prompt,
-            "tools": await init_tools(
-                subagent.tools, subagent.a2a, subagent.mcp, service_context
-            ),
+            "tools": await init_tools(subagent.tools, subagent.a2a, subagent.mcp, service_context),
         }
 
         if getattr(subagent, "model", None) is not None:
@@ -375,9 +362,7 @@ async def construct_agent(
             model=model,
             tools=tools,
             subagents=subagents,
-            system_prompt=init_system_prompt(
-                system_prompt, service_context.config or {}, instructions
-            ),
+            system_prompt=init_system_prompt(system_prompt, service_context.config or {}, instructions),
             checkpointer=checkpointer,
             store=service_context.store,
             middleware=middleware,
@@ -449,6 +434,4 @@ def astream(
         config: RunnableConfig = None,
         context: dict[str, Any] = None,
     ) -> AsyncGenerator[BaseMessage, None]:
-        return self.graph.astream(
-            messages, config=config, stream_mode=stream_mode, context=context
-        )
+        return self.graph.astream(messages, config=config, stream_mode=stream_mode, context=context)

backend/src/common/client/client.py

@@ -35,14 +35,10 @@ async def send_task(self, payload: dict[str, Any]) -> SendTaskResponse:
         request = SendTaskRequest(params=payload)
         return SendTaskResponse(**await self._send_request(request))
 
-    async def send_task_streaming(
-        self, payload: dict[str, Any]
-    ) -> AsyncIterable[SendTaskStreamingResponse]:
+    async def send_task_streaming(self, payload: dict[str, Any]) -> AsyncIterable[SendTaskStreamingResponse]:
         request = SendTaskStreamingRequest(params=payload)
         with httpx.Client(timeout=None) as client:
-            with connect_sse(
-                client, "POST", self.url, json=request.model_dump()
-            ) as event_source:
+            with connect_sse(client, "POST", self.url, json=request.model_dump()) as event_source:
                 try:
                     for sse in event_source.iter_sse():
                         yield SendTaskStreamingResponse(**json.loads(sse.data))
@@ -55,9 +51,7 @@ async def _send_request(self, request: JSONRPCRequest) -> dict[str, Any]:
         async with httpx.AsyncClient() as client:
             try:
                 # Image generation could take time, adding timeout
-                response = await client.post(
-                    self.url, json=request.model_dump(), timeout=30
-                )
+                response = await client.post(self.url, json=request.model_dump(), timeout=30)
                 response.raise_for_status()
                 return response.json()
             except httpx.HTTPStatusError as e:
@@ -73,14 +67,10 @@ async def cancel_task(self, payload: dict[str, Any]) -> CancelTaskResponse:
         request = CancelTaskRequest(params=payload)
         return CancelTaskResponse(**await self._send_request(request))
 
-    async def set_task_callback(
-        self, payload: dict[str, Any]
-    ) -> SetTaskPushNotificationResponse:
+    async def set_task_callback(self, payload: dict[str, Any]) -> SetTaskPushNotificationResponse:
         request = SetTaskPushNotificationRequest(params=payload)
         return SetTaskPushNotificationResponse(**await self._send_request(request))
 
-    async def get_task_callback(
-        self, payload: dict[str, Any]
-    ) -> GetTaskPushNotificationResponse:
+    async def get_task_callback(self, payload: dict[str, Any]) -> GetTaskPushNotificationResponse:
         request = GetTaskPushNotificationRequest(params=payload)
         return GetTaskPushNotificationResponse(**await self._send_request(request))

backend/src/common/server/server.py

@@ -43,9 +43,7 @@ def __init__(
         self.agent_card = agent_card
         self.app = Starlette()
         self.app.add_route(self.endpoint, self._process_request, methods=["POST"])
-        self.app.add_route(
-            "/.well-known/agent.json", self._get_agent_card, methods=["GET"]
-        )
+        self.app.add_route("/.well-known/agent.json", self._get_agent_card, methods=["GET"])
 
     def start(self):
         if self.agent_card is None:
@@ -71,23 +69,15 @@ async def _process_request(self, request: Request):
             elif isinstance(json_rpc_request, SendTaskRequest):
                 result = await self.task_manager.on_send_task(json_rpc_request)
             elif isinstance(json_rpc_request, SendTaskStreamingRequest):
-                result = await self.task_manager.on_send_task_subscribe(
-                    json_rpc_request
-                )
+                result = await self.task_manager.on_send_task_subscribe(json_rpc_request)
             elif isinstance(json_rpc_request, CancelTaskRequest):
                 result = await self.task_manager.on_cancel_task(json_rpc_request)
             elif isinstance(json_rpc_request, SetTaskPushNotificationRequest):
-                result = await self.task_manager.on_set_task_push_notification(
-                    json_rpc_request
-                )
+                result = await self.task_manager.on_set_task_push_notification(json_rpc_request)
             elif isinstance(json_rpc_request, GetTaskPushNotificationRequest):
-                result = await self.task_manager.on_get_task_push_notification(
-                    json_rpc_request
-                )
+                result = await self.task_manager.on_get_task_push_notification(json_rpc_request)
             elif isinstance(json_rpc_request, TaskResubscriptionRequest):
-                result = await self.task_manager.on_resubscribe_to_task(
-                    json_rpc_request
-                )
+                result = await self.task_manager.on_resubscribe_to_task(json_rpc_request)
             else:
                 logger.warning(f"Unexpected request type: {type(json_rpc_request)}")
                 raise ValueError(f"Unexpected request type: {type(request)}")