kasper-socket 0.1.0

Rooms, broadcast, and presence for WebSocket apps behind a small async API.

kasper-socket

Rooms, broadcast, and presence for WebSocket apps - behind a small async API. Framework-agnostic: works with FastAPI / Starlette / the websockets library. Any object with an async send(str) is a valid socket.

pip install kasper-socket

from kasper_socket import SocketHub

hub = SocketHub()

conn = await hub.connect(ws, user_id="u1", rooms=["case-42"])
await hub.broadcast("case-42", {"type": "edit", "field": "status"})
await hub.presence("case-42")     # -> ["u1", "u2"]
await hub.disconnect(conn)

@hub.on("edit")
async def handle(conn, msg):
    ...
await hub.dispatch(conn, {"type": "edit", "field": "status"})

Notes

• Single node broadcast is an in-process room lookup.
• Presence is tracked per room and emitted as a sorted member list.
• A Redis pub/sub backend (for multi-node broadcast across server instances) is the planned [redis] extra.

MIT licensed.