Mercurial > libervia-backend
comparison libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py @ 4270:0d7bb4df2343
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## |