1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
from autobahn.twisted.wamp import Connection
def on_join(session):
"""
This is user code triggered when a session was created on top of
a connection, and the sessin has joined a realm.
"""
print('session connected: {}'.format(session))
def on_leave(details):
print("on_leave", details)
session.on_leave(on_leave)
# explicitly leaving a realm will disconnect the connection
# cleanly and not try to reconnect, but exit cleanly.
session.leave()
def on_create(connection):
"""
This is the main entry into user code. It _gets_ a connection
instance, which it then can hook onto.
"""
def on_connect(session):
session.on_join(on_join)
session.join(u'public')
# we attach our listener code on the connection. whenever there
# is a session created which has joined, our callback code is run
connection.on_connect(on_connect)
def run(on_create):
"""
This could be a high level "runner" tool we ship.
"""
from twisted.internet import reactor
# multiple, configurable transports, either via dict-like config, or
# from native Twisted endpoints
transports = [
{
"type": "websocket",
"url": "ws://127.0.0.1:8080/ws"
}
]
# a connection connects and automatically reconnects WAMP client
# transports to a WAMP router. A connection has a listener system
# where user code can hook into different events : on_join
connection = Connection(on_create, realm=u'public',
transports=transports, reactor=reactor)
# the following returns a deferred that fires when the connection is
# finally done: either by explicit close by user code, or by error or
# when stop reconnecting
done = connection.connect()
def finish(res):
print(res)
reactor.stop()
done.addBoth(finish)
reactor.run()
if __name__ == '__main__':
# here, run() could be s.th. we ship, and a user would just
# provide a on_create() thing and run:
return run(on_create)
|
