Deploy from GitHub Actions (2026-03-12 11:50 UTC)

.gitignore

@@ -200,6 +200,7 @@ PROJECT.md
 # Everything inside `archive` except `daily_log.md`
 archive/*
 !archive/daily_log.md
+!archive/development_notes/
 
 # Microservice credentials (sensitive)
 services/credentials/*.json

app/main.py

@@ -17,6 +17,7 @@ from app.models.conversation_manager import ConversationManager
 from app.models.database import init_database, get_database, User, Conversation, Message
 from app.models.smart_models import UserPreference, UserInsight, ConversationTopic
 from app.data.training_data import TRAINING_DATA
+from app.routers import knowledge_base
 
 # Load configuration (this sets up logging automatically)
 config = get_config()
@@ -54,6 +55,7 @@ async def lifespan(fastapi_app: FastAPI):  # pylint: disable=unused-argument
 
 
 app = FastAPI(title=config.api.title, debug=config.api.debug, lifespan=lifespan)
+app.include_router(knowledge_base.router)
 
 # Enable CORS
 app.add_middleware(
@@ -247,4 +249,6 @@ async def get_user_stats(session_id: str):
 # Must be mounted LAST so API routes above take precedence
 _frontend_dir = Path(__file__).parent.parent / "frontend"
 if _frontend_dir.exists():
-    app.mount("/", StaticFiles(directory=str(_frontend_dir), html=True), name="frontend")
+    app.mount(
+        "/", StaticFiles(directory=str(_frontend_dir), html=True), name="frontend"
+    )

app/models/database.py

@@ -185,3 +185,11 @@ def get_database() -> DatabaseManager:
 def init_database():
     """Initialize the global database manager instance and create tables"""
     return db_manager.init_database()
+
+
+def get_db():
+    db = get_database().get_session()
+    try:
+        yield db
+    finally:
+        db.close()

app/models/smart_models.py

@@ -107,3 +107,20 @@ class UserInsight(Base):
 
     def __repr__(self):
         return f"<UserInsight(id={self.id} user_id={self.user_id}, {self.insight_key}={self.insight_value})>"
+
+
+class KnowledgeBase(Base):
+    __tablename__ = "knowledge_base"
+
+    id = Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
+    created_at = Column(DateTime, default=lambda: datetime.now(timezone.utc))
+    updated_at = Column(
+        DateTime,
+        default=lambda: datetime.now(timezone.utc),
+        onupdate=lambda: datetime.now(timezone.utc),
+    )
+    tenant_id = Column(UUID(as_uuid=True), nullable=False)
+    entry = Column(Text, nullable=False)
+
+    def __repr__(self):
+        return f"<KnowledgeBase(id={self.id} tenant_id={self.tenant_id})>"

app/routers/knowledge_base.py

@@ -0,0 +1,75 @@
+import uuid
+
+from fastapi import APIRouter, Depends, HTTPException
+from sqlalchemy import select
+from sqlalchemy.orm import Session
+
+from app.models.smart_models import KnowledgeBase
+from app.schemas.knowledge_base import KBEntryCreate, KBEntryResponse, KBEntryUpdate
+from app.models.database import get_db
+
+router = APIRouter()
+
+
+@router.post("/kb/entries", status_code=201, response_model=KBEntryResponse)
+def create_entry(
+    entry: KBEntryCreate, db: Session = Depends(get_db)
+) -> KBEntryResponse:
+
+    knowledge_base = KnowledgeBase()
+    knowledge_base.tenant_id = uuid.uuid4()
+    knowledge_base.entry = entry.entry
+    db.add(knowledge_base)
+    db.commit()
+    db.refresh(knowledge_base)
+
+    return knowledge_base
+
+
+@router.get("/kb/entries/{entry_id}", status_code=200, response_model=KBEntryResponse)
+def read_entry(entry_id: uuid.UUID, db: Session = Depends(get_db)) -> KBEntryResponse:
+
+    kb = db.get(KnowledgeBase, entry_id)
+
+    if kb is None:
+        raise HTTPException(status_code=404, detail="Entry not found")
+
+    return kb
+
+
+@router.get("/kb/entries", status_code=200, response_model=list[KBEntryResponse])
+def read_entries(db: Session = Depends(get_db)) -> list[KBEntryResponse]:
+
+    kb_entries = db.scalars(select(KnowledgeBase)).all()
+
+    return kb_entries
+
+
+@router.put("/kb/entries/{entry_id}", status_code=200, response_model=KBEntryResponse)
+def update_entry(
+    entry_id: uuid.UUID, entry: KBEntryUpdate, db: Session = Depends(get_db)
+) -> KBEntryResponse:
+
+    kb = db.get(KnowledgeBase, entry_id)
+
+    if kb is None:
+        raise HTTPException(status_code=404, detail="Entry not found")
+    kb.entry = entry.entry
+    db.commit()
+    db.refresh(kb)
+
+    return kb
+
+
+@router.delete("/kb/entries/{entry_id}", status_code=204)
+def delete_entry(entry_id: uuid.UUID, db: Session = Depends(get_db)) -> None:
+
+    kb = db.get(KnowledgeBase, entry_id)
+
+    if kb is None:
+        raise HTTPException(status_code=404, detail="Entry not found")
+
+    db.delete(kb)
+    db.commit()
+
+    return

app/schemas/knowledge_base.py

@@ -0,0 +1,19 @@
+from datetime import datetime
+import uuid
+from pydantic import BaseModel
+
+
+class KBEntryCreate(BaseModel):
+    entry: str
+
+
+class KBEntryResponse(BaseModel):
+    id: uuid.UUID
+    created_at: datetime
+    updated_at: datetime
+    tenant_id: uuid.UUID
+    entry: str
+
+
+class KBEntryUpdate(BaseModel):
+    entry: str