erebion/libervia-backend
Watch
1
0
Fork
You've already forked libervia-backend
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

bridge: added methods to let frontends store/retrieve/delete private data

Browse source
This commit is contained in:
Goffi 2020-02-10 22:01:53 +01:00
commit d684685e24
2 changed files with 168 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

51
sat_frontends/bridge/dbus_bridge.py
View file

@ -641,6 +641,33 @@ class Bridge:
kwargs['error_handler'] = error_handler
return self.db_core_iface.paramsRegisterApp(xml, security_limit, app, **kwargs)
def privateDataDelete(self, namespace, key, arg_2, callback=None, errback=None):
if callback is None:
error_handler = None
else:
if errback is None:
errback = log.error
error_handler = lambda err:errback(dbus_to_bridge_exception(err))
return self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
def privateDataGet(self, namespace, key, profile_key, callback=None, errback=None):
if callback is None:
error_handler = None
else:
if errback is None:
errback = log.error
error_handler = lambda err:errback(dbus_to_bridge_exception(err))
return str(self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
def privateDataSet(self, namespace, key, data, profile_key, callback=None, errback=None):
if callback is None:
error_handler = None
else:
if errback is None:
errback = log.error
error_handler = lambda err:errback(dbus_to_bridge_exception(err))
return self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
def profileCreate(self, profile, password='', component='', callback=None, errback=None):
if callback is None:
error_handler = None
@ -1226,6 +1253,30 @@ class AIOBridge(Bridge):
self.db_core_iface.paramsRegisterApp(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
return fut
def privateDataDelete(self, namespace, key, arg_2):
loop = asyncio.get_running_loop()
fut = loop.create_future()
reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
return fut
def privateDataGet(self, namespace, key, profile_key):
loop = asyncio.get_running_loop()
fut = loop.create_future()
reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
return fut
def privateDataSet(self, namespace, key, data, profile_key):
loop = asyncio.get_running_loop()
fut = loop.create_future()
reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
return fut
def profileCreate(self, profile, password='', component=''):
loop = asyncio.get_running_loop()
fut = loop.create_future()

39
sat_frontends/bridge/pb.py
View file

@ -487,6 +487,30 @@ class Bridge(object):
errback = self._generic_errback
d.addErrback(errback)
def privateDataDelete(self, namespace, key, arg_2, callback=None, errback=None):
d = self.root.callRemote("privateDataDelete", namespace, key, arg_2)
if callback is not None:
d.addCallback(lambda __: callback())
if errback is None:
errback = self._generic_errback
d.addErrback(errback)
def privateDataGet(self, namespace, key, profile_key, callback=None, errback=None):
d = self.root.callRemote("privateDataGet", namespace, key, profile_key)
if callback is not None:
d.addCallback(callback)
if errback is None:
errback = self._generic_errback
d.addErrback(errback)
def privateDataSet(self, namespace, key, data, profile_key, callback=None, errback=None):
d = self.root.callRemote("privateDataSet", namespace, key, data, profile_key)
if callback is not None:
d.addCallback(lambda __: callback())
if errback is None:
errback = self._generic_errback
d.addErrback(errback)
def profileCreate(self, profile, password='', component='', callback=None, errback=None):
d = self.root.callRemote("profileCreate", profile, password, component)
if callback is not None:
@ -859,6 +883,21 @@ class AIOBridge(Bridge):
d.addErrback(self._errback)
return d.asFuture(asyncio.get_event_loop())
def privateDataDelete(self, namespace, key, arg_2):
d = self.root.callRemote("privateDataDelete", namespace, key, arg_2)
d.addErrback(self._errback)
return d.asFuture(asyncio.get_event_loop())
def privateDataGet(self, namespace, key, profile_key):
d = self.root.callRemote("privateDataGet", namespace, key, profile_key)
d.addErrback(self._errback)
return d.asFuture(asyncio.get_event_loop())
def privateDataSet(self, namespace, key, data, profile_key):
d = self.root.callRemote("privateDataSet", namespace, key, data, profile_key)
d.addErrback(self._errback)
return d.asFuture(asyncio.get_event_loop())
def profileCreate(self, profile, password='', component=''):
d = self.root.callRemote("profileCreate", profile, password, component)
d.addErrback(self._errback)