import sys, time, datetime, six
from twisted.python import log
from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks
from twisted.internet.endpoints import serverFromString

from autobahn.wamp import router
from autobahn.twisted.util import sleep
from autobahn.twisted import wamp, websocket


class MyBackendComponent(wamp.ApplicationSession):
   """"""

   @inlineCallbacks
   def onJoin(self, details):

      ## publish events to a topic
      ##
      counter = 0
      while True:
         self.publish(u'com.myapp.topic1', counter)
         print("Published event.")
         counter += 1
         yield sleep(2)


if __name__=="__main__":
   log.startLogging(sys.stdout)
   router_factory = router.RouterFactory()
   session_factory = wamp.RouterSessionFactory(router_factory)
   session_factory.add(MyBackendComponent())
   transport_factory = websocket.WampWebSocketServerFactory(session_factory, \
                                                            debug = True, \
                                                            debug_wamp = True)

   server = serverFromString(reactor, "tcp:8080")
   server.listen(transport_factory)

   reactor.run()