Mercurial > libervia-backend

comparison libervia/frontends/bridge/dbus_bridge.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 730f542e4ad0
children 4cf98f506269
comparison
equal deleted inserted replaced
4269:64a85ce8be70 4270:0d7bb4df2343
31 log = getLogger(__name__) 31 log = getLogger(__name__)
32 32
33 33
34 # Interface prefix 34 # Interface prefix
35 const_INT_PREFIX = config.config_get( 35 const_INT_PREFIX = config.config_get(
36 config.parse_main_conf(), 36 config.parse_main_conf(), "", "bridge_dbus_int_prefix", "org.libervia.Libervia"
37 "", 37 )
38 "bridge_dbus_int_prefix",
39 "org.libervia.Libervia")
40 const_ERROR_PREFIX = const_INT_PREFIX + ".error" 38 const_ERROR_PREFIX = const_INT_PREFIX + ".error"
41 const_OBJ_PATH = '/org/libervia/Libervia/bridge' 39 const_OBJ_PATH = "/org/libervia/Libervia/bridge"
42 const_CORE_SUFFIX = ".core" 40 const_CORE_SUFFIX = ".core"
43 const_PLUGIN_SUFFIX = ".plugin" 41 const_PLUGIN_SUFFIX = ".plugin"
44 const_TIMEOUT = 120 42 const_TIMEOUT = 120
45 43
46 44
50 @param dbus_e (DBusException) 48 @param dbus_e (DBusException)
51 @return: BridgeException 49 @return: BridgeException
52 """ 50 """
53 full_name = dbus_e.get_dbus_name() 51 full_name = dbus_e.get_dbus_name()
54 if full_name.startswith(const_ERROR_PREFIX): 52 if full_name.startswith(const_ERROR_PREFIX):
55 name = dbus_e.get_dbus_name()[len(const_ERROR_PREFIX) + 1:] 53 name = dbus_e.get_dbus_name()[len(const_ERROR_PREFIX) + 1 :]
56 else: 54 else:
57 name = full_name 55 name = full_name
58 # XXX: dbus_e.args doesn't contain the original DBusException args, but we 56 # XXX: dbus_e.args doesn't contain the original DBusException args, but we
59 # receive its serialized form in dbus_e.args[0]. From that we can rebuild 57 # receive its serialized form in dbus_e.args[0]. From that we can rebuild
60 # the original arguments list thanks to ast.literal_eval (secure eval). 58 # the original arguments list thanks to ast.literal_eval (secure eval).
61 message = dbus_e.get_dbus_message() # similar to dbus_e.args[0] 59 message = dbus_e.get_dbus_message() # similar to dbus_e.args[0]
62 try: 60 try:
63 message, condition = ast.literal_eval(message) 61 message, condition = ast.literal_eval(message)
64 except (SyntaxError, ValueError, TypeError): 62 except (SyntaxError, ValueError, TypeError):
65 condition = '' 63 condition = ""
66 return BridgeException(name, message, condition) 64 return BridgeException(name, message, condition)
67 65
68 66
69 class bridge: 67 class bridge:
70 68
71 def bridge_connect(self, callback, errback): 69 def bridge_connect(self, callback, errback):
72 try: 70 try:
73 self.sessions_bus = dbus.SessionBus() 71 self.sessions_bus = dbus.SessionBus()
74 self.db_object = self.sessions_bus.get_object(const_INT_PREFIX, 72 self.db_object = self.sessions_bus.get_object(
75 const_OBJ_PATH) 73 const_INT_PREFIX, const_OBJ_PATH
76 self.db_core_iface = dbus.Interface(self.db_object, 74 )
77 dbus_interface=const_INT_PREFIX + const_CORE_SUFFIX) 75 self.db_core_iface = dbus.Interface(
78 self.db_plugin_iface = dbus.Interface(self.db_object, 76 self.db_object, dbus_interface=const_INT_PREFIX + const_CORE_SUFFIX
79 dbus_interface=const_INT_PREFIX + const_PLUGIN_SUFFIX) 77 )
78 self.db_plugin_iface = dbus.Interface(
79 self.db_object, dbus_interface=const_INT_PREFIX + const_PLUGIN_SUFFIX
80 )
80 except dbus.exceptions.DBusException as e: 81 except dbus.exceptions.DBusException as e:
81 if e._dbus_error_name in ('org.freedesktop.DBus.Error.ServiceUnknown', 82 if e._dbus_error_name in (
82 'org.freedesktop.DBus.Error.Spawn.ExecFailed'): 83 "org.freedesktop.DBus.Error.ServiceUnknown",
84 "org.freedesktop.DBus.Error.Spawn.ExecFailed",
85 ):
83 errback(BridgeExceptionNoService()) 86 errback(BridgeExceptionNoService())
84 elif e._dbus_error_name == 'org.freedesktop.DBus.Error.NotSupported': 87 elif e._dbus_error_name == "org.freedesktop.DBus.Error.NotSupported":
85 log.error(_("D-Bus is not launched, please see README to see instructions on how to launch it")) 88 log.error(
89 _(
90 "D-Bus is not launched, please see README to see instructions on how to launch it"
91 )
92 )
86 errback(BridgeInitError) 93 errback(BridgeInitError)
87 else: 94 else:
88 errback(e) 95 errback(e)
89 else: 96 else:
90 callback() 97 callback()
91 #props = self.db_core_iface.getProperties() 98 # props = self.db_core_iface.getProperties()
92 99
93 def register_signal(self, functionName, handler, iface="core"): 100 def register_signal(self, functionName, handler, iface="core"):
94 if iface == "core": 101 if iface == "core":
95 self.db_core_iface.connect_to_signal(functionName, handler) 102 self.db_core_iface.connect_to_signal(functionName, handler)
96 elif iface == "plugin": 103 elif iface == "plugin":
97 self.db_plugin_iface.connect_to_signal(functionName, handler) 104 self.db_plugin_iface.connect_to_signal(functionName, handler)
98 else: 105 else:
99 log.error(_('Unknown interface')) 106 log.error(_("Unknown interface"))
100 107
101 def __getattribute__(self, name): 108 def __getattribute__(self, name):
102 """ usual __getattribute__ if the method exists, else try to find a plugin method """ 109 """usual __getattribute__ if the method exists, else try to find a plugin method"""
103 try: 110 try:
104 return object.__getattribute__(self, name) 111 return object.__getattribute__(self, name)
105 except AttributeError: 112 except AttributeError:
106 # The attribute is not found, we try the plugin proxy to find the requested method 113 # The attribute is not found, we try the plugin proxy to find the requested method
107 114
112 119
113 async_ = False 120 async_ = False
114 args = list(args) 121 args = list(args)
115 122
116 if kwargs: 123 if kwargs:
117 if 'callback' in kwargs: 124 if "callback" in kwargs:
118 async_ = True 125 async_ = True
119 _callback = kwargs.pop('callback') 126 _callback = kwargs.pop("callback")
120 _errback = kwargs.pop('errback', lambda failure: log.error(str(failure))) 127 _errback = kwargs.pop(
128 "errback", lambda failure: log.error(str(failure))
129 )
121 try: 130 try:
122 args.append(kwargs.pop('profile')) 131 args.append(kwargs.pop("profile"))
123 except KeyError: 132 except KeyError:
124 try: 133 try:
125 args.append(kwargs.pop('profile_key')) 134 args.append(kwargs.pop("profile_key"))
126 except KeyError: 135 except KeyError:
127 pass 136 pass
128 # at this point, kwargs should be empty 137 # at this point, kwargs should be empty
129 if kwargs: 138 if kwargs:
130 log.warning("unexpected keyword arguments, they will be ignored: {}".format(kwargs)) 139 log.warning(
140 "unexpected keyword arguments, they will be ignored: {}".format(
141 kwargs
142 )
143 )
131 elif len(args) >= 2 and callable(args[-1]) and callable(args[-2]): 144 elif len(args) >= 2 and callable(args[-1]) and callable(args[-2]):
132 async_ = True 145 async_ = True
133 _errback = args.pop() 146 _errback = args.pop()
134 _callback = args.pop() 147 _callback = args.pop()
135 148
136 method = getattr(self.db_plugin_iface, name) 149 method = getattr(self.db_plugin_iface, name)
137 150
138 if async_: 151 if async_:
139 kwargs['timeout'] = const_TIMEOUT 152 kwargs["timeout"] = const_TIMEOUT
140 kwargs['reply_handler'] = _callback 153 kwargs["reply_handler"] = _callback
141 kwargs['error_handler'] = lambda err: _errback(dbus_to_bridge_exception(err)) 154 kwargs["error_handler"] = lambda err: _errback(
155 dbus_to_bridge_exception(err)
156 )
142 157
143 try: 158 try:
144 return method(*args, **kwargs) 159 return method(*args, **kwargs)
145 except ValueError as e: 160 except ValueError as e:
146 if e.args[0].startswith("Unable to guess signature"): 161 if e.args[0].startswith("Unable to guess signature"):
156 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs) 171 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs)
157 raise e 172 raise e
158 173
159 return get_plugin_method 174 return get_plugin_method
160 175
161 def action_launch(self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None): 176 def action_launch(
162 if callback is None: 177 self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None
163 error_handler = None 178 ):
164 else: 179 if callback is None:
165 if errback is None: 180 error_handler = None
166 errback = log.error 181 else:
167 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 182 if errback is None:
168 return str(self.db_core_iface.action_launch(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 183 errback = log.error
184 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
185 return str(
186 self.db_core_iface.action_launch(
187 callback_id,
188 data,
189 profile_key,
190 timeout=const_TIMEOUT,
191 reply_handler=callback,
192 error_handler=error_handler,
193 )
194 )
169 195
170 def actions_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 196 def actions_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
171 if callback is None: 197 if callback is None:
172 error_handler = None 198 error_handler = None
173 else: 199 else:
174 if errback is None: 200 if errback is None:
175 errback = log.error 201 errback = log.error
176 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 202 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
177 kwargs={} 203 kwargs = {}
178 if callback is not None: 204 if callback is not None:
179 kwargs['timeout'] = const_TIMEOUT 205 kwargs["timeout"] = const_TIMEOUT
180 kwargs['reply_handler'] = callback 206 kwargs["reply_handler"] = callback
181 kwargs['error_handler'] = error_handler 207 kwargs["error_handler"] = error_handler
182 return self.db_core_iface.actions_get(profile_key, **kwargs) 208 return self.db_core_iface.actions_get(profile_key, **kwargs)
183 209
184 def config_get(self, section, name, callback=None, errback=None): 210 def config_get(self, section, name, callback=None, errback=None):
185 if callback is None: 211 if callback is None:
186 error_handler = None 212 error_handler = None
187 else: 213 else:
188 if errback is None: 214 if errback is None:
189 errback = log.error 215 errback = log.error
190 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 216 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
191 kwargs={} 217 kwargs = {}
192 if callback is not None: 218 if callback is not None:
193 kwargs['timeout'] = const_TIMEOUT 219 kwargs["timeout"] = const_TIMEOUT
194 kwargs['reply_handler'] = callback 220 kwargs["reply_handler"] = callback
195 kwargs['error_handler'] = error_handler 221 kwargs["error_handler"] = error_handler
196 return str(self.db_core_iface.config_get(section, name, **kwargs)) 222 return str(self.db_core_iface.config_get(section, name, **kwargs))
197 223
198 def connect(self, profile_key="@DEFAULT@", password='', options={}, callback=None, errback=None): 224 def connect(
199 if callback is None: 225 self,
200 error_handler = None 226 profile_key="@DEFAULT@",
201 else: 227 password="",
202 if errback is None: 228 options={},
203 errback = log.error 229 callback=None,
204 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 230 errback=None,
205 return self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 231 ):
206 232 if callback is None:
207 def contact_add(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 233 error_handler = None
208 if callback is None: 234 else:
209 error_handler = None 235 if errback is None:
210 else: 236 errback = log.error
211 if errback is None: 237 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
212 errback = log.error 238 return self.db_core_iface.connect(
213 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 239 profile_key,
214 kwargs={} 240 password,
215 if callback is not None: 241 options,
216 kwargs['timeout'] = const_TIMEOUT 242 timeout=const_TIMEOUT,
217 kwargs['reply_handler'] = callback 243 reply_handler=callback,
218 kwargs['error_handler'] = error_handler 244 error_handler=error_handler,
245 )
246
247 def contact_add(
248 self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None
249 ):
250 if callback is None:
251 error_handler = None
252 else:
253 if errback is None:
254 errback = log.error
255 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
256 kwargs = {}
257 if callback is not None:
258 kwargs["timeout"] = const_TIMEOUT
259 kwargs["reply_handler"] = callback
260 kwargs["error_handler"] = error_handler
219 return self.db_core_iface.contact_add(entity_jid, profile_key, **kwargs) 261 return self.db_core_iface.contact_add(entity_jid, profile_key, **kwargs)
220 262
221 def contact_del(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 263 def contact_del(
222 if callback is None: 264 self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None
223 error_handler = None 265 ):
224 else: 266 if callback is None:
225 if errback is None: 267 error_handler = None
226 errback = log.error 268 else:
227 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 269 if errback is None:
228 return self.db_core_iface.contact_del(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 270 errback = log.error
271 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
272 return self.db_core_iface.contact_del(
273 entity_jid,
274 profile_key,
275 timeout=const_TIMEOUT,
276 reply_handler=callback,
277 error_handler=error_handler,
278 )
229 279
230 def contact_get(self, arg_0, profile_key="@DEFAULT@", callback=None, errback=None): 280 def contact_get(self, arg_0, profile_key="@DEFAULT@", callback=None, errback=None):
231 if callback is None: 281 if callback is None:
232 error_handler = None 282 error_handler = None
233 else: 283 else:
234 if errback is None: 284 if errback is None:
235 errback = log.error 285 errback = log.error
236 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 286 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
237 return self.db_core_iface.contact_get(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 287 return self.db_core_iface.contact_get(
238 288 arg_0,
239 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@", callback=None, errback=None): 289 profile_key,
240 if callback is None: 290 timeout=const_TIMEOUT,
241 error_handler = None 291 reply_handler=callback,
242 else: 292 error_handler=error_handler,
243 if errback is None: 293 )
244 errback = log.error 294
245 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 295 def contact_update(
246 kwargs={} 296 self,
247 if callback is not None: 297 entity_jid,
248 kwargs['timeout'] = const_TIMEOUT 298 name,
249 kwargs['reply_handler'] = callback 299 groups,
250 kwargs['error_handler'] = error_handler 300 profile_key="@DEFAULT@",
251 return self.db_core_iface.contact_update(entity_jid, name, groups, profile_key, **kwargs) 301 callback=None,
302 errback=None,
303 ):
304 if callback is None:
305 error_handler = None
306 else:
307 if errback is None:
308 errback = log.error
309 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
310 kwargs = {}
311 if callback is not None:
312 kwargs["timeout"] = const_TIMEOUT
313 kwargs["reply_handler"] = callback
314 kwargs["error_handler"] = error_handler
315 return self.db_core_iface.contact_update(
316 entity_jid, name, groups, profile_key, **kwargs
317 )
252 318
253 def contacts_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 319 def contacts_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
254 if callback is None: 320 if callback is None:
255 error_handler = None 321 error_handler = None
256 else: 322 else:
257 if errback is None: 323 if errback is None:
258 errback = log.error 324 errback = log.error
259 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 325 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
260 return self.db_core_iface.contacts_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 326 return self.db_core_iface.contacts_get(
261 327 profile_key,
262 def contacts_get_from_group(self, group, profile_key="@DEFAULT@", callback=None, errback=None): 328 timeout=const_TIMEOUT,
263 if callback is None: 329 reply_handler=callback,
264 error_handler = None 330 error_handler=error_handler,
265 else: 331 )
266 if errback is None: 332
267 errback = log.error 333 def contacts_get_from_group(
268 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 334 self, group, profile_key="@DEFAULT@", callback=None, errback=None
269 kwargs={} 335 ):
270 if callback is not None: 336 if callback is None:
271 kwargs['timeout'] = const_TIMEOUT 337 error_handler = None
272 kwargs['reply_handler'] = callback 338 else:
273 kwargs['error_handler'] = error_handler 339 if errback is None:
340 errback = log.error
341 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
342 kwargs = {}
343 if callback is not None:
344 kwargs["timeout"] = const_TIMEOUT
345 kwargs["reply_handler"] = callback
346 kwargs["error_handler"] = error_handler
274 return self.db_core_iface.contacts_get_from_group(group, profile_key, **kwargs) 347 return self.db_core_iface.contacts_get_from_group(group, profile_key, **kwargs)
275 348
276 def devices_infos_get(self, bare_jid, profile_key, callback=None, errback=None): 349 def devices_infos_get(self, bare_jid, profile_key, callback=None, errback=None):
277 if callback is None: 350 if callback is None:
278 error_handler = None 351 error_handler = None
279 else: 352 else:
280 if errback is None: 353 if errback is None:
281 errback = log.error 354 errback = log.error
282 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 355 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
283 return str(self.db_core_iface.devices_infos_get(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 356 return str(
284 357 self.db_core_iface.devices_infos_get(
285 def disco_find_by_features(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@", callback=None, errback=None): 358 bare_jid,
286 if callback is None: 359 profile_key,
287 error_handler = None 360 timeout=const_TIMEOUT,
288 else: 361 reply_handler=callback,
289 if errback is None: 362 error_handler=error_handler,
290 errback = log.error 363 )
291 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 364 )
292 return self.db_core_iface.disco_find_by_features(namespaces, identities, bare_jid, service, roster, own_jid, local_device, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 365
293 366 def disco_find_by_features(
294 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 367 self,
295 if callback is None: 368 namespaces,
296 error_handler = None 369 identities,
297 else: 370 bare_jid=False,
298 if errback is None: 371 service=True,
299 errback = log.error 372 roster=True,
300 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 373 own_jid=True,
301 return self.db_core_iface.disco_infos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 374 local_device=False,
302 375 profile_key="@DEFAULT@",
303 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 376 callback=None,
304 if callback is None: 377 errback=None,
305 error_handler = None 378 ):
306 else: 379 if callback is None:
307 if errback is None: 380 error_handler = None
308 errback = log.error 381 else:
309 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 382 if errback is None:
310 return self.db_core_iface.disco_items(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 383 errback = log.error
384 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
385 return self.db_core_iface.disco_find_by_features(
386 namespaces,
387 identities,
388 bare_jid,
389 service,
390 roster,
391 own_jid,
392 local_device,
393 profile_key,
394 timeout=const_TIMEOUT,
395 reply_handler=callback,
396 error_handler=error_handler,
397 )
398
399 def disco_infos(
400 self,
401 entity_jid,
402 node="",
403 use_cache=True,
404 profile_key="@DEFAULT@",
405 callback=None,
406 errback=None,
407 ):
408 if callback is None:
409 error_handler = None
410 else:
411 if errback is None:
412 errback = log.error
413 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
414 return self.db_core_iface.disco_infos(
415 entity_jid,
416 node,
417 use_cache,
418 profile_key,
419 timeout=const_TIMEOUT,
420 reply_handler=callback,
421 error_handler=error_handler,
422 )
423
424 def disco_items(
425 self,
426 entity_jid,
427 node="",
428 use_cache=True,
429 profile_key="@DEFAULT@",
430 callback=None,
431 errback=None,
432 ):
433 if callback is None:
434 error_handler = None
435 else:
436 if errback is None:
437 errback = log.error
438 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
439 return self.db_core_iface.disco_items(
440 entity_jid,
441 node,
442 use_cache,
443 profile_key,
444 timeout=const_TIMEOUT,
445 reply_handler=callback,
446 error_handler=error_handler,
447 )
311 448
312 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None): 449 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None):
313 if callback is None: 450 if callback is None:
314 error_handler = None 451 error_handler = None
315 else: 452 else:
316 if errback is None: 453 if errback is None:
317 errback = log.error 454 errback = log.error
318 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 455 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
319 return self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 456 return self.db_core_iface.disconnect(
457 profile_key,
458 timeout=const_TIMEOUT,
459 reply_handler=callback,
460 error_handler=error_handler,
461 )
320 462
321 def encryption_namespace_get(self, arg_0, callback=None, errback=None): 463 def encryption_namespace_get(self, arg_0, callback=None, errback=None):
322 if callback is None: 464 if callback is None:
323 error_handler = None 465 error_handler = None
324 else: 466 else:
325 if errback is None: 467 if errback is None:
326 errback = log.error 468 errback = log.error
327 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 469 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
328 kwargs={} 470 kwargs = {}
329 if callback is not None: 471 if callback is not None:
330 kwargs['timeout'] = const_TIMEOUT 472 kwargs["timeout"] = const_TIMEOUT
331 kwargs['reply_handler'] = callback 473 kwargs["reply_handler"] = callback
332 kwargs['error_handler'] = error_handler 474 kwargs["error_handler"] = error_handler
333 return str(self.db_core_iface.encryption_namespace_get(arg_0, **kwargs)) 475 return str(self.db_core_iface.encryption_namespace_get(arg_0, **kwargs))
334 476
335 def encryption_plugins_get(self, callback=None, errback=None): 477 def encryption_plugins_get(self, callback=None, errback=None):
336 if callback is None: 478 if callback is None:
337 error_handler = None 479 error_handler = None
338 else: 480 else:
339 if errback is None: 481 if errback is None:
340 errback = log.error 482 errback = log.error
341 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 483 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
342 kwargs={} 484 kwargs = {}
343 if callback is not None: 485 if callback is not None:
344 kwargs['timeout'] = const_TIMEOUT 486 kwargs["timeout"] = const_TIMEOUT
345 kwargs['reply_handler'] = callback 487 kwargs["reply_handler"] = callback
346 kwargs['error_handler'] = error_handler 488 kwargs["error_handler"] = error_handler
347 return str(self.db_core_iface.encryption_plugins_get(**kwargs)) 489 return str(self.db_core_iface.encryption_plugins_get(**kwargs))
348 490
349 def encryption_trust_ui_get(self, to_jid, namespace, profile_key, callback=None, errback=None): 491 def encryption_trust_ui_get(
350 if callback is None: 492 self, to_jid, namespace, profile_key, callback=None, errback=None
351 error_handler = None 493 ):
352 else: 494 if callback is None:
353 if errback is None: 495 error_handler = None
354 errback = log.error 496 else:
355 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 497 if errback is None:
356 return str(self.db_core_iface.encryption_trust_ui_get(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 498 errback = log.error
499 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
500 return str(
501 self.db_core_iface.encryption_trust_ui_get(
502 to_jid,
503 namespace,
504 profile_key,
505 timeout=const_TIMEOUT,
506 reply_handler=callback,
507 error_handler=error_handler,
508 )
509 )
357 510
358 def entities_data_get(self, jids, keys, profile, callback=None, errback=None): 511 def entities_data_get(self, jids, keys, profile, callback=None, errback=None):
359 if callback is None: 512 if callback is None:
360 error_handler = None 513 error_handler = None
361 else: 514 else:
362 if errback is None: 515 if errback is None:
363 errback = log.error 516 errback = log.error
364 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 517 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
365 kwargs={} 518 kwargs = {}
366 if callback is not None: 519 if callback is not None:
367 kwargs['timeout'] = const_TIMEOUT 520 kwargs["timeout"] = const_TIMEOUT
368 kwargs['reply_handler'] = callback 521 kwargs["reply_handler"] = callback
369 kwargs['error_handler'] = error_handler 522 kwargs["error_handler"] = error_handler
370 return self.db_core_iface.entities_data_get(jids, keys, profile, **kwargs) 523 return self.db_core_iface.entities_data_get(jids, keys, profile, **kwargs)
371 524
372 def entity_data_get(self, jid, keys, profile, callback=None, errback=None): 525 def entity_data_get(self, jid, keys, profile, callback=None, errback=None):
373 if callback is None: 526 if callback is None:
374 error_handler = None 527 error_handler = None
375 else: 528 else:
376 if errback is None: 529 if errback is None:
377 errback = log.error 530 errback = log.error
378 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 531 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
379 kwargs={} 532 kwargs = {}
380 if callback is not None: 533 if callback is not None:
381 kwargs['timeout'] = const_TIMEOUT 534 kwargs["timeout"] = const_TIMEOUT
382 kwargs['reply_handler'] = callback 535 kwargs["reply_handler"] = callback
383 kwargs['error_handler'] = error_handler 536 kwargs["error_handler"] = error_handler
384 return self.db_core_iface.entity_data_get(jid, keys, profile, **kwargs) 537 return self.db_core_iface.entity_data_get(jid, keys, profile, **kwargs)
385 538
386 def features_get(self, profile_key, callback=None, errback=None): 539 def features_get(self, profile_key, callback=None, errback=None):
387 if callback is None: 540 if callback is None:
388 error_handler = None 541 error_handler = None
389 else: 542 else:
390 if errback is None: 543 if errback is None:
391 errback = log.error 544 errback = log.error
392 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 545 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
393 return self.db_core_iface.features_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 546 return self.db_core_iface.features_get(
394 547 profile_key,
395 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@", callback=None, errback=None): 548 timeout=const_TIMEOUT,
396 if callback is None: 549 reply_handler=callback,
397 error_handler = None 550 error_handler=error_handler,
398 else: 551 )
399 if errback is None: 552
400 errback = log.error 553 def history_get(
401 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 554 self,
402 return self.db_core_iface.history_get(from_jid, to_jid, limit, between, filters, profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 555 from_jid,
556 to_jid,
557 limit,
558 between=True,
559 filters="",
560 profile="@NONE@",
561 callback=None,
562 errback=None,
563 ):
564 if callback is None:
565 error_handler = None
566 else:
567 if errback is None:
568 errback = log.error
569 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
570 return self.db_core_iface.history_get(
571 from_jid,
572 to_jid,
573 limit,
574 between,
575 filters,
576 profile,
577 timeout=const_TIMEOUT,
578 reply_handler=callback,
579 error_handler=error_handler,
580 )
403 581
404 def image_check(self, arg_0, callback=None, errback=None): 582 def image_check(self, arg_0, callback=None, errback=None):
405 if callback is None: 583 if callback is None:
406 error_handler = None 584 error_handler = None
407 else: 585 else:
408 if errback is None: 586 if errback is None:
409 errback = log.error 587 errback = log.error
410 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 588 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
411 kwargs={} 589 kwargs = {}
412 if callback is not None: 590 if callback is not None:
413 kwargs['timeout'] = const_TIMEOUT 591 kwargs["timeout"] = const_TIMEOUT
414 kwargs['reply_handler'] = callback 592 kwargs["reply_handler"] = callback
415 kwargs['error_handler'] = error_handler 593 kwargs["error_handler"] = error_handler
416 return str(self.db_core_iface.image_check(arg_0, **kwargs)) 594 return str(self.db_core_iface.image_check(arg_0, **kwargs))
417 595
418 def image_convert(self, source, dest, arg_2, extra, callback=None, errback=None): 596 def image_convert(self, source, dest, arg_2, extra, callback=None, errback=None):
419 if callback is None: 597 if callback is None:
420 error_handler = None 598 error_handler = None
421 else: 599 else:
422 if errback is None: 600 if errback is None:
423 errback = log.error 601 errback = log.error
424 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 602 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
425 return str(self.db_core_iface.image_convert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 603 return str(
426 604 self.db_core_iface.image_convert(
427 def image_generate_preview(self, image_path, profile_key, callback=None, errback=None): 605 source,
428 if callback is None: 606 dest,
429 error_handler = None 607 arg_2,
430 else: 608 extra,
431 if errback is None: 609 timeout=const_TIMEOUT,
432 errback = log.error 610 reply_handler=callback,
433 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 611 error_handler=error_handler,
434 return str(self.db_core_iface.image_generate_preview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 612 )
613 )
614
615 def image_generate_preview(
616 self, image_path, profile_key, callback=None, errback=None
617 ):
618 if callback is None:
619 error_handler = None
620 else:
621 if errback is None:
622 errback = log.error
623 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
624 return str(
625 self.db_core_iface.image_generate_preview(
626 image_path,
627 profile_key,
628 timeout=const_TIMEOUT,
629 reply_handler=callback,
630 error_handler=error_handler,
631 )
632 )
435 633
436 def image_resize(self, image_path, width, height, callback=None, errback=None): 634 def image_resize(self, image_path, width, height, callback=None, errback=None):
437 if callback is None: 635 if callback is None:
438 error_handler = None 636 error_handler = None
439 else: 637 else:
440 if errback is None: 638 if errback is None:
441 errback = log.error 639 errback = log.error
442 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 640 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
443 return str(self.db_core_iface.image_resize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 641 return str(
642 self.db_core_iface.image_resize(
643 image_path,
644 width,
645 height,
646 timeout=const_TIMEOUT,
647 reply_handler=callback,
648 error_handler=error_handler,
649 )
650 )
444 651
445 def init_pre_script(self, callback=None, errback=None): 652 def init_pre_script(self, callback=None, errback=None):
446 if callback is None: 653 if callback is None:
447 error_handler = None 654 error_handler = None
448 else: 655 else:
449 if errback is None: 656 if errback is None:
450 errback = log.error 657 errback = log.error
451 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 658 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
452 return self.db_core_iface.init_pre_script(timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 659 return self.db_core_iface.init_pre_script(
660 timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler
661 )
453 662
454 def is_connected(self, profile_key="@DEFAULT@", callback=None, errback=None): 663 def is_connected(self, profile_key="@DEFAULT@", callback=None, errback=None):
455 if callback is None: 664 if callback is None:
456 error_handler = None 665 error_handler = None
457 else: 666 else:
458 if errback is None: 667 if errback is None:
459 errback = log.error 668 errback = log.error
460 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 669 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
461 kwargs={} 670 kwargs = {}
462 if callback is not None: 671 if callback is not None:
463 kwargs['timeout'] = const_TIMEOUT 672 kwargs["timeout"] = const_TIMEOUT
464 kwargs['reply_handler'] = callback 673 kwargs["reply_handler"] = callback
465 kwargs['error_handler'] = error_handler 674 kwargs["error_handler"] = error_handler
466 return self.db_core_iface.is_connected(profile_key, **kwargs) 675 return self.db_core_iface.is_connected(profile_key, **kwargs)
467 676
468 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None): 677 def main_resource_get(
469 if callback is None: 678 self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None
470 error_handler = None 679 ):
471 else: 680 if callback is None:
472 if errback is None: 681 error_handler = None
473 errback = log.error 682 else:
474 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 683 if errback is None:
475 kwargs={} 684 errback = log.error
476 if callback is not None: 685 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
477 kwargs['timeout'] = const_TIMEOUT 686 kwargs = {}
478 kwargs['reply_handler'] = callback 687 if callback is not None:
479 kwargs['error_handler'] = error_handler 688 kwargs["timeout"] = const_TIMEOUT
480 return str(self.db_core_iface.main_resource_get(contact_jid, profile_key, **kwargs)) 689 kwargs["reply_handler"] = callback
690 kwargs["error_handler"] = error_handler
691 return str(
692 self.db_core_iface.main_resource_get(contact_jid, profile_key, **kwargs)
693 )
481 694
482 def menu_help_get(self, menu_id, language, callback=None, errback=None): 695 def menu_help_get(self, menu_id, language, callback=None, errback=None):
483 if callback is None: 696 if callback is None:
484 error_handler = None 697 error_handler = None
485 else: 698 else:
486 if errback is None: 699 if errback is None:
487 errback = log.error 700 errback = log.error
488 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 701 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
489 kwargs={} 702 kwargs = {}
490 if callback is not None: 703 if callback is not None:
491 kwargs['timeout'] = const_TIMEOUT 704 kwargs["timeout"] = const_TIMEOUT
492 kwargs['reply_handler'] = callback 705 kwargs["reply_handler"] = callback
493 kwargs['error_handler'] = error_handler 706 kwargs["error_handler"] = error_handler
494 return str(self.db_core_iface.menu_help_get(menu_id, language, **kwargs)) 707 return str(self.db_core_iface.menu_help_get(menu_id, language, **kwargs))
495 708
496 def menu_launch(self, menu_type, path, data, security_limit, profile_key, callback=None, errback=None): 709 def menu_launch(
497 if callback is None: 710 self,
498 error_handler = None 711 menu_type,
499 else: 712 path,
500 if errback is None: 713 data,
501 errback = log.error 714 security_limit,
502 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 715 profile_key,
503 return self.db_core_iface.menu_launch(menu_type, path, data, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 716 callback=None,
717 errback=None,
718 ):
719 if callback is None:
720 error_handler = None
721 else:
722 if errback is None:
723 errback = log.error
724 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
725 return self.db_core_iface.menu_launch(
726 menu_type,
727 path,
728 data,
729 security_limit,
730 profile_key,
731 timeout=const_TIMEOUT,
732 reply_handler=callback,
733 error_handler=error_handler,
734 )
504 735
505 def menus_get(self, language, security_limit, callback=None, errback=None): 736 def menus_get(self, language, security_limit, callback=None, errback=None):
506 if callback is None: 737 if callback is None:
507 error_handler = None 738 error_handler = None
508 else: 739 else:
509 if errback is None: 740 if errback is None:
510 errback = log.error 741 errback = log.error
511 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 742 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
512 kwargs={} 743 kwargs = {}
513 if callback is not None: 744 if callback is not None:
514 kwargs['timeout'] = const_TIMEOUT 745 kwargs["timeout"] = const_TIMEOUT
515 kwargs['reply_handler'] = callback 746 kwargs["reply_handler"] = callback
516 kwargs['error_handler'] = error_handler 747 kwargs["error_handler"] = error_handler
517 return self.db_core_iface.menus_get(language, security_limit, **kwargs) 748 return self.db_core_iface.menus_get(language, security_limit, **kwargs)
518 749
519 def message_encryption_get(self, to_jid, profile_key, callback=None, errback=None): 750 def message_encryption_get(self, to_jid, profile_key, callback=None, errback=None):
520 if callback is None: 751 if callback is None:
521 error_handler = None 752 error_handler = None
522 else: 753 else:
523 if errback is None: 754 if errback is None:
524 errback = log.error 755 errback = log.error
525 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 756 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
526 kwargs={} 757 kwargs = {}
527 if callback is not None: 758 if callback is not None:
528 kwargs['timeout'] = const_TIMEOUT 759 kwargs["timeout"] = const_TIMEOUT
529 kwargs['reply_handler'] = callback 760 kwargs["reply_handler"] = callback
530 kwargs['error_handler'] = error_handler 761 kwargs["error_handler"] = error_handler
531 return str(self.db_core_iface.message_encryption_get(to_jid, profile_key, **kwargs)) 762 return str(
532 763 self.db_core_iface.message_encryption_get(to_jid, profile_key, **kwargs)
533 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@", callback=None, errback=None): 764 )
534 if callback is None: 765
535 error_handler = None 766 def message_encryption_start(
536 else: 767 self,
537 if errback is None: 768 to_jid,
538 errback = log.error 769 namespace="",
539 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 770 replace=False,
540 return self.db_core_iface.message_encryption_start(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 771 profile_key="@NONE@",
772 callback=None,
773 errback=None,
774 ):
775 if callback is None:
776 error_handler = None
777 else:
778 if errback is None:
779 errback = log.error
780 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
781 return self.db_core_iface.message_encryption_start(
782 to_jid,
783 namespace,
784 replace,
785 profile_key,
786 timeout=const_TIMEOUT,
787 reply_handler=callback,
788 error_handler=error_handler,
789 )
541 790
542 def message_encryption_stop(self, to_jid, profile_key, callback=None, errback=None): 791 def message_encryption_stop(self, to_jid, profile_key, callback=None, errback=None):
543 if callback is None: 792 if callback is None:
544 error_handler = None 793 error_handler = None
545 else: 794 else:
546 if errback is None: 795 if errback is None:
547 errback = log.error 796 errback = log.error
548 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 797 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
549 return self.db_core_iface.message_encryption_stop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 798 return self.db_core_iface.message_encryption_stop(
550 799 to_jid,
551 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@", callback=None, errback=None): 800 profile_key,
552 if callback is None: 801 timeout=const_TIMEOUT,
553 error_handler = None 802 reply_handler=callback,
554 else: 803 error_handler=error_handler,
555 if errback is None: 804 )
556 errback = log.error 805
557 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 806 def message_send(
558 return self.db_core_iface.message_send(to_jid, message, subject, mess_type, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 807 self,
808 to_jid,
809 message,
810 subject={},
811 mess_type="auto",
812 extra={},
813 profile_key="@NONE@",
814 callback=None,
815 errback=None,
816 ):
817 if callback is None:
818 error_handler = None
819 else:
820 if errback is None:
821 errback = log.error
822 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
823 return self.db_core_iface.message_send(
824 to_jid,
825 message,
826 subject,
827 mess_type,
828 extra,
829 profile_key,
830 timeout=const_TIMEOUT,
831 reply_handler=callback,
832 error_handler=error_handler,
833 )
559 834
560 def namespaces_get(self, callback=None, errback=None): 835 def namespaces_get(self, callback=None, errback=None):
561 if callback is None: 836 if callback is None:
562 error_handler = None 837 error_handler = None
563 else: 838 else:
564 if errback is None: 839 if errback is None:
565 errback = log.error 840 errback = log.error
566 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 841 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
567 kwargs={} 842 kwargs = {}
568 if callback is not None: 843 if callback is not None:
569 kwargs['timeout'] = const_TIMEOUT 844 kwargs["timeout"] = const_TIMEOUT
570 kwargs['reply_handler'] = callback 845 kwargs["reply_handler"] = callback
571 kwargs['error_handler'] = error_handler 846 kwargs["error_handler"] = error_handler
572 return self.db_core_iface.namespaces_get(**kwargs) 847 return self.db_core_iface.namespaces_get(**kwargs)
573 848
574 def notification_add(self, type_, body_plain, body_rich, title, is_global, requires_action, arg_6, priority, expire_at, extra, callback=None, errback=None): 849 def notification_add(
575 if callback is None: 850 self,
576 error_handler = None 851 type_,
577 else: 852 body_plain,
578 if errback is None: 853 body_rich,
579 errback = log.error 854 title,
580 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 855 is_global,
581 kwargs={} 856 requires_action,
582 if callback is not None: 857 arg_6,
583 kwargs['timeout'] = const_TIMEOUT 858 priority,
584 kwargs['reply_handler'] = callback 859 expire_at,
585 kwargs['error_handler'] = error_handler 860 extra,
586 return self.db_core_iface.notification_add(type_, body_plain, body_rich, title, is_global, requires_action, arg_6, priority, expire_at, extra, **kwargs) 861 callback=None,
587 862 errback=None,
588 def notification_delete(self, id_, is_global, profile_key, callback=None, errback=None): 863 ):
589 if callback is None: 864 if callback is None:
590 error_handler = None 865 error_handler = None
591 else: 866 else:
592 if errback is None: 867 if errback is None:
593 errback = log.error 868 errback = log.error
594 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 869 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
595 kwargs={} 870 kwargs = {}
596 if callback is not None: 871 if callback is not None:
597 kwargs['timeout'] = const_TIMEOUT 872 kwargs["timeout"] = const_TIMEOUT
598 kwargs['reply_handler'] = callback 873 kwargs["reply_handler"] = callback
599 kwargs['error_handler'] = error_handler 874 kwargs["error_handler"] = error_handler
600 return self.db_core_iface.notification_delete(id_, is_global, profile_key, **kwargs) 875 return self.db_core_iface.notification_add(
601 876 type_,
602 def notifications_expired_clean(self, limit_timestamp, profile_key, callback=None, errback=None): 877 body_plain,
603 if callback is None: 878 body_rich,
604 error_handler = None 879 title,
605 else: 880 is_global,
606 if errback is None: 881 requires_action,
607 errback = log.error 882 arg_6,
608 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 883 priority,
609 kwargs={} 884 expire_at,
610 if callback is not None: 885 extra,
611 kwargs['timeout'] = const_TIMEOUT 886 **kwargs,
612 kwargs['reply_handler'] = callback 887 )
613 kwargs['error_handler'] = error_handler 888
614 return self.db_core_iface.notifications_expired_clean(limit_timestamp, profile_key, **kwargs) 889 def notification_delete(
890 self, id_, is_global, profile_key, callback=None, errback=None
891 ):
892 if callback is None:
893 error_handler = None
894 else:
895 if errback is None:
896 errback = log.error
897 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
898 kwargs = {}
899 if callback is not None:
900 kwargs["timeout"] = const_TIMEOUT
901 kwargs["reply_handler"] = callback
902 kwargs["error_handler"] = error_handler
903 return self.db_core_iface.notification_delete(
904 id_, is_global, profile_key, **kwargs
905 )
906
907 def notifications_expired_clean(
908 self, limit_timestamp, profile_key, callback=None, errback=None
909 ):
910 if callback is None:
911 error_handler = None
912 else:
913 if errback is None:
914 errback = log.error
915 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
916 kwargs = {}
917 if callback is not None:
918 kwargs["timeout"] = const_TIMEOUT
919 kwargs["reply_handler"] = callback
920 kwargs["error_handler"] = error_handler
921 return self.db_core_iface.notifications_expired_clean(
922 limit_timestamp, profile_key, **kwargs
923 )
615 924
616 def notifications_get(self, filters, profile_key, callback=None, errback=None): 925 def notifications_get(self, filters, profile_key, callback=None, errback=None):
617 if callback is None: 926 if callback is None:
618 error_handler = None 927 error_handler = None
619 else: 928 else:
620 if errback is None: 929 if errback is None:
621 errback = log.error 930 errback = log.error
622 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 931 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
623 kwargs={} 932 kwargs = {}
624 if callback is not None: 933 if callback is not None:
625 kwargs['timeout'] = const_TIMEOUT 934 kwargs["timeout"] = const_TIMEOUT
626 kwargs['reply_handler'] = callback 935 kwargs["reply_handler"] = callback
627 kwargs['error_handler'] = error_handler 936 kwargs["error_handler"] = error_handler
628 return str(self.db_core_iface.notifications_get(filters, profile_key, **kwargs)) 937 return str(self.db_core_iface.notifications_get(filters, profile_key, **kwargs))
629 938
630 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@", callback=None, errback=None): 939 def param_get_a(
631 if callback is None: 940 self,
632 error_handler = None 941 name,
633 else: 942 category,
634 if errback is None: 943 attribute="value",
635 errback = log.error 944 profile_key="@DEFAULT@",
636 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 945 callback=None,
637 kwargs={} 946 errback=None,
638 if callback is not None: 947 ):
639 kwargs['timeout'] = const_TIMEOUT 948 if callback is None:
640 kwargs['reply_handler'] = callback 949 error_handler = None
641 kwargs['error_handler'] = error_handler 950 else:
642 return str(self.db_core_iface.param_get_a(name, category, attribute, profile_key, **kwargs)) 951 if errback is None:
643 952 errback = log.error
644 def param_get_a_async(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None): 953 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
645 if callback is None: 954 kwargs = {}
646 error_handler = None 955 if callback is not None:
647 else: 956 kwargs["timeout"] = const_TIMEOUT
648 if errback is None: 957 kwargs["reply_handler"] = callback
649 errback = log.error 958 kwargs["error_handler"] = error_handler
650 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 959 return str(
651 return str(self.db_core_iface.param_get_a_async(name, category, attribute, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 960 self.db_core_iface.param_get_a(
652 961 name, category, attribute, profile_key, **kwargs
653 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None): 962 )
654 if callback is None: 963 )
655 error_handler = None 964
656 else: 965 def param_get_a_async(
657 if errback is None: 966 self,
658 errback = log.error 967 name,
659 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 968 category,
660 kwargs={} 969 attribute="value",
661 if callback is not None: 970 security_limit=-1,
662 kwargs['timeout'] = const_TIMEOUT 971 profile_key="@DEFAULT@",
663 kwargs['reply_handler'] = callback 972 callback=None,
664 kwargs['error_handler'] = error_handler 973 errback=None,
665 return self.db_core_iface.param_set(name, value, category, security_limit, profile_key, **kwargs) 974 ):
666 975 if callback is None:
667 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@", callback=None, errback=None): 976 error_handler = None
668 if callback is None: 977 else:
669 error_handler = None 978 if errback is None:
670 else: 979 errback = log.error
671 if errback is None: 980 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
672 errback = log.error 981 return str(
673 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 982 self.db_core_iface.param_get_a_async(
674 return str(self.db_core_iface.param_ui_get(security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 983 name,
984 category,
985 attribute,
986 security_limit,
987 profile_key,
988 timeout=const_TIMEOUT,
989 reply_handler=callback,
990 error_handler=error_handler,
991 )
992 )
993
994 def param_set(
995 self,
996 name,
997 value,
998 category,
999 security_limit=-1,
1000 profile_key="@DEFAULT@",
1001 callback=None,
1002 errback=None,
1003 ):
1004 if callback is None:
1005 error_handler = None
1006 else:
1007 if errback is None:
1008 errback = log.error
1009 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1010 kwargs = {}
1011 if callback is not None:
1012 kwargs["timeout"] = const_TIMEOUT
1013 kwargs["reply_handler"] = callback
1014 kwargs["error_handler"] = error_handler
1015 return self.db_core_iface.param_set(
1016 name, value, category, security_limit, profile_key, **kwargs
1017 )
1018
1019 def param_ui_get(
1020 self,
1021 security_limit=-1,
1022 app="",
1023 extra="",
1024 profile_key="@DEFAULT@",
1025 callback=None,
1026 errback=None,
1027 ):
1028 if callback is None:
1029 error_handler = None
1030 else:
1031 if errback is None:
1032 errback = log.error
1033 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1034 return str(
1035 self.db_core_iface.param_ui_get(
1036 security_limit,
1037 app,
1038 extra,
1039 profile_key,
1040 timeout=const_TIMEOUT,
1041 reply_handler=callback,
1042 error_handler=error_handler,
1043 )
1044 )
675 1045
676 def params_categories_get(self, callback=None, errback=None): 1046 def params_categories_get(self, callback=None, errback=None):
677 if callback is None: 1047 if callback is None:
678 error_handler = None 1048 error_handler = None
679 else: 1049 else:
680 if errback is None: 1050 if errback is None:
681 errback = log.error 1051 errback = log.error
682 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1052 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
683 kwargs={} 1053 kwargs = {}
684 if callback is not None: 1054 if callback is not None:
685 kwargs['timeout'] = const_TIMEOUT 1055 kwargs["timeout"] = const_TIMEOUT
686 kwargs['reply_handler'] = callback 1056 kwargs["reply_handler"] = callback
687 kwargs['error_handler'] = error_handler 1057 kwargs["error_handler"] = error_handler
688 return self.db_core_iface.params_categories_get(**kwargs) 1058 return self.db_core_iface.params_categories_get(**kwargs)
689 1059
690 def params_register_app(self, xml, security_limit=-1, app='', callback=None, errback=None): 1060 def params_register_app(
691 if callback is None: 1061 self, xml, security_limit=-1, app="", callback=None, errback=None
692 error_handler = None 1062 ):
693 else: 1063 if callback is None:
694 if errback is None: 1064 error_handler = None
695 errback = log.error 1065 else:
696 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1066 if errback is None:
697 kwargs={} 1067 errback = log.error
698 if callback is not None: 1068 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
699 kwargs['timeout'] = const_TIMEOUT 1069 kwargs = {}
700 kwargs['reply_handler'] = callback 1070 if callback is not None:
701 kwargs['error_handler'] = error_handler 1071 kwargs["timeout"] = const_TIMEOUT
1072 kwargs["reply_handler"] = callback
1073 kwargs["error_handler"] = error_handler
702 return self.db_core_iface.params_register_app(xml, security_limit, app, **kwargs) 1074 return self.db_core_iface.params_register_app(xml, security_limit, app, **kwargs)
703 1075
704 def params_template_load(self, filename, callback=None, errback=None): 1076 def params_template_load(self, filename, callback=None, errback=None):
705 if callback is None: 1077 if callback is None:
706 error_handler = None 1078 error_handler = None
707 else: 1079 else:
708 if errback is None: 1080 if errback is None:
709 errback = log.error 1081 errback = log.error
710 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1082 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
711 kwargs={} 1083 kwargs = {}
712 if callback is not None: 1084 if callback is not None:
713 kwargs['timeout'] = const_TIMEOUT 1085 kwargs["timeout"] = const_TIMEOUT
714 kwargs['reply_handler'] = callback 1086 kwargs["reply_handler"] = callback
715 kwargs['error_handler'] = error_handler 1087 kwargs["error_handler"] = error_handler
716 return self.db_core_iface.params_template_load(filename, **kwargs) 1088 return self.db_core_iface.params_template_load(filename, **kwargs)
717 1089
718 def params_template_save(self, filename, callback=None, errback=None): 1090 def params_template_save(self, filename, callback=None, errback=None):
719 if callback is None: 1091 if callback is None:
720 error_handler = None 1092 error_handler = None
721 else: 1093 else:
722 if errback is None: 1094 if errback is None:
723 errback = log.error 1095 errback = log.error
724 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1096 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
725 kwargs={} 1097 kwargs = {}
726 if callback is not None: 1098 if callback is not None:
727 kwargs['timeout'] = const_TIMEOUT 1099 kwargs["timeout"] = const_TIMEOUT
728 kwargs['reply_handler'] = callback 1100 kwargs["reply_handler"] = callback
729 kwargs['error_handler'] = error_handler 1101 kwargs["error_handler"] = error_handler
730 return self.db_core_iface.params_template_save(filename, **kwargs) 1102 return self.db_core_iface.params_template_save(filename, **kwargs)
731 1103
732 def params_values_from_category_get_async(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@", callback=None, errback=None): 1104 def params_values_from_category_get_async(
733 if callback is None: 1105 self,
734 error_handler = None 1106 category,
735 else: 1107 security_limit=-1,
736 if errback is None: 1108 app="",
737 errback = log.error 1109 extra="",
738 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1110 profile_key="@DEFAULT@",
739 return self.db_core_iface.params_values_from_category_get_async(category, security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1111 callback=None,
740 1112 errback=None,
741 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@", callback=None, errback=None): 1113 ):
742 if callback is None: 1114 if callback is None:
743 error_handler = None 1115 error_handler = None
744 else: 1116 else:
745 if errback is None: 1117 if errback is None:
746 errback = log.error 1118 errback = log.error
747 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1119 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
748 kwargs={} 1120 return self.db_core_iface.params_values_from_category_get_async(
749 if callback is not None: 1121 category,
750 kwargs['timeout'] = const_TIMEOUT 1122 security_limit,
751 kwargs['reply_handler'] = callback 1123 app,
752 kwargs['error_handler'] = error_handler 1124 extra,
753 return self.db_core_iface.presence_set(to_jid, show, statuses, profile_key, **kwargs) 1125 profile_key,
1126 timeout=const_TIMEOUT,
1127 reply_handler=callback,
1128 error_handler=error_handler,
1129 )
1130
1131 def presence_set(
1132 self,
1133 to_jid="",
1134 show="",
1135 statuses={},
1136 profile_key="@DEFAULT@",
1137 callback=None,
1138 errback=None,
1139 ):
1140 if callback is None:
1141 error_handler = None
1142 else:
1143 if errback is None:
1144 errback = log.error
1145 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1146 kwargs = {}
1147 if callback is not None:
1148 kwargs["timeout"] = const_TIMEOUT
1149 kwargs["reply_handler"] = callback
1150 kwargs["error_handler"] = error_handler
1151 return self.db_core_iface.presence_set(
1152 to_jid, show, statuses, profile_key, **kwargs
1153 )
754 1154
755 def presence_statuses_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 1155 def presence_statuses_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
756 if callback is None: 1156 if callback is None:
757 error_handler = None 1157 error_handler = None
758 else: 1158 else:
759 if errback is None: 1159 if errback is None:
760 errback = log.error 1160 errback = log.error
761 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1161 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
762 kwargs={} 1162 kwargs = {}
763 if callback is not None: 1163 if callback is not None:
764 kwargs['timeout'] = const_TIMEOUT 1164 kwargs["timeout"] = const_TIMEOUT
765 kwargs['reply_handler'] = callback 1165 kwargs["reply_handler"] = callback
766 kwargs['error_handler'] = error_handler 1166 kwargs["error_handler"] = error_handler
767 return self.db_core_iface.presence_statuses_get(profile_key, **kwargs) 1167 return self.db_core_iface.presence_statuses_get(profile_key, **kwargs)
768 1168
769 def private_data_delete(self, namespace, key, arg_2, callback=None, errback=None): 1169 def private_data_delete(self, namespace, key, arg_2, callback=None, errback=None):
770 if callback is None: 1170 if callback is None:
771 error_handler = None 1171 error_handler = None
772 else: 1172 else:
773 if errback is None: 1173 if errback is None:
774 errback = log.error 1174 errback = log.error
775 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1175 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
776 return self.db_core_iface.private_data_delete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1176 return self.db_core_iface.private_data_delete(
1177 namespace,
1178 key,
1179 arg_2,
1180 timeout=const_TIMEOUT,
1181 reply_handler=callback,
1182 error_handler=error_handler,
1183 )
777 1184
778 def private_data_get(self, namespace, key, profile_key, callback=None, errback=None): 1185 def private_data_get(self, namespace, key, profile_key, callback=None, errback=None):
779 if callback is None: 1186 if callback is None:
780 error_handler = None 1187 error_handler = None
781 else: 1188 else:
782 if errback is None: 1189 if errback is None:
783 errback = log.error 1190 errback = log.error
784 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1191 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
785 return str(self.db_core_iface.private_data_get(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 1192 return str(
786 1193 self.db_core_iface.private_data_get(
787 def private_data_set(self, namespace, key, data, profile_key, callback=None, errback=None): 1194 namespace,
788 if callback is None: 1195 key,
789 error_handler = None 1196 profile_key,
790 else: 1197 timeout=const_TIMEOUT,
791 if errback is None: 1198 reply_handler=callback,
792 errback = log.error 1199 error_handler=error_handler,
793 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1200 )
794 return self.db_core_iface.private_data_set(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1201 )
795 1202
796 def profile_create(self, profile, password='', component='', callback=None, errback=None): 1203 def private_data_set(
797 if callback is None: 1204 self, namespace, key, data, profile_key, callback=None, errback=None
798 error_handler = None 1205 ):
799 else: 1206 if callback is None:
800 if errback is None: 1207 error_handler = None
801 errback = log.error 1208 else:
802 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1209 if errback is None:
803 return self.db_core_iface.profile_create(profile, password, component, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1210 errback = log.error
1211 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1212 return self.db_core_iface.private_data_set(
1213 namespace,
1214 key,
1215 data,
1216 profile_key,
1217 timeout=const_TIMEOUT,
1218 reply_handler=callback,
1219 error_handler=error_handler,
1220 )
1221
1222 def profile_create(
1223 self, profile, password="", component="", callback=None, errback=None
1224 ):
1225 if callback is None:
1226 error_handler = None
1227 else:
1228 if errback is None:
1229 errback = log.error
1230 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1231 return self.db_core_iface.profile_create(
1232 profile,
1233 password,
1234 component,
1235 timeout=const_TIMEOUT,
1236 reply_handler=callback,
1237 error_handler=error_handler,
1238 )
804 1239
805 def profile_delete_async(self, profile, callback=None, errback=None): 1240 def profile_delete_async(self, profile, callback=None, errback=None):
806 if callback is None: 1241 if callback is None:
807 error_handler = None 1242 error_handler = None
808 else: 1243 else:
809 if errback is None: 1244 if errback is None:
810 errback = log.error 1245 errback = log.error
811 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1246 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
812 return self.db_core_iface.profile_delete_async(profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1247 return self.db_core_iface.profile_delete_async(
813 1248 profile,
814 def profile_is_session_started(self, profile_key="@DEFAULT@", callback=None, errback=None): 1249 timeout=const_TIMEOUT,
815 if callback is None: 1250 reply_handler=callback,
816 error_handler = None 1251 error_handler=error_handler,
817 else: 1252 )
818 if errback is None: 1253
819 errback = log.error 1254 def profile_is_session_started(
820 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1255 self, profile_key="@DEFAULT@", callback=None, errback=None
821 kwargs={} 1256 ):
822 if callback is not None: 1257 if callback is None:
823 kwargs['timeout'] = const_TIMEOUT 1258 error_handler = None
824 kwargs['reply_handler'] = callback 1259 else:
825 kwargs['error_handler'] = error_handler 1260 if errback is None:
1261 errback = log.error
1262 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1263 kwargs = {}
1264 if callback is not None:
1265 kwargs["timeout"] = const_TIMEOUT
1266 kwargs["reply_handler"] = callback
1267 kwargs["error_handler"] = error_handler
826 return self.db_core_iface.profile_is_session_started(profile_key, **kwargs) 1268 return self.db_core_iface.profile_is_session_started(profile_key, **kwargs)
827 1269
828 def profile_name_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 1270 def profile_name_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
829 if callback is None: 1271 if callback is None:
830 error_handler = None 1272 error_handler = None
831 else: 1273 else:
832 if errback is None: 1274 if errback is None:
833 errback = log.error 1275 errback = log.error
834 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1276 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
835 kwargs={} 1277 kwargs = {}
836 if callback is not None: 1278 if callback is not None:
837 kwargs['timeout'] = const_TIMEOUT 1279 kwargs["timeout"] = const_TIMEOUT
838 kwargs['reply_handler'] = callback 1280 kwargs["reply_handler"] = callback
839 kwargs['error_handler'] = error_handler 1281 kwargs["error_handler"] = error_handler
840 return str(self.db_core_iface.profile_name_get(profile_key, **kwargs)) 1282 return str(self.db_core_iface.profile_name_get(profile_key, **kwargs))
841 1283
842 def profile_set_default(self, profile, callback=None, errback=None): 1284 def profile_set_default(self, profile, callback=None, errback=None):
843 if callback is None: 1285 if callback is None:
844 error_handler = None 1286 error_handler = None
845 else: 1287 else:
846 if errback is None: 1288 if errback is None:
847 errback = log.error 1289 errback = log.error
848 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1290 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
849 kwargs={} 1291 kwargs = {}
850 if callback is not None: 1292 if callback is not None:
851 kwargs['timeout'] = const_TIMEOUT 1293 kwargs["timeout"] = const_TIMEOUT
852 kwargs['reply_handler'] = callback 1294 kwargs["reply_handler"] = callback
853 kwargs['error_handler'] = error_handler 1295 kwargs["error_handler"] = error_handler
854 return self.db_core_iface.profile_set_default(profile, **kwargs) 1296 return self.db_core_iface.profile_set_default(profile, **kwargs)
855 1297
856 def profile_start_session(self, password='', profile_key="@DEFAULT@", callback=None, errback=None): 1298 def profile_start_session(
857 if callback is None: 1299 self, password="", profile_key="@DEFAULT@", callback=None, errback=None
858 error_handler = None 1300 ):
859 else: 1301 if callback is None:
860 if errback is None: 1302 error_handler = None
861 errback = log.error 1303 else:
862 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1304 if errback is None:
863 return self.db_core_iface.profile_start_session(password, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1305 errback = log.error
864 1306 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
865 def profiles_list_get(self, clients=True, components=False, callback=None, errback=None): 1307 return self.db_core_iface.profile_start_session(
866 if callback is None: 1308 password,
867 error_handler = None 1309 profile_key,
868 else: 1310 timeout=const_TIMEOUT,
869 if errback is None: 1311 reply_handler=callback,
870 errback = log.error 1312 error_handler=error_handler,
871 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1313 )
872 kwargs={} 1314
873 if callback is not None: 1315 def profiles_list_get(
874 kwargs['timeout'] = const_TIMEOUT 1316 self, clients=True, components=False, callback=None, errback=None
875 kwargs['reply_handler'] = callback 1317 ):
876 kwargs['error_handler'] = error_handler 1318 if callback is None:
1319 error_handler = None
1320 else:
1321 if errback is None:
1322 errback = log.error
1323 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
1324 kwargs = {}
1325 if callback is not None:
1326 kwargs["timeout"] = const_TIMEOUT
1327 kwargs["reply_handler"] = callback
1328 kwargs["error_handler"] = error_handler
877 return self.db_core_iface.profiles_list_get(clients, components, **kwargs) 1329 return self.db_core_iface.profiles_list_get(clients, components, **kwargs)
878 1330
879 def progress_get(self, id, profile, callback=None, errback=None): 1331 def progress_get(self, id, profile, callback=None, errback=None):
880 if callback is None: 1332 if callback is None:
881 error_handler = None 1333 error_handler = None
882 else: 1334 else:
883 if errback is None: 1335 if errback is None:
884 errback = log.error 1336 errback = log.error
885 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1337 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
886 kwargs={} 1338 kwargs = {}
887 if callback is not None: 1339 if callback is not None:
888 kwargs['timeout'] = const_TIMEOUT 1340 kwargs["timeout"] = const_TIMEOUT
889 kwargs['reply_handler'] = callback 1341 kwargs["reply_handler"] = callback
890 kwargs['error_handler'] = error_handler 1342 kwargs["error_handler"] = error_handler
891 return self.db_core_iface.progress_get(id, profile, **kwargs) 1343 return self.db_core_iface.progress_get(id, profile, **kwargs)
892 1344
893 def progress_get_all(self, profile, callback=None, errback=None): 1345 def progress_get_all(self, profile, callback=None, errback=None):
894 if callback is None: 1346 if callback is None:
895 error_handler = None 1347 error_handler = None
896 else: 1348 else:
897 if errback is None: 1349 if errback is None:
898 errback = log.error 1350 errback = log.error
899 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1351 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
900 kwargs={} 1352 kwargs = {}
901 if callback is not None: 1353 if callback is not None:
902 kwargs['timeout'] = const_TIMEOUT 1354 kwargs["timeout"] = const_TIMEOUT
903 kwargs['reply_handler'] = callback 1355 kwargs["reply_handler"] = callback
904 kwargs['error_handler'] = error_handler 1356 kwargs["error_handler"] = error_handler
905 return self.db_core_iface.progress_get_all(profile, **kwargs) 1357 return self.db_core_iface.progress_get_all(profile, **kwargs)
906 1358
907 def progress_get_all_metadata(self, profile, callback=None, errback=None): 1359 def progress_get_all_metadata(self, profile, callback=None, errback=None):
908 if callback is None: 1360 if callback is None:
909 error_handler = None 1361 error_handler = None
910 else: 1362 else:
911 if errback is None: 1363 if errback is None:
912 errback = log.error 1364 errback = log.error
913 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1365 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
914 kwargs={} 1366 kwargs = {}
915 if callback is not None: 1367 if callback is not None:
916 kwargs['timeout'] = const_TIMEOUT 1368 kwargs["timeout"] = const_TIMEOUT
917 kwargs['reply_handler'] = callback 1369 kwargs["reply_handler"] = callback
918 kwargs['error_handler'] = error_handler 1370 kwargs["error_handler"] = error_handler
919 return self.db_core_iface.progress_get_all_metadata(profile, **kwargs) 1371 return self.db_core_iface.progress_get_all_metadata(profile, **kwargs)
920 1372
921 def ready_get(self, callback=None, errback=None): 1373 def ready_get(self, callback=None, errback=None):
922 if callback is None: 1374 if callback is None:
923 error_handler = None 1375 error_handler = None
924 else: 1376 else:
925 if errback is None: 1377 if errback is None:
926 errback = log.error 1378 errback = log.error
927 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1379 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
928 return self.db_core_iface.ready_get(timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1380 return self.db_core_iface.ready_get(
1381 timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler
1382 )
929 1383
930 def roster_resync(self, profile_key="@DEFAULT@", callback=None, errback=None): 1384 def roster_resync(self, profile_key="@DEFAULT@", callback=None, errback=None):
931 if callback is None: 1385 if callback is None:
932 error_handler = None 1386 error_handler = None
933 else: 1387 else:
934 if errback is None: 1388 if errback is None:
935 errback = log.error 1389 errback = log.error
936 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1390 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
937 return self.db_core_iface.roster_resync(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1391 return self.db_core_iface.roster_resync(
1392 profile_key,
1393 timeout=const_TIMEOUT,
1394 reply_handler=callback,
1395 error_handler=error_handler,
1396 )
938 1397
939 def session_infos_get(self, profile_key, callback=None, errback=None): 1398 def session_infos_get(self, profile_key, callback=None, errback=None):
940 if callback is None: 1399 if callback is None:
941 error_handler = None 1400 error_handler = None
942 else: 1401 else:
943 if errback is None: 1402 if errback is None:
944 errback = log.error 1403 errback = log.error
945 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1404 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
946 return self.db_core_iface.session_infos_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1405 return self.db_core_iface.session_infos_get(
1406 profile_key,
1407 timeout=const_TIMEOUT,
1408 reply_handler=callback,
1409 error_handler=error_handler,
1410 )
947 1411
948 def sub_waiting_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 1412 def sub_waiting_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
949 if callback is None: 1413 if callback is None:
950 error_handler = None 1414 error_handler = None
951 else: 1415 else:
952 if errback is None: 1416 if errback is None:
953 errback = log.error 1417 errback = log.error
954 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1418 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
955 kwargs={} 1419 kwargs = {}
956 if callback is not None: 1420 if callback is not None:
957 kwargs['timeout'] = const_TIMEOUT 1421 kwargs["timeout"] = const_TIMEOUT
958 kwargs['reply_handler'] = callback 1422 kwargs["reply_handler"] = callback
959 kwargs['error_handler'] = error_handler 1423 kwargs["error_handler"] = error_handler
960 return self.db_core_iface.sub_waiting_get(profile_key, **kwargs) 1424 return self.db_core_iface.sub_waiting_get(profile_key, **kwargs)
961 1425
962 def subscription(self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None): 1426 def subscription(
963 if callback is None: 1427 self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None
964 error_handler = None 1428 ):
965 else: 1429 if callback is None:
966 if errback is None: 1430 error_handler = None
967 errback = log.error 1431 else:
968 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1432 if errback is None:
969 kwargs={} 1433 errback = log.error
970 if callback is not None: 1434 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
971 kwargs['timeout'] = const_TIMEOUT 1435 kwargs = {}
972 kwargs['reply_handler'] = callback 1436 if callback is not None:
973 kwargs['error_handler'] = error_handler 1437 kwargs["timeout"] = const_TIMEOUT
1438 kwargs["reply_handler"] = callback
1439 kwargs["error_handler"] = error_handler
974 return self.db_core_iface.subscription(sub_type, entity, profile_key, **kwargs) 1440 return self.db_core_iface.subscription(sub_type, entity, profile_key, **kwargs)
975 1441
976 def version_get(self, callback=None, errback=None): 1442 def version_get(self, callback=None, errback=None):
977 if callback is None: 1443 if callback is None:
978 error_handler = None 1444 error_handler = None
979 else: 1445 else:
980 if errback is None: 1446 if errback is None:
981 errback = log.error 1447 errback = log.error
982 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1448 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
983 kwargs={} 1449 kwargs = {}
984 if callback is not None: 1450 if callback is not None:
985 kwargs['timeout'] = const_TIMEOUT 1451 kwargs["timeout"] = const_TIMEOUT
986 kwargs['reply_handler'] = callback 1452 kwargs["reply_handler"] = callback
987 kwargs['error_handler'] = error_handler 1453 kwargs["error_handler"] = error_handler
988 return str(self.db_core_iface.version_get(**kwargs)) 1454 return str(self.db_core_iface.version_get(**kwargs))
989 1455
990 1456
991 class AIOBridge(bridge): 1457 class AIOBridge(bridge):
992 1458
993 def register_signal(self, functionName, handler, iface="core"): 1459 def register_signal(self, functionName, handler, iface="core"):
994 loop = asyncio.get_running_loop() 1460 loop = asyncio.get_running_loop()
995 async_handler = lambda *args: asyncio.run_coroutine_threadsafe(handler(*args), loop) 1461 async_handler = lambda *args: asyncio.run_coroutine_threadsafe(
1462 handler(*args), loop
1463 )
996 return super().register_signal(functionName, async_handler, iface) 1464 return super().register_signal(functionName, async_handler, iface)
997 1465
998 def __getattribute__(self, name): 1466 def __getattribute__(self, name):
999 """ usual __getattribute__ if the method exists, else try to find a plugin method """ 1467 """usual __getattribute__ if the method exists, else try to find a plugin method"""
1000 try: 1468 try:
1001 return object.__getattribute__(self, name) 1469 return object.__getattribute__(self, name)
1002 except AttributeError: 1470 except AttributeError:
1003 # The attribute is not found, we try the plugin proxy to find the requested method 1471 # The attribute is not found, we try the plugin proxy to find the requested method
1004 def get_plugin_method(*args, **kwargs): 1472 def get_plugin_method(*args, **kwargs):
1005 loop = asyncio.get_running_loop() 1473 loop = asyncio.get_running_loop()
1006 fut = loop.create_future() 1474 fut = loop.create_future()
1007 method = getattr(self.db_plugin_iface, name) 1475 method = getattr(self.db_plugin_iface, name)
1008 reply_handler = lambda ret=None: loop.call_soon_threadsafe( 1476 reply_handler = lambda ret=None: loop.call_soon_threadsafe(
1009 fut.set_result, ret) 1477 fut.set_result, ret
1478 )
1010 error_handler = lambda err: loop.call_soon_threadsafe( 1479 error_handler = lambda err: loop.call_soon_threadsafe(
1011 fut.set_exception, dbus_to_bridge_exception(err)) 1480 fut.set_exception, dbus_to_bridge_exception(err)
1481 )
1012 try: 1482 try:
1013 method( 1483 method(
1014 *args, 1484 *args,
1015 **kwargs, 1485 **kwargs,
1016 timeout=const_TIMEOUT, 1486 timeout=const_TIMEOUT,
1017 reply_handler=reply_handler, 1487 reply_handler=reply_handler,
1018 error_handler=error_handler 1488 error_handler=error_handler,
1019 ) 1489 )
1020 except ValueError as e: 1490 except ValueError as e:
1021 if e.args[0].startswith("Unable to guess signature"): 1491 if e.args[0].startswith("Unable to guess signature"):
1022 # same hack as for bridge.__getattribute__ 1492 # same hack as for bridge.__getattribute__
1023 log.warning("using hack to work around inspection issue") 1493 log.warning("using hack to work around inspection issue")
1028 self.db_plugin_iface.get_dbus_method(name)( 1498 self.db_plugin_iface.get_dbus_method(name)(
1029 *args, 1499 *args,
1030 **kwargs, 1500 **kwargs,
1031 timeout=const_TIMEOUT, 1501 timeout=const_TIMEOUT,
1032 reply_handler=reply_handler, 1502 reply_handler=reply_handler,
1033 error_handler=error_handler 1503 error_handler=error_handler,
1034 ) 1504 )
1035 1505
1036 else: 1506 else:
1037 raise e 1507 raise e
1038 return fut 1508 return fut
1042 def bridge_connect(self): 1512 def bridge_connect(self):
1043 loop = asyncio.get_running_loop() 1513 loop = asyncio.get_running_loop()
1044 fut = loop.create_future() 1514 fut = loop.create_future()
1045 super().bridge_connect( 1515 super().bridge_connect(
1046 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None), 1516 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None),
1047 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e) 1517 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e),
1048 ) 1518 )
1049 return fut 1519 return fut
1050 1520
1051 def action_launch(self, callback_id, data, profile_key="@DEFAULT@"): 1521 def action_launch(self, callback_id, data, profile_key="@DEFAULT@"):
1052 loop = asyncio.get_running_loop() 1522 loop = asyncio.get_running_loop()
1053 fut = loop.create_future() 1523 fut = loop.create_future()
1054 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1524 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1055 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1525 error_handler = lambda err: loop.call_soon_threadsafe(
1056 self.db_core_iface.action_launch(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1526 fut.set_exception, dbus_to_bridge_exception(err)
1527 )
1528 self.db_core_iface.action_launch(
1529 callback_id,
1530 data,
1531 profile_key,
1532 timeout=const_TIMEOUT,
1533 reply_handler=reply_handler,
1534 error_handler=error_handler,
1535 )
1057 return fut 1536 return fut
1058 1537
1059 def actions_get(self, profile_key="@DEFAULT@"): 1538 def actions_get(self, profile_key="@DEFAULT@"):
1060 loop = asyncio.get_running_loop() 1539 loop = asyncio.get_running_loop()
1061 fut = loop.create_future() 1540 fut = loop.create_future()
1062 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1541 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1063 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1542 error_handler = lambda err: loop.call_soon_threadsafe(
1064 self.db_core_iface.actions_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1543 fut.set_exception, dbus_to_bridge_exception(err)
1544 )
1545 self.db_core_iface.actions_get(
1546 profile_key,
1547 timeout=const_TIMEOUT,
1548 reply_handler=reply_handler,
1549 error_handler=error_handler,
1550 )
1065 return fut 1551 return fut
1066 1552
1067 def config_get(self, section, name): 1553 def config_get(self, section, name):
1068 loop = asyncio.get_running_loop() 1554 loop = asyncio.get_running_loop()
1069 fut = loop.create_future() 1555 fut = loop.create_future()
1070 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1556 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1071 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1557 error_handler = lambda err: loop.call_soon_threadsafe(
1072 self.db_core_iface.config_get(section, name, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1558 fut.set_exception, dbus_to_bridge_exception(err)
1073 return fut 1559 )
1074 1560 self.db_core_iface.config_get(
1075 def connect(self, profile_key="@DEFAULT@", password='', options={}): 1561 section,
1076 loop = asyncio.get_running_loop() 1562 name,
1077 fut = loop.create_future() 1563 timeout=const_TIMEOUT,
1078 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1564 reply_handler=reply_handler,
1079 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1565 error_handler=error_handler,
1080 self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1566 )
1567 return fut
1568
1569 def connect(self, profile_key="@DEFAULT@", password="", options={}):
1570 loop = asyncio.get_running_loop()
1571 fut = loop.create_future()
1572 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1573 error_handler = lambda err: loop.call_soon_threadsafe(
1574 fut.set_exception, dbus_to_bridge_exception(err)
1575 )
1576 self.db_core_iface.connect(
1577 profile_key,
1578 password,
1579 options,
1580 timeout=const_TIMEOUT,
1581 reply_handler=reply_handler,
1582 error_handler=error_handler,
1583 )
1081 return fut 1584 return fut
1082 1585
1083 def contact_add(self, entity_jid, profile_key="@DEFAULT@"): 1586 def contact_add(self, entity_jid, profile_key="@DEFAULT@"):
1084 loop = asyncio.get_running_loop() 1587 loop = asyncio.get_running_loop()
1085 fut = loop.create_future() 1588 fut = loop.create_future()
1086 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1589 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1087 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1590 error_handler = lambda err: loop.call_soon_threadsafe(
1088 self.db_core_iface.contact_add(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1591 fut.set_exception, dbus_to_bridge_exception(err)
1592 )
1593 self.db_core_iface.contact_add(
1594 entity_jid,
1595 profile_key,
1596 timeout=const_TIMEOUT,
1597 reply_handler=reply_handler,
1598 error_handler=error_handler,
1599 )
1089 return fut 1600 return fut
1090 1601
1091 def contact_del(self, entity_jid, profile_key="@DEFAULT@"): 1602 def contact_del(self, entity_jid, profile_key="@DEFAULT@"):
1092 loop = asyncio.get_running_loop() 1603 loop = asyncio.get_running_loop()
1093 fut = loop.create_future() 1604 fut = loop.create_future()
1094 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1605 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1095 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1606 error_handler = lambda err: loop.call_soon_threadsafe(
1096 self.db_core_iface.contact_del(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1607 fut.set_exception, dbus_to_bridge_exception(err)
1608 )
1609 self.db_core_iface.contact_del(
1610 entity_jid,
1611 profile_key,
1612 timeout=const_TIMEOUT,
1613 reply_handler=reply_handler,
1614 error_handler=error_handler,
1615 )
1097 return fut 1616 return fut
1098 1617
1099 def contact_get(self, arg_0, profile_key="@DEFAULT@"): 1618 def contact_get(self, arg_0, profile_key="@DEFAULT@"):
1100 loop = asyncio.get_running_loop() 1619 loop = asyncio.get_running_loop()
1101 fut = loop.create_future() 1620 fut = loop.create_future()
1102 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1621 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1103 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1622 error_handler = lambda err: loop.call_soon_threadsafe(
1104 self.db_core_iface.contact_get(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1623 fut.set_exception, dbus_to_bridge_exception(err)
1624 )
1625 self.db_core_iface.contact_get(
1626 arg_0,
1627 profile_key,
1628 timeout=const_TIMEOUT,
1629 reply_handler=reply_handler,
1630 error_handler=error_handler,
1631 )
1105 return fut 1632 return fut
1106 1633
1107 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"): 1634 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"):
1108 loop = asyncio.get_running_loop() 1635 loop = asyncio.get_running_loop()
1109 fut = loop.create_future() 1636 fut = loop.create_future()
1110 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1637 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1111 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1638 error_handler = lambda err: loop.call_soon_threadsafe(
1112 self.db_core_iface.contact_update(entity_jid, name, groups, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1639 fut.set_exception, dbus_to_bridge_exception(err)
1640 )
1641 self.db_core_iface.contact_update(
1642 entity_jid,
1643 name,
1644 groups,
1645 profile_key,
1646 timeout=const_TIMEOUT,
1647 reply_handler=reply_handler,
1648 error_handler=error_handler,
1649 )
1113 return fut 1650 return fut
1114 1651
1115 def contacts_get(self, profile_key="@DEFAULT@"): 1652 def contacts_get(self, profile_key="@DEFAULT@"):
1116 loop = asyncio.get_running_loop() 1653 loop = asyncio.get_running_loop()
1117 fut = loop.create_future() 1654 fut = loop.create_future()
1118 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1655 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1119 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1656 error_handler = lambda err: loop.call_soon_threadsafe(
1120 self.db_core_iface.contacts_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1657 fut.set_exception, dbus_to_bridge_exception(err)
1658 )
1659 self.db_core_iface.contacts_get(
1660 profile_key,
1661 timeout=const_TIMEOUT,
1662 reply_handler=reply_handler,
1663 error_handler=error_handler,
1664 )
1121 return fut 1665 return fut
1122 1666
1123 def contacts_get_from_group(self, group, profile_key="@DEFAULT@"): 1667 def contacts_get_from_group(self, group, profile_key="@DEFAULT@"):
1124 loop = asyncio.get_running_loop() 1668 loop = asyncio.get_running_loop()
1125 fut = loop.create_future() 1669 fut = loop.create_future()
1126 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1670 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1127 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1671 error_handler = lambda err: loop.call_soon_threadsafe(
1128 self.db_core_iface.contacts_get_from_group(group, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1672 fut.set_exception, dbus_to_bridge_exception(err)
1673 )
1674 self.db_core_iface.contacts_get_from_group(
1675 group,
1676 profile_key,
1677 timeout=const_TIMEOUT,
1678 reply_handler=reply_handler,
1679 error_handler=error_handler,
1680 )
1129 return fut 1681 return fut
1130 1682
1131 def devices_infos_get(self, bare_jid, profile_key): 1683 def devices_infos_get(self, bare_jid, profile_key):
1132 loop = asyncio.get_running_loop() 1684 loop = asyncio.get_running_loop()
1133 fut = loop.create_future() 1685 fut = loop.create_future()
1134 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1686 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1135 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1687 error_handler = lambda err: loop.call_soon_threadsafe(
1136 self.db_core_iface.devices_infos_get(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1688 fut.set_exception, dbus_to_bridge_exception(err)
1137 return fut 1689 )
1138 1690 self.db_core_iface.devices_infos_get(
1139 def disco_find_by_features(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@"): 1691 bare_jid,
1140 loop = asyncio.get_running_loop() 1692 profile_key,
1141 fut = loop.create_future() 1693 timeout=const_TIMEOUT,
1142 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1694 reply_handler=reply_handler,
1143 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1695 error_handler=error_handler,
1144 self.db_core_iface.disco_find_by_features(namespaces, identities, bare_jid, service, roster, own_jid, local_device, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1696 )
1145 return fut 1697 return fut
1146 1698
1147 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1699 def disco_find_by_features(
1148 loop = asyncio.get_running_loop() 1700 self,
1149 fut = loop.create_future() 1701 namespaces,
1150 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1702 identities,
1151 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1703 bare_jid=False,
1152 self.db_core_iface.disco_infos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1704 service=True,
1153 return fut 1705 roster=True,
1154 1706 own_jid=True,
1155 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1707 local_device=False,
1156 loop = asyncio.get_running_loop() 1708 profile_key="@DEFAULT@",
1157 fut = loop.create_future() 1709 ):
1158 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1710 loop = asyncio.get_running_loop()
1159 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1711 fut = loop.create_future()
1160 self.db_core_iface.disco_items(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1712 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1713 error_handler = lambda err: loop.call_soon_threadsafe(
1714 fut.set_exception, dbus_to_bridge_exception(err)
1715 )
1716 self.db_core_iface.disco_find_by_features(
1717 namespaces,
1718 identities,
1719 bare_jid,
1720 service,
1721 roster,
1722 own_jid,
1723 local_device,
1724 profile_key,
1725 timeout=const_TIMEOUT,
1726 reply_handler=reply_handler,
1727 error_handler=error_handler,
1728 )
1729 return fut
1730
1731 def disco_infos(self, entity_jid, node="", use_cache=True, profile_key="@DEFAULT@"):
1732 loop = asyncio.get_running_loop()
1733 fut = loop.create_future()
1734 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1735 error_handler = lambda err: loop.call_soon_threadsafe(
1736 fut.set_exception, dbus_to_bridge_exception(err)
1737 )
1738 self.db_core_iface.disco_infos(
1739 entity_jid,
1740 node,
1741 use_cache,
1742 profile_key,
1743 timeout=const_TIMEOUT,
1744 reply_handler=reply_handler,
1745 error_handler=error_handler,
1746 )
1747 return fut
1748
1749 def disco_items(self, entity_jid, node="", use_cache=True, profile_key="@DEFAULT@"):
1750 loop = asyncio.get_running_loop()
1751 fut = loop.create_future()
1752 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1753 error_handler = lambda err: loop.call_soon_threadsafe(
1754 fut.set_exception, dbus_to_bridge_exception(err)
1755 )
1756 self.db_core_iface.disco_items(
1757 entity_jid,
1758 node,
1759 use_cache,
1760 profile_key,
1761 timeout=const_TIMEOUT,
1762 reply_handler=reply_handler,
1763 error_handler=error_handler,
1764 )
1161 return fut 1765 return fut
1162 1766
1163 def disconnect(self, profile_key="@DEFAULT@"): 1767 def disconnect(self, profile_key="@DEFAULT@"):
1164 loop = asyncio.get_running_loop() 1768 loop = asyncio.get_running_loop()
1165 fut = loop.create_future() 1769 fut = loop.create_future()
1166 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1770 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1167 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1771 error_handler = lambda err: loop.call_soon_threadsafe(
1168 self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1772 fut.set_exception, dbus_to_bridge_exception(err)
1773 )
1774 self.db_core_iface.disconnect(
1775 profile_key,
1776 timeout=const_TIMEOUT,
1777 reply_handler=reply_handler,
1778 error_handler=error_handler,
1779 )
1169 return fut 1780 return fut
1170 1781
1171 def encryption_namespace_get(self, arg_0): 1782 def encryption_namespace_get(self, arg_0):
1172 loop = asyncio.get_running_loop() 1783 loop = asyncio.get_running_loop()
1173 fut = loop.create_future() 1784 fut = loop.create_future()
1174 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1785 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1175 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1786 error_handler = lambda err: loop.call_soon_threadsafe(
1176 self.db_core_iface.encryption_namespace_get(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1787 fut.set_exception, dbus_to_bridge_exception(err)
1788 )
1789 self.db_core_iface.encryption_namespace_get(
1790 arg_0,
1791 timeout=const_TIMEOUT,
1792 reply_handler=reply_handler,
1793 error_handler=error_handler,
1794 )
1177 return fut 1795 return fut
1178 1796
1179 def encryption_plugins_get(self): 1797 def encryption_plugins_get(self):
1180 loop = asyncio.get_running_loop() 1798 loop = asyncio.get_running_loop()
1181 fut = loop.create_future() 1799 fut = loop.create_future()
1182 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1800 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1183 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1801 error_handler = lambda err: loop.call_soon_threadsafe(
1184 self.db_core_iface.encryption_plugins_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1802 fut.set_exception, dbus_to_bridge_exception(err)
1803 )
1804 self.db_core_iface.encryption_plugins_get(
1805 timeout=const_TIMEOUT,
1806 reply_handler=reply_handler,
1807 error_handler=error_handler,
1808 )
1185 return fut 1809 return fut
1186 1810
1187 def encryption_trust_ui_get(self, to_jid, namespace, profile_key): 1811 def encryption_trust_ui_get(self, to_jid, namespace, profile_key):
1188 loop = asyncio.get_running_loop() 1812 loop = asyncio.get_running_loop()
1189 fut = loop.create_future() 1813 fut = loop.create_future()
1190 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1814 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1191 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1815 error_handler = lambda err: loop.call_soon_threadsafe(
1192 self.db_core_iface.encryption_trust_ui_get(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1816 fut.set_exception, dbus_to_bridge_exception(err)
1817 )
1818 self.db_core_iface.encryption_trust_ui_get(
1819 to_jid,
1820 namespace,
1821 profile_key,
1822 timeout=const_TIMEOUT,
1823 reply_handler=reply_handler,
1824 error_handler=error_handler,
1825 )
1193 return fut 1826 return fut
1194 1827
1195 def entities_data_get(self, jids, keys, profile): 1828 def entities_data_get(self, jids, keys, profile):
1196 loop = asyncio.get_running_loop() 1829 loop = asyncio.get_running_loop()
1197 fut = loop.create_future() 1830 fut = loop.create_future()
1198 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1831 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1199 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1832 error_handler = lambda err: loop.call_soon_threadsafe(
1200 self.db_core_iface.entities_data_get(jids, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1833 fut.set_exception, dbus_to_bridge_exception(err)
1834 )
1835 self.db_core_iface.entities_data_get(
1836 jids,
1837 keys,
1838 profile,
1839 timeout=const_TIMEOUT,
1840 reply_handler=reply_handler,
1841 error_handler=error_handler,
1842 )
1201 return fut 1843 return fut
1202 1844
1203 def entity_data_get(self, jid, keys, profile): 1845 def entity_data_get(self, jid, keys, profile):
1204 loop = asyncio.get_running_loop() 1846 loop = asyncio.get_running_loop()
1205 fut = loop.create_future() 1847 fut = loop.create_future()
1206 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1848 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1207 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1849 error_handler = lambda err: loop.call_soon_threadsafe(
1208 self.db_core_iface.entity_data_get(jid, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1850 fut.set_exception, dbus_to_bridge_exception(err)
1851 )
1852 self.db_core_iface.entity_data_get(
1853 jid,
1854 keys,
1855 profile,
1856 timeout=const_TIMEOUT,
1857 reply_handler=reply_handler,
1858 error_handler=error_handler,
1859 )
1209 return fut 1860 return fut
1210 1861
1211 def features_get(self, profile_key): 1862 def features_get(self, profile_key):
1212 loop = asyncio.get_running_loop() 1863 loop = asyncio.get_running_loop()
1213 fut = loop.create_future() 1864 fut = loop.create_future()
1214 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1865 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1215 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1866 error_handler = lambda err: loop.call_soon_threadsafe(
1216 self.db_core_iface.features_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1867 fut.set_exception, dbus_to_bridge_exception(err)
1217 return fut 1868 )
1218 1869 self.db_core_iface.features_get(
1219 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@"): 1870 profile_key,
1220 loop = asyncio.get_running_loop() 1871 timeout=const_TIMEOUT,
1221 fut = loop.create_future() 1872 reply_handler=reply_handler,
1222 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1873 error_handler=error_handler,
1223 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1874 )
1224 self.db_core_iface.history_get(from_jid, to_jid, limit, between, filters, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1875 return fut
1876
1877 def history_get(
1878 self, from_jid, to_jid, limit, between=True, filters="", profile="@NONE@"
1879 ):
1880 loop = asyncio.get_running_loop()
1881 fut = loop.create_future()
1882 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1883 error_handler = lambda err: loop.call_soon_threadsafe(
1884 fut.set_exception, dbus_to_bridge_exception(err)
1885 )
1886 self.db_core_iface.history_get(
1887 from_jid,
1888 to_jid,
1889 limit,
1890 between,
1891 filters,
1892 profile,
1893 timeout=const_TIMEOUT,
1894 reply_handler=reply_handler,
1895 error_handler=error_handler,
1896 )
1225 return fut 1897 return fut
1226 1898
1227 def image_check(self, arg_0): 1899 def image_check(self, arg_0):
1228 loop = asyncio.get_running_loop() 1900 loop = asyncio.get_running_loop()
1229 fut = loop.create_future() 1901 fut = loop.create_future()
1230 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1902 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1231 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1903 error_handler = lambda err: loop.call_soon_threadsafe(
1232 self.db_core_iface.image_check(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1904 fut.set_exception, dbus_to_bridge_exception(err)
1905 )
1906 self.db_core_iface.image_check(
1907 arg_0,
1908 timeout=const_TIMEOUT,
1909 reply_handler=reply_handler,
1910 error_handler=error_handler,
1911 )
1233 return fut 1912 return fut
1234 1913
1235 def image_convert(self, source, dest, arg_2, extra): 1914 def image_convert(self, source, dest, arg_2, extra):
1236 loop = asyncio.get_running_loop() 1915 loop = asyncio.get_running_loop()
1237 fut = loop.create_future() 1916 fut = loop.create_future()
1238 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1917 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1239 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1918 error_handler = lambda err: loop.call_soon_threadsafe(
1240 self.db_core_iface.image_convert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1919 fut.set_exception, dbus_to_bridge_exception(err)
1920 )
1921 self.db_core_iface.image_convert(
1922 source,
1923 dest,
1924 arg_2,
1925 extra,
1926 timeout=const_TIMEOUT,
1927 reply_handler=reply_handler,
1928 error_handler=error_handler,
1929 )
1241 return fut 1930 return fut
1242 1931
1243 def image_generate_preview(self, image_path, profile_key): 1932 def image_generate_preview(self, image_path, profile_key):
1244 loop = asyncio.get_running_loop() 1933 loop = asyncio.get_running_loop()
1245 fut = loop.create_future() 1934 fut = loop.create_future()
1246 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1935 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1247 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1936 error_handler = lambda err: loop.call_soon_threadsafe(
1248 self.db_core_iface.image_generate_preview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1937 fut.set_exception, dbus_to_bridge_exception(err)
1938 )
1939 self.db_core_iface.image_generate_preview(
1940 image_path,
1941 profile_key,
1942 timeout=const_TIMEOUT,
1943 reply_handler=reply_handler,
1944 error_handler=error_handler,
1945 )
1249 return fut 1946 return fut
1250 1947
1251 def image_resize(self, image_path, width, height): 1948 def image_resize(self, image_path, width, height):
1252 loop = asyncio.get_running_loop() 1949 loop = asyncio.get_running_loop()
1253 fut = loop.create_future() 1950 fut = loop.create_future()
1254 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1951 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1255 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1952 error_handler = lambda err: loop.call_soon_threadsafe(
1256 self.db_core_iface.image_resize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1953 fut.set_exception, dbus_to_bridge_exception(err)
1954 )
1955 self.db_core_iface.image_resize(
1956 image_path,
1957 width,
1958 height,
1959 timeout=const_TIMEOUT,
1960 reply_handler=reply_handler,
1961 error_handler=error_handler,
1962 )
1257 return fut 1963 return fut
1258 1964
1259 def init_pre_script(self): 1965 def init_pre_script(self):
1260 loop = asyncio.get_running_loop() 1966 loop = asyncio.get_running_loop()
1261 fut = loop.create_future() 1967 fut = loop.create_future()
1262 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1968 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1263 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1969 error_handler = lambda err: loop.call_soon_threadsafe(
1264 self.db_core_iface.init_pre_script(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1970 fut.set_exception, dbus_to_bridge_exception(err)
1971 )
1972 self.db_core_iface.init_pre_script(
1973 timeout=const_TIMEOUT,
1974 reply_handler=reply_handler,
1975 error_handler=error_handler,
1976 )
1265 return fut 1977 return fut
1266 1978
1267 def is_connected(self, profile_key="@DEFAULT@"): 1979 def is_connected(self, profile_key="@DEFAULT@"):
1268 loop = asyncio.get_running_loop() 1980 loop = asyncio.get_running_loop()
1269 fut = loop.create_future() 1981 fut = loop.create_future()
1270 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1982 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1271 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1983 error_handler = lambda err: loop.call_soon_threadsafe(
1272 self.db_core_iface.is_connected(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1984 fut.set_exception, dbus_to_bridge_exception(err)
1985 )
1986 self.db_core_iface.is_connected(
1987 profile_key,
1988 timeout=const_TIMEOUT,
1989 reply_handler=reply_handler,
1990 error_handler=error_handler,
1991 )
1273 return fut 1992 return fut
1274 1993
1275 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@"): 1994 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@"):
1276 loop = asyncio.get_running_loop() 1995 loop = asyncio.get_running_loop()
1277 fut = loop.create_future() 1996 fut = loop.create_future()
1278 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1997 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1279 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1998 error_handler = lambda err: loop.call_soon_threadsafe(
1280 self.db_core_iface.main_resource_get(contact_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1999 fut.set_exception, dbus_to_bridge_exception(err)
2000 )
2001 self.db_core_iface.main_resource_get(
2002 contact_jid,
2003 profile_key,
2004 timeout=const_TIMEOUT,
2005 reply_handler=reply_handler,
2006 error_handler=error_handler,
2007 )
1281 return fut 2008 return fut
1282 2009
1283 def menu_help_get(self, menu_id, language): 2010 def menu_help_get(self, menu_id, language):
1284 loop = asyncio.get_running_loop() 2011 loop = asyncio.get_running_loop()
1285 fut = loop.create_future() 2012 fut = loop.create_future()
1286 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2013 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1287 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2014 error_handler = lambda err: loop.call_soon_threadsafe(
1288 self.db_core_iface.menu_help_get(menu_id, language, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2015 fut.set_exception, dbus_to_bridge_exception(err)
2016 )
2017 self.db_core_iface.menu_help_get(
2018 menu_id,
2019 language,
2020 timeout=const_TIMEOUT,
2021 reply_handler=reply_handler,
2022 error_handler=error_handler,
2023 )
1289 return fut 2024 return fut
1290 2025
1291 def menu_launch(self, menu_type, path, data, security_limit, profile_key): 2026 def menu_launch(self, menu_type, path, data, security_limit, profile_key):
1292 loop = asyncio.get_running_loop() 2027 loop = asyncio.get_running_loop()
1293 fut = loop.create_future() 2028 fut = loop.create_future()
1294 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2029 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1295 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2030 error_handler = lambda err: loop.call_soon_threadsafe(
1296 self.db_core_iface.menu_launch(menu_type, path, data, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2031 fut.set_exception, dbus_to_bridge_exception(err)
2032 )
2033 self.db_core_iface.menu_launch(
2034 menu_type,
2035 path,
2036 data,
2037 security_limit,
2038 profile_key,
2039 timeout=const_TIMEOUT,
2040 reply_handler=reply_handler,
2041 error_handler=error_handler,
2042 )
1297 return fut 2043 return fut
1298 2044
1299 def menus_get(self, language, security_limit): 2045 def menus_get(self, language, security_limit):
1300 loop = asyncio.get_running_loop() 2046 loop = asyncio.get_running_loop()
1301 fut = loop.create_future() 2047 fut = loop.create_future()
1302 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2048 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1303 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2049 error_handler = lambda err: loop.call_soon_threadsafe(
1304 self.db_core_iface.menus_get(language, security_limit, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2050 fut.set_exception, dbus_to_bridge_exception(err)
2051 )
2052 self.db_core_iface.menus_get(
2053 language,
2054 security_limit,
2055 timeout=const_TIMEOUT,
2056 reply_handler=reply_handler,
2057 error_handler=error_handler,
2058 )
1305 return fut 2059 return fut
1306 2060
1307 def message_encryption_get(self, to_jid, profile_key): 2061 def message_encryption_get(self, to_jid, profile_key):
1308 loop = asyncio.get_running_loop() 2062 loop = asyncio.get_running_loop()
1309 fut = loop.create_future() 2063 fut = loop.create_future()
1310 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2064 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1311 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2065 error_handler = lambda err: loop.call_soon_threadsafe(
1312 self.db_core_iface.message_encryption_get(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2066 fut.set_exception, dbus_to_bridge_exception(err)
1313 return fut 2067 )
1314 2068 self.db_core_iface.message_encryption_get(
1315 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@"): 2069 to_jid,
1316 loop = asyncio.get_running_loop() 2070 profile_key,
1317 fut = loop.create_future() 2071 timeout=const_TIMEOUT,
1318 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2072 reply_handler=reply_handler,
1319 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2073 error_handler=error_handler,
1320 self.db_core_iface.message_encryption_start(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2074 )
2075 return fut
2076
2077 def message_encryption_start(
2078 self, to_jid, namespace="", replace=False, profile_key="@NONE@"
2079 ):
2080 loop = asyncio.get_running_loop()
2081 fut = loop.create_future()
2082 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2083 error_handler = lambda err: loop.call_soon_threadsafe(
2084 fut.set_exception, dbus_to_bridge_exception(err)
2085 )
2086 self.db_core_iface.message_encryption_start(
2087 to_jid,
2088 namespace,
2089 replace,
2090 profile_key,
2091 timeout=const_TIMEOUT,
2092 reply_handler=reply_handler,
2093 error_handler=error_handler,
2094 )
1321 return fut 2095 return fut
1322 2096
1323 def message_encryption_stop(self, to_jid, profile_key): 2097 def message_encryption_stop(self, to_jid, profile_key):
1324 loop = asyncio.get_running_loop() 2098 loop = asyncio.get_running_loop()
1325 fut = loop.create_future() 2099 fut = loop.create_future()
1326 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2100 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1327 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2101 error_handler = lambda err: loop.call_soon_threadsafe(
1328 self.db_core_iface.message_encryption_stop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2102 fut.set_exception, dbus_to_bridge_exception(err)
1329 return fut 2103 )
1330 2104 self.db_core_iface.message_encryption_stop(
1331 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@"): 2105 to_jid,
1332 loop = asyncio.get_running_loop() 2106 profile_key,
1333 fut = loop.create_future() 2107 timeout=const_TIMEOUT,
1334 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2108 reply_handler=reply_handler,
1335 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2109 error_handler=error_handler,
1336 self.db_core_iface.message_send(to_jid, message, subject, mess_type, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2110 )
2111 return fut
2112
2113 def message_send(
2114 self,
2115 to_jid,
2116 message,
2117 subject={},
2118 mess_type="auto",
2119 extra={},
2120 profile_key="@NONE@",
2121 ):
2122 loop = asyncio.get_running_loop()
2123 fut = loop.create_future()
2124 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2125 error_handler = lambda err: loop.call_soon_threadsafe(
2126 fut.set_exception, dbus_to_bridge_exception(err)
2127 )
2128 self.db_core_iface.message_send(
2129 to_jid,
2130 message,
2131 subject,
2132 mess_type,
2133 extra,
2134 profile_key,
2135 timeout=const_TIMEOUT,
2136 reply_handler=reply_handler,
2137 error_handler=error_handler,
2138 )
1337 return fut 2139 return fut
1338 2140
1339 def namespaces_get(self): 2141 def namespaces_get(self):
1340 loop = asyncio.get_running_loop() 2142 loop = asyncio.get_running_loop()
1341 fut = loop.create_future() 2143 fut = loop.create_future()
1342 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2144 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1343 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2145 error_handler = lambda err: loop.call_soon_threadsafe(
1344 self.db_core_iface.namespaces_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2146 fut.set_exception, dbus_to_bridge_exception(err)
1345 return fut 2147 )
1346 2148 self.db_core_iface.namespaces_get(
1347 def notification_add(self, type_, body_plain, body_rich, title, is_global, requires_action, arg_6, priority, expire_at, extra): 2149 timeout=const_TIMEOUT,
1348 loop = asyncio.get_running_loop() 2150 reply_handler=reply_handler,
1349 fut = loop.create_future() 2151 error_handler=error_handler,
1350 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2152 )
1351 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2153 return fut
1352 self.db_core_iface.notification_add(type_, body_plain, body_rich, title, is_global, requires_action, arg_6, priority, expire_at, extra, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2154
2155 def notification_add(
2156 self,
2157 type_,
2158 body_plain,
2159 body_rich,
2160 title,
2161 is_global,
2162 requires_action,
2163 arg_6,
2164 priority,
2165 expire_at,
2166 extra,
2167 ):
2168 loop = asyncio.get_running_loop()
2169 fut = loop.create_future()
2170 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2171 error_handler = lambda err: loop.call_soon_threadsafe(
2172 fut.set_exception, dbus_to_bridge_exception(err)
2173 )
2174 self.db_core_iface.notification_add(
2175 type_,
2176 body_plain,
2177 body_rich,
2178 title,
2179 is_global,
2180 requires_action,
2181 arg_6,
2182 priority,
2183 expire_at,
2184 extra,
2185 timeout=const_TIMEOUT,
2186 reply_handler=reply_handler,
2187 error_handler=error_handler,
2188 )
1353 return fut 2189 return fut
1354 2190
1355 def notification_delete(self, id_, is_global, profile_key): 2191 def notification_delete(self, id_, is_global, profile_key):
1356 loop = asyncio.get_running_loop() 2192 loop = asyncio.get_running_loop()
1357 fut = loop.create_future() 2193 fut = loop.create_future()
1358 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2194 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1359 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2195 error_handler = lambda err: loop.call_soon_threadsafe(
1360 self.db_core_iface.notification_delete(id_, is_global, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2196 fut.set_exception, dbus_to_bridge_exception(err)
2197 )
2198 self.db_core_iface.notification_delete(
2199 id_,
2200 is_global,
2201 profile_key,
2202 timeout=const_TIMEOUT,
2203 reply_handler=reply_handler,
2204 error_handler=error_handler,
2205 )
1361 return fut 2206 return fut
1362 2207
1363 def notifications_expired_clean(self, limit_timestamp, profile_key): 2208 def notifications_expired_clean(self, limit_timestamp, profile_key):
1364 loop = asyncio.get_running_loop() 2209 loop = asyncio.get_running_loop()
1365 fut = loop.create_future() 2210 fut = loop.create_future()
1366 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2211 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1367 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2212 error_handler = lambda err: loop.call_soon_threadsafe(
1368 self.db_core_iface.notifications_expired_clean(limit_timestamp, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2213 fut.set_exception, dbus_to_bridge_exception(err)
2214 )
2215 self.db_core_iface.notifications_expired_clean(
2216 limit_timestamp,
2217 profile_key,
2218 timeout=const_TIMEOUT,
2219 reply_handler=reply_handler,
2220 error_handler=error_handler,
2221 )
1369 return fut 2222 return fut
1370 2223
1371 def notifications_get(self, filters, profile_key): 2224 def notifications_get(self, filters, profile_key):
1372 loop = asyncio.get_running_loop() 2225 loop = asyncio.get_running_loop()
1373 fut = loop.create_future() 2226 fut = loop.create_future()
1374 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2227 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1375 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2228 error_handler = lambda err: loop.call_soon_threadsafe(
1376 self.db_core_iface.notifications_get(filters, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2229 fut.set_exception, dbus_to_bridge_exception(err)
2230 )
2231 self.db_core_iface.notifications_get(
2232 filters,
2233 profile_key,
2234 timeout=const_TIMEOUT,
2235 reply_handler=reply_handler,
2236 error_handler=error_handler,
2237 )
1377 return fut 2238 return fut
1378 2239
1379 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@"): 2240 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@"):
1380 loop = asyncio.get_running_loop() 2241 loop = asyncio.get_running_loop()
1381 fut = loop.create_future() 2242 fut = loop.create_future()
1382 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2243 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1383 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2244 error_handler = lambda err: loop.call_soon_threadsafe(
1384 self.db_core_iface.param_get_a(name, category, attribute, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2245 fut.set_exception, dbus_to_bridge_exception(err)
1385 return fut 2246 )
1386 2247 self.db_core_iface.param_get_a(
1387 def param_get_a_async(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@"): 2248 name,
1388 loop = asyncio.get_running_loop() 2249 category,
1389 fut = loop.create_future() 2250 attribute,
1390 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2251 profile_key,
1391 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2252 timeout=const_TIMEOUT,
1392 self.db_core_iface.param_get_a_async(name, category, attribute, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2253 reply_handler=reply_handler,
1393 return fut 2254 error_handler=error_handler,
1394 2255 )
1395 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@"): 2256 return fut
1396 loop = asyncio.get_running_loop() 2257
1397 fut = loop.create_future() 2258 def param_get_a_async(
1398 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2259 self,
1399 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2260 name,
1400 self.db_core_iface.param_set(name, value, category, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2261 category,
1401 return fut 2262 attribute="value",
1402 2263 security_limit=-1,
1403 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@"): 2264 profile_key="@DEFAULT@",
1404 loop = asyncio.get_running_loop() 2265 ):
1405 fut = loop.create_future() 2266 loop = asyncio.get_running_loop()
1406 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2267 fut = loop.create_future()
1407 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2268 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1408 self.db_core_iface.param_ui_get(security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2269 error_handler = lambda err: loop.call_soon_threadsafe(
2270 fut.set_exception, dbus_to_bridge_exception(err)
2271 )
2272 self.db_core_iface.param_get_a_async(
2273 name,
2274 category,
2275 attribute,
2276 security_limit,
2277 profile_key,
2278 timeout=const_TIMEOUT,
2279 reply_handler=reply_handler,
2280 error_handler=error_handler,
2281 )
2282 return fut
2283
2284 def param_set(
2285 self, name, value, category, security_limit=-1, profile_key="@DEFAULT@"
2286 ):
2287 loop = asyncio.get_running_loop()
2288 fut = loop.create_future()
2289 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2290 error_handler = lambda err: loop.call_soon_threadsafe(
2291 fut.set_exception, dbus_to_bridge_exception(err)
2292 )
2293 self.db_core_iface.param_set(
2294 name,
2295 value,
2296 category,
2297 security_limit,
2298 profile_key,
2299 timeout=const_TIMEOUT,
2300 reply_handler=reply_handler,
2301 error_handler=error_handler,
2302 )
2303 return fut
2304
2305 def param_ui_get(self, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"):
2306 loop = asyncio.get_running_loop()
2307 fut = loop.create_future()
2308 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2309 error_handler = lambda err: loop.call_soon_threadsafe(
2310 fut.set_exception, dbus_to_bridge_exception(err)
2311 )
2312 self.db_core_iface.param_ui_get(
2313 security_limit,
2314 app,
2315 extra,
2316 profile_key,
2317 timeout=const_TIMEOUT,
2318 reply_handler=reply_handler,
2319 error_handler=error_handler,
2320 )
1409 return fut 2321 return fut
1410 2322
1411 def params_categories_get(self): 2323 def params_categories_get(self):
1412 loop = asyncio.get_running_loop() 2324 loop = asyncio.get_running_loop()
1413 fut = loop.create_future() 2325 fut = loop.create_future()
1414 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2326 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1415 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2327 error_handler = lambda err: loop.call_soon_threadsafe(
1416 self.db_core_iface.params_categories_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2328 fut.set_exception, dbus_to_bridge_exception(err)
1417 return fut 2329 )
1418 2330 self.db_core_iface.params_categories_get(
1419 def params_register_app(self, xml, security_limit=-1, app=''): 2331 timeout=const_TIMEOUT,
1420 loop = asyncio.get_running_loop() 2332 reply_handler=reply_handler,
1421 fut = loop.create_future() 2333 error_handler=error_handler,
1422 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2334 )
1423 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2335 return fut
1424 self.db_core_iface.params_register_app(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2336
2337 def params_register_app(self, xml, security_limit=-1, app=""):
2338 loop = asyncio.get_running_loop()
2339 fut = loop.create_future()
2340 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2341 error_handler = lambda err: loop.call_soon_threadsafe(
2342 fut.set_exception, dbus_to_bridge_exception(err)
2343 )
2344 self.db_core_iface.params_register_app(
2345 xml,
2346 security_limit,
2347 app,
2348 timeout=const_TIMEOUT,
2349 reply_handler=reply_handler,
2350 error_handler=error_handler,
2351 )
1425 return fut 2352 return fut
1426 2353
1427 def params_template_load(self, filename): 2354 def params_template_load(self, filename):
1428 loop = asyncio.get_running_loop() 2355 loop = asyncio.get_running_loop()
1429 fut = loop.create_future() 2356 fut = loop.create_future()
1430 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2357 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1431 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2358 error_handler = lambda err: loop.call_soon_threadsafe(
1432 self.db_core_iface.params_template_load(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2359 fut.set_exception, dbus_to_bridge_exception(err)
2360 )
2361 self.db_core_iface.params_template_load(
2362 filename,
2363 timeout=const_TIMEOUT,
2364 reply_handler=reply_handler,
2365 error_handler=error_handler,
2366 )
1433 return fut 2367 return fut
1434 2368
1435 def params_template_save(self, filename): 2369 def params_template_save(self, filename):
1436 loop = asyncio.get_running_loop() 2370 loop = asyncio.get_running_loop()
1437 fut = loop.create_future() 2371 fut = loop.create_future()
1438 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2372 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1439 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2373 error_handler = lambda err: loop.call_soon_threadsafe(
1440 self.db_core_iface.params_template_save(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2374 fut.set_exception, dbus_to_bridge_exception(err)
1441 return fut 2375 )
1442 2376 self.db_core_iface.params_template_save(
1443 def params_values_from_category_get_async(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"): 2377 filename,
1444 loop = asyncio.get_running_loop() 2378 timeout=const_TIMEOUT,
1445 fut = loop.create_future() 2379 reply_handler=reply_handler,
1446 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2380 error_handler=error_handler,
1447 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2381 )
1448 self.db_core_iface.params_values_from_category_get_async(category, security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2382 return fut
1449 return fut 2383
1450 2384 def params_values_from_category_get_async(
1451 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@"): 2385 self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"
1452 loop = asyncio.get_running_loop() 2386 ):
1453 fut = loop.create_future() 2387 loop = asyncio.get_running_loop()
1454 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2388 fut = loop.create_future()
1455 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2389 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1456 self.db_core_iface.presence_set(to_jid, show, statuses, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2390 error_handler = lambda err: loop.call_soon_threadsafe(
2391 fut.set_exception, dbus_to_bridge_exception(err)
2392 )
2393 self.db_core_iface.params_values_from_category_get_async(
2394 category,
2395 security_limit,
2396 app,
2397 extra,
2398 profile_key,
2399 timeout=const_TIMEOUT,
2400 reply_handler=reply_handler,
2401 error_handler=error_handler,
2402 )
2403 return fut
2404
2405 def presence_set(self, to_jid="", show="", statuses={}, profile_key="@DEFAULT@"):
2406 loop = asyncio.get_running_loop()
2407 fut = loop.create_future()
2408 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2409 error_handler = lambda err: loop.call_soon_threadsafe(
2410 fut.set_exception, dbus_to_bridge_exception(err)
2411 )
2412 self.db_core_iface.presence_set(
2413 to_jid,
2414 show,
2415 statuses,
2416 profile_key,
2417 timeout=const_TIMEOUT,
2418 reply_handler=reply_handler,
2419 error_handler=error_handler,
2420 )
1457 return fut 2421 return fut
1458 2422
1459 def presence_statuses_get(self, profile_key="@DEFAULT@"): 2423 def presence_statuses_get(self, profile_key="@DEFAULT@"):
1460 loop = asyncio.get_running_loop() 2424 loop = asyncio.get_running_loop()
1461 fut = loop.create_future() 2425 fut = loop.create_future()
1462 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2426 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1463 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2427 error_handler = lambda err: loop.call_soon_threadsafe(
1464 self.db_core_iface.presence_statuses_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2428 fut.set_exception, dbus_to_bridge_exception(err)
2429 )
2430 self.db_core_iface.presence_statuses_get(
2431 profile_key,
2432 timeout=const_TIMEOUT,
2433 reply_handler=reply_handler,
2434 error_handler=error_handler,
2435 )
1465 return fut 2436 return fut
1466 2437
1467 def private_data_delete(self, namespace, key, arg_2): 2438 def private_data_delete(self, namespace, key, arg_2):
1468 loop = asyncio.get_running_loop() 2439 loop = asyncio.get_running_loop()
1469 fut = loop.create_future() 2440 fut = loop.create_future()
1470 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2441 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1471 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2442 error_handler = lambda err: loop.call_soon_threadsafe(
1472 self.db_core_iface.private_data_delete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2443 fut.set_exception, dbus_to_bridge_exception(err)
2444 )
2445 self.db_core_iface.private_data_delete(
2446 namespace,
2447 key,
2448 arg_2,
2449 timeout=const_TIMEOUT,
2450 reply_handler=reply_handler,
2451 error_handler=error_handler,
2452 )
1473 return fut 2453 return fut
1474 2454
1475 def private_data_get(self, namespace, key, profile_key): 2455 def private_data_get(self, namespace, key, profile_key):
1476 loop = asyncio.get_running_loop() 2456 loop = asyncio.get_running_loop()
1477 fut = loop.create_future() 2457 fut = loop.create_future()
1478 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2458 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1479 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2459 error_handler = lambda err: loop.call_soon_threadsafe(
1480 self.db_core_iface.private_data_get(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2460 fut.set_exception, dbus_to_bridge_exception(err)
2461 )
2462 self.db_core_iface.private_data_get(
2463 namespace,
2464 key,
2465 profile_key,
2466 timeout=const_TIMEOUT,
2467 reply_handler=reply_handler,
2468 error_handler=error_handler,
2469 )
1481 return fut 2470 return fut
1482 2471
1483 def private_data_set(self, namespace, key, data, profile_key): 2472 def private_data_set(self, namespace, key, data, profile_key):
1484 loop = asyncio.get_running_loop() 2473 loop = asyncio.get_running_loop()
1485 fut = loop.create_future() 2474 fut = loop.create_future()
1486 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2475 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1487 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2476 error_handler = lambda err: loop.call_soon_threadsafe(
1488 self.db_core_iface.private_data_set(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2477 fut.set_exception, dbus_to_bridge_exception(err)
1489 return fut 2478 )
1490 2479 self.db_core_iface.private_data_set(
1491 def profile_create(self, profile, password='', component=''): 2480 namespace,
1492 loop = asyncio.get_running_loop() 2481 key,
1493 fut = loop.create_future() 2482 data,
1494 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2483 profile_key,
1495 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2484 timeout=const_TIMEOUT,
1496 self.db_core_iface.profile_create(profile, password, component, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2485 reply_handler=reply_handler,
2486 error_handler=error_handler,
2487 )
2488 return fut
2489
2490 def profile_create(self, profile, password="", component=""):
2491 loop = asyncio.get_running_loop()
2492 fut = loop.create_future()
2493 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2494 error_handler = lambda err: loop.call_soon_threadsafe(
2495 fut.set_exception, dbus_to_bridge_exception(err)
2496 )
2497 self.db_core_iface.profile_create(
2498 profile,
2499 password,
2500 component,
2501 timeout=const_TIMEOUT,
2502 reply_handler=reply_handler,
2503 error_handler=error_handler,
2504 )
1497 return fut 2505 return fut
1498 2506
1499 def profile_delete_async(self, profile): 2507 def profile_delete_async(self, profile):
1500 loop = asyncio.get_running_loop() 2508 loop = asyncio.get_running_loop()
1501 fut = loop.create_future() 2509 fut = loop.create_future()
1502 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2510 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1503 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2511 error_handler = lambda err: loop.call_soon_threadsafe(
1504 self.db_core_iface.profile_delete_async(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2512 fut.set_exception, dbus_to_bridge_exception(err)
2513 )
2514 self.db_core_iface.profile_delete_async(
2515 profile,
2516 timeout=const_TIMEOUT,
2517 reply_handler=reply_handler,
2518 error_handler=error_handler,
2519 )
1505 return fut 2520 return fut
1506 2521
1507 def profile_is_session_started(self, profile_key="@DEFAULT@"): 2522 def profile_is_session_started(self, profile_key="@DEFAULT@"):
1508 loop = asyncio.get_running_loop() 2523 loop = asyncio.get_running_loop()
1509 fut = loop.create_future() 2524 fut = loop.create_future()
1510 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2525 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1511 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2526 error_handler = lambda err: loop.call_soon_threadsafe(
1512 self.db_core_iface.profile_is_session_started(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2527 fut.set_exception, dbus_to_bridge_exception(err)
2528 )
2529 self.db_core_iface.profile_is_session_started(
2530 profile_key,
2531 timeout=const_TIMEOUT,
2532 reply_handler=reply_handler,
2533 error_handler=error_handler,
2534 )
1513 return fut 2535 return fut
1514 2536
1515 def profile_name_get(self, profile_key="@DEFAULT@"): 2537 def profile_name_get(self, profile_key="@DEFAULT@"):
1516 loop = asyncio.get_running_loop() 2538 loop = asyncio.get_running_loop()
1517 fut = loop.create_future() 2539 fut = loop.create_future()
1518 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2540 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1519 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2541 error_handler = lambda err: loop.call_soon_threadsafe(
1520 self.db_core_iface.profile_name_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2542 fut.set_exception, dbus_to_bridge_exception(err)
2543 )
2544 self.db_core_iface.profile_name_get(
2545 profile_key,
2546 timeout=const_TIMEOUT,
2547 reply_handler=reply_handler,
2548 error_handler=error_handler,
2549 )
1521 return fut 2550 return fut
1522 2551
1523 def profile_set_default(self, profile): 2552 def profile_set_default(self, profile):
1524 loop = asyncio.get_running_loop() 2553 loop = asyncio.get_running_loop()
1525 fut = loop.create_future() 2554 fut = loop.create_future()
1526 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2555 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1527 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2556 error_handler = lambda err: loop.call_soon_threadsafe(
1528 self.db_core_iface.profile_set_default(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2557 fut.set_exception, dbus_to_bridge_exception(err)
1529 return fut 2558 )
1530 2559 self.db_core_iface.profile_set_default(
1531 def profile_start_session(self, password='', profile_key="@DEFAULT@"): 2560 profile,
1532 loop = asyncio.get_running_loop() 2561 timeout=const_TIMEOUT,
1533 fut = loop.create_future() 2562 reply_handler=reply_handler,
1534 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2563 error_handler=error_handler,
1535 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2564 )
1536 self.db_core_iface.profile_start_session(password, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2565 return fut
2566
2567 def profile_start_session(self, password="", profile_key="@DEFAULT@"):
2568 loop = asyncio.get_running_loop()
2569 fut = loop.create_future()
2570 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
2571 error_handler = lambda err: loop.call_soon_threadsafe(
2572 fut.set_exception, dbus_to_bridge_exception(err)
2573 )
2574 self.db_core_iface.profile_start_session(
2575 password,
2576 profile_key,
2577 timeout=const_TIMEOUT,
2578 reply_handler=reply_handler,
2579 error_handler=error_handler,
2580 )
1537 return fut 2581 return fut
1538 2582
1539 def profiles_list_get(self, clients=True, components=False): 2583 def profiles_list_get(self, clients=True, components=False):
1540 loop = asyncio.get_running_loop() 2584 loop = asyncio.get_running_loop()
1541 fut = loop.create_future() 2585 fut = loop.create_future()
1542 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2586 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1543 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2587 error_handler = lambda err: loop.call_soon_threadsafe(
1544 self.db_core_iface.profiles_list_get(clients, components, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2588 fut.set_exception, dbus_to_bridge_exception(err)
2589 )
2590 self.db_core_iface.profiles_list_get(
2591 clients,
2592 components,
2593 timeout=const_TIMEOUT,
2594 reply_handler=reply_handler,
2595 error_handler=error_handler,
2596 )
1545 return fut 2597 return fut
1546 2598
1547 def progress_get(self, id, profile): 2599 def progress_get(self, id, profile):
1548 loop = asyncio.get_running_loop() 2600 loop = asyncio.get_running_loop()
1549 fut = loop.create_future() 2601 fut = loop.create_future()
1550 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2602 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1551 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2603 error_handler = lambda err: loop.call_soon_threadsafe(
1552 self.db_core_iface.progress_get(id, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2604 fut.set_exception, dbus_to_bridge_exception(err)
2605 )
2606 self.db_core_iface.progress_get(
2607 id,
2608 profile,
2609 timeout=const_TIMEOUT,
2610 reply_handler=reply_handler,
2611 error_handler=error_handler,
2612 )
1553 return fut 2613 return fut
1554 2614
1555 def progress_get_all(self, profile): 2615 def progress_get_all(self, profile):
1556 loop = asyncio.get_running_loop() 2616 loop = asyncio.get_running_loop()
1557 fut = loop.create_future() 2617 fut = loop.create_future()
1558 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2618 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1559 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2619 error_handler = lambda err: loop.call_soon_threadsafe(
1560 self.db_core_iface.progress_get_all(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2620 fut.set_exception, dbus_to_bridge_exception(err)
2621 )
2622 self.db_core_iface.progress_get_all(
2623 profile,
2624 timeout=const_TIMEOUT,
2625 reply_handler=reply_handler,
2626 error_handler=error_handler,
2627 )
1561 return fut 2628 return fut
1562 2629
1563 def progress_get_all_metadata(self, profile): 2630 def progress_get_all_metadata(self, profile):
1564 loop = asyncio.get_running_loop() 2631 loop = asyncio.get_running_loop()
1565 fut = loop.create_future() 2632 fut = loop.create_future()
1566 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2633 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1567 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2634 error_handler = lambda err: loop.call_soon_threadsafe(
1568 self.db_core_iface.progress_get_all_metadata(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2635 fut.set_exception, dbus_to_bridge_exception(err)
2636 )
2637 self.db_core_iface.progress_get_all_metadata(
2638 profile,
2639 timeout=const_TIMEOUT,
2640 reply_handler=reply_handler,
2641 error_handler=error_handler,
2642 )
1569 return fut 2643 return fut
1570 2644
1571 def ready_get(self): 2645 def ready_get(self):
1572 loop = asyncio.get_running_loop() 2646 loop = asyncio.get_running_loop()
1573 fut = loop.create_future() 2647 fut = loop.create_future()
1574 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2648 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1575 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2649 error_handler = lambda err: loop.call_soon_threadsafe(
1576 self.db_core_iface.ready_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2650 fut.set_exception, dbus_to_bridge_exception(err)
2651 )
2652 self.db_core_iface.ready_get(
2653 timeout=const_TIMEOUT,
2654 reply_handler=reply_handler,
2655 error_handler=error_handler,
2656 )
1577 return fut 2657 return fut
1578 2658
1579 def roster_resync(self, profile_key="@DEFAULT@"): 2659 def roster_resync(self, profile_key="@DEFAULT@"):
1580 loop = asyncio.get_running_loop() 2660 loop = asyncio.get_running_loop()
1581 fut = loop.create_future() 2661 fut = loop.create_future()
1582 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2662 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1583 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2663 error_handler = lambda err: loop.call_soon_threadsafe(
1584 self.db_core_iface.roster_resync(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2664 fut.set_exception, dbus_to_bridge_exception(err)
2665 )
2666 self.db_core_iface.roster_resync(
2667 profile_key,
2668 timeout=const_TIMEOUT,
2669 reply_handler=reply_handler,
2670 error_handler=error_handler,
2671 )
1585 return fut 2672 return fut
1586 2673
1587 def session_infos_get(self, profile_key): 2674 def session_infos_get(self, profile_key):
1588 loop = asyncio.get_running_loop() 2675 loop = asyncio.get_running_loop()
1589 fut = loop.create_future() 2676 fut = loop.create_future()
1590 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2677 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1591 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2678 error_handler = lambda err: loop.call_soon_threadsafe(
1592 self.db_core_iface.session_infos_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2679 fut.set_exception, dbus_to_bridge_exception(err)
2680 )
2681 self.db_core_iface.session_infos_get(
2682 profile_key,
2683 timeout=const_TIMEOUT,
2684 reply_handler=reply_handler,
2685 error_handler=error_handler,
2686 )
1593 return fut 2687 return fut
1594 2688
1595 def sub_waiting_get(self, profile_key="@DEFAULT@"): 2689 def sub_waiting_get(self, profile_key="@DEFAULT@"):
1596 loop = asyncio.get_running_loop() 2690 loop = asyncio.get_running_loop()
1597 fut = loop.create_future() 2691 fut = loop.create_future()
1598 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2692 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1599 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2693 error_handler = lambda err: loop.call_soon_threadsafe(
1600 self.db_core_iface.sub_waiting_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2694 fut.set_exception, dbus_to_bridge_exception(err)
2695 )
2696 self.db_core_iface.sub_waiting_get(
2697 profile_key,
2698 timeout=const_TIMEOUT,
2699 reply_handler=reply_handler,
2700 error_handler=error_handler,
2701 )
1601 return fut 2702 return fut
1602 2703
1603 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"): 2704 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"):
1604 loop = asyncio.get_running_loop() 2705 loop = asyncio.get_running_loop()
1605 fut = loop.create_future() 2706 fut = loop.create_future()
1606 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2707 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1607 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2708 error_handler = lambda err: loop.call_soon_threadsafe(
1608 self.db_core_iface.subscription(sub_type, entity, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2709 fut.set_exception, dbus_to_bridge_exception(err)
2710 )
2711 self.db_core_iface.subscription(
2712 sub_type,
2713 entity,
2714 profile_key,
2715 timeout=const_TIMEOUT,
2716 reply_handler=reply_handler,
2717 error_handler=error_handler,
2718 )
1609 return fut 2719 return fut
1610 2720
1611 def version_get(self): 2721 def version_get(self):
1612 loop = asyncio.get_running_loop() 2722 loop = asyncio.get_running_loop()
1613 fut = loop.create_future() 2723 fut = loop.create_future()
1614 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2724 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1615 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2725 error_handler = lambda err: loop.call_soon_threadsafe(
1616 self.db_core_iface.version_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 2726 fut.set_exception, dbus_to_bridge_exception(err)
1617 return fut 2727 )
2728 self.db_core_iface.version_get(
2729 timeout=const_TIMEOUT,
2730 reply_handler=reply_handler,
2731 error_handler=error_handler,
2732 )
2733 return fut