kicksdk (Python)

Kick (kick.com) without the I/O: requests, response parsers, the realtime chat protocol and webhook verification, from the kicksdk Rust core.

pip install kicksdk-py          # the core
pip install "kicksdk-py[aio]"   # plus connect_chat over asyncio (httpx, websockets)

The import is kicksdk. (On PyPI the name is kicksdk-py: PyPI treats kicksdk as too close to the unrelated kick-sdk.)

import asyncio, kicksdk.aio

async def main():
    async with kicksdk.aio.connect_chat(chatroom_id, channel_id) as chat:
        async for e in chat:
            ev = e["event"]
            if ev["type"] == "chat_message":
                print(ev["sender"]["username"], ev["content"])

asyncio.run(main())

connect_chat reconnects by itself until the async with block ends, which closes the socket normally. After network errors, 5xx answers and dropped sockets it waits a jittered backoff (1 s doubling to 30 s); when Kick refuses the client (a ban, a refused token, a terminal close code), or after max_refusals (5) refused attempts in a row (a 403, say), it waits 5 minutes or more (10, 20, then 30 for more in a row) and comes back as a new client. Only an unexpected error (a bug) ends it early, raised by the async for. chat.last_drop says why the last connection ended and how long the wait is, chat.retrying whether it is waiting now, and the kicksdk.aio logger reports each drop. A failed token refresh keeps the connection. Events the consumer has not read wait in a buffer of max_queue (10,000); when it is full, overflow="drop_oldest" (the default) drops the oldest and counts them in chat.dropped, and overflow="backpressure" stops reading the socket until there is room. The kicksdk.aio module docs have the details.

Everything else returns kicksdk.Request objects for any HTTP client and parses what comes back (kicksdk.website.channel_request / parse_channel, kicksdk.public_api.livestreams_requests, kicksdk.webhooks.verify, …). Errors are kicksdk.KickError with kind and status.

kicksdk.webhooks.verify(public_key_pem, headers, body) takes the body as received (bytes, or str) and refuses a delivery more than 5 minutes from now (now= in Unix seconds, tolerance_secs=), so an old one cannot be replayed; skip_freshness=True re-checks a stored one.

Wheels are built for Linux, macOS and Windows (CPython 3.9+, one abi3 wheel per platform). Anywhere else pip builds from the source distribution, which needs a Rust toolchain.

Kick's realtime server only accepts Origin: https://kick.com; connect_chat sends it. MIT OR Apache-2.0. Not affiliated with Kick.