view sat/bridge/bridge_constructor/constructors/pb/ @ 2818:9a7cb32836c6

bridge (pb): minor import order change
author Goffi <>
date Thu, 28 Feb 2019 18:57:28 +0100
parents 003b8b4b56a7
children 0f277708e2ae
line wrap: on
line source

#!/usr/bin/env python2
# -*- coding: utf-8 -*-

# SAT: a jabber client
# Copyright (C) 2009-2019 Jérôme Poisson (

# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# GNU Affero General Public License for more details.

# You should have received a copy of the GNU Affero General Public License
# along with this program.  If not, see <>.

from sat.core.log import getLogger

from twisted.spread import jelly, pb
from twisted.internet import reactor
log = getLogger(__name__)

## jelly hack
# we monkey patch jelly to handle namedtuple
ori_jelly = jelly._Jellier.jelly

def fixed_jelly(self, obj):
    """this method fix handling of namedtuple"""
    if isinstance(obj, tuple) and not obj is tuple:
        obj = tuple(obj)
    return ori_jelly(self, obj)

jelly._Jellier.jelly = fixed_jelly

class PBRoot(pb.Root):
    def __init__(self):
        self.signals_handlers = []

    def remote_initBridge(self, signals_handler):
        self.signals_handlers.append(signals_handler)"registered signal handler")

    def sendSignalEb(self, failure, signal_name):
            u"Error while sending signal {name}: {msg}".format(
                name=signal_name, msg=failure

    def sendSignal(self, name, args, kwargs):
        to_remove = []
        for handler in self.signals_handlers:
                d = handler.callRemote(name, *args, **kwargs)
            except pb.DeadReferenceError:
                d.addErrback(self.sendSignalEb, name)
        if to_remove:
            for handler in to_remove:
                log.debug(u"Removing signal handler for dead frontend")


class Bridge(object):
    def __init__(self):"Init Perspective Broker...")
        self.root = PBRoot()
        reactor.listenTCP(8789, pb.PBServerFactory(self.root))

    def sendSignal(self, name, *args, **kwargs):
        self.root.sendSignal(name, args, kwargs)

    def remote_initBridge(self, signals_handler):
        self.signals_handlers.append(signals_handler)"registered signal handler")

    def register_method(self, name, callback):
        log.debug("registering PB bridge method [%s]" % name)
        setattr(self.root, "remote_" + name, callback)
        #  self.root.register_method(name, callback)

    def addMethod(self, name, int_suffix, in_sign, out_sign, method, async=False, doc={}):
        """Dynamically add a method to PB Bridge"""
        # FIXME: doc parameter is kept only temporary, the time to remove it from calls
        log.debug("Adding method {name} to PB bridge".format(name=name))
        self.register_method(name, method)

    def addSignal(self, name, int_suffix, signature, doc={}):
        log.debug("Adding signal {name} to PB bridge".format(name=name))
            self, name, lambda *args, **kwargs: self.sendSignal(name, *args, **kwargs)