fix(deriver and dialectic) Use latest user level user_represenation

src/agent.py

@@ -108,6 +108,7 @@ async def get_latest_user_representation(
         .where(models.App.public_id == app_id)
         .where(models.User.public_id == user_id)
         .where(models.Metamessage.metamessage_type == "user_representation")
+        .order_by(models.Metamessage.id.desc())  # get the most recent
         .limit(1)
     )
     result = await db.execute(stmt)

src/deriver/__main__.py

@@ -1,10 +1,10 @@
 import asyncio
-import argparse
 
 import uvloop
 
 from .queue import main
 
 if __name__ == "__main__":
     asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
-    asyncio.run(main())
+    asyncio.run(main())
+

src/deriver/consumer.py

@@ -151,14 +151,26 @@ async def process_user_message(
                 f"Tom Inference: {tom_inference_metamessage.content}", style="orange1"
             )
 
-            # Fetch the existing user representation
+            # Fetch the latest user representation
             user_representation_stmt = (
                 select(models.Metamessage)
-                .where(models.Metamessage.message_id == ai_message.public_id)
+                .join(
+                    models.Message,
+                    models.Message.public_id == models.Metamessage.message_id,
+                )
+                .join(
+                    models.Session,
+                    models.Message.session_id == models.Session.public_id,
+                )
+                .join(models.User, models.User.public_id == models.Session.user_id)
+                .join(models.App, models.App.public_id == models.User.app_id)
+                .where(models.App.public_id == app_id)
+                .where(models.User.public_id == user_id)
                 .where(models.Metamessage.metamessage_type == "user_representation")
-                .order_by(models.Metamessage.id.desc())
+                .order_by(models.Metamessage.id.desc())  # get the most recent
                 .limit(1)
             )
+
             response = await db.execute(user_representation_stmt)
             existing_representation = response.scalar_one_or_none()
 

src/models.py

@@ -12,7 +12,7 @@
     String,
     UniqueConstraint,
 )
-from sqlalchemy.dialects.postgresql import JSONB
+from sqlalchemy.dialects.postgresql import JSONB, TEXT
 from sqlalchemy.orm import Mapped, mapped_column, relationship
 from sqlalchemy.sql import func