from twisted.python import log
from twisted.internet import reactor, ssl
from autobahn.twisted import wamp
from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS
from autobahn.wamp import types
class WampSession(wamp.ApplicationSession):
def onJoin(self, details):
print 'WAMP session joined by :', self.config.extra["ID"]
def onLeave(self, details):
print 'WAMP session left'
def RegisterWampClient(wampconf):
WSClientConf = json.load(open(wampconf))
## TODO log to PLC console instead
## 0) start logging to console
log.startLogging(sys.stdout)
## 1) create a WAMP application session factory
component_config = types.ComponentConfig(
realm = WSClientConf["realm"],
extra = {"ID":WSClientConf["ID"]})
session_factory = wamp.ApplicationSessionFactory(
config = component_config)
session_factory.session = WampSession
## TODO select optimum serializer for passing session lists
## optional: use specific set of serializers
#from autobahn.wamp.serializer import *
##serializers.append(JsonSerializer(batched = True))
##serializers.append(MsgPackSerializer(batched = True))
#serializers.append(JsonSerializer())
##serializers.append(MsgPackSerializer())
## 2) create a WAMP-over-WebSocket transport client factory
transport_factory = WampWebSocketClientFactory(
url = WSClientConf["url"],
serializers = serializers,
## 3) start the client from a Twisted endpoint
conn = connectWS(transport_factory)
print "WAMP clien connecting to :",WSClientConf["url"]
