FROM feat/420-project-endpoints TO development (#460)

* Init

* UI in place, just need to collect checkpoint_id, send payload

* Small tweak

* Have a default system prompt for app

* Fixes message content

* Can send the query but needs to be selected for checkpoint

* Can view and select, need to add final functionality

* Can select and render messages, chat exp not best thoguh

* Fix build

* Fixed formatting

* UPdate system prompts

* using default system prompt

* init

* The service works correctly

* Project Service

* Small updates

* Updates to system prommpt

* Tidy up

* optimized prompt meh

* Updates

Author: ryaneggz

Changelog.md

@@ -19,6 +19,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   - bug/370-anthropic-streaming (2025-09-16)
 
 ### Changed
+  - feat/420-project-endpoints (2025-10-28)
   - feat/464-update-input-support-multiple-keys (2025-11-11)
   - feat/490-can-read-deepagents-agent-files (2025-11-10)
   - feat/485-user-env (2025-11-08)

backend/main.py

@@ -1,10 +1,7 @@
-import os
 import json
 from typing import Callable
 from time import perf_counter
 from fastapi import FastAPI, Request, Response
-from fastapi.responses import FileResponse
-from fastapi.staticfiles import StaticFiles
 from fastapi.middleware.cors import CORSMiddleware
 from slowapi import _rate_limit_exceeded_handler
 from slowapi.errors import RateLimitExceeded
@@ -63,7 +60,7 @@ async def lifespan(app: FastAPI):
 
 
 app = FastAPI(
-    title="Enso 🤖",
+    title="Enso Labs - Orchestra 🪶",
     version=APP_VERSION,
     description=(
         "This is a simple API for building chatbots with LangGraph. "

backend/mkdocs.yml

@@ -1,4 +1,4 @@
-site_name: Enso Cloud ☁️
+site_name: Enso Labs - Orchestra 🪶
 site_dir: src/public/docs
 docs_dir: ../docs
 use_directory_urls: false

backend/pyproject.toml

@@ -61,6 +61,3 @@ pythonpath = ["."]
 filterwarnings = [
     "ignore::DeprecationWarning:passlib.*"
 ]
-
-[tool.uv]
-prerelease = "allow"

backend/src/contexts/service.py

@@ -1,6 +1,7 @@
 from typing import Optional
 from langchain_core.runnables import RunnableConfig
 from langgraph.pregel.main import BaseCheckpointSaver
+from src.services.project import ProjectService
 from src.services.checkpoint import CheckpointService
 from src.services.thread import ThreadService
 from src.services.assistant import AssistantService
@@ -31,6 +32,7 @@ def __init__(
         self.memory_service = MemoryService(user_id=self.user_id, store=store)
         self.thread_service = ThreadService(user_id=self.user_id, store=store)
         self.prompt_service = PromptService(user_id=self.user_id, store=store)
+        self.project_service = ProjectService(user_id=self.user_id, store=store)
         self.assistant_service = AssistantService(user_id=self.user_id, store=store)
         self.presidio_service = PresidioService()
 

backend/src/flows/__init__.py

@@ -55,15 +55,13 @@ def graph_builder(
     context_schema: Type[ContextSchema] | None = None,
     checkpointer: BaseCheckpointSaver | None = None,
     store: BaseStore | None = None,
-    graph_id: Literal[
-        "react", "deepagents", "deepagent", "create_react_agent", "create_deep_agent"
-    ] = "react",
+    graph_id: Literal['deepagent', 'react'] = "deepagent",
 ) -> CompiledStateGraph:
     if graph_id in ["react", "create_react_agent", "create_agent"] and not subagents:
         return create_agent(
             model=model,
             tools=tools,
-            prompt=prompt,
+            system_prompt=prompt,
             checkpointer=checkpointer,
             context_schema=context_schema,
             store=store,
@@ -189,7 +187,7 @@ def __init__(
         # context_schema: Type[Any] | None = None,
         checkpointer: BaseCheckpointSaver = None,
         store: BaseStore = None,
-        graph_id: Literal["react", "deepagent"] = "react",
+        graph_id: Literal["react", "deepagent"] = "deepagent",
     ):
         self.tools = tools
         self.model = model

backend/src/repos/project_repo.py

@@ -0,0 +1,39 @@
+from typing import Any
+from langgraph.store.base import BaseStore, SearchItem
+from src.services.db import get_in_memory_store
+
+class ProjectRepo:
+    def __init__(self, 
+        user_id: str, 
+        store: BaseStore = get_in_memory_store()
+    ):
+        self.user_id = user_id
+        self.store: BaseStore = store
+
+    def _get_namespace(self):
+        return (self.user_id, "projects")
+
+    async def set(self, key: str, value: Any, ttl: int | None = None) -> bool:
+        await self.store.aput(
+            namespace=self._get_namespace(), key=key, value=value, ttl=ttl
+        )
+        return True
+
+    async def get(self, key: str) -> Any:
+        return await self.store.aget(self._get_namespace(), key)
+
+    async def delete(self, key: str) -> bool:
+        await self.store.adelete(self._get_namespace(), key)
+        return True
+
+    async def search(
+        self, 
+        query: str = None, 
+        limit: int = 20,
+    ) -> list[SearchItem]:
+        return await self.store.asearch(
+            self._get_namespace(), query=query, limit=limit
+        )
+
+
+project_repo = ProjectRepo()

backend/src/routes/v0/__init__.py

@@ -14,6 +14,7 @@
 from .assistant import router as assistant
 from .schedule import router as schedule
 from .prompt import router as prompt
+from .project import router as project
 
 
 def create_api_router(app: FastAPI, prefix: str = "/api"):
@@ -22,8 +23,9 @@ def create_api_router(app: FastAPI, prefix: str = "/api"):
     app.include_router(llm, prefix=prefix)
     app.include_router(thread, prefix=prefix)
     app.include_router(tool, prefix=prefix)
-    app.include_router(prompt, prefix=prefix)
     app.include_router(assistant, prefix=prefix)
+    app.include_router(prompt, prefix=prefix)
+    app.include_router(project, prefix=prefix)
     app.include_router(schedule, prefix=prefix)
     if LANGCONNECT_SERVER_URL:
         from .rag import gateway as rag

backend/src/routes/v0/llm.py

@@ -224,7 +224,7 @@ async def list_models():
     return JSONResponse(
         status_code=status.HTTP_200_OK,
         content={
-            "default": ChatModels.XAI_GROK_4_FAST.value,
+            "default": ChatModels.ANTHROPIC_CLAUDE_4_5_HAIKU.value,
             "free": get_free_models(),
             "models": get_all_models(),
         }

backend/src/routes/v0/project/__init__.py

@@ -0,0 +1,38 @@
+import uuid
+from fastapi import APIRouter, Body, Depends
+
+from langgraph.store.postgres import AsyncPostgresStore
+
+from src.contexts.service import ServiceContext
+# from src.constants.examples import Examples
+from src.schemas.models import ProtectedUser
+from src.services.db import get_store
+from src.utils.auth import verify_credentials
+from src.services.project import (
+    Project,
+    ProjectSearch,
+)
+
+
+################################################################################
+### Create Assistant
+################################################################################
+router = APIRouter(tags=["Project"], prefix="/projects")
+
+
+@router.post("/search", name="Query Projects")
+async def search_projects(
+    project_search: ProjectSearch = Body(...),
+    user: ProtectedUser = Depends(verify_credentials),
+    store: AsyncPostgresStore = Depends(get_store),
+):
+    service_context = ServiceContext(user_id=user.id, store=store)
+    # If id is provided, return the project
+    if "id" in project_search.filter:
+        project = await service_context.project_service.get(
+            project_search.filter["id"]
+        )
+        return {"projects": [project.model_dump()]}
+    # If id is not provided, return all projects
+    projects: list[Project] = await service_context.project_service.search(project_search)
+    return {"projects": [project.model_dump() for project in projects]}