Skip to main content

A JSON-RPC websocket client library for asyncio

Project description

https://travis-ci.org/armills/jsonrpc-websocket.svg https://coveralls.io/repos/armills/jsonrpc-websocket/badge.svg

This is a compact and simple JSON-RPC websocket client implementation for asyncio python code. This code is forked from https://github.com/gciotta/jsonrpc-requests

Main Features

  • Python 3.5, 3.6, 3.7 & 3.8 compatible
  • Supports nested namespaces (eg. app.users.getUsers())
  • 100% test coverage

Usage

It is recommended to manage the aiohttp ClientSession object externally and pass it to the Server constructor. (See the aiohttp documentation.) If not passed to Server, a ClientSession object will be created automatically.

Execute remote JSON-RPC functions

import asyncio
from jsonrpc_websocket import Server

async def routine():
    server = Server('ws://localhost:9090')
    try:
        await server.ws_connect()

        await server.foo(1, 2)
        await server.foo(bar=1, baz=2)
        await server.foo({'foo': 'bar'})
        await server.foo.bar(baz=1, qux=2)
    finally:
        await server.close()
        await server.session.close()

asyncio.get_event_loop().run_until_complete(routine())

A notification

import asyncio
from jsonrpc_websocket import Server

async def routine():
    server = Server('ws://localhost:9090')
    try:
        await server.ws_connect()

        await server.foo(bar=1, _notification=True)
    finally:
        await server.close()
        await server.session.close()

asyncio.get_event_loop().run_until_complete(routine())

Handle requests from server to client

import asyncio
from jsonrpc_websocket import Server

def client_method(arg1, arg2):
    return arg1 + arg2

async def routine():
    server = Server('ws://localhost:9090')
    # client_method is called when server requests method 'namespace.client_method'
    server.namespace.client_method = client_method
    try:
        await server.ws_connect()
    finally:
        await server.close()
        await server.session.close()

asyncio.get_event_loop().run_until_complete(routine())

Pass through arguments to aiohttp (see also aiohttp documentation)

import asyncio
import aiohttp
from jsonrpc_websocket import Server

async def routine():
    server = Server(
        'ws://localhost:9090',
        auth=aiohttp.BasicAuth('user', 'pass'),
        headers={'x-test2': 'true'})
    try:
        await server.ws_connect()

        await server.foo()
    finally:
        await server.close()
        await server.session.close()

asyncio.get_event_loop().run_until_complete(routine())

Pass through aiohttp exceptions

import asyncio
import aiohttp
from jsonrpc_websocket import Server

async def routine():
    server = Server('ws://unknown-host')
    try:
        await server.ws_connect()

        await server.foo()
    except TransportError as transport_error:
        print(transport_error.args[1]) # this will hold a aiohttp exception instance
    finally:
        await server.close()
        await server.session.close()

asyncio.get_event_loop().run_until_complete(routine())

Tests

Install the Python tox package and run tox, it’ll test this package with various versions of Python.

Changelog

1.1.0 (February 17, 2020)

  • Support servers that send JSON-RPC requests as binary messages encoded with UTF-8 (#5) @shiaky

1.0.2 (November 12, 2019)

  • Bumped jsonrpc-base to version 1.0.3

1.0.1 (August 23, 2018)

  • Bumped jsonrpc-base to version 1.0.2

1.0.0 (July 6, 2018)

  • Bumped jsonrpc-base to version 1.0.1

0.6 (March 11, 2018)

  • Minimum required version of aiohttp is now 3.0.
  • Support for Python 3.4 is now dropped.

Credits

@gciotta for creating the base project jsonrpc-requests.

@mbroadst for providing full support for nested method calls, JSON-RPC RFC compliance and other improvements.

@vaab for providing api and tests improvements, better RFC compliance.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for jsonrpc-websocket, version 1.1.0
Filename, size File type Python version Upload date Hashes
Filename, size jsonrpc-websocket-1.1.0.tar.gz (9.1 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page