Rename to deriver

api/fly.toml

@@ -14,7 +14,7 @@ kill_timeout = "5s"
 
 [processes]
   api = "python -m uvicorn src.main:app --host 0.0.0.0 --port 8000"
-  deriver = "python -m src.harvester"
+  deriver = "python -m src.deriver"
 
 [[services]]
   auto_stop_machines = false

api/src/harvester.py → api/src/deriver.py

@@ -104,7 +104,6 @@ async def process_user_message(
     collection_id: uuid.UUID,
     message_id: uuid.UUID,
 ):
-    # TODO get messages for the session
     async with SessionLocal() as db:
         messages_stmt = await crud.get_messages(
             db=db, app_id=app_id, user_id=user_id, session_id=session_id, reverse=True
@@ -113,7 +112,7 @@ async def process_user_message(
         response = await db.execute(messages_stmt)
         messages = response.scalars().all()
         messages = messages[::-1]
-        contents = [m.content for m in messages]
+        # contents = [m.content for m in messages]
         # print(contents)
 
     facts = await derive_facts(messages, content)

api/src/routers/sessions.py

@@ -1,14 +1,14 @@
 import json
-from typing import Optional
 import uuid
+from typing import Optional
+
 from fastapi import APIRouter, HTTPException, Request
 from fastapi_pagination import Page
 from fastapi_pagination.ext.sqlalchemy import paginate
 
 from src import agent, crud, schemas
 from src.dependencies import db
 
-
 router = APIRouter(
     prefix="/apps/{app_id}/users/{user_id}/sessions",
     tags=["sessions"],