Mercurial > libervia-backend

comparison libervia/frontends/bridge/dbus_bridge.py @ 4284:3a550e9a2b55

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
black reformatting
author Goffi <goffi@goffi.org>
date Sun, 14 Jul 2024 16:47:45 +0200
parents 4cf98f506269
children
comparison
equal deleted inserted replaced
4283:23842a63ea00 4284:3a550e9a2b55
171 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs) 171 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs)
172 raise e 172 raise e
173 173
174 return get_plugin_method 174 return get_plugin_method
175 175
176 176 def action_launch(
177 def action_launch(self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None): 177 self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None
178 if callback is None: 178 ):
179 error_handler = None 179 if callback is None:
180 else: 180 error_handler = None
181 if errback is None: 181 else:
182 errback = log.error 182 if errback is None:
183 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 183 errback = log.error
184 return str(self.db_core_iface.action_launch(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 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 )
185 195
186 def actions_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 196 def actions_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
187 if callback is None: 197 if callback is None:
188 error_handler = None 198 error_handler = None
189 else: 199 else:
190 if errback is None: 200 if errback is None:
191 errback = log.error 201 errback = log.error
192 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 202 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
193 kwargs={} 203 kwargs = {}
194 if callback is not None: 204 if callback is not None:
195 kwargs['timeout'] = const_TIMEOUT 205 kwargs["timeout"] = const_TIMEOUT
196 kwargs['reply_handler'] = callback 206 kwargs["reply_handler"] = callback
197 kwargs['error_handler'] = error_handler 207 kwargs["error_handler"] = error_handler
198 return self.db_core_iface.actions_get(profile_key, **kwargs) 208 return self.db_core_iface.actions_get(profile_key, **kwargs)
199 209
200 def config_get(self, section, name, callback=None, errback=None): 210 def config_get(self, section, name, callback=None, errback=None):
201 if callback is None: 211 if callback is None:
202 error_handler = None 212 error_handler = None
203 else: 213 else:
204 if errback is None: 214 if errback is None:
205 errback = log.error 215 errback = log.error
206 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 216 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
207 kwargs={} 217 kwargs = {}
208 if callback is not None: 218 if callback is not None:
209 kwargs['timeout'] = const_TIMEOUT 219 kwargs["timeout"] = const_TIMEOUT
210 kwargs['reply_handler'] = callback 220 kwargs["reply_handler"] = callback
211 kwargs['error_handler'] = error_handler 221 kwargs["error_handler"] = error_handler
212 return str(self.db_core_iface.config_get(section, name, **kwargs)) 222 return str(self.db_core_iface.config_get(section, name, **kwargs))
213 223
214 def connect(self, profile_key="@DEFAULT@", password='', options={}, callback=None, errback=None): 224 def connect(
215 if callback is None: 225 self,
216 error_handler = None 226 profile_key="@DEFAULT@",
217 else: 227 password="",
218 if errback is None: 228 options={},
219 errback = log.error 229 callback=None,
220 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 230 errback=None,
221 return self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 231 ):
222 232 if callback is None:
223 def contact_add(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 233 error_handler = None
224 if callback is None: 234 else:
225 error_handler = None 235 if errback is None:
226 else: 236 errback = log.error
227 if errback is None: 237 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
228 errback = log.error 238 return self.db_core_iface.connect(
229 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 239 profile_key,
230 kwargs={} 240 password,
231 if callback is not None: 241 options,
232 kwargs['timeout'] = const_TIMEOUT 242 timeout=const_TIMEOUT,
233 kwargs['reply_handler'] = callback 243 reply_handler=callback,
234 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
235 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)
236 262
237 def contact_del(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 263 def contact_del(
238 if callback is None: 264 self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None
239 error_handler = None 265 ):
240 else: 266 if callback is None:
241 if errback is None: 267 error_handler = None
242 errback = log.error 268 else:
243 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 269 if errback is None:
244 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 )
245 279
246 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):
247 if callback is None: 281 if callback is None:
248 error_handler = None 282 error_handler = None
249 else: 283 else:
250 if errback is None: 284 if errback is None:
251 errback = log.error 285 errback = log.error
252 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 286 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
253 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(
254 288 arg_0,
255 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@", callback=None, errback=None): 289 profile_key,
256 if callback is None: 290 timeout=const_TIMEOUT,
257 error_handler = None 291 reply_handler=callback,
258 else: 292 error_handler=error_handler,
259 if errback is None: 293 )
260 errback = log.error 294
261 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 295 def contact_update(
262 kwargs={} 296 self,
263 if callback is not None: 297 entity_jid,
264 kwargs['timeout'] = const_TIMEOUT 298 name,
265 kwargs['reply_handler'] = callback 299 groups,
266 kwargs['error_handler'] = error_handler 300 profile_key="@DEFAULT@",
267 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 )
268 318
269 def contacts_get(self, profile_key="@DEFAULT@", callback=None, errback=None): 319 def contacts_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
270 if callback is None: 320 if callback is None:
271 error_handler = None 321 error_handler = None
272 else: 322 else:
273 if errback is None: 323 if errback is None:
274 errback = log.error 324 errback = log.error
275 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 325 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
276 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(
277 327 profile_key,
278 def contacts_get_from_group(self, group, profile_key="@DEFAULT@", callback=None, errback=None): 328 timeout=const_TIMEOUT,
279 if callback is None: 329 reply_handler=callback,
280 error_handler = None 330 error_handler=error_handler,
281 else: 331 )
282 if errback is None: 332
283 errback = log.error 333 def contacts_get_from_group(
284 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 334 self, group, profile_key="@DEFAULT@", callback=None, errback=None
285 kwargs={} 335 ):
286 if callback is not None: 336 if callback is None:
287 kwargs['timeout'] = const_TIMEOUT 337 error_handler = None
288 kwargs['reply_handler'] = callback 338 else:
289 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
290 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)
291 348
292 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):
293 if callback is None: 350 if callback is None:
294 error_handler = None 351 error_handler = None
295 else: 352 else:
296 if errback is None: 353 if errback is None:
297 errback = log.error 354 errback = log.error
298 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 355 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
299 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(
300 357 self.db_core_iface.devices_infos_get(
301 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,
302 if callback is None: 359 profile_key,
303 error_handler = None 360 timeout=const_TIMEOUT,
304 else: 361 reply_handler=callback,
305 if errback is None: 362 error_handler=error_handler,
306 errback = log.error 363 )
307 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 364 )
308 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
309 366 def disco_find_by_features(
310 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 367 self,
311 if callback is None: 368 namespaces,
312 error_handler = None 369 identities,
313 else: 370 bare_jid=False,
314 if errback is None: 371 service=True,
315 errback = log.error 372 roster=True,
316 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 373 own_jid=True,
317 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,
318 375 profile_key="@DEFAULT@",
319 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 376 callback=None,
320 if callback is None: 377 errback=None,
321 error_handler = None 378 ):
322 else: 379 if callback is None:
323 if errback is None: 380 error_handler = None
324 errback = log.error 381 else:
325 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 382 if errback is None:
326 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 )
327 448
328 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None): 449 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None):
329 if callback is None: 450 if callback is None:
330 error_handler = None 451 error_handler = None
331 else: 452 else:
332 if errback is None: 453 if errback is None:
333 errback = log.error 454 errback = log.error
334 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 455 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
335 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 )
336 462
337 def encryption_namespace_get(self, arg_0, callback=None, errback=None): 463 def encryption_namespace_get(self, arg_0, callback=None, errback=None):
338 if callback is None: 464 if callback is None:
339 error_handler = None 465 error_handler = None
340 else: 466 else:
341 if errback is None: 467 if errback is None:
342 errback = log.error 468 errback = log.error
343 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 469 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
344 kwargs={} 470 kwargs = {}
345 if callback is not None: 471 if callback is not None:
346 kwargs['timeout'] = const_TIMEOUT 472 kwargs["timeout"] = const_TIMEOUT
347 kwargs['reply_handler'] = callback 473 kwargs["reply_handler"] = callback
348 kwargs['error_handler'] = error_handler 474 kwargs["error_handler"] = error_handler
349 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))
350 476
351 def encryption_plugins_get(self, callback=None, errback=None): 477 def encryption_plugins_get(self, callback=None, errback=None):
352 if callback is None: 478 if callback is None:
353 error_handler = None 479 error_handler = None
354 else: 480 else:
355 if errback is None: 481 if errback is None:
356 errback = log.error 482 errback = log.error
357 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 483 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
358 kwargs={} 484 kwargs = {}
359 if callback is not None: 485 if callback is not None:
360 kwargs['timeout'] = const_TIMEOUT 486 kwargs["timeout"] = const_TIMEOUT
361 kwargs['reply_handler'] = callback 487 kwargs["reply_handler"] = callback
362 kwargs['error_handler'] = error_handler 488 kwargs["error_handler"] = error_handler
363 return str(self.db_core_iface.encryption_plugins_get(**kwargs)) 489 return str(self.db_core_iface.encryption_plugins_get(**kwargs))
364 490
365 def encryption_trust_ui_get(self, to_jid, namespace, profile_key, callback=None, errback=None): 491 def encryption_trust_ui_get(
366 if callback is None: 492 self, to_jid, namespace, profile_key, callback=None, errback=None
367 error_handler = None 493 ):
368 else: 494 if callback is None:
369 if errback is None: 495 error_handler = None
370 errback = log.error 496 else:
371 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 497 if errback is None:
372 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 )
373 510
374 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):
375 if callback is None: 512 if callback is None:
376 error_handler = None 513 error_handler = None
377 else: 514 else:
378 if errback is None: 515 if errback is None:
379 errback = log.error 516 errback = log.error
380 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 517 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
381 kwargs={} 518 kwargs = {}
382 if callback is not None: 519 if callback is not None:
383 kwargs['timeout'] = const_TIMEOUT 520 kwargs["timeout"] = const_TIMEOUT
384 kwargs['reply_handler'] = callback 521 kwargs["reply_handler"] = callback
385 kwargs['error_handler'] = error_handler 522 kwargs["error_handler"] = error_handler
386 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)
387 524
388 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):
389 if callback is None: 526 if callback is None:
390 error_handler = None 527 error_handler = None
391 else: 528 else:
392 if errback is None: 529 if errback is None:
393 errback = log.error 530 errback = log.error
394 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 531 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
395 kwargs={} 532 kwargs = {}
396 if callback is not None: 533 if callback is not None:
397 kwargs['timeout'] = const_TIMEOUT 534 kwargs["timeout"] = const_TIMEOUT
398 kwargs['reply_handler'] = callback 535 kwargs["reply_handler"] = callback
399 kwargs['error_handler'] = error_handler 536 kwargs["error_handler"] = error_handler
400 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)
401 538
402 def features_get(self, profile_key, callback=None, errback=None): 539 def features_get(self, profile_key, callback=None, errback=None):
403 if callback is None: 540 if callback is None:
404 error_handler = None 541 error_handler = None
405 else: 542 else:
406 if errback is None: 543 if errback is None:
407 errback = log.error 544 errback = log.error
408 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 545 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
409 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(
410 547 profile_key,
411 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@", callback=None, errback=None): 548 timeout=const_TIMEOUT,
412 if callback is None: 549 reply_handler=callback,
413 error_handler = None 550 error_handler=error_handler,
414 else: 551 )
415 if errback is None: 552
416 errback = log.error 553 def history_get(
417 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 554 self,
418 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 )
419 581
420 def image_check(self, arg_0, callback=None, errback=None): 582 def image_check(self, arg_0, callback=None, errback=None):
421 if callback is None: 583 if callback is None:
422 error_handler = None 584 error_handler = None
423 else: 585 else:
424 if errback is None: 586 if errback is None:
425 errback = log.error 587 errback = log.error
426 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 588 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
427 kwargs={} 589 kwargs = {}
428 if callback is not None: 590 if callback is not None:
429 kwargs['timeout'] = const_TIMEOUT 591 kwargs["timeout"] = const_TIMEOUT
430 kwargs['reply_handler'] = callback 592 kwargs["reply_handler"] = callback
431 kwargs['error_handler'] = error_handler 593 kwargs["error_handler"] = error_handler
432 return str(self.db_core_iface.image_check(arg_0, **kwargs)) 594 return str(self.db_core_iface.image_check(arg_0, **kwargs))
433 595
434 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):
435 if callback is None: 597 if callback is None:
436 error_handler = None 598 error_handler = None
437 else: 599 else:
438 if errback is None: 600 if errback is None:
439 errback = log.error 601 errback = log.error
440 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 602 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
441 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(
442 604 self.db_core_iface.image_convert(
443 def image_generate_preview(self, image_path, profile_key, callback=None, errback=None): 605 source,
444 if callback is None: 606 dest,
445 error_handler = None 607 arg_2,
446 else: 608 extra,
447 if errback is None: 609 timeout=const_TIMEOUT,
448 errback = log.error 610 reply_handler=callback,
449 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 611 error_handler=error_handler,
450 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 )
451 633
452 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):
453 if callback is None: 635 if callback is None:
454 error_handler = None 636 error_handler = None
455 else: 637 else:
456 if errback is None: 638 if errback is None:
457 errback = log.error 639 errback = log.error
458 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 640 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
459 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 )
460 651
461 def init_pre_script(self, callback=None, errback=None): 652 def init_pre_script(self, callback=None, errback=None):
462 if callback is None: 653 if callback is None:
463 error_handler = None 654 error_handler = None
464 else: 655 else:
465 if errback is None: 656 if errback is None:
466 errback = log.error 657 errback = log.error
467 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 658 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
468 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 )
469 662
470 def is_connected(self, profile_key="@DEFAULT@", callback=None, errback=None): 663 def is_connected(self, profile_key="@DEFAULT@", callback=None, errback=None):
471 if callback is None: 664 if callback is None:
472 error_handler = None 665 error_handler = None
473 else: 666 else:
474 if errback is None: 667 if errback is None:
475 errback = log.error 668 errback = log.error
476 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 669 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
477 kwargs={} 670 kwargs = {}
478 if callback is not None: 671 if callback is not None:
479 kwargs['timeout'] = const_TIMEOUT 672 kwargs["timeout"] = const_TIMEOUT
480 kwargs['reply_handler'] = callback 673 kwargs["reply_handler"] = callback
481 kwargs['error_handler'] = error_handler 674 kwargs["error_handler"] = error_handler
482 return self.db_core_iface.is_connected(profile_key, **kwargs) 675 return self.db_core_iface.is_connected(profile_key, **kwargs)
483 676
484 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None): 677 def main_resource_get(
485 if callback is None: 678 self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None
486 error_handler = None 679 ):
487 else: 680 if callback is None:
488 if errback is None: 681 error_handler = None
489 errback = log.error 682 else:
490 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 683 if errback is None:
491 kwargs={} 684 errback = log.error
492 if callback is not None: 685 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
493 kwargs['timeout'] = const_TIMEOUT 686 kwargs = {}
494 kwargs['reply_handler'] = callback 687 if callback is not None:
495 kwargs['error_handler'] = error_handler 688 kwargs["timeout"] = const_TIMEOUT
496 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 )
497 694
498 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):
499 if callback is None: 696 if callback is None:
500 error_handler = None 697 error_handler = None
501 else: 698 else:
502 if errback is None: 699 if errback is None:
503 errback = log.error 700 errback = log.error
504 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 701 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
505 kwargs={} 702 kwargs = {}
506 if callback is not None: 703 if callback is not None:
507 kwargs['timeout'] = const_TIMEOUT 704 kwargs["timeout"] = const_TIMEOUT
508 kwargs['reply_handler'] = callback 705 kwargs["reply_handler"] = callback
509 kwargs['error_handler'] = error_handler 706 kwargs["error_handler"] = error_handler
510 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))
511 708
512 def menu_launch(self, menu_type, path, data, security_limit, profile_key, callback=None, errback=None): 709 def menu_launch(
513 if callback is None: 710 self,
514 error_handler = None 711 menu_type,
515 else: 712 path,
516 if errback is None: 713 data,
517 errback = log.error 714 security_limit,
518 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 715 profile_key,
519 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 )
520 735
521 def menus_get(self, language, security_limit, callback=None, errback=None): 736 def menus_get(self, language, security_limit, callback=None, errback=None):
522 if callback is None: 737 if callback is None:
523 error_handler = None 738 error_handler = None
524 else: 739 else:
525 if errback is None: 740 if errback is None:
526 errback = log.error 741 errback = log.error
527 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 742 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
528 kwargs={} 743 kwargs = {}
529 if callback is not None: 744 if callback is not None:
530 kwargs['timeout'] = const_TIMEOUT 745 kwargs["timeout"] = const_TIMEOUT
531 kwargs['reply_handler'] = callback 746 kwargs["reply_handler"] = callback
532 kwargs['error_handler'] = error_handler 747 kwargs["error_handler"] = error_handler
533 return self.db_core_iface.menus_get(language, security_limit, **kwargs) 748 return self.db_core_iface.menus_get(language, security_limit, **kwargs)
534 749
535 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):
536 if callback is None: 751 if callback is None:
537 error_handler = None 752 error_handler = None
538 else: 753 else:
539 if errback is None: 754 if errback is None:
540 errback = log.error 755 errback = log.error
541 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 756 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
542 kwargs={} 757 kwargs = {}
543 if callback is not None: 758 if callback is not None:
544 kwargs['timeout'] = const_TIMEOUT 759 kwargs["timeout"] = const_TIMEOUT
545 kwargs['reply_handler'] = callback 760 kwargs["reply_handler"] = callback
546 kwargs['error_handler'] = error_handler 761 kwargs["error_handler"] = error_handler
547 return str(self.db_core_iface.message_encryption_get(to_jid, profile_key, **kwargs)) 762 return str(
548 763 self.db_core_iface.message_encryption_get(to_jid, profile_key, **kwargs)
549 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@", callback=None, errback=None): 764 )
550 if callback is None: 765
551 error_handler = None 766 def message_encryption_start(
552 else: 767 self,
553 if errback is None: 768 to_jid,
554 errback = log.error 769 namespace="",
555 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 770 replace=False,
556 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 )
557 790
558 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):
559 if callback is None: 792 if callback is None:
560 error_handler = None 793 error_handler = None
561 else: 794 else:
562 if errback is None: 795 if errback is None:
563 errback = log.error 796 errback = log.error
564 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 797 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
565 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(
566 799 to_jid,
567 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@", callback=None, errback=None): 800 profile_key,
568 if callback is None: 801 timeout=const_TIMEOUT,
569 error_handler = None 802 reply_handler=callback,
570 else: 803 error_handler=error_handler,
571 if errback is None: 804 )
572 errback = log.error 805
573 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 806 def message_send(
574 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 )
575 834
576 def namespaces_get(self, callback=None, errback=None): 835 def namespaces_get(self, callback=None, errback=None):
577 if callback is None: 836 if callback is None:
578 error_handler = None 837 error_handler = None
579 else: 838 else:
580 if errback is None: 839 if errback is None:
581 errback = log.error 840 errback = log.error
582 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 841 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
583 kwargs={} 842 kwargs = {}
584 if callback is not None: 843 if callback is not None:
585 kwargs['timeout'] = const_TIMEOUT 844 kwargs["timeout"] = const_TIMEOUT
586 kwargs['reply_handler'] = callback 845 kwargs["reply_handler"] = callback
587 kwargs['error_handler'] = error_handler 846 kwargs["error_handler"] = error_handler
588 return self.db_core_iface.namespaces_get(**kwargs) 847 return self.db_core_iface.namespaces_get(**kwargs)
589 848
590 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(
591 if callback is None: 850 self,
592 error_handler = None 851 type_,
593 else: 852 body_plain,
594 if errback is None: 853 body_rich,
595 errback = log.error 854 title,
596 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 855 is_global,
597 kwargs={} 856 requires_action,
598 if callback is not None: 857 arg_6,
599 kwargs['timeout'] = const_TIMEOUT 858 priority,
600 kwargs['reply_handler'] = callback 859 expire_at,
601 kwargs['error_handler'] = error_handler 860 extra,
602 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,
603 862 errback=None,
604 def notification_delete(self, id_, is_global, profile_key, callback=None, errback=None): 863 ):
605 if callback is None: 864 if callback is None:
606 error_handler = None 865 error_handler = None
607 else: 866 else:
608 if errback is None: 867 if errback is None:
609 errback = log.error 868 errback = log.error
610 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 869 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
611 kwargs={} 870 kwargs = {}
612 if callback is not None: 871 if callback is not None:
613 kwargs['timeout'] = const_TIMEOUT 872 kwargs["timeout"] = const_TIMEOUT
614 kwargs['reply_handler'] = callback 873 kwargs["reply_handler"] = callback
615 kwargs['error_handler'] = error_handler 874 kwargs["error_handler"] = error_handler
616 return self.db_core_iface.notification_delete(id_, is_global, profile_key, **kwargs) 875 return self.db_core_iface.notification_add(
617 876 type_,
618 def notifications_expired_clean(self, limit_timestamp, profile_key, callback=None, errback=None): 877 body_plain,
619 if callback is None: 878 body_rich,
620 error_handler = None 879 title,
621 else: 880 is_global,
622 if errback is None: 881 requires_action,
623 errback = log.error 882 arg_6,
624 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 883 priority,
625 kwargs={} 884 expire_at,
626 if callback is not None: 885 extra,
627 kwargs['timeout'] = const_TIMEOUT 886 **kwargs,
628 kwargs['reply_handler'] = callback 887 )
629 kwargs['error_handler'] = error_handler 888
630 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 )
631 924
632 def notifications_get(self, filters, profile_key, callback=None, errback=None): 925 def notifications_get(self, filters, profile_key, callback=None, errback=None):
633 if callback is None: 926 if callback is None:
634 error_handler = None 927 error_handler = None
635 else: 928 else:
636 if errback is None: 929 if errback is None:
637 errback = log.error 930 errback = log.error
638 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 931 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
639 kwargs={} 932 kwargs = {}
640 if callback is not None: 933 if callback is not None:
641 kwargs['timeout'] = const_TIMEOUT 934 kwargs["timeout"] = const_TIMEOUT
642 kwargs['reply_handler'] = callback 935 kwargs["reply_handler"] = callback
643 kwargs['error_handler'] = error_handler 936 kwargs["error_handler"] = error_handler
644 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))
645 938
646 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@", callback=None, errback=None): 939 def param_get_a(
647 if callback is None: 940 self,
648 error_handler = None 941 name,
649 else: 942 category,
650 if errback is None: 943 attribute="value",
651 errback = log.error 944 profile_key="@DEFAULT@",
652 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 945 callback=None,
653 kwargs={} 946 errback=None,
654 if callback is not None: 947 ):
655 kwargs['timeout'] = const_TIMEOUT 948 if callback is None:
656 kwargs['reply_handler'] = callback 949 error_handler = None
657 kwargs['error_handler'] = error_handler 950 else:
658 return str(self.db_core_iface.param_get_a(name, category, attribute, profile_key, **kwargs)) 951 if errback is None:
659 952 errback = log.error
660 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))
661 if callback is None: 954 kwargs = {}
662 error_handler = None 955 if callback is not None:
663 else: 956 kwargs["timeout"] = const_TIMEOUT
664 if errback is None: 957 kwargs["reply_handler"] = callback
665 errback = log.error 958 kwargs["error_handler"] = error_handler
666 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 959 return str(
667 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(
668 961 name, category, attribute, profile_key, **kwargs
669 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None): 962 )
670 if callback is None: 963 )
671 error_handler = None 964
672 else: 965 def param_get_a_async(
673 if errback is None: 966 self,
674 errback = log.error 967 name,
675 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 968 category,
676 kwargs={} 969 attribute="value",
677 if callback is not None: 970 security_limit=-1,
678 kwargs['timeout'] = const_TIMEOUT 971 profile_key="@DEFAULT@",
679 kwargs['reply_handler'] = callback 972 callback=None,
680 kwargs['error_handler'] = error_handler 973 errback=None,
681 return self.db_core_iface.param_set(name, value, category, security_limit, profile_key, **kwargs) 974 ):
682 975 if callback is None:
683 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@", callback=None, errback=None): 976 error_handler = None
684 if callback is None: 977 else:
685 error_handler = None 978 if errback is None:
686 else: 979 errback = log.error
687 if errback is None: 980 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
688 errback = log.error 981 return str(
689 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 982 self.db_core_iface.param_get_a_async(
690 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 )
691 1045
692 def params_categories_get(self, callback=None, errback=None): 1046 def params_categories_get(self, callback=None, errback=None):
693 if callback is None: 1047 if callback is None:
694 error_handler = None 1048 error_handler = None
695 else: 1049 else:
696 if errback is None: 1050 if errback is None:
697 errback = log.error 1051 errback = log.error
698 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1052 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
699 kwargs={} 1053 kwargs = {}
700 if callback is not None: 1054 if callback is not None:
701 kwargs['timeout'] = const_TIMEOUT 1055 kwargs["timeout"] = const_TIMEOUT
702 kwargs['reply_handler'] = callback 1056 kwargs["reply_handler"] = callback
703 kwargs['error_handler'] = error_handler 1057 kwargs["error_handler"] = error_handler
704 return self.db_core_iface.params_categories_get(**kwargs) 1058 return self.db_core_iface.params_categories_get(**kwargs)
705 1059
706 def params_register_app(self, xml, security_limit=-1, app='', callback=None, errback=None): 1060 def params_register_app(
707 if callback is None: 1061 self, xml, security_limit=-1, app="", callback=None, errback=None
708 error_handler = None 1062 ):
709 else: 1063 if callback is None:
710 if errback is None: 1064 error_handler = None
711 errback = log.error 1065 else:
712 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1066 if errback is None:
713 kwargs={} 1067 errback = log.error
714 if callback is not None: 1068 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
715 kwargs['timeout'] = const_TIMEOUT 1069 kwargs = {}
716 kwargs['reply_handler'] = callback 1070 if callback is not None:
717 kwargs['error_handler'] = error_handler 1071 kwargs["timeout"] = const_TIMEOUT
1072 kwargs["reply_handler"] = callback
1073 kwargs["error_handler"] = error_handler
718 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)
719 1075
720 def params_template_load(self, filename, callback=None, errback=None): 1076 def params_template_load(self, filename, callback=None, errback=None):
721 if callback is None: 1077 if callback is None:
722 error_handler = None 1078 error_handler = None
723 else: 1079 else:
724 if errback is None: 1080 if errback is None:
725 errback = log.error 1081 errback = log.error
726 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1082 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
727 kwargs={} 1083 kwargs = {}
728 if callback is not None: 1084 if callback is not None:
729 kwargs['timeout'] = const_TIMEOUT 1085 kwargs["timeout"] = const_TIMEOUT
730 kwargs['reply_handler'] = callback 1086 kwargs["reply_handler"] = callback
731 kwargs['error_handler'] = error_handler 1087 kwargs["error_handler"] = error_handler
732 return self.db_core_iface.params_template_load(filename, **kwargs) 1088 return self.db_core_iface.params_template_load(filename, **kwargs)
733 1089
734 def params_template_save(self, filename, callback=None, errback=None): 1090 def params_template_save(self, filename, callback=None, errback=None):
735 if callback is None: 1091 if callback is None:
736 error_handler = None 1092 error_handler = None
737 else: 1093 else:
738 if errback is None: 1094 if errback is None:
739 errback = log.error 1095 errback = log.error
740 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1096 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
741 kwargs={} 1097 kwargs = {}
742 if callback is not None: 1098 if callback is not None:
743 kwargs['timeout'] = const_TIMEOUT 1099 kwargs["timeout"] = const_TIMEOUT
744 kwargs['reply_handler'] = callback 1100 kwargs["reply_handler"] = callback
745 kwargs['error_handler'] = error_handler 1101 kwargs["error_handler"] = error_handler
746 return self.db_core_iface.params_template_save(filename, **kwargs) 1102 return self.db_core_iface.params_template_save(filename, **kwargs)
747 1103
748 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(
749 if callback is None: 1105 self,
750 error_handler = None 1106 category,
751 else: 1107 security_limit=-1,
752 if errback is None: 1108 app="",
753 errback = log.error 1109 extra="",
754 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1110 profile_key="@DEFAULT@",
755 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,
756 1112 errback=None,
757 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@", callback=None, errback=None): 1113 ):
758 if callback is None: 1114 if callback is None:
759 error_handler = None 1115 error_handler = None
760 else: 1116 else:
761 if errback is None: 1117 if errback is None:
762 errback = log.error 1118 errback = log.error
763 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1119 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
764 kwargs={} 1120 return self.db_core_iface.params_values_from_category_get_async(
765 if callback is not None: 1121 category,
766 kwargs['timeout'] = const_TIMEOUT 1122 security_limit,
767 kwargs['reply_handler'] = callback 1123 app,
768 kwargs['error_handler'] = error_handler 1124 extra,
769 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 )
770 1154
771 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):
772 if callback is None: 1156 if callback is None:
773 error_handler = None 1157 error_handler = None
774 else: 1158 else:
775 if errback is None: 1159 if errback is None:
776 errback = log.error 1160 errback = log.error
777 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1161 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
778 kwargs={} 1162 kwargs = {}
779 if callback is not None: 1163 if callback is not None:
780 kwargs['timeout'] = const_TIMEOUT 1164 kwargs["timeout"] = const_TIMEOUT
781 kwargs['reply_handler'] = callback 1165 kwargs["reply_handler"] = callback
782 kwargs['error_handler'] = error_handler 1166 kwargs["error_handler"] = error_handler
783 return self.db_core_iface.presence_statuses_get(profile_key, **kwargs) 1167 return self.db_core_iface.presence_statuses_get(profile_key, **kwargs)
784 1168
785 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):
786 if callback is None: 1170 if callback is None:
787 error_handler = None 1171 error_handler = None
788 else: 1172 else:
789 if errback is None: 1173 if errback is None:
790 errback = log.error 1174 errback = log.error
791 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1175 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
792 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 )
793 1184
794 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):
795 if callback is None: 1186 if callback is None:
796 error_handler = None 1187 error_handler = None
797 else: 1188 else:
798 if errback is None: 1189 if errback is None:
799 errback = log.error 1190 errback = log.error
800 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1191 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
801 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(
802 1193 self.db_core_iface.private_data_get(
803 def private_data_set(self, namespace, key, data, profile_key, callback=None, errback=None): 1194 namespace,
804 if callback is None: 1195 key,
805 error_handler = None 1196 profile_key,
806 else: 1197 timeout=const_TIMEOUT,
807 if errback is None: 1198 reply_handler=callback,
808 errback = log.error 1199 error_handler=error_handler,
809 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1200 )
810 return self.db_core_iface.private_data_set(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 1201 )
811 1202
812 def profile_create(self, profile, password='', component='', callback=None, errback=None): 1203 def private_data_set(
813 if callback is None: 1204 self, namespace, key, data, profile_key, callback=None, errback=None
814 error_handler = None 1205 ):
815 else: 1206 if callback is None:
816 if errback is None: 1207 error_handler = None
817 errback = log.error 1208 else:
818 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1209 if errback is None:
819 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 )
820 1239
821 def profile_delete_async(self, profile, callback=None, errback=None): 1240 def profile_delete_async(self, profile, callback=None, errback=None):
822 if callback is None: 1241 if callback is None:
823 error_handler = None 1242 error_handler = None
824 else: 1243 else:
825 if errback is None: 1244 if errback is None:
826 errback = log.error 1245 errback = log.error
827 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1246 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
828 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(
829 1248 profile,
830 def profile_is_session_started(self, profile_key="@DEFAULT@", callback=None, errback=None): 1249 timeout=const_TIMEOUT,
831 if callback is None: 1250 reply_handler=callback,
832 error_handler = None 1251 error_handler=error_handler,
833 else: 1252 )
834 if errback is None: 1253
835 errback = log.error 1254 def profile_is_session_started(
836 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1255 self, profile_key="@DEFAULT@", callback=None, errback=None
837 kwargs={} 1256 ):
838 if callback is not None: 1257 if callback is None:
839 kwargs['timeout'] = const_TIMEOUT 1258 error_handler = None
840 kwargs['reply_handler'] = callback 1259 else:
841 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
842 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)
843 1269
844 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):
845 if callback is None: 1271 if callback is None:
846 error_handler = None 1272 error_handler = None
847 else: 1273 else:
848 if errback is None: 1274 if errback is None:
849 errback = log.error 1275 errback = log.error
850 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1276 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
851 kwargs={} 1277 kwargs = {}
852 if callback is not None: 1278 if callback is not None:
853 kwargs['timeout'] = const_TIMEOUT 1279 kwargs["timeout"] = const_TIMEOUT
854 kwargs['reply_handler'] = callback 1280 kwargs["reply_handler"] = callback
855 kwargs['error_handler'] = error_handler 1281 kwargs["error_handler"] = error_handler
856 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))
857 1283
858 def profile_set_default(self, profile, callback=None, errback=None): 1284 def profile_set_default(self, profile, callback=None, errback=None):
859 if callback is None: 1285 if callback is None:
860 error_handler = None 1286 error_handler = None
861 else: 1287 else:
862 if errback is None: 1288 if errback is None:
863 errback = log.error 1289 errback = log.error
864 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1290 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
865 kwargs={} 1291 kwargs = {}
866 if callback is not None: 1292 if callback is not None:
867 kwargs['timeout'] = const_TIMEOUT 1293 kwargs["timeout"] = const_TIMEOUT
868 kwargs['reply_handler'] = callback 1294 kwargs["reply_handler"] = callback
869 kwargs['error_handler'] = error_handler 1295 kwargs["error_handler"] = error_handler
870 return self.db_core_iface.profile_set_default(profile, **kwargs) 1296 return self.db_core_iface.profile_set_default(profile, **kwargs)
871 1297
872 def profile_start_session(self, password='', profile_key="@DEFAULT@", callback=None, errback=None): 1298 def profile_start_session(
873 if callback is None: 1299 self, password="", profile_key="@DEFAULT@", callback=None, errback=None
874 error_handler = None 1300 ):
875 else: 1301 if callback is None:
876 if errback is None: 1302 error_handler = None
877 errback = log.error 1303 else:
878 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1304 if errback is None:
879 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
880 1306 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
881 def profiles_list_get(self, clients=True, components=False, callback=None, errback=None): 1307 return self.db_core_iface.profile_start_session(
882 if callback is None: 1308 password,
883 error_handler = None 1309 profile_key,
884 else: 1310 timeout=const_TIMEOUT,
885 if errback is None: 1311 reply_handler=callback,
886 errback = log.error 1312 error_handler=error_handler,
887 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1313 )
888 kwargs={} 1314
889 if callback is not None: 1315 def profiles_list_get(
890 kwargs['timeout'] = const_TIMEOUT 1316 self, clients=True, components=False, callback=None, errback=None
891 kwargs['reply_handler'] = callback 1317 ):
892 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
893 return self.db_core_iface.profiles_list_get(clients, components, **kwargs) 1329 return self.db_core_iface.profiles_list_get(clients, components, **kwargs)
894 1330
895 def progress_get(self, id, profile, callback=None, errback=None): 1331 def progress_get(self, id, profile, callback=None, errback=None):
896 if callback is None: 1332 if callback is None:
897 error_handler = None 1333 error_handler = None
898 else: 1334 else:
899 if errback is None: 1335 if errback is None:
900 errback = log.error 1336 errback = log.error
901 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1337 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
902 kwargs={} 1338 kwargs = {}
903 if callback is not None: 1339 if callback is not None:
904 kwargs['timeout'] = const_TIMEOUT 1340 kwargs["timeout"] = const_TIMEOUT
905 kwargs['reply_handler'] = callback 1341 kwargs["reply_handler"] = callback
906 kwargs['error_handler'] = error_handler 1342 kwargs["error_handler"] = error_handler
907 return self.db_core_iface.progress_get(id, profile, **kwargs) 1343 return self.db_core_iface.progress_get(id, profile, **kwargs)
908 1344
909 def progress_get_all(self, profile, callback=None, errback=None): 1345 def progress_get_all(self, profile, callback=None, errback=None):
910 if callback is None: 1346 if callback is None:
911 error_handler = None 1347 error_handler = None
912 else: 1348 else:
913 if errback is None: 1349 if errback is None:
914 errback = log.error 1350 errback = log.error
915 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1351 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
916 kwargs={} 1352 kwargs = {}
917 if callback is not None: 1353 if callback is not None:
918 kwargs['timeout'] = const_TIMEOUT 1354 kwargs["timeout"] = const_TIMEOUT
919 kwargs['reply_handler'] = callback 1355 kwargs["reply_handler"] = callback
920 kwargs['error_handler'] = error_handler 1356 kwargs["error_handler"] = error_handler
921 return self.db_core_iface.progress_get_all(profile, **kwargs) 1357 return self.db_core_iface.progress_get_all(profile, **kwargs)
922 1358
923 def progress_get_all_metadata(self, profile, callback=None, errback=None): 1359 def progress_get_all_metadata(self, profile, callback=None, errback=None):
924 if callback is None: 1360 if callback is None:
925 error_handler = None 1361 error_handler = None
926 else: 1362 else:
927 if errback is None: 1363 if errback is None:
928 errback = log.error 1364 errback = log.error
929 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1365 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
930 kwargs={} 1366 kwargs = {}
931 if callback is not None: 1367 if callback is not None:
932 kwargs['timeout'] = const_TIMEOUT 1368 kwargs["timeout"] = const_TIMEOUT
933 kwargs['reply_handler'] = callback 1369 kwargs["reply_handler"] = callback
934 kwargs['error_handler'] = error_handler 1370 kwargs["error_handler"] = error_handler
935 return self.db_core_iface.progress_get_all_metadata(profile, **kwargs) 1371 return self.db_core_iface.progress_get_all_metadata(profile, **kwargs)
936 1372
937 def ready_get(self, callback=None, errback=None): 1373 def ready_get(self, callback=None, errback=None):
938 if callback is None: 1374 if callback is None:
939 error_handler = None 1375 error_handler = None
940 else: 1376 else:
941 if errback is None: 1377 if errback is None:
942 errback = log.error 1378 errback = log.error
943 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1379 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
944 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 )
945 1383
946 def roster_resync(self, profile_key="@DEFAULT@", callback=None, errback=None): 1384 def roster_resync(self, profile_key="@DEFAULT@", callback=None, errback=None):
947 if callback is None: 1385 if callback is None:
948 error_handler = None 1386 error_handler = None
949 else: 1387 else:
950 if errback is None: 1388 if errback is None:
951 errback = log.error 1389 errback = log.error
952 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1390 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
953 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 )
954 1397
955 def session_infos_get(self, profile_key, callback=None, errback=None): 1398 def session_infos_get(self, profile_key, callback=None, errback=None):
956 if callback is None: 1399 if callback is None:
957 error_handler = None 1400 error_handler = None
958 else: 1401 else:
959 if errback is None: 1402 if errback is None:
960 errback = log.error 1403 errback = log.error
961 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1404 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
962 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 )
963 1411
964 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):
965 if callback is None: 1413 if callback is None:
966 error_handler = None 1414 error_handler = None
967 else: 1415 else:
968 if errback is None: 1416 if errback is None:
969 errback = log.error 1417 errback = log.error
970 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1418 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
971 kwargs={} 1419 kwargs = {}
972 if callback is not None: 1420 if callback is not None:
973 kwargs['timeout'] = const_TIMEOUT 1421 kwargs["timeout"] = const_TIMEOUT
974 kwargs['reply_handler'] = callback 1422 kwargs["reply_handler"] = callback
975 kwargs['error_handler'] = error_handler 1423 kwargs["error_handler"] = error_handler
976 return self.db_core_iface.sub_waiting_get(profile_key, **kwargs) 1424 return self.db_core_iface.sub_waiting_get(profile_key, **kwargs)
977 1425
978 def subscription(self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None): 1426 def subscription(
979 if callback is None: 1427 self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None
980 error_handler = None 1428 ):
981 else: 1429 if callback is None:
982 if errback is None: 1430 error_handler = None
983 errback = log.error 1431 else:
984 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1432 if errback is None:
985 kwargs={} 1433 errback = log.error
986 if callback is not None: 1434 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
987 kwargs['timeout'] = const_TIMEOUT 1435 kwargs = {}
988 kwargs['reply_handler'] = callback 1436 if callback is not None:
989 kwargs['error_handler'] = error_handler 1437 kwargs["timeout"] = const_TIMEOUT
1438 kwargs["reply_handler"] = callback
1439 kwargs["error_handler"] = error_handler
990 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)
991 1441
992 def version_get(self, callback=None, errback=None): 1442 def version_get(self, callback=None, errback=None):
993 if callback is None: 1443 if callback is None:
994 error_handler = None 1444 error_handler = None
995 else: 1445 else:
996 if errback is None: 1446 if errback is None:
997 errback = log.error 1447 errback = log.error
998 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 1448 error_handler = lambda err: errback(dbus_to_bridge_exception(err))
999 kwargs={} 1449 kwargs = {}
1000 if callback is not None: 1450 if callback is not None:
1001 kwargs['timeout'] = const_TIMEOUT 1451 kwargs["timeout"] = const_TIMEOUT
1002 kwargs['reply_handler'] = callback 1452 kwargs["reply_handler"] = callback
1003 kwargs['error_handler'] = error_handler 1453 kwargs["error_handler"] = error_handler
1004 return str(self.db_core_iface.version_get(**kwargs)) 1454 return str(self.db_core_iface.version_get(**kwargs))
1005
1006 1455
1007 1456
1008 class AIOBridge(bridge): 1457 class AIOBridge(bridge):
1009 1458
1010 def register_signal(self, functionName, handler, iface="core"): 1459 def register_signal(self, functionName, handler, iface="core"):
1067 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None), 1516 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None),
1068 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e), 1517 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e),
1069 ) 1518 )
1070 return fut 1519 return fut
1071 1520
1072
1073 def action_launch(self, callback_id, data, profile_key="@DEFAULT@"): 1521 def action_launch(self, callback_id, data, profile_key="@DEFAULT@"):
1074 loop = asyncio.get_running_loop() 1522 loop = asyncio.get_running_loop()
1075 fut = loop.create_future() 1523 fut = loop.create_future()
1076 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)
1077 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(
1078 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 )
1079 return fut 1536 return fut
1080 1537
1081 def actions_get(self, profile_key="@DEFAULT@"): 1538 def actions_get(self, profile_key="@DEFAULT@"):
1082 loop = asyncio.get_running_loop() 1539 loop = asyncio.get_running_loop()
1083 fut = loop.create_future() 1540 fut = loop.create_future()
1084 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)
1085 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(
1086 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 )
1087 return fut 1551 return fut
1088 1552
1089 def config_get(self, section, name): 1553 def config_get(self, section, name):
1090 loop = asyncio.get_running_loop() 1554 loop = asyncio.get_running_loop()
1091 fut = loop.create_future() 1555 fut = loop.create_future()
1092 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)
1093 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(
1094 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)
1095 return fut 1559 )
1096 1560 self.db_core_iface.config_get(
1097 def connect(self, profile_key="@DEFAULT@", password='', options={}): 1561 section,
1098 loop = asyncio.get_running_loop() 1562 name,
1099 fut = loop.create_future() 1563 timeout=const_TIMEOUT,
1100 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1564 reply_handler=reply_handler,
1101 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1565 error_handler=error_handler,
1102 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 )
1103 return fut 1584 return fut
1104 1585
1105 def contact_add(self, entity_jid, profile_key="@DEFAULT@"): 1586 def contact_add(self, entity_jid, profile_key="@DEFAULT@"):
1106 loop = asyncio.get_running_loop() 1587 loop = asyncio.get_running_loop()
1107 fut = loop.create_future() 1588 fut = loop.create_future()
1108 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)
1109 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(
1110 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 )
1111 return fut 1600 return fut
1112 1601
1113 def contact_del(self, entity_jid, profile_key="@DEFAULT@"): 1602 def contact_del(self, entity_jid, profile_key="@DEFAULT@"):
1114 loop = asyncio.get_running_loop() 1603 loop = asyncio.get_running_loop()
1115 fut = loop.create_future() 1604 fut = loop.create_future()
1116 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)
1117 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(
1118 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 )
1119 return fut 1616 return fut
1120 1617
1121 def contact_get(self, arg_0, profile_key="@DEFAULT@"): 1618 def contact_get(self, arg_0, profile_key="@DEFAULT@"):
1122 loop = asyncio.get_running_loop() 1619 loop = asyncio.get_running_loop()
1123 fut = loop.create_future() 1620 fut = loop.create_future()
1124 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)
1125 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(
1126 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 )
1127 return fut 1632 return fut
1128 1633
1129 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"): 1634 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"):
1130 loop = asyncio.get_running_loop() 1635 loop = asyncio.get_running_loop()
1131 fut = loop.create_future() 1636 fut = loop.create_future()
1132 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)
1133 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(
1134 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 )
1135 return fut 1650 return fut
1136 1651
1137 def contacts_get(self, profile_key="@DEFAULT@"): 1652 def contacts_get(self, profile_key="@DEFAULT@"):
1138 loop = asyncio.get_running_loop() 1653 loop = asyncio.get_running_loop()
1139 fut = loop.create_future() 1654 fut = loop.create_future()
1140 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)
1141 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(
1142 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 )
1143 return fut 1665 return fut
1144 1666
1145 def contacts_get_from_group(self, group, profile_key="@DEFAULT@"): 1667 def contacts_get_from_group(self, group, profile_key="@DEFAULT@"):
1146 loop = asyncio.get_running_loop() 1668 loop = asyncio.get_running_loop()
1147 fut = loop.create_future() 1669 fut = loop.create_future()
1148 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)
1149 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(
1150 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 )
1151 return fut 1681 return fut
1152 1682
1153 def devices_infos_get(self, bare_jid, profile_key): 1683 def devices_infos_get(self, bare_jid, profile_key):
1154 loop = asyncio.get_running_loop() 1684 loop = asyncio.get_running_loop()
1155 fut = loop.create_future() 1685 fut = loop.create_future()
1156 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)
1157 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(
1158 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)
1159 return fut 1689 )
1160 1690 self.db_core_iface.devices_infos_get(
1161 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,
1162 loop = asyncio.get_running_loop() 1692 profile_key,
1163 fut = loop.create_future() 1693 timeout=const_TIMEOUT,
1164 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1694 reply_handler=reply_handler,
1165 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1695 error_handler=error_handler,
1166 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 )
1167 return fut 1697 return fut
1168 1698
1169 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1699 def disco_find_by_features(
1170 loop = asyncio.get_running_loop() 1700 self,
1171 fut = loop.create_future() 1701 namespaces,
1172 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1702 identities,
1173 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1703 bare_jid=False,
1174 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,
1175 return fut 1705 roster=True,
1176 1706 own_jid=True,
1177 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1707 local_device=False,
1178 loop = asyncio.get_running_loop() 1708 profile_key="@DEFAULT@",
1179 fut = loop.create_future() 1709 ):
1180 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1710 loop = asyncio.get_running_loop()
1181 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1711 fut = loop.create_future()
1182 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 )
1183 return fut 1765 return fut
1184 1766
1185 def disconnect(self, profile_key="@DEFAULT@"): 1767 def disconnect(self, profile_key="@DEFAULT@"):
1186 loop = asyncio.get_running_loop() 1768 loop = asyncio.get_running_loop()
1187 fut = loop.create_future() 1769 fut = loop.create_future()
1188 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)
1189 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(
1190 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 )
1191 return fut 1780 return fut
1192 1781
1193 def encryption_namespace_get(self, arg_0): 1782 def encryption_namespace_get(self, arg_0):
1194 loop = asyncio.get_running_loop() 1783 loop = asyncio.get_running_loop()
1195 fut = loop.create_future() 1784 fut = loop.create_future()
1196 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)
1197 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(
1198 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 )
1199 return fut 1795 return fut
1200 1796
1201 def encryption_plugins_get(self): 1797 def encryption_plugins_get(self):
1202 loop = asyncio.get_running_loop() 1798 loop = asyncio.get_running_loop()
1203 fut = loop.create_future() 1799 fut = loop.create_future()
1204 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)
1205 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(
1206 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 )
1207 return fut 1809 return fut
1208 1810
1209 def encryption_trust_ui_get(self, to_jid, namespace, profile_key): 1811 def encryption_trust_ui_get(self, to_jid, namespace, profile_key):
1210 loop = asyncio.get_running_loop() 1812 loop = asyncio.get_running_loop()
1211 fut = loop.create_future() 1813 fut = loop.create_future()
1212 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)
1213 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(
1214 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 )
1215 return fut 1826 return fut
1216 1827
1217 def entities_data_get(self, jids, keys, profile): 1828 def entities_data_get(self, jids, keys, profile):
1218 loop = asyncio.get_running_loop() 1829 loop = asyncio.get_running_loop()
1219 fut = loop.create_future() 1830 fut = loop.create_future()
1220 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)
1221 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(
1222 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 )
1223 return fut 1843 return fut
1224 1844
1225 def entity_data_get(self, jid, keys, profile): 1845 def entity_data_get(self, jid, keys, profile):
1226 loop = asyncio.get_running_loop() 1846 loop = asyncio.get_running_loop()
1227 fut = loop.create_future() 1847 fut = loop.create_future()
1228 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)
1229 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(
1230 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 )
1231 return fut 1860 return fut
1232 1861
1233 def features_get(self, profile_key): 1862 def features_get(self, profile_key):
1234 loop = asyncio.get_running_loop() 1863 loop = asyncio.get_running_loop()
1235 fut = loop.create_future() 1864 fut = loop.create_future()
1236 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)
1237 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(
1238 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)
1239 return fut 1868 )
1240 1869 self.db_core_iface.features_get(
1241 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@"): 1870 profile_key,
1242 loop = asyncio.get_running_loop() 1871 timeout=const_TIMEOUT,
1243 fut = loop.create_future() 1872 reply_handler=reply_handler,
1244 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1873 error_handler=error_handler,
1245 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1874 )
1246 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 )
1247 return fut 1897 return fut
1248 1898
1249 def image_check(self, arg_0): 1899 def image_check(self, arg_0):
1250 loop = asyncio.get_running_loop() 1900 loop = asyncio.get_running_loop()
1251 fut = loop.create_future() 1901 fut = loop.create_future()
1252 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)
1253 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(
1254 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 )
1255 return fut 1912 return fut
1256 1913
1257 def image_convert(self, source, dest, arg_2, extra): 1914 def image_convert(self, source, dest, arg_2, extra):
1258 loop = asyncio.get_running_loop() 1915 loop = asyncio.get_running_loop()
1259 fut = loop.create_future() 1916 fut = loop.create_future()
1260 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)
1261 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(
1262 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 )
1263 return fut 1930 return fut
1264 1931
1265 def image_generate_preview(self, image_path, profile_key): 1932 def image_generate_preview(self, image_path, profile_key):
1266 loop = asyncio.get_running_loop() 1933 loop = asyncio.get_running_loop()
1267 fut = loop.create_future() 1934 fut = loop.create_future()
1268 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)
1269 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(
1270 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 )
1271 return fut 1946 return fut
1272 1947
1273 def image_resize(self, image_path, width, height): 1948 def image_resize(self, image_path, width, height):
1274 loop = asyncio.get_running_loop() 1949 loop = asyncio.get_running_loop()
1275 fut = loop.create_future() 1950 fut = loop.create_future()
1276 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)
1277 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(
1278 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 )
1279 return fut 1963 return fut
1280 1964
1281 def init_pre_script(self): 1965 def init_pre_script(self):
1282 loop = asyncio.get_running_loop() 1966 loop = asyncio.get_running_loop()
1283 fut = loop.create_future() 1967 fut = loop.create_future()
1284 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)
1285 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(
1286 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 )
1287 return fut 1977 return fut
1288 1978
1289 def is_connected(self, profile_key="@DEFAULT@"): 1979 def is_connected(self, profile_key="@DEFAULT@"):
1290 loop = asyncio.get_running_loop() 1980 loop = asyncio.get_running_loop()
1291 fut = loop.create_future() 1981 fut = loop.create_future()
1292 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)
1293 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(
1294 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 )
1295 return fut 1992 return fut
1296 1993
1297 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@"): 1994 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@"):
1298 loop = asyncio.get_running_loop() 1995 loop = asyncio.get_running_loop()
1299 fut = loop.create_future() 1996 fut = loop.create_future()
1300 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)
1301 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(
1302 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 )
1303 return fut 2008 return fut
1304 2009
1305 def menu_help_get(self, menu_id, language): 2010 def menu_help_get(self, menu_id, language):
1306 loop = asyncio.get_running_loop() 2011 loop = asyncio.get_running_loop()
1307 fut = loop.create_future() 2012 fut = loop.create_future()
1308 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)
1309 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(
1310 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 )
1311 return fut 2024 return fut
1312 2025
1313 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):
1314 loop = asyncio.get_running_loop() 2027 loop = asyncio.get_running_loop()
1315 fut = loop.create_future() 2028 fut = loop.create_future()
1316 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)
1317 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(
1318 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 )
1319 return fut 2043 return fut
1320 2044
1321 def menus_get(self, language, security_limit): 2045 def menus_get(self, language, security_limit):
1322 loop = asyncio.get_running_loop() 2046 loop = asyncio.get_running_loop()
1323 fut = loop.create_future() 2047 fut = loop.create_future()
1324 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)
1325 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(
1326 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 )
1327 return fut 2059 return fut
1328 2060
1329 def message_encryption_get(self, to_jid, profile_key): 2061 def message_encryption_get(self, to_jid, profile_key):
1330 loop = asyncio.get_running_loop() 2062 loop = asyncio.get_running_loop()
1331 fut = loop.create_future() 2063 fut = loop.create_future()
1332 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)
1333 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(
1334 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)
1335 return fut 2067 )
1336 2068 self.db_core_iface.message_encryption_get(
1337 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@"): 2069 to_jid,
1338 loop = asyncio.get_running_loop() 2070 profile_key,
1339 fut = loop.create_future() 2071 timeout=const_TIMEOUT,
1340 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2072 reply_handler=reply_handler,
1341 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2073 error_handler=error_handler,
1342 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 )
1343 return fut 2095 return fut
1344 2096
1345 def message_encryption_stop(self, to_jid, profile_key): 2097 def message_encryption_stop(self, to_jid, profile_key):
1346 loop = asyncio.get_running_loop() 2098 loop = asyncio.get_running_loop()
1347 fut = loop.create_future() 2099 fut = loop.create_future()
1348 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)
1349 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(
1350 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)
1351 return fut 2103 )
1352 2104 self.db_core_iface.message_encryption_stop(
1353 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@"): 2105 to_jid,
1354 loop = asyncio.get_running_loop() 2106 profile_key,
1355 fut = loop.create_future() 2107 timeout=const_TIMEOUT,
1356 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2108 reply_handler=reply_handler,
1357 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2109 error_handler=error_handler,
1358 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 )
1359 return fut 2139 return fut
1360 2140
1361 def namespaces_get(self): 2141 def namespaces_get(self):
1362 loop = asyncio.get_running_loop() 2142 loop = asyncio.get_running_loop()
1363 fut = loop.create_future() 2143 fut = loop.create_future()
1364 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)
1365 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(
1366 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)
1367 return fut 2147 )
1368 2148 self.db_core_iface.namespaces_get(
1369 def notification_add(self, type_, body_plain, body_rich, title, is_global, requires_action, arg_6, priority, expire_at, extra): 2149 timeout=const_TIMEOUT,
1370 loop = asyncio.get_running_loop() 2150 reply_handler=reply_handler,
1371 fut = loop.create_future() 2151 error_handler=error_handler,
1372 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2152 )
1373 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2153 return fut
1374 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 )
1375 return fut 2189 return fut
1376 2190
1377 def notification_delete(self, id_, is_global, profile_key): 2191 def notification_delete(self, id_, is_global, profile_key):
1378 loop = asyncio.get_running_loop() 2192 loop = asyncio.get_running_loop()
1379 fut = loop.create_future() 2193 fut = loop.create_future()
1380 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)
1381 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(
1382 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 )
1383 return fut 2206 return fut
1384 2207
1385 def notifications_expired_clean(self, limit_timestamp, profile_key): 2208 def notifications_expired_clean(self, limit_timestamp, profile_key):
1386 loop = asyncio.get_running_loop() 2209 loop = asyncio.get_running_loop()
1387 fut = loop.create_future() 2210 fut = loop.create_future()
1388 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)
1389 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(
1390 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 )
1391 return fut 2222 return fut
1392 2223
1393 def notifications_get(self, filters, profile_key): 2224 def notifications_get(self, filters, profile_key):
1394 loop = asyncio.get_running_loop() 2225 loop = asyncio.get_running_loop()
1395 fut = loop.create_future() 2226 fut = loop.create_future()
1396 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)
1397 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(
1398 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 )
1399 return fut 2238 return fut
1400 2239
1401 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@"):
1402 loop = asyncio.get_running_loop() 2241 loop = asyncio.get_running_loop()
1403 fut = loop.create_future() 2242 fut = loop.create_future()
1404 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)
1405 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(
1406 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)
1407 return fut 2246 )
1408 2247 self.db_core_iface.param_get_a(
1409 def param_get_a_async(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@"): 2248 name,
1410 loop = asyncio.get_running_loop() 2249 category,
1411 fut = loop.create_future() 2250 attribute,
1412 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2251 profile_key,
1413 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2252 timeout=const_TIMEOUT,
1414 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,
1415 return fut 2254 error_handler=error_handler,
1416 2255 )
1417 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@"): 2256 return fut
1418 loop = asyncio.get_running_loop() 2257
1419 fut = loop.create_future() 2258 def param_get_a_async(
1420 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2259 self,
1421 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2260 name,
1422 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,
1423 return fut 2262 attribute="value",
1424 2263 security_limit=-1,
1425 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@"): 2264 profile_key="@DEFAULT@",
1426 loop = asyncio.get_running_loop() 2265 ):
1427 fut = loop.create_future() 2266 loop = asyncio.get_running_loop()
1428 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2267 fut = loop.create_future()
1429 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)
1430 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 )
1431 return fut 2321 return fut
1432 2322
1433 def params_categories_get(self): 2323 def params_categories_get(self):
1434 loop = asyncio.get_running_loop() 2324 loop = asyncio.get_running_loop()
1435 fut = loop.create_future() 2325 fut = loop.create_future()
1436 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)
1437 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(
1438 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)
1439 return fut 2329 )
1440 2330 self.db_core_iface.params_categories_get(
1441 def params_register_app(self, xml, security_limit=-1, app=''): 2331 timeout=const_TIMEOUT,
1442 loop = asyncio.get_running_loop() 2332 reply_handler=reply_handler,
1443 fut = loop.create_future() 2333 error_handler=error_handler,
1444 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2334 )
1445 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2335 return fut
1446 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 )
1447 return fut 2352 return fut
1448 2353
1449 def params_template_load(self, filename): 2354 def params_template_load(self, filename):
1450 loop = asyncio.get_running_loop() 2355 loop = asyncio.get_running_loop()
1451 fut = loop.create_future() 2356 fut = loop.create_future()
1452 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)
1453 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(
1454 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 )
1455 return fut 2367 return fut
1456 2368
1457 def params_template_save(self, filename): 2369 def params_template_save(self, filename):
1458 loop = asyncio.get_running_loop() 2370 loop = asyncio.get_running_loop()
1459 fut = loop.create_future() 2371 fut = loop.create_future()
1460 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)
1461 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(
1462 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)
1463 return fut 2375 )
1464 2376 self.db_core_iface.params_template_save(
1465 def params_values_from_category_get_async(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"): 2377 filename,
1466 loop = asyncio.get_running_loop() 2378 timeout=const_TIMEOUT,
1467 fut = loop.create_future() 2379 reply_handler=reply_handler,
1468 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2380 error_handler=error_handler,
1469 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2381 )
1470 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
1471 return fut 2383
1472 2384 def params_values_from_category_get_async(
1473 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@"): 2385 self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"
1474 loop = asyncio.get_running_loop() 2386 ):
1475 fut = loop.create_future() 2387 loop = asyncio.get_running_loop()
1476 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2388 fut = loop.create_future()
1477 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)
1478 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 )
1479 return fut 2421 return fut
1480 2422
1481 def presence_statuses_get(self, profile_key="@DEFAULT@"): 2423 def presence_statuses_get(self, profile_key="@DEFAULT@"):
1482 loop = asyncio.get_running_loop() 2424 loop = asyncio.get_running_loop()
1483 fut = loop.create_future() 2425 fut = loop.create_future()
1484 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)
1485 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(
1486 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 )
1487 return fut 2436 return fut
1488 2437
1489 def private_data_delete(self, namespace, key, arg_2): 2438 def private_data_delete(self, namespace, key, arg_2):
1490 loop = asyncio.get_running_loop() 2439 loop = asyncio.get_running_loop()
1491 fut = loop.create_future() 2440 fut = loop.create_future()
1492 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)
1493 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(
1494 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 )
1495 return fut 2453 return fut
1496 2454
1497 def private_data_get(self, namespace, key, profile_key): 2455 def private_data_get(self, namespace, key, profile_key):
1498 loop = asyncio.get_running_loop() 2456 loop = asyncio.get_running_loop()
1499 fut = loop.create_future() 2457 fut = loop.create_future()
1500 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)
1501 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(
1502 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 )
1503 return fut 2470 return fut
1504 2471
1505 def private_data_set(self, namespace, key, data, profile_key): 2472 def private_data_set(self, namespace, key, data, profile_key):
1506 loop = asyncio.get_running_loop() 2473 loop = asyncio.get_running_loop()
1507 fut = loop.create_future() 2474 fut = loop.create_future()
1508 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)
1509 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(
1510 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)
1511 return fut 2478 )
1512 2479 self.db_core_iface.private_data_set(
1513 def profile_create(self, profile, password='', component=''): 2480 namespace,
1514 loop = asyncio.get_running_loop() 2481 key,
1515 fut = loop.create_future() 2482 data,
1516 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2483 profile_key,
1517 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2484 timeout=const_TIMEOUT,
1518 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 )
1519 return fut 2505 return fut
1520 2506
1521 def profile_delete_async(self, profile): 2507 def profile_delete_async(self, profile):
1522 loop = asyncio.get_running_loop() 2508 loop = asyncio.get_running_loop()
1523 fut = loop.create_future() 2509 fut = loop.create_future()
1524 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)
1525 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(
1526 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 )
1527 return fut 2520 return fut
1528 2521
1529 def profile_is_session_started(self, profile_key="@DEFAULT@"): 2522 def profile_is_session_started(self, profile_key="@DEFAULT@"):
1530 loop = asyncio.get_running_loop() 2523 loop = asyncio.get_running_loop()
1531 fut = loop.create_future() 2524 fut = loop.create_future()
1532 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)
1533 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(
1534 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 )
1535 return fut 2535 return fut
1536 2536
1537 def profile_name_get(self, profile_key="@DEFAULT@"): 2537 def profile_name_get(self, profile_key="@DEFAULT@"):
1538 loop = asyncio.get_running_loop() 2538 loop = asyncio.get_running_loop()
1539 fut = loop.create_future() 2539 fut = loop.create_future()
1540 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)
1541 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(
1542 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 )
1543 return fut 2550 return fut
1544 2551
1545 def profile_set_default(self, profile): 2552 def profile_set_default(self, profile):
1546 loop = asyncio.get_running_loop() 2553 loop = asyncio.get_running_loop()
1547 fut = loop.create_future() 2554 fut = loop.create_future()
1548 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)
1549 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(
1550 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)
1551 return fut 2558 )
1552 2559 self.db_core_iface.profile_set_default(
1553 def profile_start_session(self, password='', profile_key="@DEFAULT@"): 2560 profile,
1554 loop = asyncio.get_running_loop() 2561 timeout=const_TIMEOUT,
1555 fut = loop.create_future() 2562 reply_handler=reply_handler,
1556 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 2563 error_handler=error_handler,
1557 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 2564 )
1558 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 )
1559 return fut 2581 return fut
1560 2582
1561 def profiles_list_get(self, clients=True, components=False): 2583 def profiles_list_get(self, clients=True, components=False):
1562 loop = asyncio.get_running_loop() 2584 loop = asyncio.get_running_loop()
1563 fut = loop.create_future() 2585 fut = loop.create_future()
1564 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)
1565 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(
1566 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 )
1567 return fut 2597 return fut
1568 2598
1569 def progress_get(self, id, profile): 2599 def progress_get(self, id, profile):
1570 loop = asyncio.get_running_loop() 2600 loop = asyncio.get_running_loop()
1571 fut = loop.create_future() 2601 fut = loop.create_future()
1572 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)
1573 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(
1574 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 )
1575 return fut 2613 return fut
1576 2614
1577 def progress_get_all(self, profile): 2615 def progress_get_all(self, profile):
1578 loop = asyncio.get_running_loop() 2616 loop = asyncio.get_running_loop()
1579 fut = loop.create_future() 2617 fut = loop.create_future()
1580 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)
1581 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(
1582 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 )
1583 return fut 2628 return fut
1584 2629
1585 def progress_get_all_metadata(self, profile): 2630 def progress_get_all_metadata(self, profile):
1586 loop = asyncio.get_running_loop() 2631 loop = asyncio.get_running_loop()
1587 fut = loop.create_future() 2632 fut = loop.create_future()
1588 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)
1589 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(
1590 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 )
1591 return fut 2643 return fut
1592 2644
1593 def ready_get(self): 2645 def ready_get(self):
1594 loop = asyncio.get_running_loop() 2646 loop = asyncio.get_running_loop()
1595 fut = loop.create_future() 2647 fut = loop.create_future()
1596 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)
1597 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(
1598 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 )
1599 return fut 2657 return fut
1600 2658
1601 def roster_resync(self, profile_key="@DEFAULT@"): 2659 def roster_resync(self, profile_key="@DEFAULT@"):
1602 loop = asyncio.get_running_loop() 2660 loop = asyncio.get_running_loop()
1603 fut = loop.create_future() 2661 fut = loop.create_future()
1604 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)
1605 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(
1606 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 )
1607 return fut 2672 return fut
1608 2673
1609 def session_infos_get(self, profile_key): 2674 def session_infos_get(self, profile_key):
1610 loop = asyncio.get_running_loop() 2675 loop = asyncio.get_running_loop()
1611 fut = loop.create_future() 2676 fut = loop.create_future()
1612 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)
1613 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(
1614 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 )
1615 return fut 2687 return fut
1616 2688
1617 def sub_waiting_get(self, profile_key="@DEFAULT@"): 2689 def sub_waiting_get(self, profile_key="@DEFAULT@"):
1618 loop = asyncio.get_running_loop() 2690 loop = asyncio.get_running_loop()
1619 fut = loop.create_future() 2691 fut = loop.create_future()
1620 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)
1621 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(
1622 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 )
1623 return fut 2702 return fut
1624 2703
1625 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"): 2704 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"):
1626 loop = asyncio.get_running_loop() 2705 loop = asyncio.get_running_loop()
1627 fut = loop.create_future() 2706 fut = loop.create_future()
1628 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)
1629 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(
1630 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 )
1631 return fut 2719 return fut
1632 2720
1633 def version_get(self): 2721 def version_get(self):
1634 loop = asyncio.get_running_loop() 2722 loop = asyncio.get_running_loop()
1635 fut = loop.create_future() 2723 fut = loop.create_future()
1636 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)
1637 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(
1638 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)
1639 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