Logs
diff --git a/bot/utils/cat_client.py b/bot/utils/cat_client.py
index 2c05433..3a75e0f 100644
--- a/bot/utils/cat_client.py
+++ b/bot/utils/cat_client.py
@@ -21,7 +21,7 @@ from typing import Optional, Dict, Any, List
import globals
from utils.logger import get_logger
-logger = get_logger('cat_client')
+logger = get_logger('llm') # Use existing 'llm' logger component
class CatAdapter:
@@ -254,24 +254,36 @@ class CatAdapter:
async def get_memory_stats(self) -> Optional[Dict[str, Any]]:
"""
- Get memory collection statistics from Cat.
+ Get memory collection statistics with actual counts from Qdrant.
Returns dict with collection names and point counts.
"""
try:
- async with aiohttp.ClientSession() as session:
- async with session.get(
- f"{self._base_url}/memory/collections",
- headers=self._get_headers(),
- timeout=aiohttp.ClientTimeout(total=15)
- ) as response:
- if response.status == 200:
- data = await response.json()
- return data
- else:
- logger.error(f"Failed to get memory stats: {response.status}")
- return None
+ # Query Qdrant directly for accurate counts
+ qdrant_host = self._base_url.replace("http://cheshire-cat:80", "http://cheshire-cat-vector-memory:6333")
+
+ collections_data = []
+ for collection_name in ["episodic", "declarative", "procedural"]:
+ async with aiohttp.ClientSession() as session:
+ async with session.get(
+ f"{qdrant_host}/collections/{collection_name}",
+ timeout=aiohttp.ClientTimeout(total=10)
+ ) as response:
+ if response.status == 200:
+ data = await response.json()
+ count = data.get("result", {}).get("points_count", 0)
+ collections_data.append({
+ "name": collection_name,
+ "vectors_count": count
+ })
+ else:
+ collections_data.append({
+ "name": collection_name,
+ "vectors_count": 0
+ })
+
+ return {"collections": collections_data}
except Exception as e:
- logger.error(f"Error getting memory stats: {e}")
+ logger.error(f"Error getting memory stats from Qdrant: {e}")
return None
async def get_memory_points(
@@ -281,28 +293,33 @@ class CatAdapter:
offset: Optional[str] = None
) -> Optional[Dict[str, Any]]:
"""
- Get all points from a memory collection.
+ Get all points from a memory collection via Qdrant.
+ Cat doesn't expose /memory/collections/{id}/points, so we query Qdrant directly.
Returns paginated list of memory points.
"""
try:
- params = {"limit": limit}
+ # Use Qdrant directly (Cat's vector memory backend)
+ # Qdrant is accessible at the same host, port 6333 internally
+ qdrant_host = self._base_url.replace("http://cheshire-cat:80", "http://cheshire-cat-vector-memory:6333")
+
+ payload = {"limit": limit, "with_payload": True, "with_vector": False}
if offset:
- params["offset"] = offset
+ payload["offset"] = offset
async with aiohttp.ClientSession() as session:
- async with session.get(
- f"{self._base_url}/memory/collections/{collection}/points",
- headers=self._get_headers(),
- params=params,
+ async with session.post(
+ f"{qdrant_host}/collections/{collection}/points/scroll",
+ json=payload,
timeout=aiohttp.ClientTimeout(total=30)
) as response:
if response.status == 200:
- return await response.json()
+ data = await response.json()
+ return data.get("result", {})
else:
- logger.error(f"Failed to get {collection} points: {response.status}")
+ logger.error(f"Failed to get {collection} points from Qdrant: {response.status}")
return None
except Exception as e:
- logger.error(f"Error getting memory points: {e}")
+ logger.error(f"Error getting memory points from Qdrant: {e}")
return None
async def get_all_facts(self) -> List[Dict[str, Any]]:
@@ -344,22 +361,24 @@ class CatAdapter:
return all_facts
async def delete_memory_point(self, collection: str, point_id: str) -> bool:
- """Delete a single memory point by ID."""
+ """Delete a single memory point by ID via Qdrant."""
try:
+ qdrant_host = self._base_url.replace("http://cheshire-cat:80", "http://cheshire-cat-vector-memory:6333")
+
async with aiohttp.ClientSession() as session:
- async with session.delete(
- f"{self._base_url}/memory/collections/{collection}/points/{point_id}",
- headers=self._get_headers(),
+ async with session.post(
+ f"{qdrant_host}/collections/{collection}/points/delete",
+ json={"points": [point_id]},
timeout=aiohttp.ClientTimeout(total=15)
) as response:
if response.status == 200:
- logger.info(f"Deleted point {point_id} from {collection}")
+ logger.info(f"Deleted memory point {point_id} from {collection}")
return True
else:
logger.error(f"Failed to delete point: {response.status}")
return False
except Exception as e:
- logger.error(f"Error deleting point: {e}")
+ logger.error(f"Error deleting memory point: {e}")
return False
async def wipe_all_memories(self) -> bool:
diff --git a/cat-plugins/discord_bridge/discord_bridge.py b/cat-plugins/discord_bridge/discord_bridge.py
index f6b665b..ccd3e5e 100644
--- a/cat-plugins/discord_bridge/discord_bridge.py
+++ b/cat-plugins/discord_bridge/discord_bridge.py
@@ -52,6 +52,14 @@ def before_cat_reads_message(user_message_json: dict, cat) -> dict:
cat.working_memory['mood'] = mood
cat.working_memory['response_type'] = response_type
+ # If we have an author name, prepend it to the message text so the LLM can see it
+ # This ensures Miku knows who is talking to her
+ if author_name and 'text' in user_message_json:
+ original_text = user_message_json['text']
+ # Don't add name if it's already in the message
+ if not original_text.lower().startswith(author_name.lower()):
+ user_message_json['text'] = f"[{author_name} says:] {original_text}"
+
return user_message_json