import asyncio
from videodb.capture import CaptureClient

async def main():
    client_token = "<CLIENT_TOKEN_FROM_BACKEND>"
    capture_session_id = "<CAPTURE_SESSION_ID_FROM_BACKEND>"
    client = CaptureClient(client_token=client_token)

    await client.start_capture_session(
        capture_session_id=capture_session_id,
        channels=selected,
        primary_video_channel_id=display.name if display else None,
    )

    async for ev in client.events():
    event_type = ev["event"]
    payload = ev["data"]

    print(f"{event_type}: {payload}")

    if event_type in ("recording-complete", "error"):
        break

    await client.stop_capture()
    await client.shutdown()

asyncio.run(main())