import asyncio
from sqlalchemy import select
from app.core.database import AsyncSessionLocal
from app.core.onboarding import run_onboarding
from app.models.models import Customer

async def main():
    async with AsyncSessionLocal() as db:
        customer = (await db.execute(select(Customer).where(Customer.id == 3))).scalar_one_or_none()
        if customer is None:
            raise SystemExit("customer_id=3 tidak ditemukan")
        result = await run_onboarding(customer, db)
        print({"customer_id": customer.id, "mikrotik": result.mikrotik, "olt": result.olt, "message": result.message})

asyncio.run(main())