#!/usr/bin/env python3
"""查看已记录的 Episode."""
from src.config_manager import ConfigManager
from src.graphiti_client import GraphitiClient
import json
cm = ConfigManager()
client = GraphitiClient(cm)
if client.connect():
result = client.query_knowledge_graph(
'MATCH (e:Episode) RETURN e.content as content, e.metadata as metadata, e.created_at as created_at ORDER BY e.created_at DESC LIMIT 10'
)
if result['success']:
print(f"📝 已记录的 Episode（共 {len(result['results'])} 条）：\n")
for i, record in enumerate(result['results'], 1):
content = record.get('content', '')
metadata = record.get('metadata', '{}')
created_at = record.get('created_at', '')
print(f"{i}. {content}")
if metadata and metadata != '{}':
try:
meta = json.loads(metadata) if isinstance(metadata, str) else metadata
if meta:
print(f" 元数据: {meta}")
except:
pass
print()
else:
print(f"❌ 查询失败: {result['message']}")
client.disconnect()
else:
print("❌ 连接失败")
