wire_rpc

Typed asyncio JSON-RPC 2.0 for Python, with pluggable transports, codecs and authentication.

• Typed handlers. Write plain async functions with type hints; params are validated before your code runs and results are checked on the way out.
• Seven transports, one API. TCP, WebSocket, HTTP, stdio and in-process threads, with one-client and many-client servers. Swap transports without touching handlers.
• Three codecs. JSON (msgspec), Pydantic, and MessagePack.
• Full JSON-RPC 2.0. Calls, notifications and batches, plus server push (broadcast) on TCP and WebSocket.
• Authentication built in. Bearer tokens, JWTs, API keys, cookie login, TCP token and HMAC handshakes, and mutual TLS, with sessions in memory, SQLite, Redis or PostgreSQL.
• Safe by default. Every message, queue and wait is bounded; errors never leak exception text; credentials are re-checked before every call and never sent without TLS.
• Observable. An access log, a metrics hook and counters.

Python 3.12+. Documentation · Changelog · PyPI

Install

pip install wire-rpc
# extras: password, jwt, redis, postgres
pip install "wire-rpc[jwt,redis]"

Quick start

A server:

import msgspec

from wire_rpc import App
from wire_rpc.transports.tcp import TcpServerTransport


class AddParams(msgspec.Struct):
    a: int
    b: int


app = App(TcpServerTransport(host="127.0.0.1", port=9000))


@app.method("add")
async def add(params: AddParams, ctx) -> int:
    return params.a + params.b


if __name__ == "__main__":
    app.run()

A client:

import asyncio

from wire_rpc import Client
from wire_rpc.transports.tcp import TcpClientTransport


async def main():
    async with Client(TcpClientTransport(host="127.0.0.1", port=9000)) as client:
        print(await client.call("add", int, {"a": 2, "b": 3}))   # 5


asyncio.run(main())

Batches and notifications:

from wire_rpc.client import BatchCall, BatchNotification

results = await client.batch([
    BatchCall("add", int, {"a": 1, "b": 2}),
    BatchNotification("audit.log", {"event": "added"}),
])

Transports

Documentation

• Getting started
• Handlers · Routers and middleware · Apps and lifecycle · Errors
• The client
• Transports · Codecs
• Authentication · Security model
• Limits · Observability · Deployment · Benchmarks
• Protocol support · Configuration reference · Testing your service

Versioning and security

wire_rpc follows semantic versioning; while it's 0.x, minor releases may break compatibility, and every breaking change is listed in the changelog with what to do. Report vulnerabilities privately as described in SECURITY.md.

Contributing

Development setup, the test suite, design notes and the release process are in dev_notes/.

License

MIT