Commits June 2022

commits@gajim.org

1 participants
132 discussions

[Git][gajim/gajim][master] 2 commits: feat: Preferences: Add `Action on Close Button` setting
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 83906f55 by lovetox at 2022-06-17T19:50:35+02:00 feat: Preferences: Add `Action on Close Button` setting The new popover setting allows for more than two values and is a more flexibel approach. - - - - - f2702018 by lovetox at 2022-06-17T19:58:06+02:00 fix: Preferences: Remove `Minimize to Tray` setting It’s better to leave this up to the window manager and don’t mess with it. Users who don’t want to minimize to tray can either use the tray show/hide button or set the `Action on Close` setting accordingly. - - - - - 3 changed files: - gajim/common/setting_values.py - gajim/gtk/main.py - gajim/gtk/preferences.py Changes: ===================================== gajim/common/setting_values.py ===================================== @@ -66,8 +66,6 @@ class _ACCOUNT_DEFAULT: 'ignore_incoming_attention', 'is_window_visible', 'log_contact_status_changes', - 'minimize_on_window_delete', - 'minimize_to_tray', 'muc_prefer_direct_msg', 'notification_preview_message', 'notify_on_all_muc_messages', @@ -138,6 +136,7 @@ class _ACCOUNT_DEFAULT: ] StringSettings = Literal[ + 'action_on_close', 'audio_input_device', 'audio_output_device', 'autoaway_message', @@ -234,8 +233,7 @@ class _ACCOUNT_DEFAULT: 'mainwin_width': 1000, 'mainwin_x_position': 0, 'mainwin_y_position': 0, - 'minimize_on_window_delete': True, - 'minimize_to_tray': False, + 'action_on_close': 'hide', 'muc_highlight_words': '', 'muc_prefer_direct_msg': True, 'muclumbus_api_http_uri': 'https://search.jabber.network/api/1.0/search', ===================================== gajim/gtk/main.py ===================================== @@ -422,11 +422,13 @@ def _on_window_delete(self, _event: Gdk.Event ) -> int: - if app.settings.get('minimize_on_window_delete'): - if app.settings.get('minimize_to_tray'): - self.hide() - else: - self.minimize() + action = app.settings.get('action_on_close') + if action == 'hide': + self.hide() + return Gdk.EVENT_STOP + + if action == 'minimize': + self.minimize() return Gdk.EVENT_STOP if not app.settings.get('confirm_on_window_delete'): ===================================== gajim/gtk/preferences.py ===================================== @@ -191,6 +191,12 @@ def __init__(self, *args: Any) -> None: 'last_state': _('Restore last state'), } + action_on_close_items = { + 'hide': _('Hide'), + 'minimize': _('Minimize'), + 'quit': _('Quit'), + } + settings = [ Setting(SettingKind.POPOVER, _('Show on Startup'), @@ -199,17 +205,12 @@ def __init__(self, *args: Any) -> None: props={'entries': main_window_on_startup_items}, desc=_('Show window when starting Gajim')), - Setting(SettingKind.SWITCH, - _('Minimize on Close'), - SettingType.CONFIG, - 'minimize_on_window_delete', - desc=_('Minimize when closing Gajim’s window')), - - Setting(SettingKind.SWITCH, - _('Minimize to Tray'), + Setting(SettingKind.POPOVER, + _('Action on Close'), SettingType.CONFIG, - 'minimize_to_tray', - desc=_('Hide window to system tray when minimized')), + 'action_on_close', + props={'entries': action_on_close_items}, + desc=_('Action when closing Gajim’s window')), Setting(SettingKind.SWITCH, _('Show in Taskbar'), View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/9fb23514a863ba399a02ba4b3608dbb… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/9fb23514a863ba399a02ba4b3608dbb… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] 2 commits: feat: Preferences: Add D-Bus Interface setting
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 91c0dba2 by lovetox at 2022-06-17T18:46:38+02:00 feat: Preferences: Add D-Bus Interface setting - - - - - 9fb23514 by lovetox at 2022-06-17T18:47:43+02:00 chore: Remove unused code - - - - - 3 changed files: - gajim/common/exceptions.py - gajim/common/setting_values.py - gajim/gtk/preferences.py Changes: ===================================== gajim/common/exceptions.py ===================================== @@ -17,33 +17,6 @@ # You should have received a copy of the GNU General Public License # along with Gajim. If not, see <http://www.gnu.org/licenses/>. -from gajim.common.i18n import _ - - -class ServiceNotAvailable(Exception): - """ - This exception is raised when we cannot use Gajim remotely' - """ - - def __init__(self) -> None: - Exception.__init__(self) - - def __str__(self) -> str: - return _('Service not available: Gajim is not running, or remote_control is False') - - -class SessionBusNotPresent(Exception): - """ - This exception indicates that there is no session daemon - """ - - def __init__(self) -> None: - Exception.__init__(self) - - def __str__(self) -> str: - return _('Session bus is not available.\nTry reading %(url)s') % \ - {'url': 'https://dev.gajim.org/gajim/gajim/wikis/help/GajimDBus'} - class GajimGeneralException(Exception): """ ===================================== gajim/common/setting_values.py ===================================== @@ -659,7 +659,6 @@ class WorkspaceSettings(TypedDict): 'notify_on_all_muc_messages': '', 'plugins_repository_enabled': _('If enabled, Gajim offers to download plugins hosted on gajim.org'), 'remote_commands': _('If enabled, Gajim will execute XEP-0146 Commands.'), - 'remote_control': _('If checked, Gajim can be controlled remotely using gajim-remote.'), 'restore_timeout': _('How far back in time (minutes) chat history is restored. -1 means no limit.'), 'save_main_window_position': _('If enabled, Gajim will save the main window position when hiding it, and restore it when showing the window again.'), 'search_engine': '', ===================================== gajim/gtk/preferences.py ===================================== @@ -1000,10 +1000,12 @@ def _purge() -> None: text=_('_Purge'), callback=_purge)]).show() + class Advanced(PreferenceBox): def __init__(self, pref_window: Preferences) -> None: settings = [ + Setting(SettingKind.SWITCH, _('Debug Logging'), SettingType.VALUE, @@ -1011,6 +1013,14 @@ def __init__(self, pref_window: Preferences) -> None: props={'button-icon-name': 'folder-symbolic', 'button-callback': self._on_open_debug_logs}, callback=self._on_debug_logging), + + Setting(SettingKind.SWITCH, + _('D-Bus Interface'), + SettingType.CONFIG, + 'remote_control', + desc=_('Allow Gajim to broadcast useful information via ' + 'D-Bus. It also allows other applications to ' + 'control Gajim remotely.')), ] PreferenceBox.__init__(self, settings) View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/809674b33152bcf5b655be6a1a48993… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/809674b33152bcf5b655be6a1a48993… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] imprv: MUC: Base invitation type on MUC type and affiliation
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 809674b3 by wurstsalat at 2022-06-17T17:49:39+02:00 imprv: MUC: Base invitation type on MUC type and affiliation Conditions are listed here: https://dev.gajim.org/gajim/gajim/-/wikis/development/MUC-Invite-Logic - - - - - 2 changed files: - gajim/common/modules/muc.py - gajim/gtk/controls/groupchat.py Changes: ===================================== gajim/common/modules/muc.py ===================================== @@ -58,6 +58,7 @@ from gajim.common.structs import MUCPresenceData from gajim.common.modules.bits_of_binary import store_bob_data from gajim.common.modules.base import BaseModule +from gajim.common.modules.contacts import GroupchatContact log = logging.getLogger('gajim.c.m.muc') @@ -431,7 +432,7 @@ def _on_config_result(self, task: Task) -> None: self.set_affiliation(result.jid, user_list) for jid in invites: - self.invite(result.jid, jid) + self.invite(result.jid, JID.from_string(jid)) def _on_disco_result_after_config(self, task: Task) -> None: try: @@ -919,17 +920,27 @@ def _on_disco_result_after_invite(self, task: Task) -> None: **invite_data._asdict())) def invite(self, - room: str, - jid: str, + room: JID, + jid: JID, reason: Optional[str] = None, continue_: bool = False ) -> str: - type_ = InviteType.MEDIATED - contact = self._get_contact(jid) - if contact and contact.supports(Namespace.CONFERENCE): + if helpers.get_muc_context(room) == 'private': + room_contact = self._get_contact(room) + assert isinstance(room_contact, GroupchatContact) + self_contact = room_contact.get_self() + affiliation = self_contact.affiliation + admin = affiliation.is_owner or affiliation.is_admin + if admin: + self.set_affiliation( + room, {jid: {'affiliation': 'member'}}) + type_ = InviteType.DIRECT + else: + type_ = InviteType.MEDIATED + else: type_ = InviteType.DIRECT - password = self._mucs[room].password + password = self._mucs[str(room)].password self._log.info('Invite %s to %s', jid, room) return self._nbxmpp('MUC').invite( room, jid, reason, password, continue_, type_) ===================================== gajim/gtk/controls/groupchat.py ===================================== @@ -410,13 +410,16 @@ def _on_invite_ready(self, def _on_invite_clicked(self, _button: Gtk.Button) -> None: invitees = self._invite_box.get_invitees() for jid in invitees: - self.invite(jid) + self.invite(JID.from_string(jid)) self._show_page('groupchat') - def invite(self, contact_jid: str) -> None: - self._client.get_module('MUC').invite(self.room_jid, contact_jid) + def invite(self, invited_jid: JID) -> None: + self._client.get_module('MUC').invite( + self.contact.jid, invited_jid) + invited_contact = self._client.get_module('Contacts').get_contact( + invited_jid) self.add_info_message( - _('%s has been invited to this group chat') % contact_jid) + _('%s has been invited to this group chat') % invited_contact.name) def _on_destroy_room(self, _button: Gtk.Button) -> None: self.xml.destroy_reason_entry.grab_focus() View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/809674b33152bcf5b655be6a1a489938… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/809674b33152bcf5b655be6a1a489938… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] 2 commits: chore: Fix codestyle errors
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: fac52588 by lovetox at 2022-06-17T16:53:13+02:00 chore: Fix codestyle errors - - - - - daa6ac86 by lovetox at 2022-06-17T16:57:53+02:00 ci: Update pylint.sh Ignore checks which are executed with flake8 - - - - - 8 changed files: - .ci/pylint.sh - gajim/common/jingle_ft.py - gajim/common/logging_helpers.py - gajim/gtk/chat_list.py - gajim/gtk/controls/base.py - gajim/gtk/features.py - gajim/gtk/types.py - setup.cfg Changes: ===================================== .ci/pylint.sh ===================================== @@ -39,6 +39,8 @@ PYLINT=${PYLINT:-pylint} # W1115 non-str-assignment-to-dunder-name # W1116 isinstance-second-argument-not-valid-type +IGNORE_FLAKE8='C0301' + IGNORE_PYRIGHT='E1101,E1102,E1111,E1120,E1121,E1123,E1124,E1125,E1126,E1127,E1128,E1129,E1130,E1131,E1132,E1133,E1134,E1135,E1136,E1137,E1138,E1139,E1140,E1141,E1142,I1101,W0212,W1113,W1114,W1115,W1116' IGNORE_ALWAYS='R0801,C0209,W0237,W0707,R1732,W1404,W1406,R1725' @@ -49,10 +51,10 @@ IGNORE_GTK_MODULE_ERRORS=C0103,C0301,C0330,C0415,E0401,E0611,R0201,R0904,R0915,R "$PYLINT" --version -"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_ERRORS" --ignore=modules,dbus,gtk "$@" -"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_GTK_MODULE_ERRORS" "$@/gtk" -"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,E0401,C0415" "$@/common/modules" -"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS" "$@/common/dbus" +"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_FLAKE8,$IGNORE_ERRORS" --ignore=modules,dbus,gtk "$@" +"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_FLAKE8,$IGNORE_GTK_MODULE_ERRORS" "$@/gtk" +"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_FLAKE8,E0401,C0415" "$@/common/modules" +"$PYLINT" --disable="$IGNORE_PYRIGHT,$IGNORE_ALWAYS,$IGNORE_FLAKE8," "$@/common/dbus" # C0103 invalid-name # C0209 use-f-string ===================================== gajim/common/jingle_ft.py ===================================== @@ -131,23 +131,23 @@ def __init__(self, self.nominated_cand = {} self.state = State.NOT_STARTED self.states = { - State.INITIALIZED : StateInitialized(self), - State.CAND_SENT : StateCandSent(self), - State.CAND_RECEIVED : StateCandReceived(self), - State.TRANSFERRING : StateTransfering(self), - State.TRANSPORT_REPLACE : StateTransportReplace(self), - State.CAND_SENT_AND_RECEIVED : StateCandSentAndRecv(self) + State.INITIALIZED: StateInitialized(self), + State.CAND_SENT: StateCandSent(self), + State.CAND_RECEIVED: StateCandReceived(self), + State.TRANSFERRING: StateTransfering(self), + State.TRANSPORT_REPLACE: StateTransportReplace(self), + State.CAND_SENT_AND_RECEIVED: StateCandSentAndRecv(self) } cert_name = (configpaths.get('MY_CERT') / jingle_xtls.SELF_SIGNED_CERTIFICATE) - if not (cert_name.with_suffix('.cert').exists() - and cert_name.with_suffix('.pkey').exists()): + if not (cert_name.with_suffix('.cert').exists() and + cert_name.with_suffix('.pkey').exists()): jingle_xtls.make_certs(cert_name, 'gajim') def __state_changed(self, nextstate: State, - args: Optional[dict[str, Any]] =None + args: Optional[dict[str, Any]] = None ) -> None: # Executes the next state action and sets the next state current_state = self.state @@ -284,18 +284,21 @@ def __on_session_initiate_sent(self, def __send_hash(self) -> None: # Send hash in a session info checksum = nbxmpp.Node(tag='checksum', - payload=[nbxmpp.Node(tag='file', - payload=[self._compute_hash()])]) + payload=[ + nbxmpp.Node(tag='file', + payload=[self._compute_hash()]) + ]) checksum.setNamespace(Namespace.JINGLE_FILE_TRANSFER_5) self.session.__session_info(checksum) pjid = app.get_jid_without_resource(self.session.peerjid) - file_info = {'name' : self.file_props.name, - 'file-name' : self.file_props.file_name, - 'hash' : self.file_props.hash_, - 'size' : self.file_props.size, - 'date' : self.file_props.date, - 'peerjid' : pjid - } + file_info = { + 'name': self.file_props.name, + 'file-name': self.file_props.file_name, + 'hash': self.file_props.hash_, + 'size': self.file_props.size, + 'date': self.file_props.date, + 'peerjid': pjid + } self.session.connection.get_module('Jingle').set_file_info(file_info) def _compute_hash(self) -> Optional[nbxmpp.Hashes2]: @@ -311,7 +314,7 @@ def _compute_hash(self) -> Optional[nbxmpp.Hashes2]: hash_ = h.calculateHash(self.file_props.algo, file_) file_.close() # DEBUG - #hash_ = '1294809248109223' + # hash_ = '1294809248109223' if not hash_: # Hash algorithm not supported return @@ -332,7 +335,7 @@ def __on_session_accept(self, log.info("__on_session_accept") con = self.session.connection security = content.getTag('security') - if not security: # responder can not verify our fingerprint + if not security: # responder can not verify our fingerprint self.use_security = False else: fingerprint = security.getTag('fingerprint') @@ -392,11 +395,11 @@ def __on_session_terminate(self, log.info("__on_session_terminate") def __on_session_info(self, - stanza: nbxmpp.Node, - content: nbxmpp.Node, - error: Optional[nbxmpp.Node], - action: str - ) -> None: + stanza: nbxmpp.Node, + content: nbxmpp.Node, + error: Optional[nbxmpp.Node], + action: str + ) -> None: pass def __on_transport_accept(self, @@ -452,7 +455,7 @@ def __on_transport_info(self, self.__state_changed(State.TRANSFERRING) raise nbxmpp.NodeProcessed else: - args = {'candError' : True} + args = {'candError': True} self.__state_changed(State.CAND_RECEIVED, args) return if cand_used: @@ -463,13 +466,13 @@ def __on_transport_info(self, streamhost_used = cand break if streamhost_used is None or streamhost_used['type'] == 'proxy': - if app.socks5queue.listener and \ - not app.socks5queue.listener.connections: + if (app.socks5queue.listener and + not app.socks5queue.listener.connections): app.socks5queue.listener.disconnect() if content.getTag('transport').getTag('activated'): self.state = State.TRANSFERRING app.socks5queue.send_file(self.file_props, - self.session.connection.name, 'client') + self.session.connection.name, 'client') return args = {'content': content, 'sendCand': False} @@ -490,8 +493,8 @@ def __on_iq_result(self, if self.state in (State.NOT_STARTED, State.CAND_RECEIVED): self.__state_changed(State.INITIALIZED) elif self.state == State.CAND_SENT_AND_RECEIVED: - if not self.nominated_cand['our-cand'] and \ - not self.nominated_cand['peer-cand']: + if (not self.nominated_cand['our-cand'] and + not self.nominated_cand['peer-cand']): if not self.weinitiate: return self.__state_changed(State.TRANSPORT_REPLACE) @@ -519,15 +522,15 @@ def on_connect(self, streamhost): log.info('send_candidate_used') if streamhost is None: return - args = {'streamhost' : streamhost, - 'sendCand' : True} + args = {'streamhost': streamhost, + 'sendCand': True} self.nominated_cand['our-cand'] = streamhost self.__send_candidate(args) def _on_connect_error(self, sid: str) -> None: log.info('connect error, sid=%s', sid) - args = {'candError' : True, - 'sendCand' : True} + args = {'candError': True, + 'sendCand': True} self.__send_candidate(args) def __send_candidate(self, args: dict[str, Any]) -> None: @@ -550,11 +553,13 @@ def _listen_host(self) -> None: fingerprint = None if self.use_security: fingerprint = 'server' - listener = app.socks5queue.start_listener(port, sha_str, - self._store_socks5_sid, - self.file_props, - fingerprint=fingerprint, - typ='sender' if self.weinitiate else 'receiver') + listener = app.socks5queue.start_listener( + port, + sha_str, + self._store_socks5_sid, + self.file_props, + fingerprint=fingerprint, + typ='sender' if self.weinitiate else 'receiver') if not listener: # send error message, notify the user return @@ -583,4 +588,5 @@ def start_ibb_transfer(self) -> None: def get_content(desc) -> JingleFileTransfer: return JingleFileTransfer + contents[Namespace.JINGLE_FILE_TRANSFER_5] = get_content ===================================== gajim/common/logging_helpers.py ===================================== @@ -82,23 +82,23 @@ def parseAndSetLogLevels(arg: str) -> None: class colors: - NONE = chr(27) + "[0m" - BLACk = chr(27) + "[30m" - RED = chr(27) + "[31m" - GREEN = chr(27) + "[32m" - BROWN = chr(27) + "[33m" - BLUE = chr(27) + "[34m" - MAGENTA = chr(27) + "[35m" - CYAN = chr(27) + "[36m" - LIGHT_GRAY = chr(27) + "[37m" - DARK_GRAY = chr(27) + "[30;1m" - BRIGHT_RED = chr(27) + "[31;1m" + NONE = chr(27) + "[0m" + BLACK = chr(27) + "[30m" + RED = chr(27) + "[31m" + GREEN = chr(27) + "[32m" + BROWN = chr(27) + "[33m" + BLUE = chr(27) + "[34m" + MAGENTA = chr(27) + "[35m" + CYAN = chr(27) + "[36m" + LIGHT_GRAY = chr(27) + "[37m" + DARK_GRAY = chr(27) + "[30;1m" + BRIGHT_RED = chr(27) + "[31;1m" BRIGHT_GREEN = chr(27) + "[32;1m" - YELLOW = chr(27) + "[33;1m" - BRIGHT_BLUE = chr(27) + "[34;1m" - PURPLE = chr(27) + "[35;1m" - BRIGHT_CYAN = chr(27) + "[36;1m" - WHITE = chr(27) + "[37;1m" + YELLOW = chr(27) + "[33;1m" + BRIGHT_BLUE = chr(27) + "[34;1m" + PURPLE = chr(27) + "[35;1m" + BRIGHT_CYAN = chr(27) + "[36;1m" + WHITE = chr(27) + "[37;1m" def colorize(text: str, color: str) -> str: ===================================== gajim/gtk/chat_list.py ===================================== @@ -596,7 +596,7 @@ def __init__(self, workspace_id: str, account: str, jid: JID, type_: str, if self.contact.is_groupchat and not self.contact.can_notify(): self._ui.unread_label.get_style_context().add_class( - 'unread-counter-silent') + 'unread-counter-silent') # Get last chat message from archive line = app.storage.archive.get_last_conversation_line(account, jid) ===================================== gajim/gtk/controls/base.py ===================================== @@ -1146,7 +1146,7 @@ def add_message(self, displaymarking: Optional[Displaymarking] = None, msg_log_id: Optional[int] = None, message_id: Optional[str] = None, - stanza_id: Optional[str] =None, + stanza_id: Optional[str] = None, additional_data: Optional[AdditionalDataDict] = None ) -> None: ===================================== gajim/gtk/features.py ===================================== @@ -118,13 +118,6 @@ def _get_features(self) -> list[Feature]: _('Requires: libxss'), _('No additional requirements'), auto_status_enabled), -# Feature(_('Location detection'), -# app.is_installed('GEOCLUE'), -# _('Enables Gajim to be location-aware, if the user decides ' -# 'to publish the device’s location'), -# _('Requires: geoclue'), -# _('Feature is not available under Windows'), -# None), Feature(_('Notification Sounds'), notification_sounds_available, _('Enables Gajim to play sounds for various notifications'), ===================================== gajim/gtk/types.py ===================================== @@ -38,8 +38,7 @@ from .conversation.rows.scroll_hint import ScrollHintRow - -ControlT = Union [ +ControlT = Union[ 'BaseControl', 'ChatControl', 'PrivateChatControl', ===================================== setup.cfg ===================================== @@ -6,14 +6,17 @@ exclude = dist, debian_build, test, - typings + typings, gajim/command_system, - gajim/common/config.py - gajim/common/optparser.py + gajim/common/config.py, + gajim/common/optparser.py, + gajim/common/socks5.py, + gajim/gui, max-complexity = 15 builtins=_ max-line-length = 80 statistics = True +count = True [metadata] name = gajim View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/246e509049b365076f55547d8f8b090… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/246e509049b365076f55547d8f8b090… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] chore: Fix codestyle errors
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 246e5090 by lovetox at 2022-06-17T16:26:02+02:00 chore: Fix codestyle errors - - - - - 7 changed files: - gajim/common/modules/bits_of_binary.py - gajim/common/modules/contacts.py - gajim/common/modules/httpupload.py - gajim/common/modules/ibb.py - gajim/common/modules/jingle.py - gajim/common/modules/misc.py - gajim/common/modules/user_avatar.py Changes: ===================================== gajim/common/modules/bits_of_binary.py ===================================== @@ -86,6 +86,7 @@ def _on_bob_received(self, args = func[1] pos = func[2] bob_data = data.getData() + def recurs(node, cid, data): if node.getData() == 'cid:' + cid: node.setData(data) ===================================== gajim/common/modules/contacts.py ===================================== @@ -62,21 +62,23 @@ def __init__(self, account: str, jid: JID) -> None: self._jid = jid @overload - def get(self, setting: StringGroupChatSettings) -> str: ... + def get(self, setting: StringGroupChatSettings) -> str: ... # noqa: E704 @overload - def get(self, setting: BoolGroupChatSettings) -> bool: ... + def get(self, setting: BoolGroupChatSettings) -> bool: ... # noqa: E704 @overload - def get(self, setting: IntGroupChatSettings) -> int: ... + def get(self, setting: IntGroupChatSettings) -> int: ... # noqa: E704 + def get(self, setting: Any) -> Any: return app.settings.get_group_chat_setting( self._account, self._jid, setting) @overload - def set(self, setting: StringGroupChatSettings, value: str) -> None: ... + def set(self, setting: StringGroupChatSettings, value: str) -> None: ... # noqa: E501, E704 @overload - def set(self, setting: BoolGroupChatSettings, value: bool) -> None: ... + def set(self, setting: BoolGroupChatSettings, value: bool) -> None: ... # noqa: E501, E704 @overload - def set(self, setting: IntGroupChatSettings, value: int) -> None: ... + def set(self, setting: IntGroupChatSettings, value: int) -> None: ... # noqa: E501, E704 + def set(self, setting: Any, value: Any) -> None: app.settings.set_group_chat_setting( self._account, self._jid, setting, value) ===================================== gajim/common/modules/httpupload.py ===================================== @@ -251,6 +251,7 @@ def _check_certificate(self, if app.cert_store.verify(tls_certificate, tls_errors): return + phrase = '' for error in tls_errors: phrase = get_tls_error_phrase(error) self._log.warning('TLS verification failed: %s', phrase) @@ -273,7 +274,6 @@ def _on_finish(self, self._log.info('Upload completed successfully') transfer.set_finished() - else: phrase = Soup.Status.get_phrase(message.props.status_code) self._log.error('Got unexpected http upload response code: %s', @@ -416,7 +416,7 @@ def _close(self) -> None: def get_chunk(self) -> Optional[bytes]: if self._stream is None: if self._encryption is None: - self._stream = open(self._path, 'rb') # pylint: disable=consider-using-with + self._stream = open(self._path, 'rb') # pylint: disable=consider-using-with # noqa: E501 else: self._stream = io.BytesIO(self._data) ===================================== gajim/common/modules/ibb.py ===================================== @@ -97,7 +97,7 @@ def _ibb_received(self, file_props.disconnect_cb = None file_props.continue_cb = None file_props.syn_id = stanza.getID() - file_props.fp = open(file_props.file_name, 'wb') # pylint: disable=consider-using-with + file_props.fp = open(file_props.file_name, 'wb') # pylint: disable=consider-using-with # noqa: E501 self.send_reply(stanza) elif properties.ibb.type == 'close': ===================================== gajim/common/modules/jingle.py ===================================== @@ -16,7 +16,7 @@ Handles the jingle signalling protocol """ -#TODO: +# TODO: # * things in XEP 0176, including: # - http://xmpp.org/extensions/xep-0176.html#protocol-restarts # - http://xmpp.org/extensions/xep-0176.html#fallback @@ -94,7 +94,7 @@ def delete_jingle_session(self, sid: str) -> None: Remove a jingle session from a jingle stanza dispatcher """ if sid in self._sessions: - #FIXME: Move this elsewhere? + # FIXME: Move this elsewhere? for content in list(self._sessions[sid].contents.values()): content.destroy() self._sessions[sid].callbacks = [] @@ -159,7 +159,7 @@ def _on_jingle_iq(self, # do we need to create a new jingle object if sid not in self._sessions: - #TODO: tie-breaking and other things... + # TODO: tie-breaking and other things... newjingle = JingleSession(self._con, weinitiate=False, jid=jid, iq_id=id_, sid=sid) self._sessions[sid] = newjingle @@ -313,8 +313,8 @@ def get_file_info(self, _account: Optional[str] = None ) -> Optional[dict[str, Any]]: if hash_: - for file in self.files: # DEBUG - #if f['hash'] == '1294809248109223': + for file in self.files: # DEBUG + # if f['hash'] == '1294809248109223': if file['hash'] == hash_ and file['peerjid'] == peerjid: return file elif name: ===================================== gajim/common/modules/misc.py ===================================== @@ -25,6 +25,7 @@ log = logging.getLogger('gajim.c.m.misc') + # XEP-0066: Out of Band Data def parse_oob(properties: MessageProperties, additional_data: AdditionalDataDict ===================================== gajim/common/modules/user_avatar.py ===================================== @@ -31,6 +31,7 @@ from gajim.common.modules.util import event_node from gajim.common.modules.util import as_task + class UserAvatar(BaseModule): _nbxmpp_extends = 'UserAvatar' View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/246e509049b365076f55547d8f8b090f… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/246e509049b365076f55547d8f8b090f… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] chore: Remote: Fix pylint errors
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 94c213ab by lovetox at 2022-06-17T16:10:28+02:00 chore: Remote: Fix pylint errors - - - - - 1 changed file: - gajim/common/dbus/remote_control.py Changes: ===================================== gajim/common/dbus/remote_control.py ===================================== @@ -407,5 +407,5 @@ def get_unread_msgs_number() -> str: return str(app.window.get_total_unread_count()) @staticmethod - def Introspect() -> str: + def Introspect() -> str: # pylint: disable=invalid-name return INTERFACE_DESC View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/94c213ab598555d27b785d64a185cb49… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/94c213ab598555d27b785d64a185cb49… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] 2 commits: feat: Rewrite gajim-remote
by Philipp Hörist (＠lovetox) 17 Jun '22

17 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 79dba5b3 by lovetox at 2022-06-17T14:42:00+02:00 feat: Rewrite gajim-remote - Rewrite using argparse and Gio - - - - - 64821fe3 by lovetox at 2022-06-17T14:42:00+02:00 chore: Remote: Fix pylint errors - - - - - 4 changed files: - debian/control - gajim/common/dbus/remote_control.py - gajim/gajim_remote.py - pyrightconfig.json Changes: ===================================== debian/control ===================================== @@ -45,7 +45,6 @@ Depends: Recommends: aspell-en | aspell-dictionary, ca-certificates, - dbus, fonts-noto-color-emoji, gir1.2-gsound-1.0, gir1.2-gspell-1, @@ -59,7 +58,6 @@ Recommends: gstreamer1.0-gtk3, notification-daemon, pulseaudio-utils | alsa-utils | sox | oss4-base, - python3-dbus (>=0.81), python3-sentry-sdk, Suggests: libxss1, ===================================== gajim/common/dbus/remote_control.py ===================================== @@ -244,18 +244,20 @@ def raise_signal(self, event_name: str, data: Any) -> None: event_name, GLib.Variant.new_tuple(get_dbus_struct(data))) - def get_status(self, account: str) -> str: + @staticmethod + def get_status(account: str) -> str: if not account: return helpers.get_global_show() return app.get_client(account).status - def get_status_message(self, account: str) -> str: + @staticmethod + def get_status_message(account: str) -> str: if not account: return str(helpers.get_global_status_message()) return app.get_client(account).status_message - def _send_message(self, - jid: str, + @staticmethod + def _send_message(jid: str, message: str, account: str, type_: str) -> bool: @@ -295,7 +297,8 @@ def send_groupchat_message(self, return self._send_message(jid, message, account, 'groupchat') - def change_status(self, status: str, message: str, account: str) -> bool: + @staticmethod + def change_status(status: str, message: str, account: str) -> bool: """ change_status(status, message, account). Account is optional - if not specified status is changed for all accounts @@ -325,7 +328,8 @@ def change_status(self, status: str, message: str, account: str) -> bool: message) # pyright: ignore return False - def list_accounts(self) -> list[str]: + @staticmethod + def list_accounts() -> list[str]: """ List register accounts """ @@ -336,7 +340,8 @@ def list_accounts(self) -> list[str]: result_array.append(account) return result_array - def account_info(self, account: str) -> dict[str, str]: + @staticmethod + def account_info(account: str) -> dict[str, str]: """ Show info on account: resource, jid, nick, prio, message """ @@ -371,8 +376,8 @@ def list_contacts(self, account: str) -> list[dict[str, GLib.Variant]]: result.append(item) return result - def _contacts_as_dbus_structure(self, - contact: BareContact + @staticmethod + def _contacts_as_dbus_structure(contact: BareContact ) -> dict[str, GLib.Variant]: """ Get info from list of Contact objects and create dbus dict @@ -397,8 +402,10 @@ def _contacts_as_dbus_structure(self, contact_dict['groups'] = groups.end() return contact_dict - def get_unread_msgs_number(self) -> str: + @staticmethod + def get_unread_msgs_number() -> str: return str(app.window.get_total_unread_count()) - def Introspect(self) -> str: + @staticmethod + def Introspect() -> str: return INTERFACE_DESC ===================================== gajim/gajim_remote.py ===================================== @@ -1,13 +1,5 @@ #!/usr/bin/env python3 -# Copyright (C) 2005-2006 Dimitur Kirov <dkirov AT gmail.com> -# Nikos Kouremenos <kourem AT gmail.com> -# Copyright (C) 2005-2014 Yann Leboulanger <asterix AT lagaule.org> -# Copyright (C) 2006 Junglecow <junglecow AT gmail.com> -# Travis Shirk <travis AT pobox.com> -# Copyright (C) 2006-2008 Jean-Marie Traissard <jim AT lapin.org> -# Copyright (C) 2007 Julien Pivotto <roidelapluie AT gmail.com> -# # This file is part of Gajim. # # Gajim is free software; you can redistribute it and/or modify @@ -22,448 +14,146 @@ # You should have received a copy of the GNU General Public License # along with Gajim. If not, see <http://www.gnu.org/licenses/>. -# gajim-remote help will show you the D-BUS API of Gajim +from typing import Any -import os import sys -import locale -import signal -import warnings - -from gajim.common import exceptions -from gajim.common.i18n import _ -from gajim.common.i18n import Q_ - -signal.signal(signal.SIGINT, signal.SIG_DFL) # ^C exits the application - -try: - PREFERRED_ENCODING = locale.getpreferredencoding() -except Exception: - PREFERRED_ENCODING = 'UTF-8' - -def send_error(error_message): - '''Writes error message to stderr and exits''' - print(error_message, file=sys.stderr) - sys.exit(1) - -try: - import dbus - import dbus.service -# import dbus.glib - # test if dbus-x11 is installed - bus = dbus.SessionBus() -except Exception: - print(_('D-Bus is not present on this machine or python module is missing')) - sys.exit(1) - -if not sys.warnoptions: - warnings.simplefilter("default") - -warnings.warn( - "gajim-remote is deprecated, use Gajim's DBus interface instead. " - "For further information see " - "https://dev.gajim.org/gajim/gajim/-/wikis/help/GajimDBus.", - DeprecationWarning -) +import argparse +import logging + +from gi.repository import GLib +from gi.repository import Gio + + +LOG_FORMAT = '%(asctime)s %(levelname)s %(message)s' +logging.basicConfig(level=logging.INFO, format=LOG_FORMAT) +log = logging.getLogger() + OBJ_PATH = '/org/gajim/dbus/RemoteObject' INTERFACE = 'org.gajim.dbus.RemoteInterface' SERVICE = 'org.gajim.Gajim' -BASENAME = 'gajim-remote' - -class GajimRemote: - - def __init__(self): - self.argv_len = len(sys.argv) - # define commands dict. Prototype : - # { - # 'command': [comment, [list of arguments] ] - # } - # - # each argument is defined as a tuple: - # (argument name, help on argument, is mandatory) - # - self.commands = { - 'help': [ - _('Shows a help on specific command'), - [ - #User gets help for the command, specified by this parameter - (_('command'), - _('show help on command'), False) - ] - ], - 'list_contacts': [ - _('Lists all contacts in the contact list, one for each line'), - [ - (Q_('?CLI:account'), _('show only contacts of the given account'), - False) - ] - - ], - 'list_accounts': [ - _('Prints a list of registered accounts'), - [] - ], - 'change_status': [ - _('Changes the status of account(s)'), - [ -#offline, online, chat, away, xa, dnd should not be translated - (Q_('?CLI:status'), _('one of: offline, online, chat, away, xa, dnd. If not set, use account\'s previous status'), False), - (Q_('?CLI:message'), _('status message'), False), - (Q_('?CLI:account'), _('change status of account "account". ' - 'If not specified, try to change status of all accounts that have ' - '"sync with global status" option set'), False) - ] - ], - 'set_priority': [ - _('Changes the priority of account(s)'), - [ - (Q_('?CLI:priority'), _('priority you want to give to the account'), - True), - (Q_('?CLI:account'), _('change the priority of the given account. ' - 'If not specified, change status of all accounts that have' - ' "sync with global status" option set'), False) - ] - ], - 'send_chat_message': [ - _('Sends new chat message to a contact in the contact list. Account is optional.'), - [ - ('jid', _('XMPP Address of the contact that will receive the message'), True), - (Q_('?CLI:message'), _('message contents'), True), - (Q_('?CLI:account'), _('if specified, the message will be sent ' - 'using this account'), False), - ] - ], - 'send_single_message': [ - _('Sends a chat message to someone on your contact list. ' - 'Account is optional.'), - [ - ('jid', _('XMPP Address of the contact that will receive the message'), True), - (_('subject'), _('message subject'), True), - (Q_('?CLI:message'), _('message contents'), True), - (Q_('?CLI:account'), _('if specified, the message will be sent ' - 'using this account'), False), - ] - ], - 'send_groupchat_message': [ - _('Sends new message to a group chat you\'ve joined.'), - [ - ('room_jid', _('XMPP Address of the group chat that will receive the message'), True), - (Q_('?CLI:message'), _('message contents'), True), - (Q_('?CLI:account'), _('if specified, the message will be sent ' - 'using this account'), False), - ] - ], - 'contact_info': [ - _('Gets detailed info on a contact'), - [ - ('jid', _('XMPP Address of the contact'), True) - ] - ], - 'account_info': [ - _('Gets detailed info on a account'), - [ - ('account', _('Name of the account'), True) - ] - ], - 'send_file': [ - _('Sends file to a contact'), - [ - (_('file'), _('File path'), True), - ('jid', _('XMPP Address of the contact'), True), - (Q_('?CLI:account'), _('if specified, file will be sent using this ' - 'account'), False) - ] - ], - 'remove_contact': [ - _('Removes contact from contact list'), - [ - ('jid', _('XMPP Address of the contact'), True), - (Q_('?CLI:account'), _('if specified, contact is taken from the ' - 'contact list of this account'), False) - - ] - ], - - 'get_status': [ - _('Returns current status (the global one unless account is specified)'), - [ - (Q_('?CLI:account'), '', False) - ] - ], - - 'get_status_message': [ - _('Returns current status message (the global one unless account is specified)'), - [ - (Q_('?CLI:account'), '', False) - ] - ], - - 'get_unread_msgs_number': [ - _('Returns number of unread messages'), - [] - ], - - 'send_xml': [ - _('Sends custom XML'), - [ - ('xml', _('XML to send'), True), - ('account', _('Account to which the XML will be sent; ' - 'if not specified, XML will be sent to all accounts'), - False) - ] - ], - - 'check_gajim_running': [ - _('Check if Gajim is running'), - [] - ], - - } - - self.sbus = None - if self.argv_len < 2 or sys.argv[1] not in self.commands: - # no args or bad args - send_error(self.compose_help()) - self.command = sys.argv[1] - if self.command == 'help': - if self.argv_len == 3: - print(self.help_on_command(sys.argv[2]).encode( - PREFERRED_ENCODING)) - else: - print(self.compose_help().encode(PREFERRED_ENCODING)) - sys.exit(0) - if self.command == 'check_gajim_running': - print(self.check_gajim_running()) - sys.exit(0) - self.init_connection() - self.check_arguments() - - if self.command == 'contact_info': - if self.argv_len < 3: - send_error(_('Missing argument "contact_jid"')) - - try: - res = self.call_remote_method() - except exceptions.ServiceNotAvailable: - # At this point an error message has already been displayed - sys.exit(1) - else: - self.print_result(res) - - def print_result(self, res): - """ - Print retrieved result to the output - """ - if res is not None: - if self.command in ('send_chat_message', 'send_single_message'): - self.argv_len -= 2 - - if res is False: - if self.argv_len < 4: - send_error(_('\'%s\' is not in your contact list.\n' - 'Please specify account for sending the message.') % sys.argv[2]) - else: - send_error(_('You have no active account')) - elif self.command == 'list_accounts': - if isinstance(res, list): - for account in res: - print(account) - elif self.command == 'account_info': - if res: - print(self.print_info(0, res, True)) - elif self.command == 'list_contacts': - for account_dict in res: - print(self.print_info(0, account_dict, True)) - elif self.command == 'prefs_list': - pref_keys = sorted(res.keys()) - for pref_key in pref_keys: - result = '%s = %s' % (pref_key, res[pref_key]) - print(result) - elif self.command == 'contact_info': - print(self.print_info(0, res, True)) - elif res: - print(res) - - def check_gajim_running(self): - if not self.sbus: - try: - self.sbus = dbus.SessionBus() - except Exception: - raise exceptions.SessionBusNotPresent - - test = False - if hasattr(self.sbus, 'name_has_owner'): - if self.sbus.name_has_owner(SERVICE): - test = True - elif dbus.dbus_bindings.bus_name_has_owner(self.sbus.get_connection(), - SERVICE): - test = True - return test - - def init_connection(self): - """ - Create the connection to the session dbus, or exit if it is not possible - """ - try: - self.sbus = dbus.SessionBus() - except Exception: - raise exceptions.SessionBusNotPresent - - if not self.check_gajim_running(): - #Do not translate "gajim-remote" - send_error(_('It seems Gajim is not running. So you can\'t use gajim-remote.')) - obj = self.sbus.get_object(SERVICE, OBJ_PATH) - interface = dbus.Interface(obj, INTERFACE) - - # get the function asked - self.method = interface.__getattr__(self.command) - - def make_arguments_row(self, args): - """ - Return arguments list. Mandatory arguments are enclosed with: - '<', '>', optional arguments - with '[', ']' - """ - s = '' - for arg in args: - if arg[2]: - s += ' <' + arg[0] + '>' - else: - s += ' [' + arg[0] + ']' - return s - - def help_on_command(self, command): - """ - Return help message for a given command - """ - if command in self.commands: - command_props = self.commands[command] - arguments_str = self.make_arguments_row(command_props[1]) - str_ = _('Usage: %(basename)s %(command)s %(arguments)s \n\t %(help)s')\ - % {'basename': BASENAME, 'command': command, - 'arguments': arguments_str, 'help': command_props[0]} - if command_props[1]: - str_ += '\n\n' + _('Arguments:') + '\n' - for argument in command_props[1]: - str_ += ' ' + argument[0] + ' - ' + argument[1] + '\n' - return str_ - send_error(_('%s not found') % command) - - def compose_help(self): - """ - Print usage, and list available commands - """ - s = _('Usage:\n %s command [arguments]\n\nCommand is one of:\n') % ( - BASENAME) - for command in sorted(self.commands): - s += ' ' + command - for arg in self.commands[command][1]: - if arg[2]: - s += ' <' + arg[0] + '>' - else: - s += ' [' + arg[0] + ']' - s += '\n' - return s - - def print_info(self, level, prop_dict, encode_return=False): - """ - Return formatted string from data structure - """ - if prop_dict is None or not isinstance(prop_dict, (dict, list, tuple)): - return '' - ret_str = '' - if isinstance(prop_dict, (list, tuple)): - ret_str = '' - spacing = ' ' * level * 4 - for val in prop_dict: - if val is None: - ret_str += '\t' - elif isinstance(val, int): - ret_str += '\t' + str(val) - elif isinstance(val, str): - ret_str += '\t' + val - elif isinstance(val, (list, tuple)): - res = '' - for items in val: - res += self.print_info(level+1, items) - if res != '': - ret_str += '\t' + res - elif isinstance(val, dict): - ret_str += self.print_info(level+1, val) - ret_str = '%s(%s)\n' % (spacing, ret_str[1:]) - elif isinstance(prop_dict, dict): - for key in prop_dict.keys(): - val = prop_dict[key] - spacing = ' ' * level * 4 - if isinstance(val, (int, str)): - if val is not None: - val = val.strip() - ret_str += '%s%-10s: %s\n' % (spacing, key, val) - elif isinstance(val, (list, tuple)): - res = '' - for items in val: - res += self.print_info(level+1, items) - if res != '': - ret_str += '%s%s: \n%s' % (spacing, key, res) - elif isinstance(val, dict): - res = self.print_info(level+1, val) - if res != '': - ret_str += '%s%s: \n%s' % (spacing, key, res) - if encode_return: - try: - ret_str = ret_str.encode(PREFERRED_ENCODING) - except Exception: - pass - return ret_str - - def check_arguments(self): - """ - Make check if all necessary arguments are given - """ - argv_len = self.argv_len - 2 - args = self.commands[self.command][1] - if len(args) < argv_len: - send_error(_('Too many arguments. \n' - 'Type "%(basename)s help %(command)s" for more info') % { - 'basename': BASENAME, 'command': self.command}) - if len(args) > argv_len: - if args[argv_len][2]: - send_error(_('Argument "%(arg)s" is not specified. \n' - 'Type "%(basename)s help %(command)s" for more info') % - {'arg': args[argv_len][0], 'basename': BASENAME, - 'command': self.command}) - self.arguments = [] - i = 0 - for arg in sys.argv[2:]: - i += 1 - if i < len(args): - self.arguments.append(arg) - else: - # it's latest argument with spaces - self.arguments.append(' '.join(sys.argv[i+1:])) - break - # add empty string for missing args - self.arguments += ['']*(len(args)-i) - - def call_remote_method(self): - """ - Calls self.method with arguments from sys.argv[2:] - """ - args = [dbus.String(i) for i in self.arguments] - try: - res = self.method(*args) - return res - except Exception: - raise exceptions.ServiceNotAvailable - return None - - -def main(): - if os.geteuid() == 0: - sys.exit("You must not launch gajim as root, it is insecure.") - - GajimRemote() + +SIGNATURES = { + 'list_contacts': '(s)', + 'list_accounts': '()', + 'change_status': '(sss)', + 'send_chat_message': '(sss)', + 'send_groupchat_message': '(sss)', + 'account_info': '(s)', + 'get_status': '(s)', + 'get_status_message': '(s)', + 'get_unread_msgs_number': '()', +} + + +def call_method(args: argparse.Namespace) -> Any: + arg_dict = vars(args) + app_id = arg_dict.pop('app_id') + command = arg_dict.pop('command') + + proxy = Gio.DBusProxy.new_for_bus_sync( + Gio.BusType.SESSION, + Gio.DBusProxyFlags.NONE, + None, + app_id, + OBJ_PATH, + INTERFACE, + None) + + arguments = tuple(arg_dict.values()) + signature = SIGNATURES[command] + method = getattr(proxy, command) + return method(signature, *arguments) + + +def create_arg_parser() -> argparse.ArgumentParser: + + account_help = 'The account the command is executed for' + + parser = argparse.ArgumentParser(prog='gajim-remote') + parser.add_argument('--app-id', default=SERVICE) + + subparsers = parser.add_subparsers(required=True, + metavar='commands', + dest='command') + + subparser = subparsers.add_parser( + 'list_contacts', + help='Get all roster contacts') + subparser.add_argument('account', type=str) + + subparser = subparsers.add_parser( + 'list_accounts', + help='Get the list of accounts') + + subparser = subparsers.add_parser( + 'change_status', + help='Change the status') + subparser.add_argument('status', + choices=['offline', 'online', 'away', 'xa', 'dnd']) + subparser.add_argument('message', type=str) + subparser.add_argument('account', type=str) + + subparser = subparsers.add_parser( + 'send_chat_message', + help='Send a chat message to a contact') + subparser.add_argument('address', type=str, + help='The XMPP address of the contact') + subparser.add_argument('message', type=str, + help='The message to be sent') + subparser.add_argument('account', type=str, + help=account_help) + + subparser = subparsers.add_parser( + 'send_groupchat_message', + help='Send a chat message to a group chat') + subparser.add_argument('address', type=str, + help='The XMPP address of the group chat') + subparser.add_argument('message', type=str, + help='The message to be sent') + subparser.add_argument('account', type=str, + help=account_help) + + subparser = subparsers.add_parser( + 'account_info', + help='Get account details') + subparser.add_argument('account', type=str, help=account_help) + + subparser = subparsers.add_parser( + 'get_status', + help='Get the current status') + subparser.add_argument('account', type=str, help=account_help) + + subparser = subparsers.add_parser( + 'get_status_message', + help='Get the current status message') + subparser.add_argument('account', type=str, help=account_help) + + subparser = subparsers.add_parser( + 'get_unread_msgs_number', + help='Get the unread message count') + + return parser if __name__ == '__main__': - main() + args = create_arg_parser().parse_args() + try: + result = call_method(args) + except GLib.Error as error: + quark = GLib.quark_try_string('g-dbus-error-quark') + if error.matches(quark, Gio.DBusError.SERVICE_UNKNOWN): + log.error('Service not found. Check if Gajim is running. ' + 'If Gajim is running under a custom profile use ' + '--app-id=org.gajim.Gajim.myprofilename') + + else: + log.exception('Failed to execute method') + + sys.exit(1) + + except Exception: + log.exception('Failed to execute method') + sys.exit(1) + + print(result) ===================================== pyrightconfig.json ===================================== @@ -16,6 +16,7 @@ "scripts/*", "win/*", "gajim/gajim.py", + "gajim/gajim_remote.py", "gajim/common/dbus/*", "gajim/common/application.py", "gajim/common/call_manager.py", View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/7e24d615a37caf81f3d41b4dbea2694… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/7e24d615a37caf81f3d41b4dbea2694… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] imprv: Rework DBus Remote Interface
by Philipp Hörist (＠lovetox) 16 Jun '22

16 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: 7e24d615 by lovetox at 2022-06-16T20:39:27+02:00 imprv: Rework DBus Remote Interface - Add type annotations - Remove non-essential signals and methods - Refactor and simplify code - - - - - 3 changed files: - + gajim/common/dbus/remote_control.py - gajim/gui_interface.py - − gajim/remote_control.py Changes: ===================================== gajim/common/dbus/remote_control.py ===================================== @@ -0,0 +1,404 @@ +# This file is part of Gajim. +# +# Gajim is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published +# by the Free Software Foundation; version 3 only. +# +# Gajim is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with Gajim. If not, see <http://www.gnu.org/licenses/>. + +from typing import Any +from typing import cast + +import logging + +from gi.repository import GLib +from gi.repository import Gio + +from gajim.common import app +from gajim.common import ged +from gajim.common import helpers +from gajim.common import events +from gajim.common.structs import OutgoingMessage +from gajim.common.modules.contacts import BareContact + + +log = logging.getLogger('gajim.c.dbus.remote_control') + +INTERFACE_DESC = ''' +<!DOCTYPE node PUBLIC '-//freedesktop//DTD D-BUS Object Introspection 1.0//EN' +'http://www.freedesktop.org/standards/dbus/1.0/introspect.dtd'> +<node> + <interface name='org.freedesktop.DBus.Introspectable'> + <method name='Introspect'> + <arg name='data' direction='out' type='s'/> + </method> + </interface> + <interface name='org.gajim.dbus.RemoteInterface'> + <method name='account_info'> + <arg name='account' type='s' /> + <arg direction='out' type='a{ss}' /> + </method> + <method name='change_status'> + <arg name='status' type='s' /> + <arg name='message' type='s' /> + <arg name='account' type='s' /> + <arg direction='out' type='b' /> + </method> + <method name='get_status'> + <arg name='account' type='s' /> + <arg direction='out' type='s' /> + </method> + <method name='get_status_message'> + <arg name='account' type='s' /> + <arg direction='out' type='s' /> + </method> + <method name='get_unread_msgs_number'> + <arg direction='out' type='s' /> + </method> + <method name='list_accounts'> + <arg direction='out' type='as' /> + </method> + <method name='list_contacts'> + <arg name='account' type='s' /> + <arg direction='out' type='aa{sv}' /> + </method> + <method name='send_chat_message'> + <arg name='jid' type='s' /> + <arg name='message' type='s' /> + <arg name='account' type='s' /> + <arg direction='out' type='b' /> + </method> + <method name='send_groupchat_message'> + <arg name='room_jid' type='s' /> + <arg name='message' type='s' /> + <arg name='account' type='s' /> + <arg direction='out' type='b' /> + </method> + <signal name='AccountPresence'> + <arg type='av' /> + </signal> + <signal name='ContactPresence'> + <arg type='av' /> + </signal> + <signal name='GCMessage'> + <arg type='av' /> + </signal> + <signal name='MessageSent'> + <arg type='av' /> + </signal> + <signal name='NewMessage'> + <arg type='av' /> + </signal> + </interface> +</node> +''' + + +def get_dbus_struct(obj: Any) -> GLib.Variant: + """ + Recursively go through all the items and replace them with their casted dbus + equivalents + """ + if isinstance(obj, str): + return GLib.Variant('s', obj) + if isinstance(obj, int): + return GLib.Variant('i', obj) + if isinstance(obj, float): + return GLib.Variant('d', obj) + if isinstance(obj, bool): + return GLib.Variant('b', obj) + if isinstance(obj, (list, tuple)): + lst = [get_dbus_struct(i) for i in obj # pyright: ignore + if i is not None] + result = GLib.Variant('av', lst) + return result + if isinstance(obj, dict): + obj = cast(dict[str, Any], obj) + result = GLib.VariantDict() + for key, value in obj.items(): + result.insert_value(key, get_dbus_struct(value)) + return result.end() + # unknown type + return GLib.Variant('s', str(obj)) + + +class Server: + def __init__(self, con: Gio.DBusConnection, path: str) -> None: + self._method_outargs: dict[str, str] = {} + self._method_inargs: dict[str, tuple[str, ...]] = {} + node_info = Gio.DBusNodeInfo.new_for_xml(INTERFACE_DESC) + for interface in node_info.interfaces: + for method in interface.methods: + self._method_outargs[method.name] = '(' + ''.join( + [arg.signature for arg in method.out_args]) + ')' + self._method_inargs[method.name] = tuple( + arg.signature for arg in method.in_args) + + con.register_object( + object_path=path, + interface_info=interface, + method_call_closure=self._on_method_call) + + def _on_method_call(self, + _connection: Gio.DBusConnection, + _sender: str, + _object_path: str, + _interface_name: str, + method_name: str, + parameters: GLib.Variant, + invocation: Gio.DBusMethodInvocation) -> None: + + args = list(parameters.unpack()) + for i, sig in enumerate(self._method_inargs[method_name]): + if sig == 'h': + msg = invocation.get_message() + fd_list = msg.get_unix_fd_list() + args[i] = fd_list.get(args[i]) + + result = getattr(self, method_name)(*args) + + # out_args is at least (signature1). We therefore always wrap the result + # as a tuple. Refer to https://bugzilla.gnome.org/show_bug.cgi?id=765603 + result = (result, ) + + out_args = self._method_outargs[method_name] + if out_args != '()': + variant = GLib.Variant(out_args, result) + invocation.return_value(variant) + else: + invocation.return_value(None) + + +class GajimRemote(Server): + def __init__(self) -> None: + self._con = Gio.bus_get_sync(Gio.BusType.SESSION, None) + Gio.bus_own_name_on_connection(self._con, 'org.gajim.Gajim', + Gio.BusNameOwnerFlags.NONE, None, None) + super().__init__(self._con, '/org/gajim/dbus/RemoteObject') + + app.ged.register_event_handler('presence-received', + ged.POSTGUI, + self._on_presence_received) + app.ged.register_event_handler('gc-message-received', + ged.POSTGUI, + self._on_gc_message_received) + app.ged.register_event_handler('message-received', + ged.POSTGUI, + self._on_message_received) + app.ged.register_event_handler('our-show', + ged.POSTGUI, + self._on_our_status) + app.ged.register_event_handler('message-sent', + ged.POSTGUI, + self._on_message_sent) + + def _on_message_sent(self, event: events.MessageSent) -> None: + self.raise_signal('MessageSent', ( + event.account, [event.jid, + event.message])) + + def _on_presence_received(self, event: events.PresenceReceived) -> None: + self.raise_signal('ContactPresence', (event.account, [ + event.jid, + event.resource, + event.show, + event.status])) + + def _on_gc_message_received(self, event: events.GcMessageReceived) -> None: + self.raise_signal('GCMessage', ( + event.conn.name, [event.fjid, + event.msgtxt, + event.properties.timestamp, + event.delayed, + event.displaymarking])) + + def _on_message_received(self, + event: events.MessageReceived) -> None: + + event_type = event.properties.type.value + if event.properties.is_muc_pm: + event_type = 'pm' + self.raise_signal('NewMessage', ( + event.conn.name, [event.fjid, + event.msgtxt, + event.properties.timestamp, + event_type, + event.properties.subject, + event.msg_log_id, + event.properties.nickname])) + + def _on_our_status(self, event: events.ShowChanged) -> None: + self.raise_signal('AccountPresence', (event.show, event.account)) + + def raise_signal(self, event_name: str, data: Any) -> None: + log.info('Send event %s', event_name) + self._con.emit_signal(None, + '/org/gajim/dbus/RemoteObject', + 'org.gajim.dbus.RemoteInterface', + event_name, + GLib.Variant.new_tuple(get_dbus_struct(data))) + + def get_status(self, account: str) -> str: + if not account: + return helpers.get_global_show() + return app.get_client(account).status + + def get_status_message(self, account: str) -> str: + if not account: + return str(helpers.get_global_status_message()) + return app.get_client(account).status_message + + def _send_message(self, + jid: str, + message: str, + account: str, + type_: str) -> bool: + + if not app.account_is_available(account): + return False + + client = app.get_client(account) + contact = client.get_module('Contacts').get_contact( + jid, groupchat=type_ == 'groupchat') + + if type_ == 'groupchat': + if not contact.is_joined: + return False + + message_ = OutgoingMessage(account=account, + contact=contact, + message=message, + type_=type_) + + app.get_client(account).send_message(message_) + return True + + def send_chat_message(self, jid: str, message: str, account: str) -> bool: + if not jid or not message or not account: + return False + + return self._send_message(jid, message, account, 'chat') + + def send_groupchat_message(self, + jid: str, + message: str, + account: str) -> bool: + + if not jid or not message or not account: + return False + + return self._send_message(jid, message, account, 'groupchat') + + def change_status(self, status: str, message: str, account: str) -> bool: + """ + change_status(status, message, account). Account is optional - if not + specified status is changed for all accounts + """ + if status not in ('offline', 'online', 'chat', 'away', 'xa', 'dnd'): + status = '' + if account: + if not status: + if account not in app.connections: + return False + status = app.connections[account].status + GLib.idle_add(app.connections[account].change_status, status, + message) # pyright: ignore + else: + # account not specified, so change the status of all accounts + for acc in app.settings.get_active_accounts(): + if not app.settings.get_account_setting( + acc, 'sync_with_global_status'): + continue + if status: + status_ = status + else: + if acc not in app.connections: + continue + status_ = app.connections[acc].status + GLib.idle_add(app.connections[acc].change_status, status_, + message) # pyright: ignore + return False + + def list_accounts(self) -> list[str]: + """ + List register accounts + """ + result = app.settings.get_active_accounts() + result_array: list[str] = [] + if result: + for account in result: + result_array.append(account) + return result_array + + def account_info(self, account: str) -> dict[str, str]: + """ + Show info on account: resource, jid, nick, prio, message + """ + result: dict[str, str] = {} + if account in app.connections: + # account is valid + con = app.connections[account] + result['status'] = con.status + result['name'] = con.name + result['jid'] = app.get_jid_from_account(con.name) + result['message'] = con.status_message + result['priority'] = str(con.priority) + result['resource'] = app.settings.get_account_setting(con.name, + 'resource') + return result + + def list_contacts(self, account: str) -> list[dict[str, GLib.Variant]]: + result: list[dict[str, GLib.Variant]] = [] + accounts = app.settings.get_active_accounts() + if not accounts: + return result + if account: + accounts_to_search = [account] + else: + accounts_to_search = accounts + for acct in accounts_to_search: + if acct in accounts: + client = app.get_client(acct) + for contact in client.get_module('Roster').iter_contacts(): + item = self._contacts_as_dbus_structure(contact) + if item: + result.append(item) + return result + + def _contacts_as_dbus_structure(self, + contact: BareContact + ) -> dict[str, GLib.Variant]: + """ + Get info from list of Contact objects and create dbus dict + """ + + contact_dict: dict[str, GLib.Variant] = {} + + contact_dict['name'] = GLib.Variant('s', contact.name) + contact_dict['show'] = GLib.Variant('s', contact.show.value) + contact_dict['jid'] = GLib.Variant('s', str(contact.jid)) + + resources = GLib.VariantBuilder(GLib.VariantType('a(ss)')) + for res_contact in contact.iter_resources(): + resource_props = (res_contact.resource, + res_contact.status) + resources.add_value(GLib.Variant('(ss)', resource_props)) + contact_dict['resources'] = resources.end() + + groups = GLib.VariantBuilder(GLib.VariantType('as')) + for group in contact.groups: + groups.add_value(GLib.Variant('s', group)) + contact_dict['groups'] = groups.end() + return contact_dict + + def get_unread_msgs_number(self) -> str: + return str(app.window.get_total_unread_count()) + + def Introspect(self) -> str: + return INTERFACE_DESC ===================================== gajim/gui_interface.py ===================================== @@ -697,7 +697,7 @@ def run(self, _application: Gtk.Application) -> None: def remote_init(): if app.settings.get('remote_control'): try: - from gajim import remote_control + from gajim.common.dbus import remote_control remote_control.GajimRemote() except Exception: log.exception('Failed to init remote control') ===================================== gajim/remote_control.py deleted ===================================== @@ -1,743 +0,0 @@ -# Copyright (C) 2005-2006 Andrew Sayman <lorien420 AT myrealbox.com> -# Dimitur Kirov <dkirov AT gmail.com> -# Nikos Kouremenos <kourem AT gmail.com> -# Copyright (C) 2005-2014 Yann Leboulanger <asterix AT lagaule.org> -# Copyright (C) 2006-2007 Travis Shirk <travis AT pobox.com> -# Copyright (C) 2006-2008 Jean-Marie Traissard <jim AT lapin.org> -# Copyright (C) 2007 Lukas Petrovicky <lukas AT petrovicky.net> -# Julien Pivotto <roidelapluie AT gmail.com> -# Copyright (C) 2008 Jonathan Schleifer <js-gajim AT webkeks.org> -# -# This file is part of Gajim. -# -# Gajim is free software; you can redistribute it and/or modify -# it under the terms of the GNU General Public License as published -# by the Free Software Foundation; version 3 only. -# -# Gajim is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# GNU General Public License for more details. -# -# You should have received a copy of the GNU General Public License -# along with Gajim. If not, see <http://www.gnu.org/licenses/>. - -from typing import Any - -import os -import logging - -from gi.repository import GLib -from gi.repository import Gio - -from gajim.common import app -from gajim.common import ged -from gajim.common import helpers -from gajim.common import events -from gajim.common.structs import OutgoingMessage -from gajim.common.modules.contacts import BareContact - -from gajim.gui.add_contact import AddContact - - -log = logging.getLogger('gajim.remote_control') - - -def get_dbus_struct(obj): - """ - Recursively go through all the items and replace them with their casted dbus - equivalents - """ - if obj is None: - return None - if isinstance(obj, str): - return GLib.Variant('s', obj) - if isinstance(obj, int): - return GLib.Variant('i', obj) - if isinstance(obj, float): - return GLib.Variant('d', obj) - if isinstance(obj, bool): - return GLib.Variant('b', obj) - if isinstance(obj, (list, tuple)): - lst = [get_dbus_struct(i) for i in obj if i is not None] - result = GLib.Variant('av', lst) - return result - if isinstance(obj, dict): - result = GLib.VariantDict() - for key, value in obj.items(): - result.insert_value(key, get_dbus_struct(value)) - return result.end() - # unknown type - return GLib.Variant('s', str(obj)) - - -class Server: - def __init__(self, con, path): - method_outargs = {} - method_inargs = {} - for interface in Gio.DBusNodeInfo.new_for_xml(self.__doc__).interfaces: - - for method in interface.methods: - method_outargs[method.name] = '(' + ''.join( - [arg.signature for arg in method.out_args]) + ')' - method_inargs[method.name] = tuple( - arg.signature for arg in method.in_args) - - con.register_object( - object_path=path, - interface_info=interface, - method_call_closure=self.on_method_call) - - self.method_inargs = method_inargs - self.method_outargs = method_outargs - - def on_method_call(self, connection, sender, object_path, interface_name, - method_name, parameters, invocation): - - args = list(parameters.unpack()) - for i, sig in enumerate(self.method_inargs[method_name]): - if sig == 'h': - msg = invocation.get_message() - fd_list = msg.get_unix_fd_list() - args[i] = fd_list.get(args[i]) - - result = getattr(self, method_name)(*args) - - # out_args is at least (signature1). We therefore always wrap the result - # as a tuple. Refer to https://bugzilla.gnome.org/show_bug.cgi?id=765603 - result = (result, ) - - out_args = self.method_outargs[method_name] - if out_args != '()': - variant = GLib.Variant(out_args, result) - invocation.return_value(variant) - else: - invocation.return_value(None) - - -class GajimRemote(Server): - ''' - <!DOCTYPE node PUBLIC '-//freedesktop//DTD D-BUS Object Introspection 1.0//EN' - 'http://www.freedesktop.org/standards/dbus/1.0/introspect.dtd'> - <node> - <interface name='org.freedesktop.DBus.Introspectable'> - <method name='Introspect'> - <arg name='data' direction='out' type='s'/> - </method> - </interface> - <interface name='org.gajim.dbus.RemoteInterface'> - <method name='account_info'> - <arg name='account' type='s' /> - <arg direction='out' type='a{ss}' /> - </method> - <method name='add_contact'> - <arg name='jid' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='change_status'> - <arg name='status' type='s' /> - <arg name='message' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='get_status'> - <arg name='account' type='s' /> - <arg direction='out' type='s' /> - </method> - <method name='get_status_message'> - <arg name='account' type='s' /> - <arg direction='out' type='s' /> - </method> - <method name='get_unread_msgs_number'> - <arg direction='out' type='s' /> - </method> - <method name='join_room'> - <arg name='room_jid' type='s' /> - <arg name='password' type='s' /> - <arg name='account' type='s' /> - </method> - <method name='list_accounts'> - <arg direction='out' type='as' /> - </method> - <method name='list_contacts'> - <arg name='account' type='s' /> - <arg direction='out' type='aa{sv}' /> - </method> - <method name='open_chat'> - <arg name='jid' type='s' /> - <arg name='account' type='s' /> - <arg name='message' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='remove_contact'> - <arg name='jid' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='send_chat_message'> - <arg name='jid' type='s' /> - <arg name='message' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='send_file'> - <arg name='file_path' type='s' /> - <arg name='jid' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='send_groupchat_message'> - <arg name='room_jid' type='s' /> - <arg name='message' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='send_single_message'> - <arg name='jid' type='s' /> - <arg name='subject' type='s' /> - <arg name='message' type='s' /> - <arg name='account' type='s' /> - <arg direction='out' type='b' /> - </method> - <method name='send_xml'> - <arg name='xml' type='s' /> - <arg name='account' type='s' /> - </method> - <method name='set_priority'> - <arg name='prio' type='s' /> - <arg name='account' type='s' /> - </method> - <signal name='AccountPresence'> - <arg type='av' /> - </signal> - <signal name='ContactPresence'> - <arg type='av' /> - </signal> - <signal name='GCMessage'> - <arg type='av' /> - </signal> - <signal name='MessageSent'> - <arg type='av' /> - </signal> - <signal name='NewMessage'> - <arg type='av' /> - </signal> - <signal name='Subscribe'> - <arg type='av' /> - </signal> - <signal name='Subscribed'> - <arg type='av' /> - </signal> - <signal name='Unsubscribed'> - <arg type='av' /> - </signal> - </interface> - </node> - ''' - - def __init__(self): - self.con = Gio.bus_get_sync(Gio.BusType.SESSION, None) - Gio.bus_own_name_on_connection(self.con, 'org.gajim.Gajim', - Gio.BusNameOwnerFlags.NONE, None, None) - super().__init__(self.con, '/org/gajim/dbus/RemoteObject') - self.first_show = True - - app.ged.register_event_handler('presence-received', ged.POSTGUI, - self.on_presence_received) - app.ged.register_event_handler('subscribe-presence-received', - ged.POSTGUI, self.on_subscribe_presence_received) - app.ged.register_event_handler('subscribed-presence-received', - ged.POSTGUI, self.on_subscribed_presence_received) - app.ged.register_event_handler('unsubscribed-presence-received', - ged.POSTGUI, self.on_unsubscribed_presence_received) - app.ged.register_event_handler('gc-message-received', - ged.POSTGUI, self.on_gc_message_received) - app.ged.register_event_handler('decrypted-message-received', - ged.POSTGUI, self._nec_decrypted_message_received) - app.ged.register_event_handler('our-show', ged.POSTGUI, - self.on_our_status) - app.ged.register_event_handler('message-sent', ged.POSTGUI, - self.on_message_sent) - - def on_message_sent(self, obj): - try: - chatstate = obj.chatstate - except AttributeError: - chatstate = '' - self.raise_signal('MessageSent', (obj.account, [ - obj.jid, obj.message, chatstate])) - - def on_presence_received(self, event: events.PresenceReceived) -> None: - self.raise_signal('ContactPresence', (event.account, [ - event.jid, - event.resource, - event.show, - event.status])) - - def on_subscribe_presence_received(self, obj): - self.raise_signal('Subscribe', (obj.conn.name, [obj.jid, obj.status, - obj.user_nick])) - - def on_subscribed_presence_received(self, event): - self.raise_signal('Subscribed', (event.account, - [event.jid.bare, - event.jid.resource])) - - def on_unsubscribed_presence_received(self, obj): - self.raise_signal('Unsubscribed', (obj.conn.name, obj.jid)) - - def on_gc_message_received(self, obj): - if not hasattr(obj, 'needs_highlight'): - # TODO: - # event has not been handled at GUI level - return - self.raise_signal('GCMessage', (obj.conn.name, [obj.fjid, obj.msgtxt, - obj.properties.timestamp, obj.delayed, - obj.displaymarking, obj.needs_highlight])) - - def _nec_decrypted_message_received(self, obj): - event_type = obj.properties.type.value - if obj.properties.is_muc_pm: - event_type = 'pm' - self.raise_signal('NewMessage', ( - obj.conn.name, [obj.fjid, obj.msgtxt, obj.properties.timestamp, - event_type, obj.properties.subject, - obj.msg_log_id, obj.properties.nickname])) - - def on_our_status(self, event): - self.raise_signal('AccountPresence', (event.show, event.account)) - - def raise_signal(self, event_name: str, data: Any) -> None: - log.info('Send event %s', event_name) - self.con.emit_signal(None, - '/org/gajim/dbus/RemoteObject', - 'org.gajim.dbus.RemoteInterface', - event_name, - GLib.Variant.new_tuple(get_dbus_struct(data))) - - def get_status(self, account): - """ - Return status (show to be exact) which is the global one unless - account is given - """ - if not account: - # If user did not ask for account, returns the global status - return helpers.get_global_show() - # return show for the given account - return app.connections[account].status - - def get_status_message(self, account): - """ - Return status which is the global one unless account is given - """ - if not account: - # If user did not ask for account, returns the global status - return str(helpers.get_global_status_message()) - # return show for the given account - return app.connections[account].status_message - - def _get_account_and_contact(self, account, jid): - """ - Get the account (if not given) and contact instance from jid - """ - connected_account = None - contact = None - accounts = app.settings.get_active_accounts() - # if there is only one account in roster, take it as default - # if user did not ask for account - if not account and len(accounts) == 1: - account = accounts[0] - if account: - if app.account_is_available(account): # account is connected - connected_account = account - client = app.get_client(account) - contact = client.get_module('Contacts').get_contact(jid) - else: - for account_ in accounts: - client = app.get_client(account_) - contact = client.get_module('Contacts').get_contact(jid) - if app.account_is_available(account_): - # account is connected - connected_account = account_ - break - - return connected_account, contact - - def _get_account_for_groupchat(self, account, room_jid): - """ - Get the account which is connected to groupchat (if not given) - or check if the given account is connected to the groupchat - """ - connected_account = None - accounts = app.settings.get_active_accounts() - # if there is only one account in roster, take it as default - # if user did not ask for account - if not account and len(accounts) == 1: - account = accounts[0] - if account: - if app.account_is_available(account) and \ - room_jid in app.gc_connected[account] and \ - app.gc_connected[account][room_jid]: - # account and groupchat are connected - connected_account = account - else: - for account_ in accounts: - if app.account_is_available(account_) and \ - room_jid in app.gc_connected[account_] and \ - app.gc_connected[account_][room_jid]: - # account and groupchat are connected - connected_account = account_ - break - return connected_account - - def send_file(self, file_path, jid, account): - """ - Send file, located at 'file_path' to 'jid', using account (optional) - 'account' - """ - jid = self._get_real_jid(jid, account) - connected_account, contact = self._get_account_and_contact( - account, jid) - - if connected_account: - if file_path.startswith('file://'): - file_path = file_path[7:] - if os.path.isfile(file_path): # is it file? - app.interface.instances['file_transfers'].send_file( - connected_account, contact, file_path) - return True - return False - - def _send_message(self, - jid, - message, - account, - type_='chat', - subject=None): - """ - Can be called from send_chat_message (default when send_message) or - send_single_message - """ - if not jid or not message: - return False - - connected_account, contact = self._get_account_and_contact(account, jid) - if not connected_account or contact is None: - return False - - client = app.get_client(connected_account) - control = app.window.get_control(connected_account, jid) - if control is not None: - control.send_message(message) - else: - message_ = OutgoingMessage(account=connected_account, - contact=contact, - message=message, - type_=type_, - subject=subject, - control=control) - client.send_message(message_) - return True - - def send_chat_message(self, jid, message, account): - """ - Send chat 'message' to 'jid', using account (optional) 'account'. - """ - jid = self._get_real_jid(jid, account) - return self._send_message(jid, message, account) - - def send_single_message(self, jid, subject, message, account): - """ - Send single 'message' to 'jid', using account (optional) 'account'. - """ - jid = self._get_real_jid(jid, account) - return self._send_message(jid, message, account, 'normal', subject) - - def send_groupchat_message(self, room_jid, message, account): - """ - Send 'message' to groupchat 'room_jid', - using account (optional) 'account' - """ - if not room_jid or not message: - return False - connected_account = self._get_account_for_groupchat(account, room_jid) - if not connected_account: - return False - - client = app.get_client(connected_account) - contact = client.get_module('Contacts').get_contact( - connected_account, room_jid, groupchat=True) - - if not contact.is_joined: - return False - - message_ = OutgoingMessage(account=connected_account, - contact=contact, - message=message, - type_='groupchat') - client.send_message(message_) - return True - - def open_chat(self, jid, account, message): - """ - Shows the tabbed window for new message to 'jid', using account - 'account' (optional) - """ - if not jid: - raise ValueError('jid is missing') - jid = self._get_real_jid(jid, account) - try: - jid = helpers.parse_jid(jid) - except Exception: - # Jid is not conform, ignore it - return False - - if account: - accounts = [account] - else: - accounts = app.connections.keys() - if len(accounts) == 1: - account = accounts[0] - connected_account = None - first_connected_acct = None - for acct in accounts: - if app.account_is_available(acct): # account is online - client = app.get_client(acct) - contact = client.get_module('Contacts').get_contact(jid) - control = app.window.get_control(acct, jid) - if control is not None: - connected_account = acct - break - # jid is in roster - if contact.is_in_roster: - connected_account = acct - break - # we send the message to jid not in roster, because account is - # specified, or there is only one account - if account: - connected_account = acct - elif first_connected_acct is None: - first_connected_acct = acct - - # if jid is not a contact, open-chat with first connected account - if connected_account is None and first_connected_acct: - connected_account = first_connected_acct - - if connected_account: - app.interface.start_chat_from_jid(connected_account, jid, message) - # preserve the 'steal focus preservation' - if app.window.get_property('visible'): - app.window.present() - return True - return False - - def change_status(self, status, message, account): - """ - change_status(status, message, account). Account is optional - if not - specified status is changed for all accounts - """ - if status not in ('offline', 'online', 'chat', 'away', 'xa', 'dnd'): - status = '' - if account: - if not status: - if account not in app.connections: - return False - status = app.connections[account].status - GLib.idle_add(app.connections[account].change_status, status, - message) - else: - # account not specified, so change the status of all accounts - for acc in app.settings.get_active_accounts(): - if not app.settings.get_account_setting( - acc, 'sync_with_global_status'): - continue - if status: - status_ = status - else: - if acc not in app.connections: - continue - status_ = app.connections[acc].status - GLib.idle_add(app.connections[acc].change_status, status_, - message) - return False - - def set_priority(self, prio, account): - """ - set_priority(prio, account). Account is optional - if not specified - priority is changed for all accounts. That are synced with global status - """ - if account: - app.settings.set_account_setting(account, 'priority', prio) - show = app.connections[account].status - status = app.connections[account].status_message - GLib.idle_add(app.connections[account].change_status, show, status) - else: - # account not specified, so change prio of all accounts - for acc in app.settings.get_active_accounts(): - if not app.account_is_available(acc): - continue - if not app.settings.get_account_setting( - acc, 'sync_with_global_status'): - continue - app.settings.set_account_setting(acc, 'priority', prio) - show = app.connections[acc].status - status = app.connections[acc].status_message - GLib.idle_add(app.connections[acc].change_status, show, status) - - def list_accounts(self): - """ - List register accounts - """ - result = app.settings.get_active_accounts() - result_array = [] - if result: - for account in result: - result_array.append(account) - return result_array - - def account_info(self, account): - """ - Show info on account: resource, jid, nick, prio, message - """ - result = {} - if account in app.connections: - # account is valid - con = app.connections[account] - result['status'] = con.status - result['name'] = con.name - result['jid'] = app.get_jid_from_account(con.name) - result['message'] = con.status_message - result['priority'] = str(con.priority) - result['resource'] = app.settings.get_account_setting(con.name, - 'resource') - return result - - def list_contacts(self, account): - """ - List all contacts in the roster. If the first argument is specified, - then return the contacts for the specified account - """ - result = [] - accounts = app.settings.get_active_accounts() - if not accounts: - return result - if account: - accounts_to_search = [account] - else: - accounts_to_search = accounts - for acct in accounts_to_search: - if acct in accounts: - client = app.get_client(acct) - for contact in client.get_module('Roster').iter_contacts(): - item = self._contacts_as_dbus_structure(contact) - if item: - result.append(item) - return result - - def add_contact(self, jid, account): - if account: - if app.account_is_available(account): - # if given account is active, use it - AddContact(account=account, jid=jid) - else: - # wrong account - return False - else: - # if account is not given, show account combobox - AddContact(account=None, jid=jid) - return True - - def remove_contact(self, jid, account): - jid = self._get_real_jid(jid, account) - accounts = app.settings.get_active_accounts() - - # if there is only one account in roster, take it as default - if account: - accounts = [account] - contact_exists = False - for account_ in accounts: - client = app.get_client(account_) - contact = client.get_module('Contacts').get_contact(jid) - if contact.is_in_roster: - client.get_module('Presence').unsubscribe(jid) - client.get_module('Roster').delete_item(jid) - contact_exists = True - return contact_exists - - def _is_first(self): - if self.first_show: - self.first_show = False - return True - return False - - def _get_real_jid(self, jid, account=None): - """ - Get the real jid from the given one: removes xmpp: or get jid from nick - if account is specified, search only in this account - """ - if account: - accounts = [account] - else: - accounts = app.connections.keys() - if jid.startswith('xmpp:'): - return jid[5:] # len('xmpp:') = 5 - for account_ in accounts: - # Does jid exists in roster of one account ? - client = app.get_client(account_) - contact = client.get_module('Contacts').get_contact(jid) - if contact.is_pm_contact: - return contact.real_jid - return jid - - def _contacts_as_dbus_structure(self, contact: BareContact): - """ - Get info from list of Contact objects and create dbus dict - """ - - contact_dict = {} - - contact_dict['name'] = GLib.Variant('s', contact.name) - contact_dict['show'] = GLib.Variant('s', contact.show.value) - contact_dict['jid'] = GLib.Variant('s', str(contact.jid)) - - resources = GLib.VariantBuilder(GLib.VariantType('a(ss)')) - for res_contact in contact.iter_resources(): - resource_props = (res_contact.resource, - res_contact.status) - resources.add_value(GLib.Variant('(ss)', resource_props)) - contact_dict['resources'] = resources.end() - - groups = GLib.VariantBuilder(GLib.VariantType('as')) - for group in contact.groups: - groups.add_value(GLib.Variant('s', group)) - contact_dict['groups'] = groups.end() - return contact_dict - - def get_unread_msgs_number(self): - return str(app.window.get_total_unread_count()) - - def send_xml(self, xml, account): - if account: - app.connections[account].send_stanza(str(xml)) - else: - for acc in app.settings.get_active_accounts(): - app.connections[acc].send_stanza(str(xml)) - - def join_room(self, room_jid, password, account): - if not account: - # get the first connected account - accounts = app.connections.keys() - for acct in accounts: - if app.account_is_available(acct): - account = acct - break - if not account: - return - - app.interface.show_add_join_groupchat(account, - room_jid, - password=password) - - def Introspect(self): - return self.__doc__ View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/7e24d615a37caf81f3d41b4dbea2694d… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/7e24d615a37caf81f3d41b4dbea2694d… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] chore: Fix codestyle errors
by Philipp Hörist (＠lovetox) 16 Jun '22

16 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: b32e35af by lovetox at 2022-06-16T16:20:44+02:00 chore: Fix codestyle errors - - - - - 2 changed files: - gajim/common/jingle_xtls.py - setup.cfg Changes: ===================================== gajim/common/jingle_xtls.py ===================================== @@ -25,18 +25,22 @@ log = logging.getLogger('gajim.c.jingle_xtls') -# key-exchange id -> [callback, args], accept that session once key-exchange completes +# key-exchange id -> [callback, args] +# accept that session once key-exchange completes pending_contents = {} + def key_exchange_pend(id_, cb, args): # args is a list pending_contents[id_] = [cb, args] + def approve_pending_content(id_): cb = pending_contents[id_][0] args = pending_contents[id_][1] cb(*args) + TYPE_RSA = crypto.TYPE_RSA TYPE_DSA = crypto.TYPE_DSA @@ -44,10 +48,12 @@ def approve_pending_content(id_): DH_PARAMS = 'dh_params.pem' DEFAULT_DH_PARAMS = 'dh4096.pem' + def default_callback(connection, certificate, error_num, depth, return_code): log.info("certificate: %s", certificate) return return_code + def load_cert_file(cert_path, cert_store=None): """ This is almost identical to the one in nbxmpp.tls_nb @@ -67,7 +73,7 @@ def load_cert_file(cert_path, cert_store=None): if 'BEGIN CERTIFICATE' in line: begin = i elif 'END CERTIFICATE' in line and begin > -1: - cert = ''.join(lines[begin:i+2]) + cert = ''.join(lines[begin:i + 2]) try: x509cert = crypto.load_certificate(crypto.FILETYPE_PEM, cert) if cert_store: @@ -84,25 +90,27 @@ def load_cert_file(cert_path, cert_store=None): i += 1 f.close() + def get_context(fingerprint, verify_cb=None, remote_jid=None): """ constructs and returns the context objects """ ctx = SSL.Context(SSL.SSLv23_METHOD) - flags = (SSL.OP_NO_SSLv2 | SSL.OP_NO_SSLv3 | SSL.OP_SINGLE_DH_USE \ - | SSL.OP_NO_TICKET) + flags = (SSL.OP_NO_SSLv2 | SSL.OP_NO_SSLv3 | SSL.OP_SINGLE_DH_USE | + SSL.OP_NO_TICKET) ctx.set_options(flags) ctx.set_cipher_list(b'HIGH:!aNULL:!3DES') - if fingerprint == 'server': # for testing purposes only - ctx.set_verify(SSL.VERIFY_NONE|SSL.VERIFY_FAIL_IF_NO_PEER_CERT, + if fingerprint == 'server': # for testing purposes only + ctx.set_verify(SSL.VERIFY_NONE | SSL.VERIFY_FAIL_IF_NO_PEER_CERT, verify_cb or default_callback) elif fingerprint == 'client': ctx.set_verify(SSL.VERIFY_PEER, verify_cb or default_callback) cert_name = configpaths.get('MY_CERT') / SELF_SIGNED_CERTIFICATE ctx.use_privatekey_file(str(cert_name.with_suffix('.pkey')).encode('utf-8')) - ctx.use_certificate_file(str(cert_name.with_suffix('.cert')).encode('utf-8')) + ctx.use_certificate_file( + str(cert_name.with_suffix('.cert')).encode('utf-8')) # Try to load Diffie-Hellman parameters. # First try user DH parameters, if this fails load the default DH parameters @@ -110,7 +118,7 @@ def get_context(fingerprint, verify_cb=None, remote_jid=None): try: with open(dh_params_name, "r", encoding='utf8'): ctx.load_tmp_dh(dh_params_name.encode('utf-8')) - except FileNotFoundError as err: + except FileNotFoundError: default_dh_params_name = (configpaths.get('DATA') / 'other' / DEFAULT_DH_PARAMS) try: @@ -123,14 +131,15 @@ def get_context(fingerprint, verify_cb=None, remote_jid=None): if remote_jid: store = ctx.get_cert_store() - path = configpaths.get('MY_PEER_CERTS').expanduser() / (remote_jid - + '.cert') + path = configpaths.get('MY_PEER_CERTS').expanduser() + path = path / f'{remote_jid}.cert' if path.exists(): load_cert_file(path, cert_store=store) log.debug('certificate file %s loaded fingerprint %s', path, fingerprint) return ctx + def read_cert(certpath): certificate = '' with open(certpath, 'r', encoding='utf8') as certfile: @@ -139,9 +148,9 @@ def read_cert(certpath): certificate += line return certificate + def send_cert(con, jid_from, sid): - certpath = configpaths.get('MY_CERT') / (SELF_SIGNED_CERTIFICATE - + '.cert') + certpath = configpaths.get('MY_CERT') / f'{SELF_SIGNED_CERTIFICATE}.cert' certificate = read_cert(certpath) iq = nbxmpp.Iq('result', to=jid_from) iq.setAttr('id', sid) @@ -157,6 +166,7 @@ def send_cert(con, jid_from, sid): con.send(iq) + def handle_new_cert(con, obj, jid_from): jid = app.get_jid_without_resource(jid_from) certpath = configpaths.get('MY_PEER_CERTS').expanduser() / (jid + '.cert') @@ -175,17 +185,19 @@ def handle_new_cert(con, obj, jid_from): approve_pending_content(id_) + def check_cert(jid, fingerprint): certpath = configpaths.get('MY_PEER_CERTS').expanduser() / (jid + '.cert') if certpath.exists(): cert = load_cert_file(certpath) if cert: - digest_algo = cert.get_signature_algorithm().decode('utf-8')\ - .split('With')[0] + digest_algo = cert.get_signature_algorithm() + digest_algo = digest_algo.decode('utf-8').split('With')[0] if cert.digest(digest_algo) == fingerprint: return True return False + def send_cert_request(con, to_jid): iq = nbxmpp.Iq('get', to=to_jid) id_ = generate_id() @@ -197,6 +209,7 @@ def send_cert_request(con, to_jid): # the following code is partly due to pyopenssl examples + def createKeyPair(type_, bits): """ Create a public/private key pair. @@ -209,6 +222,7 @@ def createKeyPair(type_, bits): pkey.generate_key(type_, bits) return pkey + def createCertRequest(pkey, digest="sha256", **name): """ Create a certificate request. @@ -236,7 +250,9 @@ def createCertRequest(pkey, digest="sha256", **name): req.sign(pkey, digest) return req -def createCertificate(req, issuerCert, issuerKey, serial, notBefore, notAfter, digest="sha256"): + +def createCertificate(req, issuerCert, issuerKey, serial, notBefore, notAfter, + digest="sha256"): """ Generate a certificate given a certificate request. @@ -261,6 +277,7 @@ def createCertificate(req, issuerCert, issuerKey, serial, notBefore, notAfter, d cert.sign(issuerKey, digest) return cert + def make_certs(filepath, CN): """ make self signed certificates @@ -270,7 +287,8 @@ def make_certs(filepath, CN): """ key = createKeyPair(TYPE_RSA, 4096) req = createCertRequest(key, CN=CN) - cert = createCertificate(req, req, key, 0, 0, 60*60*24*365*5) # five years + # five years + cert = createCertificate(req, req, key, 0, 0, 60 * 60 * 24 * 365 * 5) with open(filepath.with_suffix('.pkey'), 'wb') as f: filepath.with_suffix('.pkey').chmod(0o600) f.write(crypto.dump_privatekey(crypto.FILETYPE_PEM, key)) ===================================== setup.cfg ===================================== @@ -8,9 +8,8 @@ exclude = test, typings gajim/command_system, - gajim/gajim_remote.py, - gajim/remote_control.py, gajim/common/config.py + gajim/common/optparser.py max-complexity = 15 builtins=_ max-line-length = 80 View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/b32e35af5a027c79dfdd37339b623daf… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/commit/b32e35af5a027c79dfdd37339b623daf… You're receiving this email because of your account on dev.gajim.org.

1 0

[Git][gajim/gajim][master] 2 commits: refactor: Remove dead code
by Philipp Hörist (＠lovetox) 16 Jun '22

16 Jun '22

Philipp Hörist pushed to branch master at gajim / gajim Commits: ede6ad92 by lovetox at 2022-06-16T16:12:10+02:00 refactor: Remove dead code - - - - - 93b7eb22 by lovetox at 2022-06-16T16:12:10+02:00 chore: Fix codestyle errors - - - - - 4 changed files: - gajim/common/modules/bytestream.py - gajim/common/modules/message.py - gajim/common/storage/base.py - setup.cfg Changes: ===================================== gajim/common/modules/bytestream.py ===================================== @@ -63,6 +63,7 @@ def is_transfer_paused(file_props: FileProp) -> bool: return False return file_props.paused + def is_transfer_active(file_props: FileProp) -> bool: if file_props.stopped: return False @@ -74,6 +75,7 @@ def is_transfer_active(file_props: FileProp) -> bool: return True return not file_props.paused + def is_transfer_stopped(file_props: FileProp) -> bool: if not file_props: return True @@ -378,16 +380,18 @@ def ip_is_local(ip: str) -> bool: # it's an IPv6 return True ip_s = ip.split('.') - ip_l = int(ip_s[0])<<24 | int(ip_s[1])<<16 | int(ip_s[2])<<8 | \ - int(ip_s[3]) + ip_l = (int(ip_s[0]) << 24 | + int(ip_s[1]) << 16 | + int(ip_s[2]) << 8 | + int(ip_s[3])) # 10/8 - if ip_l & (255<<24) == 10<<24: + if ip_l & (255 << 24) == 10 << 24: return True # 172.16/12 - if ip_l & (255<<24 | 240<<16) == (172<<24 | 16<<16): + if ip_l & (255 << 24 | 240 << 16) == (172 << 24 | 16 << 16): return True # 192.168 - if ip_l & (255<<24 | 255<<16) == (192<<24 | 168<<16): + if ip_l & (255 << 24 | 255 << 16) == (192 << 24 | 168 << 16): return True return False @@ -446,7 +450,6 @@ def no_upnp_reply() -> bool: cleanup_gupnp() return False - self.ok_id = app.gupnp_igd.connect('mapped-external-port', success) self.fail_id = app.gupnp_igd.connect('error-mapping-port', fail) @@ -628,7 +631,7 @@ def _on_bytestream_set(self, streamhosts.append(host_dict) file_props = FilesProp.getFilePropBySid(sid) if file_props is not None: - if file_props.type_ == 's': # FIXME: remove fast xmlns + if file_props.type_ == 's': # FIXME: remove fast xmlns # only psi do this if file_props.streamhosts: file_props.streamhosts.extend(streamhosts) @@ -646,6 +649,7 @@ def _on_bytestream_set(self, raise nbxmpp.NodeProcessed file_props.streamhosts = streamhosts + def _connection_error(sid: str) -> None: self._connect_error(sid, 'item-not-found', @@ -693,7 +697,7 @@ def _on_bytestream_result(self, try: streamhost = query.getTag('streamhost-used') - except Exception: # this bytestream result is not what we need + except Exception: # this bytestream result is not what we need pass id_ = real_id[3:] file_props = FilesProp.getFileProp(self._account, id_) @@ -704,11 +708,11 @@ def _on_bytestream_result(self, if real_id.startswith('au_'): if file_props.streamhost_used is False: raise nbxmpp.NodeProcessed - if not file_props.proxyhosts: + if not file_props.proxyhosts: raise nbxmpp.NodeProcessed for host in file_props.proxyhosts: - if host['initiator'] == frm and \ - query.getAttr('sid') == file_props.sid: + if (host['initiator'] == frm and + query.getAttr('sid') == file_props.sid): app.socks5queue.activate_proxy(host['idx']) break raise nbxmpp.NodeProcessed ===================================== gajim/common/modules/message.py ===================================== @@ -152,22 +152,6 @@ def _message_received(self, msgtxt = properties.body session = None - # if not properties.type.is_groupchat: - # if properties.is_muc_pm and properties.type.is_error: - # session = self._con.find_session(fjid, properties.thread) - # if not session: - # session = self._con.get_latest_session(fjid) - # if not session: - # session = self._con.make_new_session( - # fjid, properties.thread, type_='pm') - # else: - # session = self._con.get_or_create_session( - # fjid, properties.thread) - - # if properties.thread and not session.received_thread_id: - # session.received_thread_id = True - - # session.last_receive = time.time() additional_data = AdditionalDataDict() @@ -208,12 +192,11 @@ def _message_received(self, correct_id = parse_correction(properties) if correct_id is not None: - event = MessageUpdated( - account=self._account, - jid=event_attr['jid'], - msgtxt=msgtxt, - properties=properties, - correct_id=correct_id) + event = MessageUpdated(account=self._account, + jid=event_attr['jid'], + msgtxt=msgtxt, + properties=properties, + correct_id=correct_id) app.storage.archive.store_message_correction( self._account, ===================================== gajim/common/storage/base.py ===================================== @@ -38,6 +38,7 @@ _T = TypeVar('_T') + def timeit(func: Callable[..., _T]) -> Callable[..., _T]: def func_wrapper(self: Any, *args: Any, **kwargs: Any) -> _T: start = time.time() @@ -55,9 +56,11 @@ def func_wrapper(self: Any, *args: Any, **kwargs: Any) -> _T: def _convert_common_error(common_error: bytes) -> CommonError: return CommonError.from_string(common_error) + def _adapt_common_error(common_error: CommonError) -> str: return common_error.serialize() + sqlite3.register_converter('common_error', _convert_common_error) sqlite3.register_adapter(CommonError, _adapt_common_error) @@ -68,21 +71,27 @@ def _convert_marker(marker: bytes): sqlite3.register_converter('marker', _convert_marker) + def _jid_adapter(jid: JID) -> str: return str(jid) + def _jid_converter(jid: bytes) -> JID: return JID.from_string(jid.decode()) + sqlite3.register_converter('jid', _jid_converter) sqlite3.register_adapter(JID, _jid_adapter) + def _convert_disco_info(disco_info: bytes) -> DiscoInfo: return parse_disco_info(Iq(node=disco_info)) # type: ignore + def _adapt_disco_info(disco_info: DiscoInfo) -> str: return str(disco_info.stanza) + sqlite3.register_converter('disco_info', _convert_disco_info) sqlite3.register_adapter(DiscoInfo, _adapt_disco_info) ===================================== setup.cfg ===================================== @@ -1,5 +1,5 @@ [flake8] -ignore = W504 +ignore = W504, C901 exclude = __pycache__, build, View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/61fae3de28986cde47cafa0dd854495… -- View it on GitLab: https://dev.gajim.org/gajim/gajim/-/compare/61fae3de28986cde47cafa0dd854495… You're receiving this email because of your account on dev.gajim.org.

1 0

← Newer
1
...
4
5
6
7
8
9
10
...
14
Older →

Jump to page:

2026

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

Commits June 2022