Update db_helper.py

db_helper.py

@@ -62,7 +62,19 @@ class DB:
             .order("created_at", desc=True)\
             .execute()
         return result.data
-    
+    def get_user_messages(self, user_id: str, limit: int = 5) -> List[Dict]:
+        """Get recent chat messages for a user (used in /journey endpoint)"""
+        try:
+            result = self.client.table("chat_history")\
+                .select("*")\
+                .eq("user_id", user_id)\
+                .order("happened_at", desc=True)\
+                .limit(limit)\
+                .execute()
+            return result.data
+        except Exception as e:
+            print(f"Error fetching user messages: {str(e)}")
+            return []  # Graceful fallback so endpoint doesn't crash
     # ==================== JOURNEYS ====================
     
     def create_journey(self, user_id: str, category: str) -> dict: