import asyncio
from app.services.orchestrator import orchestrator

async def main():
    print("=== ORA Swarm Orchestrator Verification ===")
    
    test_cases = [
        "I need help studying Genesis 1.",         # Should trigger Theologian
        "I am feeling very sad and need prayer.",  # Should trigger Healer
        "Hey ORA, do you remember our talk about job stress?" # Should trigger memory recall
    ]
    
    for msg in test_cases:
        print(f"\n[USER]: {msg}")
        res = await orchestrator.process_message(user_id="seeker_77", message=msg)
        print(f"[ORA - {res.get('agent')}]: {res['content']}")

if __name__ == "__main__":
    asyncio.run(main())