Mercurial > libervia-backend
comparison sat_frontends/bridge/dbus_bridge.py @ 4037:524856bd7b19
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 |