Mercurial > libervia-backend

comparison libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py @ 4270:0d7bb4df2343

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Reformatted code base using black.
author Goffi <goffi@goffi.org>
date Wed, 19 Jun 2024 18:44:57 +0200
parents 26b7ed2817da
children
comparison
equal deleted inserted replaced
4269:64a85ce8be70 4270:0d7bb4df2343
46 self.__getattribute__(method_name) 46 self.__getattribute__(method_name)
47 except AttributeError: 47 except AttributeError:
48 pass 48 pass
49 else: 49 else:
50 raise exceptions.InternalError( 50 raise exceptions.InternalError(
51 "{name} signal handler has been registered twice".format( 51 "{name} signal handler has been registered twice".format(name=method_name)
52 name=method_name
53 )
54 ) 52 )
55 setattr(self, method_name, handler) 53 setattr(self, method_name, handler)
56 54
57 55
58 class bridge(object): 56 class bridge(object):
68 66
69 def _errback(self, failure_, ori_errback): 67 def _errback(self, failure_, ori_errback):
70 """Convert Failure to BridgeException""" 68 """Convert Failure to BridgeException"""
71 ori_errback( 69 ori_errback(
72 BridgeException( 70 BridgeException(
73 name=failure_.type.decode('utf-8'), 71 name=failure_.type.decode("utf-8"), message=str(failure_.value)
74 message=str(failure_.value)
75 ) 72 )
76 ) 73 )
77 74
78 def remote_callback(self, result, callback): 75 def remote_callback(self, result, callback):
79 """call callback with argument or None 76 """call callback with argument or None
165 self.signals_handler.register_signal(functionName, handler, iface) 162 self.signals_handler.register_signal(functionName, handler, iface)
166 163
167 164
168 ##METHODS_PART## 165 ##METHODS_PART##
169 166
167
170 class AIOSignalsHandler(SignalsHandler): 168 class AIOSignalsHandler(SignalsHandler):
171 169
172 def register_signal(self, name, handler, iface="core"): 170 def register_signal(self, name, handler, iface="core"):
173 async_handler = lambda *args, **kwargs: defer.Deferred.fromFuture( 171 async_handler = lambda *args, **kwargs: defer.Deferred.fromFuture(
174 asyncio.ensure_future(handler(*args, **kwargs))) 172 asyncio.ensure_future(handler(*args, **kwargs))
173 )
175 return super().register_signal(name, async_handler, iface) 174 return super().register_signal(name, async_handler, iface)
176 175
177 176
178 class AIOBridge(bridge): 177 class AIOBridge(bridge):
179 178
181 self.signals_handler = AIOSignalsHandler() 180 self.signals_handler = AIOSignalsHandler()
182 181
183 def _errback(self, failure_): 182 def _errback(self, failure_):
184 """Convert Failure to BridgeException""" 183 """Convert Failure to BridgeException"""
185 raise BridgeException( 184 raise BridgeException(
186 name=failure_.type.decode('utf-8'), 185 name=failure_.type.decode("utf-8"), message=str(failure_.value)
187 message=str(failure_.value) 186 )
188 )
189 187
190 def call(self, name, *args, **kwargs): 188 def call(self, name, *args, **kwargs):
191 d = self.root.callRemote(name, *args, *kwargs) 189 d = self.root.callRemote(name, *args, *kwargs)
192 d.addErrback(self._errback) 190 d.addErrback(self._errback)
193 return d.asFuture(asyncio.get_event_loop()) 191 return d.asFuture(asyncio.get_event_loop())
194 192
195 async def bridge_connect(self): 193 async def bridge_connect(self):
196 d = super().bridge_connect(callback=None, errback=None) 194 d = super().bridge_connect(callback=None, errback=None)
197 return await d.asFuture(asyncio.get_event_loop()) 195 return await d.asFuture(asyncio.get_event_loop())
198 196
197
199 ##ASYNC_METHODS_PART## 198 ##ASYNC_METHODS_PART##