Mercurial > libervia-backend

comparison sat_frontends/bridge/dbus_bridge.py @ 3163:d10b2368684e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bridge: added methods to let frontends store/retrieve/delete private data
author Goffi <goffi@goffi.org>
date Mon, 10 Feb 2020 22:01:53 +0100
parents 830fce0db15d
children 439e2f88c3a9
comparison
equal deleted inserted replaced
3162:b5c058c7692e 3163:d10b2368684e
638 if callback is not None: 638 if callback is not None:
639 kwargs['timeout'] = const_TIMEOUT 639 kwargs['timeout'] = const_TIMEOUT
640 kwargs['reply_handler'] = callback 640 kwargs['reply_handler'] = callback
641 kwargs['error_handler'] = error_handler 641 kwargs['error_handler'] = error_handler
642 return self.db_core_iface.paramsRegisterApp(xml, security_limit, app, **kwargs) 642 return self.db_core_iface.paramsRegisterApp(xml, security_limit, app, **kwargs)
643
644 def privateDataDelete(self, namespace, key, arg_2, callback=None, errback=None):
645 if callback is None:
646 error_handler = None
647 else:
648 if errback is None:
649 errback = log.error
650 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
651 return self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
652
653 def privateDataGet(self, namespace, key, profile_key, callback=None, errback=None):
654 if callback is None:
655 error_handler = None
656 else:
657 if errback is None:
658 errback = log.error
659 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
660 return str(self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
661
662 def privateDataSet(self, namespace, key, data, profile_key, callback=None, errback=None):
663 if callback is None:
664 error_handler = None
665 else:
666 if errback is None:
667 errback = log.error
668 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
669 return self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
643 670
644 def profileCreate(self, profile, password='', component='', callback=None, errback=None): 671 def profileCreate(self, profile, password='', component='', callback=None, errback=None):
645 if callback is None: 672 if callback is None:
646 error_handler = None 673 error_handler = None
647 else: 674 else:
1224 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1251 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1225 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1252 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1226 self.db_core_iface.paramsRegisterApp(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1253 self.db_core_iface.paramsRegisterApp(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1227 return fut 1254 return fut
1228 1255
1256 def privateDataDelete(self, namespace, key, arg_2):
1257 loop = asyncio.get_running_loop()
1258 fut = loop.create_future()
1259 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1260 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1261 self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1262 return fut
1263
1264 def privateDataGet(self, namespace, key, profile_key):
1265 loop = asyncio.get_running_loop()
1266 fut = loop.create_future()
1267 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1268 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1269 self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1270 return fut
1271
1272 def privateDataSet(self, namespace, key, data, profile_key):
1273 loop = asyncio.get_running_loop()
1274 fut = loop.create_future()
1275 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1276 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1277 self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1278 return fut
1279
1229 def profileCreate(self, profile, password='', component=''): 1280 def profileCreate(self, profile, password='', component=''):
1230 loop = asyncio.get_running_loop() 1281 loop = asyncio.get_running_loop()
1231 fut = loop.create_future() 1282 fut = loop.create_future()
1232 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1283 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1233 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1284 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))