WSRPC is the RPC over WebSocket for aiohttp
Project description
Easy to use minimal WebSocket Remote Procedure Call library for aiohttp servers.
See online demo and documentation with examples.
Features
Call server functions from the client side;
Call client functions from the server (for example to notify clients about events);
Async connection protocol: both server or client are able to call several functions and get responses as soon as each response would be ready in any order.
Fully async server-side functions;
Transfer any exceptions from a client side to the server side and vise versa;
Ready-to-use frontend-library without dependencies;
Thread-based websocket handler for writing fully-synchronous backend code (for synchronous database drivers etc.)
Protected server-side methods (cliens are not able to call methods, starting with underline directly);
Installation
Install via pip:
pip install wsrpc-aiohttp
You may want to install optional ujson library to speedup message serialization/deserialization:
pip install ujson
Python module provides client js library out of the box. But for pure javascript applications you can install standalone js client library using npm:
npm install @wsrpc/client
Usage
Backend code:
import logging
from time import time
import aiohttp.web
from wsrpc_aiohttp import Route, STATIC_DIR, WebSocketRoute, decorators
log = logging.getLogger(__name__)
# This class can be called by client.
# Connection object will have this class instance after calling route-alias.
class TestRoute(Route):
# This method will be executed when client calls route-alias
# for the first time.
def init(self, **kwargs):
# Python __init__ must be return "self".
# This method might return anything.
return kwargs
# This method named by camelCase because the client can call it.
@decorators.proxy
async def getEpoch(self):
# You can execute functions on the client side
await self.do_notify()
return time()
# This method calls function on the client side
@decorators.proxy
async def do_notify(self):
awesome = 'Somebody executed test1.getEpoch method!'
await self.socket.call('notify', result=awesome)
app = aiohttp.web.Application()
app.router.add_route("*", "/ws/", WebSocketAsync) # Websocket route
app.router.add_static('/js', STATIC_DIR) # WSRPC js library
app.router.add_static('/', ".") # Your static files
# Stateful request
# This is the route alias TestRoute as "test1"
WebSocketAsync.add_route('test1', TestRoute)
# Stateless request
WebSocketAsync.add_route('test2', lambda *a, **kw: True)
if __name__ == '__main__':
logging.basicConfig(level=logging.DEBUG)
aiohttp.web.run_app(app, port=8000)Frontend code:
<script type="text/javascript" src="/js/wsrpc.min.js"></script>
<script>
var url = (window.location.protocol==="https):"?"wss://":"ws://") + window.location.host + '/ws/';
RPC = new WSRPC(url, 8000);
// Configure client API, that can be called from server
RPC.addRoute('notify', function (data) {
console.log('Server called client route "notify":', data);
return data.result;
});
RPC.connect();
// Call stateful route
// After you call that route, server would execute 'notify' route on the
// client, that is registered above.
RPC.call('test1.getEpoch').then(function (data) {
console.log('Result for calling server route "test1.getEpoch": ', data);
}, function (error) {
alert(error);
});
// Call stateless method
RPC.call('test2').then(function (data) {
console.log('Result for calling server route "test2"', data);
});
</script>Versioning
This software follows Semantic Versioning
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file wsrpc-aiohttp-3.1.2.tar.gz.
File metadata
- Download URL: wsrpc-aiohttp-3.1.2.tar.gz
- Upload date:
- Size: 16.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.4.1 importlib_metadata/3.10.0 pkginfo/1.7.0 requests/2.25.1 requests-toolbelt/0.9.1 tqdm/4.59.0 CPython/3.9.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 891164dfe06a8d8d846b485d04b1e56b2c397ff1b46ef0348e6f62bd8efb1693 |
|
| MD5 | 7fa89f2bf2cd799b728eb55c0898e894 |
|
| BLAKE2b-256 | d2d5d66d1429921ca31c02ab580d4265d840c5c22dfedcd8cdd0d2030d69af4d |
File details
Details for the file wsrpc_aiohttp-3.1.2-py3-none-any.whl.
File metadata
- Download URL: wsrpc_aiohttp-3.1.2-py3-none-any.whl
- Upload date:
- Size: 60.3 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.4.1 importlib_metadata/3.10.0 pkginfo/1.7.0 requests/2.25.1 requests-toolbelt/0.9.1 tqdm/4.59.0 CPython/3.9.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 4ba64e02b12dcbc09d02544f35bceba49bd04cbc496db47aa8559ae4609ada8e |
|
| MD5 | f5f8b3a79d9f7df2806c99a0d47ead64 |
|
| BLAKE2b-256 | 502fb51d098440903872ca4cbad69dcbd8d2b33bfd6177a9ceaa2b8708d50183 |
