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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
from __future__ import print_function
import os
import txaio
from twisted.internet.defer import inlineCallbacks
from twisted.internet.endpoints import TCP4ClientEndpoint
from twisted.internet.endpoints import SSL4ClientEndpoint
from twisted.internet.endpoints import UNIXClientEndpoint
from twisted.internet.ssl import optionsForClientTLS, trustRootFromCertificates, Certificate, CertificateOptions
from twisted.internet import reactor
from autobahn.twisted.component import Component, run
from autobahn.twisted.util import sleep
from autobahn.twisted.wamp import Session
# This uses the new-api with various Twisted native objects. For the
# Unix socket things, you'll have to add a transport to "config.json"
# like this:
# {
# "type": "websocket",
# "endpoint": {
# "type": "unix",
# "path": "unix-websocket"
# }
# }
# ...then, the socket will appear in the .crossbar directory as
# "unix-websocket". Everything in here presumes you're using the
# "example/router/.crossbar" with config.json linked to either
# "config-no-tls.json" or "config-tls.json"
class Foo(Session):
def __init__(self, *args, **kw):
1 / 0
@inlineCallbacks
def setup(reactor, session):
print('bob created', session)
def on_join(session, details):
print('bob joined', session, details)
session.on('join', on_join)
yield sleep(5)
print("bob done sleeping")
# session.leave()
if __name__ == '__main__':
cert_fname = os.path.join(
os.path.split(__file__)[0],
'..', '..', '..', '..', 'router', '.crossbar', 'ca.cert.pem',
)
inter_cert_fname = os.path.join(
os.path.split(__file__)[0],
'..', '..', '..', '..', 'router', '.crossbar', 'intermediate.cert.pem',
)
tls_transport = {
"type": "websocket",
"url": "wss://127.0.0.1:8083/ws",
"endpoint": SSL4ClientEndpoint(
reactor, '127.0.0.1', 8083,
optionsForClientTLS(
u'localhost',
# XXX why do I need BOTH the intermediate and actual
# cert? Did I create the CA/intermediate certificates
# incorrectly?
trustRoot=trustRootFromCertificates(
[
Certificate.loadPEM(open(cert_fname).read()),
Certificate.loadPEM(open(inter_cert_fname).read()),
]
),
),
)
}
unix_transport = {
"type": "websocket",
"url": "ws://localhost/ws",
"endpoint": UNIXClientEndpoint(
reactor,
os.path.join(
os.path.split(__file__)[0],
'..', '..', '..', '..', 'router', '.crossbar', 'intermediate.cert.pem',
)
)
}
# this one should produce handshake errors etc, good for testing error-cases:
tls_transport_untrusted = {
"type": "websocket",
"url": "wss://127.0.0.1:8083/ws",
"endpoint": SSL4ClientEndpoint(
reactor,
'127.0.0.1',
8080,
optionsForClientTLS(u'localhost'),
),
}
clearnet_transport = {
"type": "websocket",
"url": "ws://127.0.0.1:8080/ws",
"endpoint": TCP4ClientEndpoint(reactor, 'localhost', 8080)
}
transports = [
tls_transport_untrusted,
tls_transport,
clearnet_transport,
]
# try main= vs. setup= to see different exit behavior
component = Component(main=setup, transports=transports, realm=u'crossbardemo')
#component = Component(setup=setup, transports=transports, realm=u'crossbardemo')
# can add this confirm logging of more error-cases
#component.session_factory = Foo
txaio.start_logging(level='info')
run(component)
|
