import asyncio
import asyncpg

async def apply_migrations():
    # Connect to correct database
    conn = await asyncpg.connect(
        host='localhost',
        port=5433,
        database='archie_brain_dev',  # Correct database name
        user='archie_dev',
        password='archie_dev_password'
    )
    
    try:
        print("✅ Connected to archie_brain_dev database")
        
        # Apply migration 010
        print("\n📋 Applying 010_conversation_participants.sql...")
        with open('/mnt/data-disk1/archie-main-integration/infrastructure/database/manual-migrations/010_conversation_participants.sql') as f:
            await conn.execute(f.read())
        print("✅ Migration 010 applied")
        
        # Apply migration 011
        print("\n📋 Applying 011_conversations_enhancement.sql...")
        with open('/mnt/data-disk1/archie-main-integration/infrastructure/database/manual-migrations/011_conversations_enhancement.sql') as f:
            await conn.execute(f.read())
        print("✅ Migration 011 applied")
        
        print("\n✅ ALL MIGRATIONS COMPLETE!")
        
    finally:
        await conn.close()

asyncio.run(apply_migrations())