# This file is part of Beremiz runtime.
# Copyright (C) 2007: Edouard TISSERANT and Laurent BESSARD
# See COPYING.Runtime file for copyrights details.
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Lesser General Public License for more details.
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
from __future__ import absolute_import
from __future__ import print_function
from autobahn.twisted import wamp
from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS
from autobahn.wamp import types, auth
from autobahn.wamp.serializer import MsgPackSerializer
from twisted.internet.defer import inlineCallbacks
from twisted.internet.protocol import ReconnectingClientFactory
ExposedProgressCalls = []
# Those two lists are meant to be filled by customized runtime
""" crossbar Events to register to """
""" things to do on join (callables) """
""" Get Callee or Subscriber corresponding to '.' spearated object path """
obj = getattr(obj, names.pop(0))
def getValidOptins(options, arguments):
validOptions[key] = options[key]
if len(validOptions) > 0:
class WampSession(wamp.ApplicationSession):
if "secret" in self.config.extra:
user = self.config.extra["ID"]
self.join(u"Automation", [u"wampcra"], user)
def onChallenge(self, challenge):
if challenge.method == u"wampcra":
secret = self.config.extra["secret"].encode('utf8')
signature = auth.compute_wcs(secret, challenge.extra['challenge'].encode('utf8'))
return signature.decode("ascii")
raise Exception("don't know how to handle authmethod {}".format(challenge.method))
def onJoin(self, details):
ID = self.config.extra["ID"]
validRegisterOptions = {}
registerOptions = self.config.extra.get('registerOptions', None)
arguments = inspect.getargspec(types.RegisterOptions.__init__).args
validRegisterOptions = getValidOptins(registerOptions, arguments)
registerOptions = types.RegisterOptions(**validRegisterOptions)
#print(_("Added custom register options"))
for name in ExposedCalls:
yield self.register(GetCallee(name), u'.'.join((ID, name)), registerOptions)
validRegisterOptions["details_arg"] = 'details'
registerOptions = types.RegisterOptions(**validRegisterOptions)
# using progress, details argument must be added
for name in ExposedProgressCalls:
yield self.register(GetCallee(name), u'.'.join((ID, name)), registerOptions)
for name in SubscribedEvents:
yield self.subscribe(GetCallee(name), unicode(name))
print(_('WAMP session joined (%s) by:' % time.ctime()), ID)
def onLeave(self, details):
global _WampSession, _transportFactory
super(WampSession, self).onLeave(details)
print(_('WAMP session left'))
class ReconnectingWampWebSocketClientFactory(WampWebSocketClientFactory, ReconnectingClientFactory):
def __init__(self, config, *args, **kwargs):
WampWebSocketClientFactory.__init__(self, *args, **kwargs)
protocolOptions = config.extra.get('protocolOptions', None)
arguments = inspect.getargspec(self.setProtocolOptions).args
validProtocolOptions = getValidOptins(protocolOptions, arguments)
self.setProtocolOptions(**validProtocolOptions)
#print(_("Added custom protocol options"))
def buildProtocol(self, addr):
return ReconnectingClientFactory.buildProtocol(self, addr)
def clientConnectionFailed(self, connector, reason):
print(_("WAMP Client connection failed (%s) .. retrying .." % time.ctime()))
super(ReconnectingWampWebSocketClientFactory, self).clientConnectionFailed(connector, reason)
def clientConnectionLost(self, connector, reason):
print(_("WAMP Client connection lost (%s) .. retrying .." % time.ctime()))
super(ReconnectingWampWebSocketClientFactory, self).clientConnectionFailed(connector, reason)
def LoadWampClientConf(wampconf):
WSClientConf = json.load(open(wampconf))
print(_("WAMP load error: "), ve)
def LoadWampSecret(secretfname):
WSClientWampSecret = open(secretfname, 'rb').read()
return WSClientWampSecret
print(_("Wamp secret load error:"), ve)
if re.match(r'w{1}s{1,2}:{1}/{2}.+:{1}[0-9]+/{1}.+', uri):
def RegisterWampClient(wampconf, secretfname):
WSClientConf = LoadWampClientConf(wampconf)
print(_("WAMP client connection not established!"))
if not IsCorrectUri(WSClientConf["url"]):
print(_("WAMP url {} is not correct!".format(WSClientConf["url"])))
WampSecret = LoadWampSecret(secretfname)
if WampSecret is not None:
WSClientConf["secret"] = WampSecret
# create a WAMP application session factory
component_config = types.ComponentConfig(
realm=WSClientConf["realm"],
session_factory = wamp.ApplicationSessionFactory(
session_factory.session = WampSession
# create a WAMP-over-WebSocket transport client factory
transport_factory = ReconnectingWampWebSocketClientFactory(
serializers=[MsgPackSerializer()])
# start the client from a Twisted endpoint
conn = connectWS(transport_factory)
print(_("WAMP client connecting to :"), WSClientConf["url"])
def GetTransportFactory():