libervia-backend: sat/bridge/pb.py annotate

annotate sat/bridge/pb.py @ 3040:fee60f17ebac

jp: jp asyncio port: /!\ this commit is huge. Jp is temporarily not working with `dbus` bridge /!\ This patch implements the port of jp to asyncio, so it is now correctly using the bridge asynchronously, and it can be used with bridges like `pb`. This also simplify the code, notably for things which were previously implemented with many callbacks (like pagination with RSM). During the process, some behaviours have been modified/fixed, in jp and backends, check diff for details.

author	Goffi <goffi@goffi.org>
date	Wed, 25 Sep 2019 08:56:41 +0200
parents	a1bc34f90fa5
children	9d0df638c8b4

rev	line source
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	1 #!/usr/bin/env python3
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	2 # -- coding: utf-8 --
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	3
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	4 # SAT: a jabber client
2771 003b8b4b56a7 date update Goffi <goffi@goffi.org> parents: 2655 diff changeset	5 # Copyright (C) 2009-2019 Jérôme Poisson (goffi@goffi.org)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	6
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	7 # This program is free software: you can redistribute it and/or modify
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	10 # (at your option) any later version.
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	11
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	12 # This program is distributed in the hope that it will be useful,
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	15 # GNU Affero General Public License for more details.
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	16
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	17 # You should have received a copy of the GNU Affero General Public License
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	19
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	20
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	21 import dataclasses
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	22 from sat.core.log import getLogger
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	23 from twisted.spread import jelly, pb
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	24 from twisted.internet import reactor
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	25
2892 82b781c46841 core: added a rosterResync method to bridge: Goffi <goffi@goffi.org> parents: 2854 diff changeset	26 log = getLogger(__name__)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	27
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	28
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	29 ## jelly hack
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	30 # we monkey patch jelly to handle namedtuple
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	31 ori_jelly = jelly._Jellier.jelly
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	32
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	33
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	34 def fixed_jelly(self, obj):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	35 """this method fix handling of namedtuple"""
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	36 if isinstance(obj, tuple) and not obj is tuple:
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	37 obj = tuple(obj)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	38 return ori_jelly(self, obj)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	39
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	40
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	41 jelly._Jellier.jelly = fixed_jelly
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	42
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	43
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	44 @dataclasses.dataclass(eq=False)
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	45 class HandlerWrapper:
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	46 # we use a wrapper to keep signals handlers because RemoteReference doesn't support
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	47 # comparison (other than equality), making it unusable with a list
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	48 handler: pb.RemoteReference
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	49
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	50
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	51 class PBRoot(pb.Root):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	52 def __init__(self):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	53 self.signals_handlers = []
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	54
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	55 def remote_initBridge(self, signals_handler):
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	56 self.signals_handlers.append(HandlerWrapper(signals_handler))
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	57 log.info("registered signal handler")
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	58
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	59 def sendSignalEb(self, failure_, signal_name):
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	60 if not failure_.check(pb.PBConnectionLost):
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	61 log.error(
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	62 f"Error while sending signal {signal_name}: {failure_}",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	63 )
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	64
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	65 def sendSignal(self, name, args, kwargs):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	66 to_remove = []
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	67 for wrapper in self.signals_handlers:
a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	68 handler = wrapper.handler
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	69 try:
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	70 d = handler.callRemote(name, args, *kwargs)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	71 except pb.DeadReferenceError:
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	72 to_remove.append(wrapper)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	73 else:
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	74 d.addErrback(self.sendSignalEb, name)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	75 if to_remove:
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	76 for wrapper in to_remove:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	77 log.debug("Removing signal handler for dead frontend")
3039 a1bc34f90fa5 bridge (pb): implemented an asyncio compatible bridge: Goffi <goffi@goffi.org> parents: 3028 diff changeset	78 self.signals_handlers.remove(wrapper)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	79
2840 0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	80 def _bridgeDeactivateSignals(self):
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	81 if hasattr(self, "signals_paused"):
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	82 log.warning("bridge signals already deactivated")
2840 0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	83 if self.signals_handler:
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	84 self.signals_paused.extend(self.signals_handler)
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	85 else:
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	86 self.signals_paused = self.signals_handlers
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	87 self.signals_handlers = []
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	88 log.debug("bridge signals have been deactivated")
2840 0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	89
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	90 def _bridgeReactivateSignals(self):
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	91 try:
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	92 self.signals_handlers = self.signals_paused
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	93 except AttributeError:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	94 log.debug("signals were already activated")
2840 0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	95 else:
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	96 del self.signals_paused
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	97 log.debug("bridge signals have been reactivated")
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	98
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	99 ##METHODS_PART##
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	100
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	101
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	102 class Bridge(object):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	103 def __init__(self):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	104 log.info("Init Perspective Broker...")
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	105 self.root = PBRoot()
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	106 reactor.listenTCP(8789, pb.PBServerFactory(self.root))
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	107
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	108 def sendSignal(self, name, args, *kwargs):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	109 self.root.sendSignal(name, args, kwargs)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	110
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	111 def remote_initBridge(self, signals_handler):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	112 self.signals_handlers.append(signals_handler)
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	113 log.info("registered signal handler")
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	114
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	115 def register_method(self, name, callback):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	116 log.debug("registering PB bridge method [%s]" % name)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	117 setattr(self.root, "remote_" + name, callback)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	118 # self.root.register_method(name, callback)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	119
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2894 diff changeset	120 def addMethod(self, name, int_suffix, in_sign, out_sign, method, async_=False, doc={}):
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	121 """Dynamically add a method to PB Bridge"""
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	122 # FIXME: doc parameter is kept only temporary, the time to remove it from calls
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	123 log.debug("Adding method {name} to PB bridge".format(name=name))
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	124 self.register_method(name, method)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	125
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	126 def addSignal(self, name, int_suffix, signature, doc={}):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	127 log.debug("Adding signal {name} to PB bridge".format(name=name))
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	128 setattr(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	129 self, name, lambda args, kwargs: self.sendSignal(name, args, **kwargs)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2579 diff changeset	130 )
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	131
2840 0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	132 def bridgeDeactivateSignals(self):
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	133 """Stop sending signals to bridge
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	134
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	135 Mainly used for mobile frontends, when the frontend is paused
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	136 """
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	137 self.root._bridgeDeactivateSignals()
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	138
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	139 def bridgeReactivateSignals(self):
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	140 """Send again signals to bridge
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	141
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	142 Should only be used after bridgeDeactivateSignals has been called
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	143 """
0f277708e2ae bridge (pb): added bridgeDeactivateSignals and bridgeReactivateSignals methods: Goffi <goffi@goffi.org> parents: 2771 diff changeset	144 self.root._bridgeReactivateSignals()
2628 779351da2c13 core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation: Goffi <goffi@goffi.org> parents: 2624 diff changeset	145
2854 eb9fa72eb62b core: added a "_debug" signal: Goffi <goffi@goffi.org> parents: 2840 diff changeset	146 def _debug(self, action, params, profile):
eb9fa72eb62b core: added a "_debug" signal: Goffi <goffi@goffi.org> parents: 2840 diff changeset	147 self.sendSignal("_debug", action, params, profile)
eb9fa72eb62b core: added a "_debug" signal: Goffi <goffi@goffi.org> parents: 2840 diff changeset	148
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	149 def actionNew(self, action_data, id, security_limit, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	150 self.sendSignal("actionNew", action_data, id, security_limit, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	151
2894 c7c52c0dc13a core, quick_frontend(app): fixed connected signal handling Goffi <goffi@goffi.org> parents: 2892 diff changeset	152 def connected(self, jid_s, profile):
c7c52c0dc13a core, quick_frontend(app): fixed connected signal handling Goffi <goffi@goffi.org> parents: 2892 diff changeset	153 self.sendSignal("connected", jid_s, profile)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	154
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	155 def contactDeleted(self, entity_jid, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	156 self.sendSignal("contactDeleted", entity_jid, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	157
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	158 def disconnected(self, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	159 self.sendSignal("disconnected", profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	160
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	161 def entityDataUpdated(self, jid, name, value, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	162 self.sendSignal("entityDataUpdated", jid, name, value, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	163
2655 b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	164 def messageEncryptionStarted(self, to_jid, encryption_data, profile_key):
b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	165 self.sendSignal("messageEncryptionStarted", to_jid, encryption_data, profile_key)
b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	166
b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	167 def messageEncryptionStopped(self, to_jid, encryption_data, profile_key):
b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	168 self.sendSignal("messageEncryptionStopped", to_jid, encryption_data, profile_key)
b8600f8130ac core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet) Goffi <goffi@goffi.org> parents: 2628 diff changeset	169
2628 779351da2c13 core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation: Goffi <goffi@goffi.org> parents: 2624 diff changeset	170 def messageNew(self, uid, timestamp, from_jid, to_jid, message, subject, mess_type, extra, profile):
779351da2c13 core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation: Goffi <goffi@goffi.org> parents: 2624 diff changeset	171 self.sendSignal("messageNew", uid, timestamp, from_jid, to_jid, message, subject, mess_type, extra, profile)
2579 787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	172
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	173 def newContact(self, contact_jid, attributes, groups, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	174 self.sendSignal("newContact", contact_jid, attributes, groups, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	175
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	176 def paramUpdate(self, name, value, category, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	177 self.sendSignal("paramUpdate", name, value, category, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	178
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	179 def presenceUpdate(self, entity_jid, show, priority, statuses, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	180 self.sendSignal("presenceUpdate", entity_jid, show, priority, statuses, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	181
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	182 def progressError(self, id, error, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	183 self.sendSignal("progressError", id, error, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	184
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	185 def progressFinished(self, id, metadata, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	186 self.sendSignal("progressFinished", id, metadata, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	187
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	188 def progressStarted(self, id, metadata, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	189 self.sendSignal("progressStarted", id, metadata, profile)
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	190
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	191 def subscribe(self, sub_type, entity_jid, profile):
787b15d16347 bridge: added generated pb files to repository (needed for Cagou on Android) Goffi <goffi@goffi.org> parents: diff changeset	192 self.sendSignal("subscribe", sub_type, entity_jid, profile)

Mercurial > libervia-backend

annotate sat/bridge/pb.py @ 3040:fee60f17ebac