import asyncio
import os
from kilovolt import KilovoltClient


async def connect():
    kv = KilovoltClient("ws://localhost:4337/ws", os.getenv("KILOVOLT_PASSWORD"))
    await kv.connect()

    # Subscribe to key
    await kv.subscribe("twitch/ev/message", lambda key, val: print(val))
    
    # List all keys that begin with "twitch"
    print(await kv.list("twitch"))

asyncio.run(connect())