Sans-IO implementation of the WAMP protocol in Python
This is a library that could be used to build a WAMP client or server. It operates on strings and bytes. A WAMP client can be split into two parts.
- Session establishment
- Session management.
Assuming we have a websocket connection established to a WAMP server using sub protocol wamp.2.json. The first
"message" is going to be sent by the client as HELLO
from wampproto.joiner import Joiner
j = Joiner("realm1")
# this doesn't actually send the message, it just returns the
# payload that needs to be sent over websocket.
hello = j.send_hello()
ws.send_str(hello)
response = ws.receive_str()
to_send = j.receive(response)
if to_send is None:
# if there is nothing to send, this means
# the server returned WELCOME.
print(j.get_session_details())Now that the session is established, we could instantiate a WAMPSession instance
to handle further messages.
from wampproto.session import WAMPSession
from wampproto.messages import Call
from wampproto.idgen import SessionScopeIDGenerator
session = WAMPSession()
idgen = SessionScopeIDGenerator()
call = Call(idgen.next(), "foo.bar")
to_send = session.send_message(call)
ws.send_str(to_send)
incoming_payload = ws.receive_str()
result = session.receive(incoming_payload)
print(result)