notification.py

# coding: utf-8

from __future__ import unicode_literals

from twisted.internet.defer import inlineCallbacks

from autobahn.twisted.wamp import ApplicationSession
from autobahn.twisted.wamp import ApplicationRunner
from queue import NotificationRunner
from config.settings import REALM_NAME, WEB_SOCKET_HOST, WEB_SOCKET_PORT


class ListenForEvent(ApplicationSession):

    def __init__(self, config):
        ApplicationSession.__init__(self)
        self.config = config
        self.runner = NotificationRunner(self)

    def onConnect(self):
        self.join(self.config.realm)

    @inlineCallbacks
    def onJoin(self, details):
        # callback = lambda x: log.msg("Received event %s" % x)
        # yield self.subscribe(callback, 'un_evenement')
        print("Client session joined: {}".format(details))
        yield self.runner.connect()

    def onLeave(self, details):
        print('Client session left: {}'.format(details))
        self.disconnect()

    def onDisconnect(self):
        print('Client session disconnected.')


# Start reactor here
if __name__ == '__main__':
    runner = ApplicationRunner("ws://%s:%d/ws" % (WEB_SOCKET_HOST, WEB_SOCKET_PORT), REALM_NAME)
    runner.run(ListenForEvent)