from app.database import SessionLocal
from app.models.chat_message import ChatMessage

db = SessionLocal()
stream_id = 'c1d0097e-8a8f-4242-a3d0-0f8851ec73d2'
messages = db.query(ChatMessage).filter(ChatMessage.stream_id == stream_id).all()
print(f'Chat messages for test stream: {len(messages)}')
if messages:
    print(f'First message: {messages[0].username}: {messages[0].message}')
db.close()