Mercurial > libervia-backend
annotate libervia/backend/bridge/dbus_bridge.py @ 4309:b56b1eae7994
component email gateway: add multicasting:
XEP-0033 multicasting is now supported both for incoming and outgoing messages. XEP-0033
metadata are converted to suitable Email headers and vice versa.
Email address and JID are both supported, and delivery is done by the gateway when
suitable on incoming messages.
rel 450
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Thu, 26 Sep 2024 16:12:01 +0200 |
| parents | 3a550e9a2b55 |
| children |
| rev | line source |
|---|---|
| 3028 | 1 #!/usr/bin/env python3 |
| 3137 | 2 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
3 # Libervia communication bridge |
| 3479 | 4 # Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org) |
| 0 | 5 |
|
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
6 # This program is free software: you can redistribute it and/or modify |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
7 # it under the terms of the GNU Affero General Public License as published by |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
8 # the Free Software Foundation, either version 3 of the License, or |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
9 # (at your option) any later version. |
| 0 | 10 |
|
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
11 # This program is distributed in the hope that it will be useful, |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
14 # GNU Affero General Public License for more details. |
| 0 | 15 |
|
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
16 # You should have received a copy of the GNU Affero General Public License |
|
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
595
diff
changeset
|
17 # along with this program. If not, see <http://www.gnu.org/licenses/>. |
| 0 | 18 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
19 from types import MethodType |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
20 from functools import partialmethod |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
21 from twisted.internet import defer, reactor |
|
4071
4b842c1fb686
refactoring: renamed `sat` package to `libervia.backend`
Goffi <goffi@goffi.org>
parents:
4041
diff
changeset
|
22 from libervia.backend.core.i18n import _ |
|
4b842c1fb686
refactoring: renamed `sat` package to `libervia.backend`
Goffi <goffi@goffi.org>
parents:
4041
diff
changeset
|
23 from libervia.backend.core.log import getLogger |
|
4b842c1fb686
refactoring: renamed `sat` package to `libervia.backend`
Goffi <goffi@goffi.org>
parents:
4041
diff
changeset
|
24 from libervia.backend.core.exceptions import BridgeInitError |
|
4b842c1fb686
refactoring: renamed `sat` package to `libervia.backend`
Goffi <goffi@goffi.org>
parents:
4041
diff
changeset
|
25 from libervia.backend.tools import config |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
26 from txdbus import client, objects, error |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
27 from txdbus.interface import DBusInterface, Method, Signal |
| 0 | 28 |
|
3143
830fce0db15d
bridge (dbus): new `bridge_dbus_int_prefix` option (in `[DEFAULT]` settings) to change interface prefix
Goffi <goffi@goffi.org>
parents:
3137
diff
changeset
|
29 |
|
830fce0db15d
bridge (dbus): new `bridge_dbus_int_prefix` option (in `[DEFAULT]` settings) to change interface prefix
Goffi <goffi@goffi.org>
parents:
3137
diff
changeset
|
30 log = getLogger(__name__) |
|
830fce0db15d
bridge (dbus): new `bridge_dbus_int_prefix` option (in `[DEFAULT]` settings) to change interface prefix
Goffi <goffi@goffi.org>
parents:
3137
diff
changeset
|
31 |
|
830fce0db15d
bridge (dbus): new `bridge_dbus_int_prefix` option (in `[DEFAULT]` settings) to change interface prefix
Goffi <goffi@goffi.org>
parents:
3137
diff
changeset
|
32 # Interface prefix |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
33 const_INT_PREFIX = config.config_get( |
|
4270
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
34 config.parse_main_conf(), "", "bridge_dbus_int_prefix", "org.libervia.Libervia" |
|
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
35 ) |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
36 const_ERROR_PREFIX = const_INT_PREFIX + ".error" |
|
3480
7550ae9cfbac
Renamed the project from "Salut à Toi" to "Libervia":
Goffi <goffi@goffi.org>
parents:
3479
diff
changeset
|
37 const_OBJ_PATH = "/org/libervia/Libervia/bridge" |
|
371
3ea41a199b36
bridge refactoring: categories are now core and plugin instead of communication and request
Goffi <goffi@goffi.org>
parents:
365
diff
changeset
|
38 const_CORE_SUFFIX = ".core" |
|
3ea41a199b36
bridge refactoring: categories are now core and plugin instead of communication and request
Goffi <goffi@goffi.org>
parents:
365
diff
changeset
|
39 const_PLUGIN_SUFFIX = ".plugin" |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
40 |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
41 |
|
477
031b0e0aaab8
plugin groupblog: subscriptions/notifications
Goffi <goffi@goffi.org>
parents:
469
diff
changeset
|
42 class ParseError(Exception): |
|
031b0e0aaab8
plugin groupblog: subscriptions/notifications
Goffi <goffi@goffi.org>
parents:
469
diff
changeset
|
43 pass |
|
031b0e0aaab8
plugin groupblog: subscriptions/notifications
Goffi <goffi@goffi.org>
parents:
469
diff
changeset
|
44 |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
45 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
46 class DBusException(Exception): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
47 pass |
|
423
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
48 |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
49 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
50 class MethodNotRegistered(DBusException): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
51 dbusErrorName = const_ERROR_PREFIX + ".MethodNotRegistered" |
|
423
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
52 |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
53 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
54 class GenericException(DBusException): |
|
423
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
55 def __init__(self, twisted_error): |
|
1073
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
56 """ |
|
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
57 |
|
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
58 @param twisted_error (Failure): instance of twisted Failure |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
59 error message is used to store a repr of message and condition in a tuple, |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
60 so it can be evaluated by the frontend bridge. |
|
1073
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
61 """ |
|
751
1def5b7edf9f
core, bridge: better GenericException handling
Goffi <goffi@goffi.org>
parents:
698
diff
changeset
|
62 try: |
|
1def5b7edf9f
core, bridge: better GenericException handling
Goffi <goffi@goffi.org>
parents:
698
diff
changeset
|
63 # twisted_error.value is a class |
|
1062
95758ef3faa8
bridge: async failures are more detailed (full class name + error message)
souliane <souliane@mailoo.org>
parents:
1060
diff
changeset
|
64 class_ = twisted_error.value().__class__ |
|
751
1def5b7edf9f
core, bridge: better GenericException handling
Goffi <goffi@goffi.org>
parents:
698
diff
changeset
|
65 except TypeError: |
|
1def5b7edf9f
core, bridge: better GenericException handling
Goffi <goffi@goffi.org>
parents:
698
diff
changeset
|
66 # twisted_error.value is an instance |
|
1062
95758ef3faa8
bridge: async failures are more detailed (full class name + error message)
souliane <souliane@mailoo.org>
parents:
1060
diff
changeset
|
67 class_ = twisted_error.value.__class__ |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
68 data = twisted_error.getErrorMessage() |
|
1073
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
69 try: |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
70 data = (data, twisted_error.value.condition) |
|
1073
f094583732de
bridge: DBusException also transports the twisted failure condition
souliane <souliane@mailoo.org>
parents:
1062
diff
changeset
|
71 except AttributeError: |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
72 data = (data,) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
73 else: |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
74 data = (str(twisted_error),) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
75 self.dbusErrorName = ".".join( |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
76 (const_ERROR_PREFIX, class_.__module__, class_.__name__) |
|
2624
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
77 ) |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
78 super(GenericException, self).__init__(repr(data)) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
79 |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
80 @classmethod |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
81 def create_and_raise(cls, exc): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
82 raise cls(exc) |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
83 |
|
419
6c167a2e04b8
bridge: added generic D-Bus exception management + asyncCreateProfile method
Goffi <goffi@goffi.org>
parents:
413
diff
changeset
|
84 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
85 class DBusObject(objects.DBusObject): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
86 |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
87 core_iface = DBusInterface( |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
88 const_INT_PREFIX + const_CORE_SUFFIX, |
| 4284 | 89 Method("action_launch", arguments="sss", returns="s"), |
| 90 Method("actions_get", arguments="s", returns="a(ssi)"), | |
| 91 Method("config_get", arguments="ss", returns="s"), | |
| 92 Method("connect", arguments="ssa{ss}", returns="b"), | |
| 93 Method("contact_add", arguments="ss", returns=""), | |
| 94 Method("contact_del", arguments="ss", returns=""), | |
| 95 Method("contact_get", arguments="ss", returns="(a{ss}as)"), | |
| 96 Method("contact_update", arguments="ssass", returns=""), | |
| 97 Method("contacts_get", arguments="s", returns="a(sa{ss}as)"), | |
| 98 Method("contacts_get_from_group", arguments="ss", returns="as"), | |
| 99 Method("devices_infos_get", arguments="ss", returns="s"), | |
| 100 Method( | |
| 101 "disco_find_by_features", | |
| 102 arguments="asa(ss)bbbbbs", | |
| 103 returns="(a{sa(sss)}a{sa(sss)}a{sa(sss)})", | |
| 104 ), | |
| 105 Method("disco_infos", arguments="ssbs", returns="(asa(sss)a{sa(a{ss}as)})"), | |
| 106 Method("disco_items", arguments="ssbs", returns="a(sss)"), | |
| 107 Method("disconnect", arguments="s", returns=""), | |
| 108 Method("encryption_namespace_get", arguments="s", returns="s"), | |
| 109 Method("encryption_plugins_get", arguments="", returns="s"), | |
| 110 Method("encryption_trust_ui_get", arguments="sss", returns="s"), | |
| 111 Method("entities_data_get", arguments="asass", returns="a{sa{ss}}"), | |
| 112 Method("entity_data_get", arguments="sass", returns="a{ss}"), | |
| 113 Method("features_get", arguments="s", returns="a{sa{ss}}"), | |
| 114 Method("history_get", arguments="ssiba{ss}s", returns="a(sdssa{ss}a{ss}ss)"), | |
| 115 Method("image_check", arguments="s", returns="s"), | |
| 116 Method("image_convert", arguments="ssss", returns="s"), | |
| 117 Method("image_generate_preview", arguments="ss", returns="s"), | |
| 118 Method("image_resize", arguments="sii", returns="s"), | |
| 119 Method("init_pre_script", arguments="", returns=""), | |
| 120 Method("is_connected", arguments="s", returns="b"), | |
| 121 Method("main_resource_get", arguments="ss", returns="s"), | |
| 122 Method("menu_help_get", arguments="ss", returns="s"), | |
| 123 Method("menu_launch", arguments="sasa{ss}is", returns="a{ss}"), | |
| 124 Method("menus_get", arguments="si", returns="a(ssasasa{ss})"), | |
| 125 Method("message_encryption_get", arguments="ss", returns="s"), | |
| 126 Method("message_encryption_start", arguments="ssbs", returns=""), | |
| 127 Method("message_encryption_stop", arguments="ss", returns=""), | |
| 128 Method("message_send", arguments="sa{ss}a{ss}sss", returns=""), | |
| 129 Method("namespaces_get", arguments="", returns="a{ss}"), | |
| 130 Method("notification_add", arguments="ssssbbsdss", returns=""), | |
| 131 Method("notification_delete", arguments="sbs", returns=""), | |
| 132 Method("notifications_expired_clean", arguments="ds", returns=""), | |
| 133 Method("notifications_get", arguments="ss", returns="s"), | |
| 134 Method("param_get_a", arguments="ssss", returns="s"), | |
| 135 Method("param_get_a_async", arguments="sssis", returns="s"), | |
| 136 Method("param_set", arguments="sssis", returns=""), | |
| 137 Method("param_ui_get", arguments="isss", returns="s"), | |
| 138 Method("params_categories_get", arguments="", returns="as"), | |
| 139 Method("params_register_app", arguments="sis", returns=""), | |
| 140 Method("params_template_load", arguments="s", returns="b"), | |
| 141 Method("params_template_save", arguments="s", returns="b"), | |
| 142 Method( | |
| 143 "params_values_from_category_get_async", arguments="sisss", returns="a{ss}" | |
| 144 ), | |
| 145 Method("presence_set", arguments="ssa{ss}s", returns=""), | |
| 146 Method("presence_statuses_get", arguments="s", returns="a{sa{s(sia{ss})}}"), | |
| 147 Method("private_data_delete", arguments="sss", returns=""), | |
| 148 Method("private_data_get", arguments="sss", returns="s"), | |
| 149 Method("private_data_set", arguments="ssss", returns=""), | |
| 150 Method("profile_create", arguments="sss", returns=""), | |
| 151 Method("profile_delete_async", arguments="s", returns=""), | |
| 152 Method("profile_is_session_started", arguments="s", returns="b"), | |
| 153 Method("profile_name_get", arguments="s", returns="s"), | |
| 154 Method("profile_set_default", arguments="s", returns=""), | |
| 155 Method("profile_start_session", arguments="ss", returns="b"), | |
| 156 Method("profiles_list_get", arguments="bb", returns="as"), | |
| 157 Method("progress_get", arguments="ss", returns="a{ss}"), | |
| 158 Method("progress_get_all", arguments="s", returns="a{sa{sa{ss}}}"), | |
| 159 Method("progress_get_all_metadata", arguments="s", returns="a{sa{sa{ss}}}"), | |
| 160 Method("ready_get", arguments="", returns=""), | |
| 161 Method("roster_resync", arguments="s", returns=""), | |
| 162 Method("session_infos_get", arguments="s", returns="a{ss}"), | |
| 163 Method("sub_waiting_get", arguments="s", returns="a{ss}"), | |
| 164 Method("subscription", arguments="sss", returns=""), | |
| 165 Method("version_get", arguments="", returns="s"), | |
| 166 Signal("_debug", "sa{ss}s"), | |
| 167 Signal("action_new", "ssis"), | |
| 168 Signal("connected", "ss"), | |
| 169 Signal("contact_deleted", "ss"), | |
| 170 Signal("contact_new", "sa{ss}ass"), | |
| 171 Signal("disconnected", "s"), | |
| 172 Signal("entity_data_updated", "ssss"), | |
| 173 Signal("message_encryption_started", "sss"), | |
| 174 Signal("message_encryption_stopped", "sa{ss}s"), | |
| 175 Signal("message_new", "sdssa{ss}a{ss}sss"), | |
| 176 Signal("message_update", "ssss"), | |
| 177 Signal("notification_deleted", "ss"), | |
| 178 Signal("notification_new", "sdssssbidss"), | |
| 179 Signal("param_update", "ssss"), | |
| 180 Signal("presence_update", "ssia{ss}s"), | |
| 181 Signal("progress_error", "sss"), | |
| 182 Signal("progress_finished", "sa{ss}s"), | |
| 183 Signal("progress_started", "sa{ss}s"), | |
| 184 Signal("subscribe", "sss"), | |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
185 ) |
|
4270
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
186 plugin_iface = DBusInterface(const_INT_PREFIX + const_PLUGIN_SUFFIX) |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
187 |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
188 dbusInterfaces = [core_iface, plugin_iface] |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
189 |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
190 def __init__(self, path): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
191 super().__init__(path) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
192 log.debug("Init DBusObject...") |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
193 self.cb = {} |
| 0 | 194 |
| 2086 | 195 def register_method(self, name, cb): |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
196 self.cb[name] = cb |
| 0 | 197 |
|
423
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
198 def _callback(self, name, *args, **kwargs): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
199 """Call the callback if it exists, raise an exception else""" |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
200 try: |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
201 cb = self.cb[name] |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
202 except KeyError: |
|
423
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
203 raise MethodNotRegistered |
|
6c20c76abdcc
backend: - bridge async D-Bus method now automatically manage callback and errback, we just have to return a deferred
Goffi <goffi@goffi.org>
parents:
419
diff
changeset
|
204 else: |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
205 d = defer.maybeDeferred(cb, *args, **kwargs) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
206 d.addErrback(GenericException.create_and_raise) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
207 return d |
|
1467
ceba6fd77739
core, bridge: new signal actionNew to launch an action from the backend (e.g. display a dialog message):
Goffi <goffi@goffi.org>
parents:
1435
diff
changeset
|
208 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
209 def dbus_action_launch(self, callback_id, data, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
210 return self._callback("action_launch", callback_id, data, profile_key) |
|
2655
b8600f8130ac
core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet)
Goffi <goffi@goffi.org>
parents:
2646
diff
changeset
|
211 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
212 def dbus_actions_get(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
213 return self._callback("actions_get", profile_key) |
| 0 | 214 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
215 def dbus_config_get(self, section, name): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
216 return self._callback("config_get", section, name) |
|
1522
7d7e57a84792
core: progression handling improvments:
Goffi <goffi@goffi.org>
parents:
1482
diff
changeset
|
217 |
| 4284 | 218 def dbus_connect(self, profile_key="@DEFAULT@", password="", options={}): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
219 return self._callback("connect", profile_key, password, options) |
|
1522
7d7e57a84792
core: progression handling improvments:
Goffi <goffi@goffi.org>
parents:
1482
diff
changeset
|
220 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
221 def dbus_contact_add(self, entity_jid, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
222 return self._callback("contact_add", entity_jid, profile_key) |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
223 |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
224 def dbus_contact_del(self, entity_jid, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
225 return self._callback("contact_del", entity_jid, profile_key) |
| 1622 | 226 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
227 def dbus_contact_get(self, arg_0, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
228 return self._callback("contact_get", arg_0, profile_key) |
|
893
308a96bc7c1b
core, frontends: add method asyncDeleteProfile, remove synchronous methods createProfile and deleteProfile
souliane <souliane@mailoo.org>
parents:
811
diff
changeset
|
229 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
230 def dbus_contact_update(self, entity_jid, name, groups, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
231 return self._callback("contact_update", entity_jid, name, groups, profile_key) |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
232 |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
233 def dbus_contacts_get(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
234 return self._callback("contacts_get", profile_key) |
|
2142
be96beb7ca14
core, bridge, frontends: renamed asyncConnect to connect, and added options parameters (not used yet)
Goffi <goffi@goffi.org>
parents:
2126
diff
changeset
|
235 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
236 def dbus_contacts_get_from_group(self, group, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
237 return self._callback("contacts_get_from_group", group, profile_key) |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
238 |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
239 def dbus_devices_infos_get(self, bare_jid, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
240 return self._callback("devices_infos_get", bare_jid, profile_key) |
|
2628
779351da2c13
core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation:
Goffi <goffi@goffi.org>
parents:
2624
diff
changeset
|
241 |
| 4284 | 242 def dbus_disco_find_by_features( |
| 243 self, | |
| 244 namespaces, | |
| 245 identities, | |
| 246 bare_jid=False, | |
| 247 service=True, | |
| 248 roster=True, | |
| 249 own_jid=True, | |
| 250 local_device=False, | |
| 251 profile_key="@DEFAULT@", | |
| 252 ): | |
| 253 return self._callback( | |
| 254 "disco_find_by_features", | |
| 255 namespaces, | |
| 256 identities, | |
| 257 bare_jid, | |
| 258 service, | |
| 259 roster, | |
| 260 own_jid, | |
| 261 local_device, | |
| 262 profile_key, | |
| 263 ) | |
|
2534
7da86e1633a5
core: new discoFindFeatures method which return all server services/roster entities implementing a set of features.
Goffi <goffi@goffi.org>
parents:
2483
diff
changeset
|
264 |
| 4284 | 265 def dbus_disco_infos( |
| 266 self, entity_jid, node="", use_cache=True, profile_key="@DEFAULT@" | |
| 267 ): | |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
268 return self._callback("disco_infos", entity_jid, node, use_cache, profile_key) |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
269 |
| 4284 | 270 def dbus_disco_items( |
| 271 self, entity_jid, node="", use_cache=True, profile_key="@DEFAULT@" | |
| 272 ): | |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
273 return self._callback("disco_items", entity_jid, node, use_cache, profile_key) |
|
963
723f28cd15c7
core (disco): added discoInfos and discoItems bridge methods
Goffi <goffi@goffi.org>
parents:
943
diff
changeset
|
274 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
275 def dbus_disconnect(self, profile_key="@DEFAULT@"): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
276 return self._callback("disconnect", profile_key) |
| 267 | 277 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
278 def dbus_encryption_namespace_get(self, arg_0): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
279 return self._callback("encryption_namespace_get", arg_0) |
|
2733
e347e32aa07f
core (memory/encryption): new encryptionNamespaceGet and encryptionTrustUIGet methods:
Goffi <goffi@goffi.org>
parents:
2658
diff
changeset
|
280 |
| 4284 | 281 def dbus_encryption_plugins_get( |
| 282 self, | |
| 283 ): | |
| 284 return self._callback( | |
| 285 "encryption_plugins_get", | |
| 286 ) | |
|
2658
4e130cc9bfc0
core (memore/encryption): new methods and checks:
Goffi <goffi@goffi.org>
parents:
2655
diff
changeset
|
287 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
288 def dbus_encryption_trust_ui_get(self, to_jid, namespace, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
289 return self._callback("encryption_trust_ui_get", to_jid, namespace, profile_key) |
|
2733
e347e32aa07f
core (memory/encryption): new encryptionNamespaceGet and encryptionTrustUIGet methods:
Goffi <goffi@goffi.org>
parents:
2658
diff
changeset
|
290 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
291 def dbus_entities_data_get(self, jids, keys, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
292 return self._callback("entities_data_get", jids, keys, profile) |
| 364 | 293 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
294 def dbus_entity_data_get(self, jid, keys, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
295 return self._callback("entity_data_get", jid, keys, profile) |
| 267 | 296 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
297 def dbus_features_get(self, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
298 return self._callback("features_get", profile_key) |
|
501
e9634d2e7b38
core, quick_frontend, primitivus, wix: Contacts List refactoring phase 1:
Goffi <goffi@goffi.org>
parents:
480
diff
changeset
|
299 |
| 4284 | 300 def dbus_history_get( |
| 301 self, from_jid, to_jid, limit, between=True, filters="", profile="@NONE@" | |
| 302 ): | |
| 303 return self._callback( | |
| 304 "history_get", from_jid, to_jid, limit, between, filters, profile | |
| 305 ) | |
|
1314
bb9c32249778
core: added getEntitiesData which get cache data for several entities at once
Goffi <goffi@goffi.org>
parents:
1290
diff
changeset
|
306 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
307 def dbus_image_check(self, arg_0): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
308 return self._callback("image_check", arg_0) |
|
504
65ecbb473cbb
core, quick frontend, plugin xep-0054, bridge: use of memory's entities data for vcard:
Goffi <goffi@goffi.org>
parents:
501
diff
changeset
|
309 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
310 def dbus_image_convert(self, source, dest, arg_2, extra): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
311 return self._callback("image_convert", source, dest, arg_2, extra) |
|
1482
80cd55dd5b04
core, bridge: added getFeatures method:
Goffi <goffi@goffi.org>
parents:
1467
diff
changeset
|
312 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
313 def dbus_image_generate_preview(self, image_path, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
314 return self._callback("image_generate_preview", image_path, profile_key) |
| 267 | 315 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
316 def dbus_image_resize(self, image_path, width, height): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
317 return self._callback("image_resize", image_path, width, height) |
| 267 | 318 |
| 4284 | 319 def dbus_init_pre_script( |
| 320 self, | |
| 321 ): | |
| 322 return self._callback( | |
| 323 "init_pre_script", | |
| 324 ) | |
|
4193
730f542e4ad0
core: add new `init_script_path` option:
Goffi <goffi@goffi.org>
parents:
4148
diff
changeset
|
325 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
326 def dbus_is_connected(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
327 return self._callback("is_connected", profile_key) |
| 267 | 328 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
329 def dbus_main_resource_get(self, contact_jid, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
330 return self._callback("main_resource_get", contact_jid, profile_key) |
|
2628
779351da2c13
core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation:
Goffi <goffi@goffi.org>
parents:
2624
diff
changeset
|
331 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
332 def dbus_menu_help_get(self, menu_id, language): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
333 return self._callback("menu_help_get", menu_id, language) |
| 267 | 334 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
335 def dbus_menu_launch(self, menu_type, path, data, security_limit, profile_key): |
| 4284 | 336 return self._callback( |
| 337 "menu_launch", menu_type, path, data, security_limit, profile_key | |
| 338 ) | |
|
1023
8bae81e254a2
core: added a getReady method which can be called by frontends to ensure that backend is fully initialised before doing anything + this ckeck is automatically done in asyncConnect
Goffi <goffi@goffi.org>
parents:
1015
diff
changeset
|
339 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
340 def dbus_menus_get(self, language, security_limit): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
341 return self._callback("menus_get", language, security_limit) |
| 267 | 342 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
343 def dbus_message_encryption_get(self, to_jid, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
344 return self._callback("message_encryption_get", to_jid, profile_key) |
| 267 | 345 |
| 4284 | 346 def dbus_message_encryption_start( |
| 347 self, to_jid, namespace="", replace=False, profile_key="@NONE@" | |
| 348 ): | |
| 349 return self._callback( | |
| 350 "message_encryption_start", to_jid, namespace, replace, profile_key | |
| 351 ) | |
|
1955
633b5c21aefd
backend, frontend: messages refactoring (huge commit, not finished):
Goffi <goffi@goffi.org>
parents:
1934
diff
changeset
|
352 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
353 def dbus_message_encryption_stop(self, to_jid, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
354 return self._callback("message_encryption_stop", to_jid, profile_key) |
|
3066
2cc2f65379f7
core: added imageCheck and imageResize methods:
Goffi <goffi@goffi.org>
parents:
3028
diff
changeset
|
355 |
| 4284 | 356 def dbus_message_send( |
| 357 self, | |
| 358 to_jid, | |
| 359 message, | |
| 360 subject={}, | |
| 361 mess_type="auto", | |
| 362 extra={}, | |
| 363 profile_key="@NONE@", | |
| 364 ): | |
| 365 return self._callback( | |
| 366 "message_send", to_jid, message, subject, mess_type, extra, profile_key | |
| 367 ) | |
| 368 | |
| 369 def dbus_namespaces_get( | |
| 370 self, | |
| 371 ): | |
| 372 return self._callback( | |
| 373 "namespaces_get", | |
| 374 ) | |
|
3259
f300d78f08f3
core: image convertion + SVG support:
Goffi <goffi@goffi.org>
parents:
3254
diff
changeset
|
375 |
| 4284 | 376 def dbus_notification_add( |
| 377 self, | |
| 378 type_, | |
| 379 body_plain, | |
| 380 body_rich, | |
| 381 title, | |
| 382 is_global, | |
| 383 requires_action, | |
| 384 arg_6, | |
| 385 priority, | |
| 386 expire_at, | |
| 387 extra, | |
| 388 ): | |
| 389 return self._callback( | |
| 390 "notification_add", | |
| 391 type_, | |
| 392 body_plain, | |
| 393 body_rich, | |
| 394 title, | |
| 395 is_global, | |
| 396 requires_action, | |
| 397 arg_6, | |
| 398 priority, | |
| 399 expire_at, | |
| 400 extra, | |
| 401 ) | |
|
4130
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
402 |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
403 def dbus_notification_delete(self, id_, is_global, profile_key): |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
404 return self._callback("notification_delete", id_, is_global, profile_key) |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
405 |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
406 def dbus_notifications_expired_clean(self, limit_timestamp, profile_key): |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
407 return self._callback("notifications_expired_clean", limit_timestamp, profile_key) |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
408 |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
409 def dbus_notifications_get(self, filters, profile_key): |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
410 return self._callback("notifications_get", filters, profile_key) |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
411 |
| 4284 | 412 def dbus_param_get_a( |
| 413 self, name, category, attribute="value", profile_key="@DEFAULT@" | |
| 414 ): | |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
415 return self._callback("param_get_a", name, category, attribute, profile_key) |
| 267 | 416 |
| 4284 | 417 def dbus_param_get_a_async( |
| 418 self, | |
| 419 name, | |
| 420 category, | |
| 421 attribute="value", | |
| 422 security_limit=-1, | |
| 423 profile_key="@DEFAULT@", | |
| 424 ): | |
| 425 return self._callback( | |
| 426 "param_get_a_async", name, category, attribute, security_limit, profile_key | |
| 427 ) | |
|
60
9764e027ecc0
SàT: multi-profile parameters, first draft
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
428 |
| 4284 | 429 def dbus_param_set( |
| 430 self, name, value, category, security_limit=-1, profile_key="@DEFAULT@" | |
| 431 ): | |
| 432 return self._callback( | |
| 433 "param_set", name, value, category, security_limit, profile_key | |
| 434 ) | |
|
1015
fee00f2e11c2
memory, jp: added jp commands to load/save parameters template
souliane <souliane@mailoo.org>
parents:
993
diff
changeset
|
435 |
| 4284 | 436 def dbus_param_ui_get( |
| 437 self, security_limit=-1, app="", extra="", profile_key="@DEFAULT@" | |
| 438 ): | |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
439 return self._callback("param_ui_get", security_limit, app, extra, profile_key) |
| 2126 | 440 |
| 4284 | 441 def dbus_params_categories_get( |
| 442 self, | |
| 443 ): | |
| 444 return self._callback( | |
| 445 "params_categories_get", | |
| 446 ) | |
| 2126 | 447 |
| 4284 | 448 def dbus_params_register_app(self, xml, security_limit=-1, app=""): |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
449 return self._callback("params_register_app", xml, security_limit, app) |
| 2126 | 450 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
451 def dbus_params_template_load(self, filename): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
452 return self._callback("params_template_load", filename) |
|
2658
4e130cc9bfc0
core (memore/encryption): new methods and checks:
Goffi <goffi@goffi.org>
parents:
2655
diff
changeset
|
453 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
454 def dbus_params_template_save(self, filename): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
455 return self._callback("params_template_save", filename) |
|
2658
4e130cc9bfc0
core (memore/encryption): new methods and checks:
Goffi <goffi@goffi.org>
parents:
2655
diff
changeset
|
456 |
| 4284 | 457 def dbus_params_values_from_category_get_async( |
| 458 self, category, security_limit=-1, app="", extra="", profile_key="@DEFAULT@" | |
| 459 ): | |
| 460 return self._callback( | |
| 461 "params_values_from_category_get_async", | |
| 462 category, | |
| 463 security_limit, | |
| 464 app, | |
| 465 extra, | |
| 466 profile_key, | |
| 467 ) | |
|
2646
712cb4ff3e13
core: new EncryptionHandler class which manage encrypted session as a core feature:
Goffi <goffi@goffi.org>
parents:
2628
diff
changeset
|
468 |
| 4284 | 469 def dbus_presence_set(self, to_jid="", show="", statuses={}, profile_key="@DEFAULT@"): |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
470 return self._callback("presence_set", to_jid, show, statuses, profile_key) |
|
2628
779351da2c13
core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation:
Goffi <goffi@goffi.org>
parents:
2624
diff
changeset
|
471 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
472 def dbus_presence_statuses_get(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
473 return self._callback("presence_statuses_get", profile_key) |
|
2443
81a45e7886c9
core: added a mechanism to associate short names to namespaces:
Goffi <goffi@goffi.org>
parents:
2414
diff
changeset
|
474 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
475 def dbus_private_data_delete(self, namespace, key, arg_2): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
476 return self._callback("private_data_delete", namespace, key, arg_2) |
|
777
5642939d254e
core, bridge: new method paramsRegisterApp to register frontend's specific parameters
souliane <souliane@mailoo.org>
parents:
773
diff
changeset
|
477 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
478 def dbus_private_data_get(self, namespace, key, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
479 return self._callback("private_data_get", namespace, key, profile_key) |
|
3163
d10b2368684e
bridge: added methods to let frontends store/retrieve/delete private data
Goffi <goffi@goffi.org>
parents:
3143
diff
changeset
|
480 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
481 def dbus_private_data_set(self, namespace, key, data, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
482 return self._callback("private_data_set", namespace, key, data, profile_key) |
|
3163
d10b2368684e
bridge: added methods to let frontends store/retrieve/delete private data
Goffi <goffi@goffi.org>
parents:
3143
diff
changeset
|
483 |
| 4284 | 484 def dbus_profile_create(self, profile, password="", component=""): |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
485 return self._callback("profile_create", profile, password, component) |
|
2144
1d3f73e065e1
core, jp: component handling + client handling refactoring:
Goffi <goffi@goffi.org>
parents:
2142
diff
changeset
|
486 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
487 def dbus_profile_delete_async(self, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
488 return self._callback("profile_delete_async", profile) |
|
1592
d6d655238a93
bridge: new core method profileStartSession to start a session without connecting the profile
Goffi <goffi@goffi.org>
parents:
1587
diff
changeset
|
489 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
490 def dbus_profile_is_session_started(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
491 return self._callback("profile_is_session_started", profile_key) |
|
2168
255830fdb80b
core, bridge: renamed getProfileName to profileNameGet according to new conventions
Goffi <goffi@goffi.org>
parents:
2150
diff
changeset
|
492 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
493 def dbus_profile_name_get(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
494 return self._callback("profile_name_get", profile_key) |
|
1595
a3d0cfa5b7a6
core, bridge: added a profileSetDefault method
Goffi <goffi@goffi.org>
parents:
1592
diff
changeset
|
495 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
496 def dbus_profile_set_default(self, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
497 return self._callback("profile_set_default", profile) |
|
1592
d6d655238a93
bridge: new core method profileStartSession to start a session without connecting the profile
Goffi <goffi@goffi.org>
parents:
1587
diff
changeset
|
498 |
| 4284 | 499 def dbus_profile_start_session(self, password="", profile_key="@DEFAULT@"): |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
500 return self._callback("profile_start_session", password, profile_key) |
|
2146
1bb9bf1b4150
core, frontends: getProfilesList renamed to profilesGetList + behaviour change:
Goffi <goffi@goffi.org>
parents:
2144
diff
changeset
|
501 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
502 def dbus_profiles_list_get(self, clients=True, components=False): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
503 return self._callback("profiles_list_get", clients, components) |
|
1626
63cef4dbf2a4
core, plugins file, XEP-0234, bridge: progression api enhancement:
Goffi <goffi@goffi.org>
parents:
1622
diff
changeset
|
504 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
505 def dbus_progress_get(self, id, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
506 return self._callback("progress_get", id, profile) |
|
2113
9c861d07b5b6
core: added sessionGetInfos bridge method to retrieve various data on current profile session + client.started keep start time
Goffi <goffi@goffi.org>
parents:
2086
diff
changeset
|
507 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
508 def dbus_progress_get_all(self, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
509 return self._callback("progress_get_all", profile) |
|
2628
779351da2c13
core, frontends: replaced org\.goffi namespaces by org.salutatoi + fixed generation:
Goffi <goffi@goffi.org>
parents:
2624
diff
changeset
|
510 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
511 def dbus_progress_get_all_metadata(self, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
512 return self._callback("progress_get_all_metadata", profile) |
| 345 | 513 |
| 4284 | 514 def dbus_ready_get( |
| 515 self, | |
| 516 ): | |
| 517 return self._callback( | |
| 518 "ready_get", | |
| 519 ) | |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
520 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
521 def dbus_roster_resync(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
522 return self._callback("roster_resync", profile_key) |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
523 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
524 def dbus_session_infos_get(self, profile_key): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
525 return self._callback("session_infos_get", profile_key) |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
526 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
527 def dbus_sub_waiting_get(self, profile_key="@DEFAULT@"): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
528 return self._callback("sub_waiting_get", profile_key) |
|
468
c97640c90a94
D-Bus Bridge: use inspection to name attribute + fix asynchronous calls for dynamically added method, it now use deferred return value instead of callback/errback attributes
Goffi <goffi@goffi.org>
parents:
459
diff
changeset
|
529 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
530 def dbus_subscription(self, sub_type, entity, profile_key="@DEFAULT@"): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
531 return self._callback("subscription", sub_type, entity, profile_key) |
|
587
952322b1d490
Remove trailing whitespaces.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
572
diff
changeset
|
532 |
| 4284 | 533 def dbus_version_get( |
| 534 self, | |
| 535 ): | |
| 536 return self._callback( | |
| 537 "version_get", | |
| 538 ) | |
|
595
1f160467f5de
Fix pep8 support in src/bridge.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
587
diff
changeset
|
539 |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
540 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
541 class bridge: |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
542 |
| 0 | 543 def __init__(self): |
|
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
963
diff
changeset
|
544 log.info("Init DBus...") |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
545 self._obj = DBusObject(const_OBJ_PATH) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
546 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
547 async def post_init(self): |
|
627
d207c2186519
core, bridge, jp, quick_frontend: SàT stop more gracefully if bridge can't be initialised:
Goffi <goffi@goffi.org>
parents:
609
diff
changeset
|
548 try: |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
549 conn = await client.connect(reactor) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
550 except error.DBusException as e: |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
551 if e.errName == "org.freedesktop.DBus.Error.NotSupported": |
|
2624
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
552 log.error( |
|
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
553 _( |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
554 "D-Bus is not launched, please see README to see instructions on " |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
555 "how to launch it" |
|
2624
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
556 ) |
|
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
557 ) |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
558 raise BridgeInitError(str(e)) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
559 |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
560 conn.exportObject(self._obj) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
561 await conn.requestBusName(const_INT_PREFIX) |
| 0 | 562 |
| 2854 | 563 def _debug(self, action, params, profile): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
564 self._obj.emitSignal("_debug", action, params, profile) |
| 2854 | 565 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
566 def action_new(self, action_data, id, security_limit, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
567 self._obj.emitSignal("action_new", action_data, id, security_limit, profile) |
|
1467
ceba6fd77739
core, bridge: new signal actionNew to launch an action from the backend (e.g. display a dialog message):
Goffi <goffi@goffi.org>
parents:
1435
diff
changeset
|
568 |
|
2894
c7c52c0dc13a
core, quick_frontend(app): fixed connected signal handling
Goffi <goffi@goffi.org>
parents:
2892
diff
changeset
|
569 def connected(self, jid_s, profile): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
570 self._obj.emitSignal("connected", jid_s, profile) |
| 267 | 571 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
572 def contact_deleted(self, entity_jid, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
573 self._obj.emitSignal("contact_deleted", entity_jid, profile) |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
574 |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
575 def contact_new(self, contact_jid, attributes, groups, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
576 self._obj.emitSignal("contact_new", contact_jid, attributes, groups, profile) |
| 267 | 577 |
|
66
8147b4f40809
SàT: multi-profile: DBus signals and frontend adaptation (first draft)
Goffi <goffi@goffi.org>
parents:
65
diff
changeset
|
578 def disconnected(self, profile): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
579 self._obj.emitSignal("disconnected", profile) |
| 267 | 580 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
581 def entity_data_updated(self, jid, name, value, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
582 self._obj.emitSignal("entity_data_updated", jid, name, value, profile) |
|
504
65ecbb473cbb
core, quick frontend, plugin xep-0054, bridge: use of memory's entities data for vcard:
Goffi <goffi@goffi.org>
parents:
501
diff
changeset
|
583 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
584 def message_encryption_started(self, to_jid, encryption_data, profile_key): |
| 4284 | 585 self._obj.emitSignal( |
| 586 "message_encryption_started", to_jid, encryption_data, profile_key | |
| 587 ) | |
|
2655
b8600f8130ac
core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet)
Goffi <goffi@goffi.org>
parents:
2646
diff
changeset
|
588 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
589 def message_encryption_stopped(self, to_jid, encryption_data, profile_key): |
| 4284 | 590 self._obj.emitSignal( |
| 591 "message_encryption_stopped", to_jid, encryption_data, profile_key | |
| 592 ) | |
|
2655
b8600f8130ac
core (bridge): new messageEncryptionStarted and messageEncryptionStopped signals (not used yet)
Goffi <goffi@goffi.org>
parents:
2646
diff
changeset
|
593 |
| 4284 | 594 def message_new( |
| 595 self, | |
| 596 uid, | |
| 597 timestamp, | |
| 598 from_jid, | |
| 599 to_jid, | |
| 600 message, | |
| 601 subject, | |
| 602 mess_type, | |
| 603 extra, | |
| 604 profile, | |
| 605 ): | |
| 606 self._obj.emitSignal( | |
| 607 "message_new", | |
| 608 uid, | |
| 609 timestamp, | |
| 610 from_jid, | |
| 611 to_jid, | |
| 612 message, | |
| 613 subject, | |
| 614 mess_type, | |
| 615 extra, | |
| 616 profile, | |
| 617 ) | |
| 0 | 618 |
|
4148
a8a0fa678ce2
bridge: add `message_update` signal
Goffi <goffi@goffi.org>
parents:
4130
diff
changeset
|
619 def message_update(self, uid, message_type, message_data, profile): |
|
a8a0fa678ce2
bridge: add `message_update` signal
Goffi <goffi@goffi.org>
parents:
4130
diff
changeset
|
620 self._obj.emitSignal("message_update", uid, message_type, message_data, profile) |
|
a8a0fa678ce2
bridge: add `message_update` signal
Goffi <goffi@goffi.org>
parents:
4130
diff
changeset
|
621 |
|
4130
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
622 def notification_deleted(self, id, profile): |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
623 self._obj.emitSignal("notification_deleted", id, profile) |
|
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
624 |
| 4284 | 625 def notification_new( |
| 626 self, | |
| 627 id, | |
| 628 timestamp, | |
| 629 type, | |
| 630 body_plain, | |
| 631 body_rich, | |
| 632 title, | |
| 633 requires_action, | |
| 634 priority, | |
| 635 expire_at, | |
| 636 extra, | |
| 637 profile, | |
| 638 ): | |
| 639 self._obj.emitSignal( | |
| 640 "notification_new", | |
| 641 id, | |
| 642 timestamp, | |
| 643 type, | |
| 644 body_plain, | |
| 645 body_rich, | |
| 646 title, | |
| 647 requires_action, | |
| 648 priority, | |
| 649 expire_at, | |
| 650 extra, | |
| 651 profile, | |
| 652 ) | |
|
4130
02f0adc745c6
core: notifications implementation, first draft:
Goffi <goffi@goffi.org>
parents:
4071
diff
changeset
|
653 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
654 def param_update(self, name, value, category, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
655 self._obj.emitSignal("param_update", name, value, category, profile) |
| 267 | 656 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
657 def presence_update(self, entity_jid, show, priority, statuses, profile): |
| 4284 | 658 self._obj.emitSignal( |
| 659 "presence_update", entity_jid, show, priority, statuses, profile | |
| 660 ) | |
| 49 | 661 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
662 def progress_error(self, id, error, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
663 self._obj.emitSignal("progress_error", id, error, profile) |
|
1522
7d7e57a84792
core: progression handling improvments:
Goffi <goffi@goffi.org>
parents:
1482
diff
changeset
|
664 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
665 def progress_finished(self, id, metadata, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
666 self._obj.emitSignal("progress_finished", id, metadata, profile) |
|
1522
7d7e57a84792
core: progression handling improvments:
Goffi <goffi@goffi.org>
parents:
1482
diff
changeset
|
667 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
668 def progress_started(self, id, metadata, profile): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
669 self._obj.emitSignal("progress_started", id, metadata, profile) |
|
1522
7d7e57a84792
core: progression handling improvments:
Goffi <goffi@goffi.org>
parents:
1482
diff
changeset
|
670 |
|
387
e66d300c5d42
frontends, bridge: sendFile method signature change + jid parameters in bridge now use _jid suffix
Goffi <goffi@goffi.org>
parents:
371
diff
changeset
|
671 def subscribe(self, sub_type, entity_jid, profile): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
672 self._obj.emitSignal("subscribe", sub_type, entity_jid, profile) |
| 0 | 673 |
| 2086 | 674 def register_method(self, name, callback): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
675 log.debug(f"registering DBus bridge method [{name}]") |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
676 self._obj.register_method(name, callback) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
677 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
678 def emit_signal(self, name, *args): |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
679 self._obj.emitSignal(name, *args) |
| 0 | 680 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
681 def add_method( |
|
4270
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
682 self, name, int_suffix, in_sign, out_sign, method, async_=False, doc={} |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
683 ): |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
684 """Dynamically add a method to D-Bus bridge""" |
|
2624
56f94936df1e
code style reformatting using black
Goffi <goffi@goffi.org>
parents:
2595
diff
changeset
|
685 # FIXME: doc parameter is kept only temporary, the time to remove it from calls |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
686 log.debug(f"Adding method {name!r} to D-Bus bridge") |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
687 self._obj.plugin_iface.addMethod( |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
688 Method(name, arguments=in_sign, returns=out_sign) |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
689 ) |
|
4270
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
690 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
691 # we have to create a method here instead of using partialmethod, because txdbus |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
692 # uses __func__ which doesn't work with partialmethod |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
693 def caller(self_, *args, **kwargs): |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
694 return self_._callback(name, *args, **kwargs) |
|
4270
0d7bb4df2343
Reformatted code base using black.
Goffi <goffi@goffi.org>
parents:
4193
diff
changeset
|
695 |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
696 setattr(self._obj, f"dbus_{name}", MethodType(caller, self._obj)) |
| 2086 | 697 self.register_method(name, method) |
|
7
c14a3a7018a5
added dynamic exportation of Dbus bridge method (usefull for plugins)
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
698 |
|
4037
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
699 def add_signal(self, name, int_suffix, signature, doc={}): |
|
524856bd7b19
massive refactoring to switch from camelCase to snake_case:
Goffi <goffi@goffi.org>
parents:
3539
diff
changeset
|
700 """Dynamically add a signal to D-Bus bridge""" |
|
3539
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
701 log.debug(f"Adding signal {name!r} to D-Bus bridge") |
|
60d3861e5996
bridge (dbus): use Tx DBus for backend part of D-Bus bridge:
Goffi <goffi@goffi.org>
parents:
3480
diff
changeset
|
702 self._obj.plugin_iface.addSignal(Signal(name, signature)) |
| 4284 | 703 setattr(bridge, name, partialmethod(bridge.emit_signal, name)) |