File: frontend.py

package info (click to toggle)
python-autobahn 17.10.1%2Bdfsg1-7
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 4,452 kB
  • sloc: python: 22,598; javascript: 2,705; makefile: 497; sh: 3
file content (56 lines) | stat: -rw-r--r-- 1,551 bytes parent folder | download | duplicates (2)
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


from autobahn.asyncio.component import Component, run
from autobahn.wamp.types import RegisterOptions
from autobahn.wamp.exception import ApplicationError
import asyncio


@asyncio.coroutine
def main(reactor, session):
    print("Client session={}".format(session))

    try:
        res = yield from session.register(lambda: None, u"com.foo.private")
        print("\n\nregistering 'com.foo.private' should have failed\n\n")
    except ApplicationError as e:
        print("registering 'com.foo.private' failed as expected: {}".format(e.error))

    res = yield from session.register(
        lambda: None, u"should.work",
        options=RegisterOptions(match=u'exact'),
    )
    print("registered 'should.work' with id {}".format(res.id))

    try:
        res = yield from session.register(
            lambda: None, u"prefix.fail.",
            options=RegisterOptions(match=u'prefix'),
        )
        print("\n\nshould have failed\n\n")
    except ApplicationError as e:
        print("prefix-match 'prefix.fail.' failed as expected: {}".format(e.error))

    print("calling 'example.foo'")
    res = yield from session.call(u"example.foo")
    print("example.foo() = {}".format(res))

    print("done")


component = Component(
    transports=u"ws://localhost:8080/auth_ws",
    main=main,
    realm=u"crossbardemo",
    authentication={
        u"wampcra": {
            u"authid": u"bob",
            u"authrole": "dynamic_authed",
            u"secret": u"p4ssw0rd",
        }
    }
)


if __name__ == "__main__":
    run([component])