Mercurial > libervia-backend

comparison sat_frontends/bridge/dbus_bridge.py @ 4037:524856bd7b19

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
massive refactoring to switch from camelCase to snake_case: historically, Libervia (SàT before) was using camelCase as allowed by PEP8 when using a pre-PEP8 code, to use the same coding style as in Twisted. However, snake_case is more readable and it's better to follow PEP8 best practices, so it has been decided to move on full snake_case. Because Libervia has a huge codebase, this ended with a ugly mix of camelCase and snake_case. To fix that, this patch does a big refactoring by renaming every function and method (including bridge) that are not coming from Twisted or Wokkel, to use fully snake_case. This is a massive change, and may result in some bugs.
author Goffi <goffi@goffi.org>
date Sat, 08 Apr 2023 13:54:42 +0200
parents 71cfe9334f73
children 2594e1951cf7
comparison
equal deleted inserted replaced
4036:c4464d7ae97b 4037:524856bd7b19
30 DBusGMainLoop(set_as_default=True) 30 DBusGMainLoop(set_as_default=True)
31 log = getLogger(__name__) 31 log = getLogger(__name__)
32 32
33 33
34 # Interface prefix 34 # Interface prefix
35 const_INT_PREFIX = config.getConfig( 35 const_INT_PREFIX = config.config_get(
36 config.parseMainConf(), 36 config.parse_main_conf(),
37 "", 37 "",
38 "bridge_dbus_int_prefix", 38 "bridge_dbus_int_prefix",
39 "org.libervia.Libervia") 39 "org.libervia.Libervia")
40 const_ERROR_PREFIX = const_INT_PREFIX + ".error" 40 const_ERROR_PREFIX = const_INT_PREFIX + ".error"
41 const_OBJ_PATH = '/org/libervia/Libervia/bridge' 41 const_OBJ_PATH = '/org/libervia/Libervia/bridge'
64 except (SyntaxError, ValueError, TypeError): 64 except (SyntaxError, ValueError, TypeError):
65 condition = '' 65 condition = ''
66 return BridgeException(name, message, condition) 66 return BridgeException(name, message, condition)
67 67
68 68
69 class Bridge: 69 class bridge:
70 70
71 def bridgeConnect(self, callback, errback): 71 def bridge_connect(self, callback, errback):
72 try: 72 try:
73 self.sessions_bus = dbus.SessionBus() 73 self.sessions_bus = dbus.SessionBus()
74 self.db_object = self.sessions_bus.get_object(const_INT_PREFIX, 74 self.db_object = self.sessions_bus.get_object(const_INT_PREFIX,
75 const_OBJ_PATH) 75 const_OBJ_PATH)
76 self.db_core_iface = dbus.Interface(self.db_object, 76 self.db_core_iface = dbus.Interface(self.db_object,
103 try: 103 try:
104 return object.__getattribute__(self, name) 104 return object.__getattribute__(self, name)
105 except AttributeError: 105 except AttributeError:
106 # The attribute is not found, we try the plugin proxy to find the requested method 106 # The attribute is not found, we try the plugin proxy to find the requested method
107 107
108 def getPluginMethod(*args, **kwargs): 108 def get_plugin_method(*args, **kwargs):
109 # We first check if we have an async call. We detect this in two ways: 109 # We first check if we have an async call. We detect this in two ways:
110 # - if we have the 'callback' and 'errback' keyword arguments 110 # - if we have the 'callback' and 'errback' keyword arguments
111 # - or if the last two arguments are callable 111 # - or if the last two arguments are callable
112 112
113 async_ = False 113 async_ = False
154 proxy._introspect_state = IN_PROGRESS 154 proxy._introspect_state = IN_PROGRESS
155 proxy._Introspect() 155 proxy._Introspect()
156 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs) 156 return self.db_plugin_iface.get_dbus_method(name)(*args, **kwargs)
157 raise e 157 raise e
158 158
159 return getPluginMethod 159 return get_plugin_method
160 160
161 def actionsGet(self, profile_key="@DEFAULT@", callback=None, errback=None): 161 def action_launch(self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None):
162 if callback is None: 162 if callback is None:
163 error_handler = None 163 error_handler = None
164 else: 164 else:
165 if errback is None: 165 if errback is None:
166 errback = log.error 166 errback = log.error
167 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 167 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
168 kwargs={} 168 return self.db_core_iface.action_launch(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
169 if callback is not None: 169
170 kwargs['timeout'] = const_TIMEOUT 170 def actions_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
171 kwargs['reply_handler'] = callback 171 if callback is None:
172 kwargs['error_handler'] = error_handler 172 error_handler = None
173 return self.db_core_iface.actionsGet(profile_key, **kwargs) 173 else:
174 174 if errback is None:
175 def addContact(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 175 errback = log.error
176 if callback is None: 176 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
177 error_handler = None 177 kwargs={}
178 else: 178 if callback is not None:
179 if errback is None: 179 kwargs['timeout'] = const_TIMEOUT
180 errback = log.error 180 kwargs['reply_handler'] = callback
181 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 181 kwargs['error_handler'] = error_handler
182 kwargs={} 182 return self.db_core_iface.actions_get(profile_key, **kwargs)
183 if callback is not None: 183
184 kwargs['timeout'] = const_TIMEOUT 184 def config_get(self, section, name, callback=None, errback=None):
185 kwargs['reply_handler'] = callback 185 if callback is None:
186 kwargs['error_handler'] = error_handler 186 error_handler = None
187 return self.db_core_iface.addContact(entity_jid, profile_key, **kwargs) 187 else:
188 188 if errback is None:
189 def asyncDeleteProfile(self, profile, callback=None, errback=None): 189 errback = log.error
190 if callback is None: 190 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
191 error_handler = None 191 kwargs={}
192 else: 192 if callback is not None:
193 if errback is None: 193 kwargs['timeout'] = const_TIMEOUT
194 errback = log.error 194 kwargs['reply_handler'] = callback
195 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 195 kwargs['error_handler'] = error_handler
196 return self.db_core_iface.asyncDeleteProfile(profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 196 return str(self.db_core_iface.config_get(section, name, **kwargs))
197
198 def asyncGetParamA(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None):
199 if callback is None:
200 error_handler = None
201 else:
202 if errback is None:
203 errback = log.error
204 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
205 return str(self.db_core_iface.asyncGetParamA(name, category, attribute, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
206
207 def asyncGetParamsValuesFromCategory(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@", callback=None, errback=None):
208 if callback is None:
209 error_handler = None
210 else:
211 if errback is None:
212 errback = log.error
213 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
214 return self.db_core_iface.asyncGetParamsValuesFromCategory(category, security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
215 197
216 def connect(self, profile_key="@DEFAULT@", password='', options={}, callback=None, errback=None): 198 def connect(self, profile_key="@DEFAULT@", password='', options={}, callback=None, errback=None):
217 if callback is None: 199 if callback is None:
218 error_handler = None 200 error_handler = None
219 else: 201 else:
220 if errback is None: 202 if errback is None:
221 errback = log.error 203 errback = log.error
222 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 204 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
223 return self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 205 return self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
224 206
225 def contactGet(self, arg_0, profile_key="@DEFAULT@", callback=None, errback=None): 207 def contact_add(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None):
226 if callback is None: 208 if callback is None:
227 error_handler = None 209 error_handler = None
228 else: 210 else:
229 if errback is None: 211 if errback is None:
230 errback = log.error 212 errback = log.error
231 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 213 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
232 return self.db_core_iface.contactGet(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 214 kwargs={}
233 215 if callback is not None:
234 def delContact(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None): 216 kwargs['timeout'] = const_TIMEOUT
235 if callback is None: 217 kwargs['reply_handler'] = callback
236 error_handler = None 218 kwargs['error_handler'] = error_handler
237 else: 219 return self.db_core_iface.contact_add(entity_jid, profile_key, **kwargs)
238 if errback is None: 220
239 errback = log.error 221 def contact_del(self, entity_jid, profile_key="@DEFAULT@", callback=None, errback=None):
240 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 222 if callback is None:
241 return self.db_core_iface.delContact(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 223 error_handler = None
242 224 else:
243 def devicesInfosGet(self, bare_jid, profile_key, callback=None, errback=None): 225 if errback is None:
244 if callback is None: 226 errback = log.error
245 error_handler = None 227 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
246 else: 228 return self.db_core_iface.contact_del(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
247 if errback is None: 229
248 errback = log.error 230 def contact_get(self, arg_0, profile_key="@DEFAULT@", callback=None, errback=None):
249 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 231 if callback is None:
250 return str(self.db_core_iface.devicesInfosGet(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 232 error_handler = None
251 233 else:
252 def discoFindByFeatures(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@", callback=None, errback=None): 234 if errback is None:
253 if callback is None: 235 errback = log.error
254 error_handler = None 236 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
255 else: 237 return self.db_core_iface.contact_get(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
256 if errback is None: 238
257 errback = log.error 239 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@", callback=None, errback=None):
258 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 240 if callback is None:
259 return self.db_core_iface.discoFindByFeatures(namespaces, identities, bare_jid, service, roster, own_jid, local_device, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 241 error_handler = None
260 242 else:
261 def discoInfos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 243 if errback is None:
262 if callback is None: 244 errback = log.error
263 error_handler = None 245 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
264 else: 246 kwargs={}
265 if errback is None: 247 if callback is not None:
266 errback = log.error 248 kwargs['timeout'] = const_TIMEOUT
267 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 249 kwargs['reply_handler'] = callback
268 return self.db_core_iface.discoInfos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 250 kwargs['error_handler'] = error_handler
269 251 return self.db_core_iface.contact_update(entity_jid, name, groups, profile_key, **kwargs)
270 def discoItems(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None): 252
271 if callback is None: 253 def contacts_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
272 error_handler = None 254 if callback is None:
273 else: 255 error_handler = None
274 if errback is None: 256 else:
275 errback = log.error 257 if errback is None:
276 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 258 errback = log.error
277 return self.db_core_iface.discoItems(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 259 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
260 return self.db_core_iface.contacts_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
261
262 def contacts_get_from_group(self, group, profile_key="@DEFAULT@", callback=None, errback=None):
263 if callback is None:
264 error_handler = None
265 else:
266 if errback is None:
267 errback = log.error
268 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
269 kwargs={}
270 if callback is not None:
271 kwargs['timeout'] = const_TIMEOUT
272 kwargs['reply_handler'] = callback
273 kwargs['error_handler'] = error_handler
274 return self.db_core_iface.contacts_get_from_group(group, profile_key, **kwargs)
275
276 def devices_infos_get(self, bare_jid, profile_key, callback=None, errback=None):
277 if callback is None:
278 error_handler = None
279 else:
280 if errback is None:
281 errback = log.error
282 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
283 return str(self.db_core_iface.devices_infos_get(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
284
285 def disco_find_by_features(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@", callback=None, errback=None):
286 if callback is None:
287 error_handler = None
288 else:
289 if errback is None:
290 errback = log.error
291 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
292 return self.db_core_iface.disco_find_by_features(namespaces, identities, bare_jid, service, roster, own_jid, local_device, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
293
294 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None):
295 if callback is None:
296 error_handler = None
297 else:
298 if errback is None:
299 errback = log.error
300 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
301 return self.db_core_iface.disco_infos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
302
303 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@", callback=None, errback=None):
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 return self.db_core_iface.disco_items(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
278 311
279 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None): 312 def disconnect(self, profile_key="@DEFAULT@", callback=None, errback=None):
280 if callback is None: 313 if callback is None:
281 error_handler = None 314 error_handler = None
282 else: 315 else:
283 if errback is None: 316 if errback is None:
284 errback = log.error 317 errback = log.error
285 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 318 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
286 return self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 319 return self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
287 320
288 def encryptionNamespaceGet(self, arg_0, callback=None, errback=None): 321 def encryption_namespace_get(self, arg_0, callback=None, errback=None):
289 if callback is None: 322 if callback is None:
290 error_handler = None 323 error_handler = None
291 else: 324 else:
292 if errback is None: 325 if errback is None:
293 errback = log.error 326 errback = log.error
294 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 327 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
295 kwargs={} 328 kwargs={}
296 if callback is not None: 329 if callback is not None:
297 kwargs['timeout'] = const_TIMEOUT 330 kwargs['timeout'] = const_TIMEOUT
298 kwargs['reply_handler'] = callback 331 kwargs['reply_handler'] = callback
299 kwargs['error_handler'] = error_handler 332 kwargs['error_handler'] = error_handler
300 return str(self.db_core_iface.encryptionNamespaceGet(arg_0, **kwargs)) 333 return str(self.db_core_iface.encryption_namespace_get(arg_0, **kwargs))
301 334
302 def encryptionPluginsGet(self, callback=None, errback=None): 335 def encryption_plugins_get(self, callback=None, errback=None):
303 if callback is None: 336 if callback is None:
304 error_handler = None 337 error_handler = None
305 else: 338 else:
306 if errback is None: 339 if errback is None:
307 errback = log.error 340 errback = log.error
308 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 341 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
309 kwargs={} 342 kwargs={}
310 if callback is not None: 343 if callback is not None:
311 kwargs['timeout'] = const_TIMEOUT 344 kwargs['timeout'] = const_TIMEOUT
312 kwargs['reply_handler'] = callback 345 kwargs['reply_handler'] = callback
313 kwargs['error_handler'] = error_handler 346 kwargs['error_handler'] = error_handler
314 return str(self.db_core_iface.encryptionPluginsGet(**kwargs)) 347 return str(self.db_core_iface.encryption_plugins_get(**kwargs))
315 348
316 def encryptionTrustUIGet(self, to_jid, namespace, profile_key, callback=None, errback=None): 349 def encryption_trust_ui_get(self, to_jid, namespace, profile_key, callback=None, errback=None):
317 if callback is None: 350 if callback is None:
318 error_handler = None 351 error_handler = None
319 else: 352 else:
320 if errback is None: 353 if errback is None:
321 errback = log.error 354 errback = log.error
322 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 355 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
323 return str(self.db_core_iface.encryptionTrustUIGet(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 356 return str(self.db_core_iface.encryption_trust_ui_get(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
324 357
325 def getConfig(self, section, name, callback=None, errback=None): 358 def entities_data_get(self, jids, keys, profile, callback=None, errback=None):
326 if callback is None: 359 if callback is None:
327 error_handler = None 360 error_handler = None
328 else: 361 else:
329 if errback is None: 362 if errback is None:
330 errback = log.error 363 errback = log.error
331 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 364 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
332 kwargs={} 365 kwargs={}
333 if callback is not None: 366 if callback is not None:
334 kwargs['timeout'] = const_TIMEOUT 367 kwargs['timeout'] = const_TIMEOUT
335 kwargs['reply_handler'] = callback 368 kwargs['reply_handler'] = callback
336 kwargs['error_handler'] = error_handler 369 kwargs['error_handler'] = error_handler
337 return str(self.db_core_iface.getConfig(section, name, **kwargs)) 370 return self.db_core_iface.entities_data_get(jids, keys, profile, **kwargs)
338 371
339 def getContacts(self, profile_key="@DEFAULT@", callback=None, errback=None): 372 def entity_data_get(self, jid, keys, profile, callback=None, errback=None):
340 if callback is None: 373 if callback is None:
341 error_handler = None 374 error_handler = None
342 else: 375 else:
343 if errback is None: 376 if errback is None:
344 errback = log.error 377 errback = log.error
345 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 378 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
346 return self.db_core_iface.getContacts(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 379 kwargs={}
347 380 if callback is not None:
348 def getContactsFromGroup(self, group, profile_key="@DEFAULT@", callback=None, errback=None): 381 kwargs['timeout'] = const_TIMEOUT
349 if callback is None: 382 kwargs['reply_handler'] = callback
350 error_handler = None 383 kwargs['error_handler'] = error_handler
351 else: 384 return self.db_core_iface.entity_data_get(jid, keys, profile, **kwargs)
352 if errback is None: 385
353 errback = log.error 386 def features_get(self, profile_key, callback=None, errback=None):
354 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 387 if callback is None:
355 kwargs={} 388 error_handler = None
356 if callback is not None: 389 else:
357 kwargs['timeout'] = const_TIMEOUT 390 if errback is None:
358 kwargs['reply_handler'] = callback 391 errback = log.error
359 kwargs['error_handler'] = error_handler 392 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
360 return self.db_core_iface.getContactsFromGroup(group, profile_key, **kwargs) 393 return self.db_core_iface.features_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
361 394
362 def getEntitiesData(self, jids, keys, profile, callback=None, errback=None): 395 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@", callback=None, errback=None):
363 if callback is None: 396 if callback is None:
364 error_handler = None 397 error_handler = None
365 else: 398 else:
366 if errback is None: 399 if errback is None:
367 errback = log.error 400 errback = log.error
368 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 401 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
369 kwargs={} 402 return self.db_core_iface.history_get(from_jid, to_jid, limit, between, filters, profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
370 if callback is not None: 403
371 kwargs['timeout'] = const_TIMEOUT 404 def image_check(self, arg_0, callback=None, errback=None):
372 kwargs['reply_handler'] = callback 405 if callback is None:
373 kwargs['error_handler'] = error_handler 406 error_handler = None
374 return self.db_core_iface.getEntitiesData(jids, keys, profile, **kwargs) 407 else:
375 408 if errback is None:
376 def getEntityData(self, jid, keys, profile, callback=None, errback=None): 409 errback = log.error
377 if callback is None: 410 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
378 error_handler = None 411 kwargs={}
379 else: 412 if callback is not None:
380 if errback is None: 413 kwargs['timeout'] = const_TIMEOUT
381 errback = log.error 414 kwargs['reply_handler'] = callback
382 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 415 kwargs['error_handler'] = error_handler
383 kwargs={} 416 return str(self.db_core_iface.image_check(arg_0, **kwargs))
384 if callback is not None: 417
385 kwargs['timeout'] = const_TIMEOUT 418 def image_convert(self, source, dest, arg_2, extra, callback=None, errback=None):
386 kwargs['reply_handler'] = callback 419 if callback is None:
387 kwargs['error_handler'] = error_handler 420 error_handler = None
388 return self.db_core_iface.getEntityData(jid, keys, profile, **kwargs) 421 else:
389 422 if errback is None:
390 def getFeatures(self, profile_key, callback=None, errback=None): 423 errback = log.error
391 if callback is None: 424 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
392 error_handler = None 425 return str(self.db_core_iface.image_convert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
393 else: 426
394 if errback is None: 427 def image_generate_preview(self, image_path, profile_key, callback=None, errback=None):
395 errback = log.error 428 if callback is None:
396 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 429 error_handler = None
397 return self.db_core_iface.getFeatures(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 430 else:
398 431 if errback is None:
399 def getMainResource(self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None): 432 errback = log.error
400 if callback is None: 433 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
401 error_handler = None 434 return str(self.db_core_iface.image_generate_preview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
402 else: 435
403 if errback is None: 436 def image_resize(self, image_path, width, height, callback=None, errback=None):
404 errback = log.error 437 if callback is None:
405 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 438 error_handler = None
406 kwargs={} 439 else:
407 if callback is not None: 440 if errback is None:
408 kwargs['timeout'] = const_TIMEOUT 441 errback = log.error
409 kwargs['reply_handler'] = callback 442 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
410 kwargs['error_handler'] = error_handler 443 return str(self.db_core_iface.image_resize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
411 return str(self.db_core_iface.getMainResource(contact_jid, profile_key, **kwargs)) 444
412 445 def is_connected(self, profile_key="@DEFAULT@", callback=None, errback=None):
413 def getParamA(self, name, category, attribute="value", profile_key="@DEFAULT@", callback=None, errback=None): 446 if callback is None:
414 if callback is None: 447 error_handler = None
415 error_handler = None 448 else:
416 else: 449 if errback is None:
417 if errback is None: 450 errback = log.error
418 errback = log.error 451 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
419 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 452 kwargs={}
420 kwargs={} 453 if callback is not None:
421 if callback is not None: 454 kwargs['timeout'] = const_TIMEOUT
422 kwargs['timeout'] = const_TIMEOUT 455 kwargs['reply_handler'] = callback
423 kwargs['reply_handler'] = callback 456 kwargs['error_handler'] = error_handler
424 kwargs['error_handler'] = error_handler 457 return self.db_core_iface.is_connected(profile_key, **kwargs)
425 return str(self.db_core_iface.getParamA(name, category, attribute, profile_key, **kwargs)) 458
426 459 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@", callback=None, errback=None):
427 def getParamsCategories(self, callback=None, errback=None): 460 if callback is None:
428 if callback is None: 461 error_handler = None
429 error_handler = None 462 else:
430 else: 463 if errback is None:
431 if errback is None: 464 errback = log.error
432 errback = log.error 465 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
433 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 466 kwargs={}
434 kwargs={} 467 if callback is not None:
435 if callback is not None: 468 kwargs['timeout'] = const_TIMEOUT
436 kwargs['timeout'] = const_TIMEOUT 469 kwargs['reply_handler'] = callback
437 kwargs['reply_handler'] = callback 470 kwargs['error_handler'] = error_handler
438 kwargs['error_handler'] = error_handler 471 return str(self.db_core_iface.main_resource_get(contact_jid, profile_key, **kwargs))
439 return self.db_core_iface.getParamsCategories(**kwargs) 472
440 473 def menu_help_get(self, menu_id, language, callback=None, errback=None):
441 def getParamsUI(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@", callback=None, errback=None): 474 if callback is None:
442 if callback is None: 475 error_handler = None
443 error_handler = None 476 else:
444 else: 477 if errback is None:
445 if errback is None: 478 errback = log.error
446 errback = log.error 479 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
447 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 480 kwargs={}
448 return str(self.db_core_iface.getParamsUI(security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 481 if callback is not None:
449 482 kwargs['timeout'] = const_TIMEOUT
450 def getPresenceStatuses(self, profile_key="@DEFAULT@", callback=None, errback=None): 483 kwargs['reply_handler'] = callback
451 if callback is None: 484 kwargs['error_handler'] = error_handler
452 error_handler = None 485 return str(self.db_core_iface.menu_help_get(menu_id, language, **kwargs))
453 else: 486
454 if errback is None: 487 def menu_launch(self, menu_type, path, data, security_limit, profile_key, callback=None, errback=None):
455 errback = log.error 488 if callback is None:
456 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 489 error_handler = None
457 kwargs={} 490 else:
458 if callback is not None: 491 if errback is None:
459 kwargs['timeout'] = const_TIMEOUT 492 errback = log.error
460 kwargs['reply_handler'] = callback 493 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
461 kwargs['error_handler'] = error_handler 494 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)
462 return self.db_core_iface.getPresenceStatuses(profile_key, **kwargs) 495
463 496 def menus_get(self, language, security_limit, callback=None, errback=None):
464 def getReady(self, callback=None, errback=None): 497 if callback is None:
465 if callback is None: 498 error_handler = None
466 error_handler = None 499 else:
467 else: 500 if errback is None:
468 if errback is None: 501 errback = log.error
469 errback = log.error 502 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
470 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 503 kwargs={}
471 return self.db_core_iface.getReady(timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 504 if callback is not None:
472 505 kwargs['timeout'] = const_TIMEOUT
473 def getVersion(self, callback=None, errback=None): 506 kwargs['reply_handler'] = callback
474 if callback is None: 507 kwargs['error_handler'] = error_handler
475 error_handler = None 508 return self.db_core_iface.menus_get(language, security_limit, **kwargs)
476 else: 509
477 if errback is None: 510 def message_encryption_get(self, to_jid, profile_key, callback=None, errback=None):
478 errback = log.error 511 if callback is None:
479 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 512 error_handler = None
480 kwargs={} 513 else:
481 if callback is not None: 514 if errback is None:
482 kwargs['timeout'] = const_TIMEOUT 515 errback = log.error
483 kwargs['reply_handler'] = callback 516 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
484 kwargs['error_handler'] = error_handler 517 kwargs={}
485 return str(self.db_core_iface.getVersion(**kwargs)) 518 if callback is not None:
486 519 kwargs['timeout'] = const_TIMEOUT
487 def getWaitingSub(self, profile_key="@DEFAULT@", callback=None, errback=None): 520 kwargs['reply_handler'] = callback
488 if callback is None: 521 kwargs['error_handler'] = error_handler
489 error_handler = None 522 return str(self.db_core_iface.message_encryption_get(to_jid, profile_key, **kwargs))
490 else: 523
491 if errback is None: 524 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@", callback=None, errback=None):
492 errback = log.error 525 if callback is None:
493 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 526 error_handler = None
494 kwargs={} 527 else:
495 if callback is not None: 528 if errback is None:
496 kwargs['timeout'] = const_TIMEOUT 529 errback = log.error
497 kwargs['reply_handler'] = callback 530 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
498 kwargs['error_handler'] = error_handler 531 return self.db_core_iface.message_encryption_start(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
499 return self.db_core_iface.getWaitingSub(profile_key, **kwargs) 532
500 533 def message_encryption_stop(self, to_jid, profile_key, callback=None, errback=None):
501 def historyGet(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@", callback=None, errback=None): 534 if callback is None:
502 if callback is None: 535 error_handler = None
503 error_handler = None 536 else:
504 else: 537 if errback is None:
505 if errback is None: 538 errback = log.error
506 errback = log.error 539 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
507 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 540 return self.db_core_iface.message_encryption_stop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
508 return self.db_core_iface.historyGet(from_jid, to_jid, limit, between, filters, profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 541
509 542 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@", callback=None, errback=None):
510 def imageCheck(self, arg_0, callback=None, errback=None): 543 if callback is None:
511 if callback is None: 544 error_handler = None
512 error_handler = None 545 else:
513 else: 546 if errback is None:
514 if errback is None: 547 errback = log.error
515 errback = log.error 548 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
516 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 549 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)
517 kwargs={} 550
518 if callback is not None: 551 def namespaces_get(self, callback=None, errback=None):
519 kwargs['timeout'] = const_TIMEOUT 552 if callback is None:
520 kwargs['reply_handler'] = callback 553 error_handler = None
521 kwargs['error_handler'] = error_handler 554 else:
522 return str(self.db_core_iface.imageCheck(arg_0, **kwargs)) 555 if errback is None:
523 556 errback = log.error
524 def imageConvert(self, source, dest, arg_2, extra, callback=None, errback=None): 557 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
525 if callback is None: 558 kwargs={}
526 error_handler = None 559 if callback is not None:
527 else: 560 kwargs['timeout'] = const_TIMEOUT
528 if errback is None: 561 kwargs['reply_handler'] = callback
529 errback = log.error 562 kwargs['error_handler'] = error_handler
530 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 563 return self.db_core_iface.namespaces_get(**kwargs)
531 return str(self.db_core_iface.imageConvert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 564
532 565 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@", callback=None, errback=None):
533 def imageGeneratePreview(self, image_path, profile_key, callback=None, errback=None): 566 if callback is None:
534 if callback is None: 567 error_handler = None
535 error_handler = None 568 else:
536 else: 569 if errback is None:
537 if errback is None: 570 errback = log.error
538 errback = log.error 571 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
539 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 572 kwargs={}
540 return str(self.db_core_iface.imageGeneratePreview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 573 if callback is not None:
541 574 kwargs['timeout'] = const_TIMEOUT
542 def imageResize(self, image_path, width, height, callback=None, errback=None): 575 kwargs['reply_handler'] = callback
543 if callback is None: 576 kwargs['error_handler'] = error_handler
544 error_handler = None 577 return str(self.db_core_iface.param_get_a(name, category, attribute, profile_key, **kwargs))
545 else: 578
546 if errback is None: 579 def param_get_a_async(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None):
547 errback = log.error 580 if callback is None:
548 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 581 error_handler = None
549 return str(self.db_core_iface.imageResize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 582 else:
550 583 if errback is None:
551 def isConnected(self, profile_key="@DEFAULT@", callback=None, errback=None): 584 errback = log.error
552 if callback is None: 585 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
553 error_handler = None 586 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))
554 else: 587
555 if errback is None: 588 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None):
556 errback = log.error 589 if callback is None:
557 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 590 error_handler = None
558 kwargs={} 591 else:
559 if callback is not None: 592 if errback is None:
560 kwargs['timeout'] = const_TIMEOUT 593 errback = log.error
561 kwargs['reply_handler'] = callback 594 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
562 kwargs['error_handler'] = error_handler 595 kwargs={}
563 return self.db_core_iface.isConnected(profile_key, **kwargs) 596 if callback is not None:
564 597 kwargs['timeout'] = const_TIMEOUT
565 def launchAction(self, callback_id, data, profile_key="@DEFAULT@", callback=None, errback=None): 598 kwargs['reply_handler'] = callback
566 if callback is None: 599 kwargs['error_handler'] = error_handler
567 error_handler = None 600 return self.db_core_iface.param_set(name, value, category, security_limit, profile_key, **kwargs)
568 else: 601
569 if errback is None: 602 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@", callback=None, errback=None):
570 errback = log.error 603 if callback is None:
571 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 604 error_handler = None
572 return self.db_core_iface.launchAction(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 605 else:
573 606 if errback is None:
574 def loadParamsTemplate(self, filename, callback=None, errback=None): 607 errback = log.error
575 if callback is None: 608 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
576 error_handler = None 609 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))
577 else: 610
578 if errback is None: 611 def params_categories_get(self, callback=None, errback=None):
579 errback = log.error 612 if callback is None:
580 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 613 error_handler = None
581 kwargs={} 614 else:
582 if callback is not None: 615 if errback is None:
583 kwargs['timeout'] = const_TIMEOUT 616 errback = log.error
584 kwargs['reply_handler'] = callback 617 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
585 kwargs['error_handler'] = error_handler 618 kwargs={}
586 return self.db_core_iface.loadParamsTemplate(filename, **kwargs) 619 if callback is not None:
587 620 kwargs['timeout'] = const_TIMEOUT
588 def menuHelpGet(self, menu_id, language, callback=None, errback=None): 621 kwargs['reply_handler'] = callback
589 if callback is None: 622 kwargs['error_handler'] = error_handler
590 error_handler = None 623 return self.db_core_iface.params_categories_get(**kwargs)
591 else: 624
592 if errback is None: 625 def params_register_app(self, xml, security_limit=-1, app='', callback=None, errback=None):
593 errback = log.error 626 if callback is None:
594 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 627 error_handler = None
595 kwargs={} 628 else:
596 if callback is not None: 629 if errback is None:
597 kwargs['timeout'] = const_TIMEOUT 630 errback = log.error
598 kwargs['reply_handler'] = callback 631 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
599 kwargs['error_handler'] = error_handler 632 kwargs={}
600 return str(self.db_core_iface.menuHelpGet(menu_id, language, **kwargs)) 633 if callback is not None:
601 634 kwargs['timeout'] = const_TIMEOUT
602 def menuLaunch(self, menu_type, path, data, security_limit, profile_key, callback=None, errback=None): 635 kwargs['reply_handler'] = callback
603 if callback is None: 636 kwargs['error_handler'] = error_handler
604 error_handler = None 637 return self.db_core_iface.params_register_app(xml, security_limit, app, **kwargs)
605 else: 638
606 if errback is None: 639 def params_template_load(self, filename, callback=None, errback=None):
607 errback = log.error 640 if callback is None:
608 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 641 error_handler = None
609 return self.db_core_iface.menuLaunch(menu_type, path, data, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 642 else:
610 643 if errback is None:
611 def menusGet(self, language, security_limit, callback=None, errback=None): 644 errback = log.error
612 if callback is None: 645 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
613 error_handler = None 646 kwargs={}
614 else: 647 if callback is not None:
615 if errback is None: 648 kwargs['timeout'] = const_TIMEOUT
616 errback = log.error 649 kwargs['reply_handler'] = callback
617 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 650 kwargs['error_handler'] = error_handler
618 kwargs={} 651 return self.db_core_iface.params_template_load(filename, **kwargs)
619 if callback is not None: 652
620 kwargs['timeout'] = const_TIMEOUT 653 def params_template_save(self, filename, callback=None, errback=None):
621 kwargs['reply_handler'] = callback 654 if callback is None:
622 kwargs['error_handler'] = error_handler 655 error_handler = None
623 return self.db_core_iface.menusGet(language, security_limit, **kwargs) 656 else:
624 657 if errback is None:
625 def messageEncryptionGet(self, to_jid, profile_key, callback=None, errback=None): 658 errback = log.error
626 if callback is None: 659 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
627 error_handler = None 660 kwargs={}
628 else: 661 if callback is not None:
629 if errback is None: 662 kwargs['timeout'] = const_TIMEOUT
630 errback = log.error 663 kwargs['reply_handler'] = callback
631 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 664 kwargs['error_handler'] = error_handler
632 kwargs={} 665 return self.db_core_iface.params_template_save(filename, **kwargs)
633 if callback is not None: 666
634 kwargs['timeout'] = const_TIMEOUT 667 def params_values_from_category_get_async(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@", callback=None, errback=None):
635 kwargs['reply_handler'] = callback 668 if callback is None:
636 kwargs['error_handler'] = error_handler 669 error_handler = None
637 return str(self.db_core_iface.messageEncryptionGet(to_jid, profile_key, **kwargs)) 670 else:
638 671 if errback is None:
639 def messageEncryptionStart(self, to_jid, namespace='', replace=False, profile_key="@NONE@", callback=None, errback=None): 672 errback = log.error
640 if callback is None: 673 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
641 error_handler = None 674 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)
642 else: 675
643 if errback is None: 676 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@", callback=None, errback=None):
644 errback = log.error 677 if callback is None:
645 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 678 error_handler = None
646 return self.db_core_iface.messageEncryptionStart(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 679 else:
647 680 if errback is None:
648 def messageEncryptionStop(self, to_jid, profile_key, callback=None, errback=None): 681 errback = log.error
649 if callback is None: 682 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
650 error_handler = None 683 kwargs={}
651 else: 684 if callback is not None:
652 if errback is None: 685 kwargs['timeout'] = const_TIMEOUT
653 errback = log.error 686 kwargs['reply_handler'] = callback
654 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 687 kwargs['error_handler'] = error_handler
655 return self.db_core_iface.messageEncryptionStop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 688 return self.db_core_iface.presence_set(to_jid, show, statuses, profile_key, **kwargs)
656 689
657 def messageSend(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@", callback=None, errback=None): 690 def presence_statuses_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
658 if callback is None: 691 if callback is None:
659 error_handler = None 692 error_handler = None
660 else: 693 else:
661 if errback is None: 694 if errback is None:
662 errback = log.error 695 errback = log.error
663 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 696 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
664 return self.db_core_iface.messageSend(to_jid, message, subject, mess_type, extra, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 697 kwargs={}
665 698 if callback is not None:
666 def namespacesGet(self, callback=None, errback=None): 699 kwargs['timeout'] = const_TIMEOUT
667 if callback is None: 700 kwargs['reply_handler'] = callback
668 error_handler = None 701 kwargs['error_handler'] = error_handler
669 else: 702 return self.db_core_iface.presence_statuses_get(profile_key, **kwargs)
670 if errback is None: 703
671 errback = log.error 704 def private_data_delete(self, namespace, key, arg_2, callback=None, errback=None):
672 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 705 if callback is None:
673 kwargs={} 706 error_handler = None
674 if callback is not None: 707 else:
675 kwargs['timeout'] = const_TIMEOUT 708 if errback is None:
676 kwargs['reply_handler'] = callback 709 errback = log.error
677 kwargs['error_handler'] = error_handler 710 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
678 return self.db_core_iface.namespacesGet(**kwargs) 711 return self.db_core_iface.private_data_delete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
679 712
680 def paramsRegisterApp(self, xml, security_limit=-1, app='', callback=None, errback=None): 713 def private_data_get(self, namespace, key, profile_key, callback=None, errback=None):
681 if callback is None: 714 if callback is None:
682 error_handler = None 715 error_handler = None
683 else: 716 else:
684 if errback is None: 717 if errback is None:
685 errback = log.error 718 errback = log.error
686 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 719 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
687 kwargs={} 720 return str(self.db_core_iface.private_data_get(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler))
688 if callback is not None: 721
689 kwargs['timeout'] = const_TIMEOUT 722 def private_data_set(self, namespace, key, data, profile_key, callback=None, errback=None):
690 kwargs['reply_handler'] = callback 723 if callback is None:
691 kwargs['error_handler'] = error_handler 724 error_handler = None
692 return self.db_core_iface.paramsRegisterApp(xml, security_limit, app, **kwargs) 725 else:
693 726 if errback is None:
694 def privateDataDelete(self, namespace, key, arg_2, callback=None, errback=None): 727 errback = log.error
695 if callback is None: 728 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
696 error_handler = None 729 return self.db_core_iface.private_data_set(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
697 else: 730
698 if errback is None: 731 def profile_create(self, profile, password='', component='', callback=None, errback=None):
699 errback = log.error 732 if callback is None:
700 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 733 error_handler = None
701 return self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 734 else:
702 735 if errback is None:
703 def privateDataGet(self, namespace, key, profile_key, callback=None, errback=None): 736 errback = log.error
704 if callback is None: 737 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
705 error_handler = None 738 return self.db_core_iface.profile_create(profile, password, component, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
706 else: 739
707 if errback is None: 740 def profile_delete_async(self, profile, callback=None, errback=None):
708 errback = log.error 741 if callback is None:
709 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 742 error_handler = None
710 return str(self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)) 743 else:
711 744 if errback is None:
712 def privateDataSet(self, namespace, key, data, profile_key, callback=None, errback=None): 745 errback = log.error
713 if callback is None: 746 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
714 error_handler = None 747 return self.db_core_iface.profile_delete_async(profile, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
715 else: 748
716 if errback is None: 749 def profile_is_session_started(self, profile_key="@DEFAULT@", callback=None, errback=None):
717 errback = log.error 750 if callback is None:
718 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 751 error_handler = None
719 return self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 752 else:
720 753 if errback is None:
721 def profileCreate(self, profile, password='', component='', callback=None, errback=None): 754 errback = log.error
722 if callback is None: 755 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
723 error_handler = None 756 kwargs={}
724 else: 757 if callback is not None:
725 if errback is None: 758 kwargs['timeout'] = const_TIMEOUT
726 errback = log.error 759 kwargs['reply_handler'] = callback
727 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 760 kwargs['error_handler'] = error_handler
728 return self.db_core_iface.profileCreate(profile, password, component, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 761 return self.db_core_iface.profile_is_session_started(profile_key, **kwargs)
729 762
730 def profileIsSessionStarted(self, profile_key="@DEFAULT@", callback=None, errback=None): 763 def profile_name_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
731 if callback is None: 764 if callback is None:
732 error_handler = None 765 error_handler = None
733 else: 766 else:
734 if errback is None: 767 if errback is None:
735 errback = log.error 768 errback = log.error
736 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 769 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
737 kwargs={} 770 kwargs={}
738 if callback is not None: 771 if callback is not None:
739 kwargs['timeout'] = const_TIMEOUT 772 kwargs['timeout'] = const_TIMEOUT
740 kwargs['reply_handler'] = callback 773 kwargs['reply_handler'] = callback
741 kwargs['error_handler'] = error_handler 774 kwargs['error_handler'] = error_handler
742 return self.db_core_iface.profileIsSessionStarted(profile_key, **kwargs) 775 return str(self.db_core_iface.profile_name_get(profile_key, **kwargs))
743 776
744 def profileNameGet(self, profile_key="@DEFAULT@", callback=None, errback=None): 777 def profile_set_default(self, profile, callback=None, errback=None):
745 if callback is None: 778 if callback is None:
746 error_handler = None 779 error_handler = None
747 else: 780 else:
748 if errback is None: 781 if errback is None:
749 errback = log.error 782 errback = log.error
750 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 783 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
751 kwargs={} 784 kwargs={}
752 if callback is not None: 785 if callback is not None:
753 kwargs['timeout'] = const_TIMEOUT 786 kwargs['timeout'] = const_TIMEOUT
754 kwargs['reply_handler'] = callback 787 kwargs['reply_handler'] = callback
755 kwargs['error_handler'] = error_handler 788 kwargs['error_handler'] = error_handler
756 return str(self.db_core_iface.profileNameGet(profile_key, **kwargs)) 789 return self.db_core_iface.profile_set_default(profile, **kwargs)
757 790
758 def profileSetDefault(self, profile, callback=None, errback=None): 791 def profile_start_session(self, password='', profile_key="@DEFAULT@", callback=None, errback=None):
759 if callback is None: 792 if callback is None:
760 error_handler = None 793 error_handler = None
761 else: 794 else:
762 if errback is None: 795 if errback is None:
763 errback = log.error 796 errback = log.error
764 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 797 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
765 kwargs={} 798 return self.db_core_iface.profile_start_session(password, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
766 if callback is not None: 799
767 kwargs['timeout'] = const_TIMEOUT 800 def profiles_list_get(self, clients=True, components=False, callback=None, errback=None):
768 kwargs['reply_handler'] = callback 801 if callback is None:
769 kwargs['error_handler'] = error_handler 802 error_handler = None
770 return self.db_core_iface.profileSetDefault(profile, **kwargs) 803 else:
771 804 if errback is None:
772 def profileStartSession(self, password='', profile_key="@DEFAULT@", callback=None, errback=None): 805 errback = log.error
773 if callback is None: 806 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
774 error_handler = None 807 kwargs={}
775 else: 808 if callback is not None:
776 if errback is None: 809 kwargs['timeout'] = const_TIMEOUT
777 errback = log.error 810 kwargs['reply_handler'] = callback
778 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 811 kwargs['error_handler'] = error_handler
779 return self.db_core_iface.profileStartSession(password, profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 812 return self.db_core_iface.profiles_list_get(clients, components, **kwargs)
780 813
781 def profilesListGet(self, clients=True, components=False, callback=None, errback=None): 814 def progress_get(self, id, profile, callback=None, errback=None):
782 if callback is None: 815 if callback is None:
783 error_handler = None 816 error_handler = None
784 else: 817 else:
785 if errback is None: 818 if errback is None:
786 errback = log.error 819 errback = log.error
787 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 820 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
788 kwargs={} 821 kwargs={}
789 if callback is not None: 822 if callback is not None:
790 kwargs['timeout'] = const_TIMEOUT 823 kwargs['timeout'] = const_TIMEOUT
791 kwargs['reply_handler'] = callback 824 kwargs['reply_handler'] = callback
792 kwargs['error_handler'] = error_handler 825 kwargs['error_handler'] = error_handler
793 return self.db_core_iface.profilesListGet(clients, components, **kwargs) 826 return self.db_core_iface.progress_get(id, profile, **kwargs)
794 827
795 def progressGet(self, id, profile, callback=None, errback=None): 828 def progress_get_all(self, profile, callback=None, errback=None):
796 if callback is None: 829 if callback is None:
797 error_handler = None 830 error_handler = None
798 else: 831 else:
799 if errback is None: 832 if errback is None:
800 errback = log.error 833 errback = log.error
801 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 834 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
802 kwargs={} 835 kwargs={}
803 if callback is not None: 836 if callback is not None:
804 kwargs['timeout'] = const_TIMEOUT 837 kwargs['timeout'] = const_TIMEOUT
805 kwargs['reply_handler'] = callback 838 kwargs['reply_handler'] = callback
806 kwargs['error_handler'] = error_handler 839 kwargs['error_handler'] = error_handler
807 return self.db_core_iface.progressGet(id, profile, **kwargs) 840 return self.db_core_iface.progress_get_all(profile, **kwargs)
808 841
809 def progressGetAll(self, profile, callback=None, errback=None): 842 def progress_get_all_metadata(self, profile, callback=None, errback=None):
810 if callback is None: 843 if callback is None:
811 error_handler = None 844 error_handler = None
812 else: 845 else:
813 if errback is None: 846 if errback is None:
814 errback = log.error 847 errback = log.error
815 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 848 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
816 kwargs={} 849 kwargs={}
817 if callback is not None: 850 if callback is not None:
818 kwargs['timeout'] = const_TIMEOUT 851 kwargs['timeout'] = const_TIMEOUT
819 kwargs['reply_handler'] = callback 852 kwargs['reply_handler'] = callback
820 kwargs['error_handler'] = error_handler 853 kwargs['error_handler'] = error_handler
821 return self.db_core_iface.progressGetAll(profile, **kwargs) 854 return self.db_core_iface.progress_get_all_metadata(profile, **kwargs)
822 855
823 def progressGetAllMetadata(self, profile, callback=None, errback=None): 856 def ready_get(self, callback=None, errback=None):
824 if callback is None: 857 if callback is None:
825 error_handler = None 858 error_handler = None
826 else: 859 else:
827 if errback is None: 860 if errback is None:
828 errback = log.error 861 errback = log.error
829 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 862 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
830 kwargs={} 863 return self.db_core_iface.ready_get(timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
831 if callback is not None: 864
832 kwargs['timeout'] = const_TIMEOUT 865 def roster_resync(self, profile_key="@DEFAULT@", callback=None, errback=None):
833 kwargs['reply_handler'] = callback 866 if callback is None:
834 kwargs['error_handler'] = error_handler 867 error_handler = None
835 return self.db_core_iface.progressGetAllMetadata(profile, **kwargs) 868 else:
836 869 if errback is None:
837 def rosterResync(self, profile_key="@DEFAULT@", callback=None, errback=None): 870 errback = log.error
838 if callback is None: 871 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
839 error_handler = None 872 return self.db_core_iface.roster_resync(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
840 else: 873
841 if errback is None: 874 def session_infos_get(self, profile_key, callback=None, errback=None):
842 errback = log.error 875 if callback is None:
843 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 876 error_handler = None
844 return self.db_core_iface.rosterResync(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler) 877 else:
845 878 if errback is None:
846 def saveParamsTemplate(self, filename, callback=None, errback=None): 879 errback = log.error
847 if callback is None: 880 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
848 error_handler = None 881 return self.db_core_iface.session_infos_get(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
849 else: 882
850 if errback is None: 883 def sub_waiting_get(self, profile_key="@DEFAULT@", callback=None, errback=None):
851 errback = log.error 884 if callback is None:
852 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 885 error_handler = None
853 kwargs={} 886 else:
854 if callback is not None: 887 if errback is None:
855 kwargs['timeout'] = const_TIMEOUT 888 errback = log.error
856 kwargs['reply_handler'] = callback 889 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
857 kwargs['error_handler'] = error_handler 890 kwargs={}
858 return self.db_core_iface.saveParamsTemplate(filename, **kwargs) 891 if callback is not None:
859 892 kwargs['timeout'] = const_TIMEOUT
860 def sessionInfosGet(self, profile_key, callback=None, errback=None): 893 kwargs['reply_handler'] = callback
861 if callback is None: 894 kwargs['error_handler'] = error_handler
862 error_handler = None 895 return self.db_core_iface.sub_waiting_get(profile_key, **kwargs)
863 else:
864 if errback is None:
865 errback = log.error
866 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
867 return self.db_core_iface.sessionInfosGet(profile_key, timeout=const_TIMEOUT, reply_handler=callback, error_handler=error_handler)
868
869 def setParam(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@", callback=None, errback=None):
870 if callback is None:
871 error_handler = None
872 else:
873 if errback is None:
874 errback = log.error
875 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
876 kwargs={}
877 if callback is not None:
878 kwargs['timeout'] = const_TIMEOUT
879 kwargs['reply_handler'] = callback
880 kwargs['error_handler'] = error_handler
881 return self.db_core_iface.setParam(name, value, category, security_limit, profile_key, **kwargs)
882
883 def setPresence(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@", callback=None, errback=None):
884 if callback is None:
885 error_handler = None
886 else:
887 if errback is None:
888 errback = log.error
889 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
890 kwargs={}
891 if callback is not None:
892 kwargs['timeout'] = const_TIMEOUT
893 kwargs['reply_handler'] = callback
894 kwargs['error_handler'] = error_handler
895 return self.db_core_iface.setPresence(to_jid, show, statuses, profile_key, **kwargs)
896 896
897 def subscription(self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None): 897 def subscription(self, sub_type, entity, profile_key="@DEFAULT@", callback=None, errback=None):
898 if callback is None: 898 if callback is None:
899 error_handler = None 899 error_handler = None
900 else: 900 else:
906 kwargs['timeout'] = const_TIMEOUT 906 kwargs['timeout'] = const_TIMEOUT
907 kwargs['reply_handler'] = callback 907 kwargs['reply_handler'] = callback
908 kwargs['error_handler'] = error_handler 908 kwargs['error_handler'] = error_handler
909 return self.db_core_iface.subscription(sub_type, entity, profile_key, **kwargs) 909 return self.db_core_iface.subscription(sub_type, entity, profile_key, **kwargs)
910 910
911 def updateContact(self, entity_jid, name, groups, profile_key="@DEFAULT@", callback=None, errback=None): 911 def version_get(self, callback=None, errback=None):
912 if callback is None: 912 if callback is None:
913 error_handler = None 913 error_handler = None
914 else: 914 else:
915 if errback is None: 915 if errback is None:
916 errback = log.error 916 errback = log.error
917 error_handler = lambda err:errback(dbus_to_bridge_exception(err)) 917 error_handler = lambda err:errback(dbus_to_bridge_exception(err))
918 kwargs={} 918 kwargs={}
919 if callback is not None: 919 if callback is not None:
920 kwargs['timeout'] = const_TIMEOUT 920 kwargs['timeout'] = const_TIMEOUT
921 kwargs['reply_handler'] = callback 921 kwargs['reply_handler'] = callback
922 kwargs['error_handler'] = error_handler 922 kwargs['error_handler'] = error_handler
923 return self.db_core_iface.updateContact(entity_jid, name, groups, profile_key, **kwargs) 923 return str(self.db_core_iface.version_get(**kwargs))
924 924
925 925
926 class AIOBridge(Bridge): 926 class AIOBridge(bridge):
927 927
928 def register_signal(self, functionName, handler, iface="core"): 928 def register_signal(self, functionName, handler, iface="core"):
929 loop = asyncio.get_running_loop() 929 loop = asyncio.get_running_loop()
930 async_handler = lambda *args: asyncio.run_coroutine_threadsafe(handler(*args), loop) 930 async_handler = lambda *args: asyncio.run_coroutine_threadsafe(handler(*args), loop)
931 return super().register_signal(functionName, async_handler, iface) 931 return super().register_signal(functionName, async_handler, iface)
934 """ usual __getattribute__ if the method exists, else try to find a plugin method """ 934 """ usual __getattribute__ if the method exists, else try to find a plugin method """
935 try: 935 try:
936 return object.__getattribute__(self, name) 936 return object.__getattribute__(self, name)
937 except AttributeError: 937 except AttributeError:
938 # The attribute is not found, we try the plugin proxy to find the requested method 938 # The attribute is not found, we try the plugin proxy to find the requested method
939 def getPluginMethod(*args, **kwargs): 939 def get_plugin_method(*args, **kwargs):
940 loop = asyncio.get_running_loop() 940 loop = asyncio.get_running_loop()
941 fut = loop.create_future() 941 fut = loop.create_future()
942 method = getattr(self.db_plugin_iface, name) 942 method = getattr(self.db_plugin_iface, name)
943 reply_handler = lambda ret=None: loop.call_soon_threadsafe( 943 reply_handler = lambda ret=None: loop.call_soon_threadsafe(
944 fut.set_result, ret) 944 fut.set_result, ret)
952 reply_handler=reply_handler, 952 reply_handler=reply_handler,
953 error_handler=error_handler 953 error_handler=error_handler
954 ) 954 )
955 except ValueError as e: 955 except ValueError as e:
956 if e.args[0].startswith("Unable to guess signature"): 956 if e.args[0].startswith("Unable to guess signature"):
957 # same hack as for Bridge.__getattribute__ 957 # same hack as for bridge.__getattribute__
958 log.warning("using hack to work around inspection issue") 958 log.warning("using hack to work around inspection issue")
959 proxy = self.db_plugin_iface.proxy_object 959 proxy = self.db_plugin_iface.proxy_object
960 IN_PROGRESS = proxy.INTROSPECT_STATE_INTROSPECT_IN_PROGRESS 960 IN_PROGRESS = proxy.INTROSPECT_STATE_INTROSPECT_IN_PROGRESS
961 proxy._introspect_state = IN_PROGRESS 961 proxy._introspect_state = IN_PROGRESS
962 proxy._Introspect() 962 proxy._Introspect()
970 970
971 else: 971 else:
972 raise e 972 raise e
973 return fut 973 return fut
974 974
975 return getPluginMethod 975 return get_plugin_method
976 976
977 def bridgeConnect(self): 977 def bridge_connect(self):
978 loop = asyncio.get_running_loop() 978 loop = asyncio.get_running_loop()
979 fut = loop.create_future() 979 fut = loop.create_future()
980 super().bridgeConnect( 980 super().bridge_connect(
981 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None), 981 callback=lambda: loop.call_soon_threadsafe(fut.set_result, None),
982 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e) 982 errback=lambda e: loop.call_soon_threadsafe(fut.set_exception, e)
983 ) 983 )
984 return fut 984 return fut
985 985
986 def actionsGet(self, profile_key="@DEFAULT@"): 986 def action_launch(self, callback_id, data, profile_key="@DEFAULT@"):
987 loop = asyncio.get_running_loop() 987 loop = asyncio.get_running_loop()
988 fut = loop.create_future() 988 fut = loop.create_future()
989 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 989 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
990 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 990 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
991 self.db_core_iface.actionsGet(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 991 self.db_core_iface.action_launch(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
992 return fut 992 return fut
993 993
994 def addContact(self, entity_jid, profile_key="@DEFAULT@"): 994 def actions_get(self, profile_key="@DEFAULT@"):
995 loop = asyncio.get_running_loop() 995 loop = asyncio.get_running_loop()
996 fut = loop.create_future() 996 fut = loop.create_future()
997 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 997 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
998 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 998 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
999 self.db_core_iface.addContact(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 999 self.db_core_iface.actions_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1000 return fut 1000 return fut
1001 1001
1002 def asyncDeleteProfile(self, profile): 1002 def config_get(self, section, name):
1003 loop = asyncio.get_running_loop() 1003 loop = asyncio.get_running_loop()
1004 fut = loop.create_future() 1004 fut = loop.create_future()
1005 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1005 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1006 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1006 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1007 self.db_core_iface.asyncDeleteProfile(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1007 self.db_core_iface.config_get(section, name, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1008 return fut
1009
1010 def asyncGetParamA(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@"):
1011 loop = asyncio.get_running_loop()
1012 fut = loop.create_future()
1013 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1014 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1015 self.db_core_iface.asyncGetParamA(name, category, attribute, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1016 return fut
1017
1018 def asyncGetParamsValuesFromCategory(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"):
1019 loop = asyncio.get_running_loop()
1020 fut = loop.create_future()
1021 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1022 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1023 self.db_core_iface.asyncGetParamsValuesFromCategory(category, security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1024 return fut 1008 return fut
1025 1009
1026 def connect(self, profile_key="@DEFAULT@", password='', options={}): 1010 def connect(self, profile_key="@DEFAULT@", password='', options={}):
1027 loop = asyncio.get_running_loop() 1011 loop = asyncio.get_running_loop()
1028 fut = loop.create_future() 1012 fut = loop.create_future()
1029 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1013 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1030 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1014 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1031 self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1015 self.db_core_iface.connect(profile_key, password, options, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1032 return fut 1016 return fut
1033 1017
1034 def contactGet(self, arg_0, profile_key="@DEFAULT@"): 1018 def contact_add(self, entity_jid, profile_key="@DEFAULT@"):
1035 loop = asyncio.get_running_loop() 1019 loop = asyncio.get_running_loop()
1036 fut = loop.create_future() 1020 fut = loop.create_future()
1037 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1021 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1038 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1022 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1039 self.db_core_iface.contactGet(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1023 self.db_core_iface.contact_add(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1040 return fut 1024 return fut
1041 1025
1042 def delContact(self, entity_jid, profile_key="@DEFAULT@"): 1026 def contact_del(self, entity_jid, profile_key="@DEFAULT@"):
1043 loop = asyncio.get_running_loop() 1027 loop = asyncio.get_running_loop()
1044 fut = loop.create_future() 1028 fut = loop.create_future()
1045 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1029 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1046 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1030 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1047 self.db_core_iface.delContact(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1031 self.db_core_iface.contact_del(entity_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1048 return fut 1032 return fut
1049 1033
1050 def devicesInfosGet(self, bare_jid, profile_key): 1034 def contact_get(self, arg_0, profile_key="@DEFAULT@"):
1051 loop = asyncio.get_running_loop() 1035 loop = asyncio.get_running_loop()
1052 fut = loop.create_future() 1036 fut = loop.create_future()
1053 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1037 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1054 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1038 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1055 self.db_core_iface.devicesInfosGet(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1039 self.db_core_iface.contact_get(arg_0, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1056 return fut 1040 return fut
1057 1041
1058 def discoFindByFeatures(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@"): 1042 def contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"):
1059 loop = asyncio.get_running_loop() 1043 loop = asyncio.get_running_loop()
1060 fut = loop.create_future() 1044 fut = loop.create_future()
1061 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1045 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1062 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1046 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1063 self.db_core_iface.discoFindByFeatures(namespaces, identities, bare_jid, service, roster, own_jid, local_device, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1047 self.db_core_iface.contact_update(entity_jid, name, groups, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1064 return fut 1048 return fut
1065 1049
1066 def discoInfos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1050 def contacts_get(self, profile_key="@DEFAULT@"):
1067 loop = asyncio.get_running_loop() 1051 loop = asyncio.get_running_loop()
1068 fut = loop.create_future() 1052 fut = loop.create_future()
1069 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1053 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1070 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1054 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1071 self.db_core_iface.discoInfos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1055 self.db_core_iface.contacts_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1072 return fut 1056 return fut
1073 1057
1074 def discoItems(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"): 1058 def contacts_get_from_group(self, group, profile_key="@DEFAULT@"):
1075 loop = asyncio.get_running_loop() 1059 loop = asyncio.get_running_loop()
1076 fut = loop.create_future() 1060 fut = loop.create_future()
1077 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1061 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1078 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1062 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1079 self.db_core_iface.discoItems(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1063 self.db_core_iface.contacts_get_from_group(group, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1064 return fut
1065
1066 def devices_infos_get(self, bare_jid, profile_key):
1067 loop = asyncio.get_running_loop()
1068 fut = loop.create_future()
1069 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1070 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1071 self.db_core_iface.devices_infos_get(bare_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1072 return fut
1073
1074 def disco_find_by_features(self, namespaces, identities, bare_jid=False, service=True, roster=True, own_jid=True, local_device=False, profile_key="@DEFAULT@"):
1075 loop = asyncio.get_running_loop()
1076 fut = loop.create_future()
1077 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1078 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1079 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)
1080 return fut
1081
1082 def disco_infos(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"):
1083 loop = asyncio.get_running_loop()
1084 fut = loop.create_future()
1085 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1086 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1087 self.db_core_iface.disco_infos(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1088 return fut
1089
1090 def disco_items(self, entity_jid, node=u'', use_cache=True, profile_key="@DEFAULT@"):
1091 loop = asyncio.get_running_loop()
1092 fut = loop.create_future()
1093 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1094 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1095 self.db_core_iface.disco_items(entity_jid, node, use_cache, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1080 return fut 1096 return fut
1081 1097
1082 def disconnect(self, profile_key="@DEFAULT@"): 1098 def disconnect(self, profile_key="@DEFAULT@"):
1083 loop = asyncio.get_running_loop() 1099 loop = asyncio.get_running_loop()
1084 fut = loop.create_future() 1100 fut = loop.create_future()
1085 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1101 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1086 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1102 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1087 self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1103 self.db_core_iface.disconnect(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1088 return fut 1104 return fut
1089 1105
1090 def encryptionNamespaceGet(self, arg_0): 1106 def encryption_namespace_get(self, arg_0):
1091 loop = asyncio.get_running_loop() 1107 loop = asyncio.get_running_loop()
1092 fut = loop.create_future() 1108 fut = loop.create_future()
1093 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1109 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1094 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1110 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1095 self.db_core_iface.encryptionNamespaceGet(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1111 self.db_core_iface.encryption_namespace_get(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1096 return fut 1112 return fut
1097 1113
1098 def encryptionPluginsGet(self): 1114 def encryption_plugins_get(self):
1099 loop = asyncio.get_running_loop() 1115 loop = asyncio.get_running_loop()
1100 fut = loop.create_future() 1116 fut = loop.create_future()
1101 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1117 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1102 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1118 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1103 self.db_core_iface.encryptionPluginsGet(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1119 self.db_core_iface.encryption_plugins_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1104 return fut 1120 return fut
1105 1121
1106 def encryptionTrustUIGet(self, to_jid, namespace, profile_key): 1122 def encryption_trust_ui_get(self, to_jid, namespace, profile_key):
1107 loop = asyncio.get_running_loop() 1123 loop = asyncio.get_running_loop()
1108 fut = loop.create_future() 1124 fut = loop.create_future()
1109 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1125 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1110 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1126 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1111 self.db_core_iface.encryptionTrustUIGet(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1127 self.db_core_iface.encryption_trust_ui_get(to_jid, namespace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1112 return fut 1128 return fut
1113 1129
1114 def getConfig(self, section, name): 1130 def entities_data_get(self, jids, keys, profile):
1115 loop = asyncio.get_running_loop() 1131 loop = asyncio.get_running_loop()
1116 fut = loop.create_future() 1132 fut = loop.create_future()
1117 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1133 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1118 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1134 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1119 self.db_core_iface.getConfig(section, name, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1135 self.db_core_iface.entities_data_get(jids, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1120 return fut 1136 return fut
1121 1137
1122 def getContacts(self, profile_key="@DEFAULT@"): 1138 def entity_data_get(self, jid, keys, profile):
1123 loop = asyncio.get_running_loop() 1139 loop = asyncio.get_running_loop()
1124 fut = loop.create_future() 1140 fut = loop.create_future()
1125 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1141 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1126 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1142 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1127 self.db_core_iface.getContacts(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1143 self.db_core_iface.entity_data_get(jid, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1128 return fut 1144 return fut
1129 1145
1130 def getContactsFromGroup(self, group, profile_key="@DEFAULT@"): 1146 def features_get(self, profile_key):
1131 loop = asyncio.get_running_loop() 1147 loop = asyncio.get_running_loop()
1132 fut = loop.create_future() 1148 fut = loop.create_future()
1133 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1149 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1134 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1150 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1135 self.db_core_iface.getContactsFromGroup(group, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1151 self.db_core_iface.features_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1136 return fut 1152 return fut
1137 1153
1138 def getEntitiesData(self, jids, keys, profile): 1154 def history_get(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@"):
1139 loop = asyncio.get_running_loop() 1155 loop = asyncio.get_running_loop()
1140 fut = loop.create_future() 1156 fut = loop.create_future()
1141 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1157 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1142 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1158 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1143 self.db_core_iface.getEntitiesData(jids, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1159 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)
1144 return fut 1160 return fut
1145 1161
1146 def getEntityData(self, jid, keys, profile): 1162 def image_check(self, arg_0):
1147 loop = asyncio.get_running_loop() 1163 loop = asyncio.get_running_loop()
1148 fut = loop.create_future() 1164 fut = loop.create_future()
1149 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1165 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1150 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1166 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1151 self.db_core_iface.getEntityData(jid, keys, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1167 self.db_core_iface.image_check(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1152 return fut 1168 return fut
1153 1169
1154 def getFeatures(self, profile_key): 1170 def image_convert(self, source, dest, arg_2, extra):
1155 loop = asyncio.get_running_loop() 1171 loop = asyncio.get_running_loop()
1156 fut = loop.create_future() 1172 fut = loop.create_future()
1157 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1173 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1158 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1174 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1159 self.db_core_iface.getFeatures(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1175 self.db_core_iface.image_convert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1160 return fut 1176 return fut
1161 1177
1162 def getMainResource(self, contact_jid, profile_key="@DEFAULT@"): 1178 def image_generate_preview(self, image_path, profile_key):
1163 loop = asyncio.get_running_loop() 1179 loop = asyncio.get_running_loop()
1164 fut = loop.create_future() 1180 fut = loop.create_future()
1165 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1181 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1166 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1182 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1167 self.db_core_iface.getMainResource(contact_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1183 self.db_core_iface.image_generate_preview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1168 return fut 1184 return fut
1169 1185
1170 def getParamA(self, name, category, attribute="value", profile_key="@DEFAULT@"): 1186 def image_resize(self, image_path, width, height):
1171 loop = asyncio.get_running_loop() 1187 loop = asyncio.get_running_loop()
1172 fut = loop.create_future() 1188 fut = loop.create_future()
1173 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1189 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1174 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1190 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1175 self.db_core_iface.getParamA(name, category, attribute, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1191 self.db_core_iface.image_resize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1176 return fut 1192 return fut
1177 1193
1178 def getParamsCategories(self): 1194 def is_connected(self, profile_key="@DEFAULT@"):
1179 loop = asyncio.get_running_loop() 1195 loop = asyncio.get_running_loop()
1180 fut = loop.create_future() 1196 fut = loop.create_future()
1181 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1197 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1182 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1198 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1183 self.db_core_iface.getParamsCategories(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1199 self.db_core_iface.is_connected(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1184 return fut 1200 return fut
1185 1201
1186 def getParamsUI(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@"): 1202 def main_resource_get(self, contact_jid, profile_key="@DEFAULT@"):
1187 loop = asyncio.get_running_loop() 1203 loop = asyncio.get_running_loop()
1188 fut = loop.create_future() 1204 fut = loop.create_future()
1189 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1205 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1190 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1206 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1191 self.db_core_iface.getParamsUI(security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1207 self.db_core_iface.main_resource_get(contact_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1192 return fut 1208 return fut
1193 1209
1194 def getPresenceStatuses(self, profile_key="@DEFAULT@"): 1210 def menu_help_get(self, menu_id, language):
1195 loop = asyncio.get_running_loop() 1211 loop = asyncio.get_running_loop()
1196 fut = loop.create_future() 1212 fut = loop.create_future()
1197 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1213 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1198 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1214 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1199 self.db_core_iface.getPresenceStatuses(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1215 self.db_core_iface.menu_help_get(menu_id, language, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1200 return fut 1216 return fut
1201 1217
1202 def getReady(self): 1218 def menu_launch(self, menu_type, path, data, security_limit, profile_key):
1203 loop = asyncio.get_running_loop() 1219 loop = asyncio.get_running_loop()
1204 fut = loop.create_future() 1220 fut = loop.create_future()
1205 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1221 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1206 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1222 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1207 self.db_core_iface.getReady(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1223 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)
1208 return fut 1224 return fut
1209 1225
1210 def getVersion(self): 1226 def menus_get(self, language, security_limit):
1211 loop = asyncio.get_running_loop() 1227 loop = asyncio.get_running_loop()
1212 fut = loop.create_future() 1228 fut = loop.create_future()
1213 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1229 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1214 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1230 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1215 self.db_core_iface.getVersion(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1231 self.db_core_iface.menus_get(language, security_limit, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1216 return fut 1232 return fut
1217 1233
1218 def getWaitingSub(self, profile_key="@DEFAULT@"): 1234 def message_encryption_get(self, to_jid, profile_key):
1219 loop = asyncio.get_running_loop() 1235 loop = asyncio.get_running_loop()
1220 fut = loop.create_future() 1236 fut = loop.create_future()
1221 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1237 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1222 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1238 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1223 self.db_core_iface.getWaitingSub(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1239 self.db_core_iface.message_encryption_get(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1224 return fut 1240 return fut
1225 1241
1226 def historyGet(self, from_jid, to_jid, limit, between=True, filters='', profile="@NONE@"): 1242 def message_encryption_start(self, to_jid, namespace='', replace=False, profile_key="@NONE@"):
1227 loop = asyncio.get_running_loop() 1243 loop = asyncio.get_running_loop()
1228 fut = loop.create_future() 1244 fut = loop.create_future()
1229 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1245 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1230 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1246 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1231 self.db_core_iface.historyGet(from_jid, to_jid, limit, between, filters, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1247 self.db_core_iface.message_encryption_start(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1232 return fut 1248 return fut
1233 1249
1234 def imageCheck(self, arg_0): 1250 def message_encryption_stop(self, to_jid, profile_key):
1235 loop = asyncio.get_running_loop() 1251 loop = asyncio.get_running_loop()
1236 fut = loop.create_future() 1252 fut = loop.create_future()
1237 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1253 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1238 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1254 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1239 self.db_core_iface.imageCheck(arg_0, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1255 self.db_core_iface.message_encryption_stop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1240 return fut 1256 return fut
1241 1257
1242 def imageConvert(self, source, dest, arg_2, extra): 1258 def message_send(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@"):
1243 loop = asyncio.get_running_loop() 1259 loop = asyncio.get_running_loop()
1244 fut = loop.create_future() 1260 fut = loop.create_future()
1245 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1261 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1246 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1262 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1247 self.db_core_iface.imageConvert(source, dest, arg_2, extra, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1263 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)
1248 return fut 1264 return fut
1249 1265
1250 def imageGeneratePreview(self, image_path, profile_key): 1266 def namespaces_get(self):
1251 loop = asyncio.get_running_loop() 1267 loop = asyncio.get_running_loop()
1252 fut = loop.create_future() 1268 fut = loop.create_future()
1253 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1269 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1254 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1270 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1255 self.db_core_iface.imageGeneratePreview(image_path, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1271 self.db_core_iface.namespaces_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1256 return fut 1272 return fut
1257 1273
1258 def imageResize(self, image_path, width, height): 1274 def param_get_a(self, name, category, attribute="value", profile_key="@DEFAULT@"):
1259 loop = asyncio.get_running_loop() 1275 loop = asyncio.get_running_loop()
1260 fut = loop.create_future() 1276 fut = loop.create_future()
1261 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1277 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1262 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1278 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1263 self.db_core_iface.imageResize(image_path, width, height, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1279 self.db_core_iface.param_get_a(name, category, attribute, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1264 return fut 1280 return fut
1265 1281
1266 def isConnected(self, profile_key="@DEFAULT@"): 1282 def param_get_a_async(self, name, category, attribute="value", security_limit=-1, profile_key="@DEFAULT@"):
1267 loop = asyncio.get_running_loop() 1283 loop = asyncio.get_running_loop()
1268 fut = loop.create_future() 1284 fut = loop.create_future()
1269 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1285 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1270 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1286 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1271 self.db_core_iface.isConnected(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1287 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)
1272 return fut 1288 return fut
1273 1289
1274 def launchAction(self, callback_id, data, profile_key="@DEFAULT@"): 1290 def param_set(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@"):
1275 loop = asyncio.get_running_loop() 1291 loop = asyncio.get_running_loop()
1276 fut = loop.create_future() 1292 fut = loop.create_future()
1277 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1293 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1278 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1294 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1279 self.db_core_iface.launchAction(callback_id, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1295 self.db_core_iface.param_set(name, value, category, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1280 return fut 1296 return fut
1281 1297
1282 def loadParamsTemplate(self, filename): 1298 def param_ui_get(self, security_limit=-1, app='', extra='', profile_key="@DEFAULT@"):
1283 loop = asyncio.get_running_loop() 1299 loop = asyncio.get_running_loop()
1284 fut = loop.create_future() 1300 fut = loop.create_future()
1285 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1301 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1286 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1302 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1287 self.db_core_iface.loadParamsTemplate(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1303 self.db_core_iface.param_ui_get(security_limit, app, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1288 return fut 1304 return fut
1289 1305
1290 def menuHelpGet(self, menu_id, language): 1306 def params_categories_get(self):
1291 loop = asyncio.get_running_loop() 1307 loop = asyncio.get_running_loop()
1292 fut = loop.create_future() 1308 fut = loop.create_future()
1293 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1309 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1294 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1310 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1295 self.db_core_iface.menuHelpGet(menu_id, language, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1311 self.db_core_iface.params_categories_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1296 return fut 1312 return fut
1297 1313
1298 def menuLaunch(self, menu_type, path, data, security_limit, profile_key): 1314 def params_register_app(self, xml, security_limit=-1, app=''):
1299 loop = asyncio.get_running_loop() 1315 loop = asyncio.get_running_loop()
1300 fut = loop.create_future() 1316 fut = loop.create_future()
1301 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1317 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1302 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1318 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1303 self.db_core_iface.menuLaunch(menu_type, path, data, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1319 self.db_core_iface.params_register_app(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1304 return fut 1320 return fut
1305 1321
1306 def menusGet(self, language, security_limit): 1322 def params_template_load(self, filename):
1307 loop = asyncio.get_running_loop() 1323 loop = asyncio.get_running_loop()
1308 fut = loop.create_future() 1324 fut = loop.create_future()
1309 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1325 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1310 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1326 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1311 self.db_core_iface.menusGet(language, security_limit, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1327 self.db_core_iface.params_template_load(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1312 return fut 1328 return fut
1313 1329
1314 def messageEncryptionGet(self, to_jid, profile_key): 1330 def params_template_save(self, filename):
1315 loop = asyncio.get_running_loop() 1331 loop = asyncio.get_running_loop()
1316 fut = loop.create_future() 1332 fut = loop.create_future()
1317 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1333 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1318 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1334 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1319 self.db_core_iface.messageEncryptionGet(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1335 self.db_core_iface.params_template_save(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1320 return fut 1336 return fut
1321 1337
1322 def messageEncryptionStart(self, to_jid, namespace='', replace=False, profile_key="@NONE@"): 1338 def params_values_from_category_get_async(self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@"):
1323 loop = asyncio.get_running_loop() 1339 loop = asyncio.get_running_loop()
1324 fut = loop.create_future() 1340 fut = loop.create_future()
1325 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1341 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1326 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1342 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1327 self.db_core_iface.messageEncryptionStart(to_jid, namespace, replace, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1343 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)
1328 return fut 1344 return fut
1329 1345
1330 def messageEncryptionStop(self, to_jid, profile_key): 1346 def presence_set(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@"):
1331 loop = asyncio.get_running_loop() 1347 loop = asyncio.get_running_loop()
1332 fut = loop.create_future() 1348 fut = loop.create_future()
1333 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1349 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1334 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1350 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1335 self.db_core_iface.messageEncryptionStop(to_jid, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1351 self.db_core_iface.presence_set(to_jid, show, statuses, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1336 return fut 1352 return fut
1337 1353
1338 def messageSend(self, to_jid, message, subject={}, mess_type="auto", extra={}, profile_key="@NONE@"): 1354 def presence_statuses_get(self, profile_key="@DEFAULT@"):
1339 loop = asyncio.get_running_loop() 1355 loop = asyncio.get_running_loop()
1340 fut = loop.create_future() 1356 fut = loop.create_future()
1341 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1357 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1342 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1358 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1343 self.db_core_iface.messageSend(to_jid, message, subject, mess_type, extra, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1359 self.db_core_iface.presence_statuses_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1344 return fut 1360 return fut
1345 1361
1346 def namespacesGet(self): 1362 def private_data_delete(self, namespace, key, arg_2):
1347 loop = asyncio.get_running_loop() 1363 loop = asyncio.get_running_loop()
1348 fut = loop.create_future() 1364 fut = loop.create_future()
1349 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1365 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1350 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1366 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1351 self.db_core_iface.namespacesGet(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1367 self.db_core_iface.private_data_delete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1352 return fut 1368 return fut
1353 1369
1354 def paramsRegisterApp(self, xml, security_limit=-1, app=''): 1370 def private_data_get(self, namespace, key, profile_key):
1355 loop = asyncio.get_running_loop() 1371 loop = asyncio.get_running_loop()
1356 fut = loop.create_future() 1372 fut = loop.create_future()
1357 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1373 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1358 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1374 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1359 self.db_core_iface.paramsRegisterApp(xml, security_limit, app, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1375 self.db_core_iface.private_data_get(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1360 return fut 1376 return fut
1361 1377
1362 def privateDataDelete(self, namespace, key, arg_2): 1378 def private_data_set(self, namespace, key, data, profile_key):
1363 loop = asyncio.get_running_loop() 1379 loop = asyncio.get_running_loop()
1364 fut = loop.create_future() 1380 fut = loop.create_future()
1365 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1381 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1366 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1382 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1367 self.db_core_iface.privateDataDelete(namespace, key, arg_2, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1383 self.db_core_iface.private_data_set(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1368 return fut 1384 return fut
1369 1385
1370 def privateDataGet(self, namespace, key, profile_key): 1386 def profile_create(self, profile, password='', component=''):
1371 loop = asyncio.get_running_loop() 1387 loop = asyncio.get_running_loop()
1372 fut = loop.create_future() 1388 fut = loop.create_future()
1373 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1389 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1374 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1390 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1375 self.db_core_iface.privateDataGet(namespace, key, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1391 self.db_core_iface.profile_create(profile, password, component, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1376 return fut 1392 return fut
1377 1393
1378 def privateDataSet(self, namespace, key, data, profile_key): 1394 def profile_delete_async(self, profile):
1379 loop = asyncio.get_running_loop() 1395 loop = asyncio.get_running_loop()
1380 fut = loop.create_future() 1396 fut = loop.create_future()
1381 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1397 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1382 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1398 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1383 self.db_core_iface.privateDataSet(namespace, key, data, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1399 self.db_core_iface.profile_delete_async(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1384 return fut 1400 return fut
1385 1401
1386 def profileCreate(self, profile, password='', component=''): 1402 def profile_is_session_started(self, profile_key="@DEFAULT@"):
1387 loop = asyncio.get_running_loop() 1403 loop = asyncio.get_running_loop()
1388 fut = loop.create_future() 1404 fut = loop.create_future()
1389 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1405 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1390 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1406 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1391 self.db_core_iface.profileCreate(profile, password, component, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1407 self.db_core_iface.profile_is_session_started(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1392 return fut 1408 return fut
1393 1409
1394 def profileIsSessionStarted(self, profile_key="@DEFAULT@"): 1410 def profile_name_get(self, profile_key="@DEFAULT@"):
1395 loop = asyncio.get_running_loop() 1411 loop = asyncio.get_running_loop()
1396 fut = loop.create_future() 1412 fut = loop.create_future()
1397 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1413 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1398 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1414 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1399 self.db_core_iface.profileIsSessionStarted(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1415 self.db_core_iface.profile_name_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1400 return fut 1416 return fut
1401 1417
1402 def profileNameGet(self, profile_key="@DEFAULT@"): 1418 def profile_set_default(self, profile):
1403 loop = asyncio.get_running_loop() 1419 loop = asyncio.get_running_loop()
1404 fut = loop.create_future() 1420 fut = loop.create_future()
1405 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1421 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1406 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1422 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1407 self.db_core_iface.profileNameGet(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1423 self.db_core_iface.profile_set_default(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1408 return fut 1424 return fut
1409 1425
1410 def profileSetDefault(self, profile): 1426 def profile_start_session(self, password='', profile_key="@DEFAULT@"):
1411 loop = asyncio.get_running_loop() 1427 loop = asyncio.get_running_loop()
1412 fut = loop.create_future() 1428 fut = loop.create_future()
1413 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1429 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1414 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1430 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1415 self.db_core_iface.profileSetDefault(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1431 self.db_core_iface.profile_start_session(password, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1416 return fut 1432 return fut
1417 1433
1418 def profileStartSession(self, password='', profile_key="@DEFAULT@"): 1434 def profiles_list_get(self, clients=True, components=False):
1419 loop = asyncio.get_running_loop() 1435 loop = asyncio.get_running_loop()
1420 fut = loop.create_future() 1436 fut = loop.create_future()
1421 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1437 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1422 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1438 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1423 self.db_core_iface.profileStartSession(password, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1439 self.db_core_iface.profiles_list_get(clients, components, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1424 return fut 1440 return fut
1425 1441
1426 def profilesListGet(self, clients=True, components=False): 1442 def progress_get(self, id, profile):
1427 loop = asyncio.get_running_loop() 1443 loop = asyncio.get_running_loop()
1428 fut = loop.create_future() 1444 fut = loop.create_future()
1429 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1445 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1430 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1446 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1431 self.db_core_iface.profilesListGet(clients, components, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1447 self.db_core_iface.progress_get(id, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1432 return fut 1448 return fut
1433 1449
1434 def progressGet(self, id, profile): 1450 def progress_get_all(self, profile):
1435 loop = asyncio.get_running_loop() 1451 loop = asyncio.get_running_loop()
1436 fut = loop.create_future() 1452 fut = loop.create_future()
1437 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1453 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1438 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1454 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1439 self.db_core_iface.progressGet(id, profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1455 self.db_core_iface.progress_get_all(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1440 return fut 1456 return fut
1441 1457
1442 def progressGetAll(self, profile): 1458 def progress_get_all_metadata(self, profile):
1443 loop = asyncio.get_running_loop() 1459 loop = asyncio.get_running_loop()
1444 fut = loop.create_future() 1460 fut = loop.create_future()
1445 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1461 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1446 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1462 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1447 self.db_core_iface.progressGetAll(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1463 self.db_core_iface.progress_get_all_metadata(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1448 return fut 1464 return fut
1449 1465
1450 def progressGetAllMetadata(self, profile): 1466 def ready_get(self):
1451 loop = asyncio.get_running_loop() 1467 loop = asyncio.get_running_loop()
1452 fut = loop.create_future() 1468 fut = loop.create_future()
1453 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1469 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1454 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1470 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1455 self.db_core_iface.progressGetAllMetadata(profile, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1471 self.db_core_iface.ready_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1456 return fut 1472 return fut
1457 1473
1458 def rosterResync(self, profile_key="@DEFAULT@"): 1474 def roster_resync(self, profile_key="@DEFAULT@"):
1459 loop = asyncio.get_running_loop() 1475 loop = asyncio.get_running_loop()
1460 fut = loop.create_future() 1476 fut = loop.create_future()
1461 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1477 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1462 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1478 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1463 self.db_core_iface.rosterResync(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1479 self.db_core_iface.roster_resync(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1464 return fut 1480 return fut
1465 1481
1466 def saveParamsTemplate(self, filename): 1482 def session_infos_get(self, profile_key):
1467 loop = asyncio.get_running_loop() 1483 loop = asyncio.get_running_loop()
1468 fut = loop.create_future() 1484 fut = loop.create_future()
1469 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1485 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1470 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1486 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1471 self.db_core_iface.saveParamsTemplate(filename, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1487 self.db_core_iface.session_infos_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1472 return fut 1488 return fut
1473 1489
1474 def sessionInfosGet(self, profile_key): 1490 def sub_waiting_get(self, profile_key="@DEFAULT@"):
1475 loop = asyncio.get_running_loop() 1491 loop = asyncio.get_running_loop()
1476 fut = loop.create_future() 1492 fut = loop.create_future()
1477 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1493 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1478 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1494 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1479 self.db_core_iface.sessionInfosGet(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1495 self.db_core_iface.sub_waiting_get(profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1480 return fut
1481
1482 def setParam(self, name, value, category, security_limit=-1, profile_key="@DEFAULT@"):
1483 loop = asyncio.get_running_loop()
1484 fut = loop.create_future()
1485 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1486 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1487 self.db_core_iface.setParam(name, value, category, security_limit, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1488 return fut
1489
1490 def setPresence(self, to_jid='', show='', statuses={}, profile_key="@DEFAULT@"):
1491 loop = asyncio.get_running_loop()
1492 fut = loop.create_future()
1493 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1494 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1495 self.db_core_iface.setPresence(to_jid, show, statuses, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1496 return fut 1496 return fut
1497 1497
1498 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"): 1498 def subscription(self, sub_type, entity, profile_key="@DEFAULT@"):
1499 loop = asyncio.get_running_loop() 1499 loop = asyncio.get_running_loop()
1500 fut = loop.create_future() 1500 fut = loop.create_future()
1501 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1501 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1502 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1502 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1503 self.db_core_iface.subscription(sub_type, entity, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1503 self.db_core_iface.subscription(sub_type, entity, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1504 return fut 1504 return fut
1505 1505
1506 def updateContact(self, entity_jid, name, groups, profile_key="@DEFAULT@"): 1506 def version_get(self):
1507 loop = asyncio.get_running_loop() 1507 loop = asyncio.get_running_loop()
1508 fut = loop.create_future() 1508 fut = loop.create_future()
1509 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret) 1509 reply_handler = lambda ret=None: loop.call_soon_threadsafe(fut.set_result, ret)
1510 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err)) 1510 error_handler = lambda err: loop.call_soon_threadsafe(fut.set_exception, dbus_to_bridge_exception(err))
1511 self.db_core_iface.updateContact(entity_jid, name, groups, profile_key, timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler) 1511 self.db_core_iface.version_get(timeout=const_TIMEOUT, reply_handler=reply_handler, error_handler=error_handler)
1512 return fut 1512 return fut