libervia-backend: libervia/backend/plugins/plugin_xep

annotate libervia/backend/plugins/plugin_xep_0353.py @ 4212:5f2d496c633f

core: get rid of `pickle`: Use of `pickle` to serialise data was a technical legacy that was causing trouble to store in database, to update (if a class was serialised, a change could break update), and to security (pickle can lead to code execution). This patch remove all use of Pickle in favour in JSON, notably: - for caching data, a Pydantic model is now used instead - for SQLAlchemy model, the LegacyPickle is replaced by JSON serialisation - in XEP-0373 a class `PublicKeyMetadata` was serialised. New method `from_dict` and `to_dict` method have been implemented to do serialisation. - new methods to (de)serialise data can now be specified with Identity data types. It is notably used to (de)serialise `path` of avatars. A migration script has been created to convert data (for upgrade or downgrade), with special care for XEP-0373 case. Depending of size of database, this migration script can be long to run. rel 443

author	Goffi <goffi@goffi.org>
date	Fri, 23 Feb 2024 13:31:04 +0100
parents	6784d07b99c8
children	e11b13418ba6

rev	line source
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	1 #!/usr/bin/env python3
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	2
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	3 # Libervia plugin for Jingle Message Initiation (XEP-0353)
3479 be6d91572633 date update Goffi <goffi@goffi.org> parents: 3405 diff changeset	4 # Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	5
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	6 # This program is free software: you can redistribute it and/or modify
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	7 # it under the terms of the GNU Affero General Public License as published by
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	8 # the Free Software Foundation, either version 3 of the License, or
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	9 # (at your option) any later version.
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	10
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	11 # This program is distributed in the hope that it will be useful,
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	14 # GNU Affero General Public License for more details.
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	15
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	16 # You should have received a copy of the GNU Affero General Public License
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	17 # along with this program. If not, see <http://www.gnu.org/licenses/>.
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	18
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	19 from twisted.internet import defer
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	20 from twisted.internet import reactor
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	21 from twisted.words.protocols.jabber import error, jid
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	22 from twisted.words.protocols.jabber import xmlstream
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	23 from twisted.words.xish import domish
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	24 from wokkel import disco, iwokkel
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	25 from zope.interface import implementer
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	26
4071 4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4055 diff changeset	27 from libervia.backend.core import exceptions
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4055 diff changeset	28 from libervia.backend.core.constants import Const as C
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4055 diff changeset	29 from libervia.backend.core.core_types import SatXMPPEntity
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4055 diff changeset	30 from libervia.backend.core.i18n import D_, _
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4055 diff changeset	31 from libervia.backend.core.log import getLogger
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	32
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	33 log = getLogger(__name__)
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	34
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	35
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	36 NS_JINGLE_MESSAGE = "urn:xmpp:jingle-message:0"
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	37
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	38 PLUGIN_INFO = {
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	39 C.PI_NAME: "Jingle Message Initiation",
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	40 C.PI_IMPORT_NAME: "XEP-0353",
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	41 C.PI_TYPE: "XEP",
4183 6784d07b99c8 plugin XEP-053, component AP gateway: use the new `trigger.add_with_check` method Goffi <goffi@goffi.org> parents: 4115 diff changeset	42 C.PI_MODES: C.PLUG_MODE_BOTH,
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	43 C.PI_PROTOCOLS: ["XEP-0353"],
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	44 C.PI_DEPENDENCIES: ["XEP-0166", "XEP-0334"],
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	45 C.PI_MAIN: "XEP_0353",
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	46 C.PI_HANDLER: "yes",
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	47 C.PI_DESCRIPTION: _("""Implementation of Jingle Message Initiation"""),
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	48 }
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	49
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	50
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	51 class RejectException(exceptions.CancelError):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	52
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	53 def __init__(self, reason: str, text: str\|None = None):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	54 super().__init__(text)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	55 self.reason = reason
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	56
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	57
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	58 class RetractException(exceptions.CancelError):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	59 pass
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	60
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	61
3517 8508fab9bcc2 plugin XEP-0353: don't use Jingle Message Initiation for components: Goffi <goffi@goffi.org> parents: 3479 diff changeset	62 class XEP_0353:
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	63 def __init__(self, host):
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	64 log.info(_("plugin {name} initialization").format(name=PLUGIN_INFO[C.PI_NAME]))
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	65 self.host = host
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	66 host.register_namespace("jingle-message", NS_JINGLE_MESSAGE)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	67 self._j = host.plugins["XEP-0166"]
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	68 self._h = host.plugins["XEP-0334"]
4183 6784d07b99c8 plugin XEP-053, component AP gateway: use the new `trigger.add_with_check` method Goffi <goffi@goffi.org> parents: 4115 diff changeset	69 host.trigger.add_with_check(
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	70 "XEP-0166_initiate_elt_built",
4183 6784d07b99c8 plugin XEP-053, component AP gateway: use the new `trigger.add_with_check` method Goffi <goffi@goffi.org> parents: 4115 diff changeset	71 self,
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	72 self._on_initiate_trigger,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	73 # this plugin set the resource, we want it to happen first to other trigger
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	74 # can get the full peer JID
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	75 priority=host.trigger.MAX_PRIORITY,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	76 )
4183 6784d07b99c8 plugin XEP-053, component AP gateway: use the new `trigger.add_with_check` method Goffi <goffi@goffi.org> parents: 4115 diff changeset	77 host.trigger.add_with_check(
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	78 "XEP-0166_terminate",
4183 6784d07b99c8 plugin XEP-053, component AP gateway: use the new `trigger.add_with_check` method Goffi <goffi@goffi.org> parents: 4115 diff changeset	79 self,
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	80 self._terminate_trigger,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	81 priority=host.trigger.MAX_PRIORITY,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	82 )
4051 c23cad65ae99 core: renamed `messageReceived` trigger to `message_received` Goffi <goffi@goffi.org> parents: 4044 diff changeset	83 host.trigger.add("message_received", self._on_message_received)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	84
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	85 def get_handler(self, client):
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	86 return Handler()
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	87
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	88 def profile_connecting(self, client):
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	89 # mapping from session id to deferred used to wait for destinee answer
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	90 client._xep_0353_pending_sessions = {}
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	91
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	92 def build_message_data(self, client, peer_jid, verb, session_id):
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	93 mess_data = {
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	94 "from": client.jid,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	95 "to": peer_jid,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	96 "uid": "",
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	97 "message": {},
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	98 "type": C.MESS_TYPE_CHAT,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	99 "subject": {},
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	100 "extra": {},
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	101 }
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	102 client.generate_message_xml(mess_data)
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	103 message_elt = mess_data["xml"]
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	104 verb_elt = message_elt.addElement((NS_JINGLE_MESSAGE, verb))
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	105 verb_elt["id"] = session_id
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	106 self._h.add_hint_elements(message_elt, [self._h.HINT_STORE])
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	107 return mess_data
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	108
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	109 async def _on_initiate_trigger(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	110 self,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	111 client: SatXMPPEntity,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	112 session: dict,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	113 iq_elt: domish.Element,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	114 jingle_elt: domish.Element,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	115 ) -> bool:
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	116 peer_jid = session["peer_jid"]
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	117 if peer_jid.resource:
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	118 return True
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	119
3652 6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	120 try:
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	121 infos = await self.host.memory.disco.get_infos(client, peer_jid)
3652 6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	122 except error.StanzaError as e:
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	123 if e.condition == "service-unavailable":
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	124 categories = {}
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	125 else:
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	126 raise e
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	127 else:
6e34307319c0 plugin XEP-0353: fix jingle initiation on disco "Service Unavailable" error: Goffi <goffi@goffi.org> parents: 3651 diff changeset	128 categories = {c for c, __ in infos.identities}
3517 8508fab9bcc2 plugin XEP-0353: don't use Jingle Message Initiation for components: Goffi <goffi@goffi.org> parents: 3479 diff changeset	129 if "component" in categories:
8508fab9bcc2 plugin XEP-0353: don't use Jingle Message Initiation for components: Goffi <goffi@goffi.org> parents: 3479 diff changeset	130 # we don't use message initiation with components
8508fab9bcc2 plugin XEP-0353: don't use Jingle Message Initiation for components: Goffi <goffi@goffi.org> parents: 3479 diff changeset	131 return True
8508fab9bcc2 plugin XEP-0353: don't use Jingle Message Initiation for components: Goffi <goffi@goffi.org> parents: 3479 diff changeset	132
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	133 if peer_jid.userhostJID() not in client.roster:
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	134 # if the contact is not in our roster, we need to send a directed presence
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	135 # according to XEP-0353 §3.1
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	136 await client.presence.available(peer_jid)
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	137
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	138 mess_data = self.build_message_data(client, peer_jid, "propose", session["id"])
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	139 message_elt = mess_data["xml"]
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	140 for content_data in session["contents"].values():
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	141 # we get the full element build by the application plugin
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	142 jingle_description_elt = content_data["application_data"]["desc_elt"]
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	143 # and copy it to only keep the root <description> element, no children
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	144 description_elt = domish.Element(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	145 (jingle_description_elt.uri, jingle_description_elt.name),
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	146 defaultUri=jingle_description_elt.defaultUri,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	147 attribs=jingle_description_elt.attributes,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	148 localPrefixes=jingle_description_elt.localPrefixes,
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	149 )
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	150 message_elt.propose.addChild(description_elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	151 response_d = defer.Deferred()
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	152 # we wait for 2 min before cancelling the session init
4044 3900626bc100 plugin XEP-0166: refactoring, and various improvments: Goffi <goffi@goffi.org> parents: 4042 diff changeset	153 # FIXME: let's application decide timeout?
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	154 response_d.addTimeout(2 * 60, reactor)
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	155 client._xep_0353_pending_sessions[session["id"]] = response_d
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	156 try:
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	157 await client.send_message_data(mess_data)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	158 accepting_jid = await response_d
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	159 except defer.TimeoutError:
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	160 log.warning(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	161 _("Message initiation with {peer_jid} timed out").format(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	162 peer_jid=peer_jid
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	163 )
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	164 )
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	165 except exceptions.CancelError as e:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	166 for content in session["contents"].values():
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	167 await content["application"].handler.jingle_preflight_cancel(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	168 client, session, e
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	169 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	170
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	171 self._j.delete_session(client, session["id"])
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	172 return False
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	173 else:
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	174 if iq_elt["to"] != accepting_jid.userhost():
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	175 raise exceptions.InternalError(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	176 f"<jingle> 'to' attribute ({iq_elt['to']!r}) must not differ "
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	177 f"from bare JID of the accepting entity ({accepting_jid!r}), this "
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	178 "may be a sign of an internal bug, a hack attempt, or a MITM attack!"
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	179 )
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	180 iq_elt["to"] = accepting_jid.full()
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	181 session["peer_jid"] = accepting_jid
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	182 finally:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	183 del client._xep_0353_pending_sessions[session["id"]]
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	184 return True
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	185
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	186 def _terminate_trigger(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	187 self,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	188 client: SatXMPPEntity,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	189 session: dict,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	190 reason_elt: domish.Element
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	191 ) -> bool:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	192 session_id = session["id"]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	193 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	194 response_d = client._xep_0353_pending_sessions[session_id]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	195 except KeyError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	196 return True
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	197 # we have a XEP-0353 session, that means that we are retracting a proposed session
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	198 mess_data = self.build_message_data(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	199 client, session["peer_jid"], "retract", session_id
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	200 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	201 defer.ensureDeferred(client.send_message_data(mess_data))
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	202 response_d.errback(RetractException())
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	203
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	204 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	205
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	206 async def _on_message_received(self, client, message_elt, post_treat):
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	207 for elt in message_elt.elements():
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	208 if elt.uri == NS_JINGLE_MESSAGE:
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	209 if elt.name == "propose":
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	210 return await self._handle_propose(client, message_elt, elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	211 elif elt.name == "retract":
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	212 return self._handle_retract(client, message_elt, elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	213 elif elt.name == "proceed":
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	214 return self._handle_proceed(client, message_elt, elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	215 elif elt.name == "accept":
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	216 return self._handle_accept(client, message_elt, elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	217 elif elt.name == "reject":
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	218 return self._handle_reject(client, message_elt, elt)
4115 0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	219 elif elt.name == "ringing":
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	220 return await self._handle_ringing(client, message_elt, elt)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	221 else:
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	222 log.warning(f"invalid element: {elt.toXml}")
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	223 return True
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	224 return True
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	225
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	226 def _get_sid_and_response_d(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	227 self,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	228 client: SatXMPPEntity,
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	229 elt: domish.Element
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	230 ) -> tuple[str, defer.Deferred]:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	231 """Retrieve session ID and response_d from response element"""
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	232 try:
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	233 session_id = elt["id"]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	234 except KeyError as e:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	235 assert elt.parent is not None
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	236 log.warning(f"invalid proceed element in message_elt: {elt.parent.toXml()}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	237 raise e
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	238 try:
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	239 response_d = client._xep_0353_pending_sessions[session_id]
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	240 except KeyError as e:
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	241 log.warning(
4055 38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	242 _(
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	243 "no pending session found with id {session_id}, did it timed out?"
38819c69aa39 plugin XEP-0353: update according to XEP changes + <description> fix: Goffi <goffi@goffi.org> parents: 4051 diff changeset	244 ).format(session_id=session_id)
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	245 )
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	246 raise e
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	247 return session_id, response_d
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	248
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	249 async def _handle_propose(self, client, message_elt, elt):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	250 peer_jid = jid.JID(message_elt["from"])
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	251 local_jid = jid.JID(message_elt["to"])
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	252 session_id = elt["id"]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	253 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	254 desc_and_apps = [
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	255 (description_elt, self._j.get_application(description_elt.uri))
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	256 for description_elt in elt.elements()
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	257 if description_elt.name == "description"
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	258 ]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	259 if not desc_and_apps:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	260 raise AttributeError
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	261 except AttributeError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	262 log.warning(f"Invalid propose element: {message_elt.toXml()}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	263 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	264 except exceptions.NotFound:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	265 log.warning(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	266 f"There is not registered application to handle this "
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	267 f"proposal: {elt.toXml()}"
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	268 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	269 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	270
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	271 if not desc_and_apps:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	272 log.warning("No application specified: {message_elt.toXml()}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	273 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	274
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	275 session = self._j.create_session(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	276 client, session_id, self._j.ROLE_RESPONDER, peer_jid, local_jid
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	277 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	278
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	279 is_in_roster = peer_jid.userhostJID() in client.roster
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	280 if is_in_roster:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	281 # we indicate that device is ringing as explained in
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	282 # https://xmpp.org/extensions/xep-0353.html#ring , but we only do that if user
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	283 # is in roster to avoid presence leak of all our devices.
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	284 mess_data = self.build_message_data(client, peer_jid, "ringing", session_id)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	285 await client.send_message_data(mess_data)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	286
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	287 for description_elt, application in desc_and_apps:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	288 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	289 await application.handler.jingle_preflight(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	290 client, session, description_elt
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	291 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	292 except exceptions.CancelError as e:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	293 log.info(f"{client.profile} refused the session: {e}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	294
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	295 if is_in_roster:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	296 # peer is in our roster, we send reject to them, ou other devices will
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	297 # get carbon copies
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	298 reject_dest_jid = peer_jid
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	299 else:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	300 # peer is not in our roster, we send the "reject" only to our own
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	301 # devices to make them stop ringing/doing notification, and we don't
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	302 # send anything to peer to avoid presence leak.
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	303 reject_dest_jid = client.jid.userhostJID()
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	304
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	305 mess_data = self.build_message_data(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	306 client, reject_dest_jid, "reject", session_id
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	307 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	308 await client.send_message_data(mess_data)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	309 self._j.delete_session(client, session_id)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	310
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	311 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	312 except defer.CancelledError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	313 # raised when call is retracted before user can reply
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	314 self._j.delete_session(client, session_id)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	315 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	316
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	317 if peer_jid.userhostJID() not in client.roster:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	318 await client.presence.available(peer_jid)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	319
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	320 mess_data = self.build_message_data(client, peer_jid, "proceed", session_id)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	321 await client.send_message_data(mess_data)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	322
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	323 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	324
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	325 def _handle_retract(self, client, message_elt, retract_elt):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	326 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	327 session = self._j.get_session(client, retract_elt["id"])
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	328 except KeyError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	329 log.warning(f"invalid retract element: {message_elt.toXml()}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	330 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	331 except exceptions.NotFound:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	332 log.warning(f"no session found with ID {retract_elt['id']}")
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	333 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	334 log.debug(
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	335 f"{message_elt['from']} are retracting their proposal {retract_elt['id']}"
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	336 )
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	337 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	338 cancellable_deferred = session["cancellable_deferred"]
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	339 if not cancellable_deferred:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	340 raise KeyError
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	341 except KeyError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	342 self._j.delete_session(client, session["id"])
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	343 else:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	344 for d in cancellable_deferred:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	345 d.cancel()
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	346 return False
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	347
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	348 def _handle_proceed(self, client, message_elt, proceed_elt):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	349 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	350 __, response_d = self._get_sid_and_response_d(client, proceed_elt)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	351 except KeyError:
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	352 return True
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	353
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	354 response_d.callback(jid.JID(message_elt["from"]))
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	355 return False
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	356
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 3652 diff changeset	357 def _handle_accept(self, client, message_elt, accept_elt):
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	358 pass
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	359
4112 bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	360 def _handle_reject(self, client, message_elt, reject_elt):
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	361 try:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	362 __, response_d = self._get_sid_and_response_d(client, reject_elt)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	363 except KeyError:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	364 return True
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	365 reason_elt = self._j.get_reason_elt(reject_elt)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	366 reason, text = self._j.parse_reason_elt(reason_elt)
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	367 if reason is None:
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	368 reason = "busy"
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	369
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	370 response_d.errback(RejectException(reason, text))
bc60875cb3b8 plugin XEP-0166, XEP-0167, XEP-0234, XEP-0353: call events management to prepare for UI: Goffi <goffi@goffi.org> parents: 4071 diff changeset	371 return False
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	372
4115 0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	373 async def _handle_ringing(self, client, message_elt, ringing_elt):
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	374 session_id = ringing_elt["id"]
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	375 try:
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	376 session = self._j.get_session(client, session_id)
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	377 except exceptions.NotFound:
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	378 log.warning(f"Session {session_id!r} unknown, ignoring ringing.")
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	379 return False
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	380 for __, content_data in session["contents"].items():
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	381 await content_data["application"].handler.jingle_preflight_info(
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	382 client, session, "ringing", None
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	383 )
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	384
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	385 return False
0da563780ffc plugin XEP-0167, XEP-0353: handle ringing: Goffi <goffi@goffi.org> parents: 4112 diff changeset	386
3405 ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	387
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	388 @implementer(iwokkel.IDisco)
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	389 class Handler(xmlstream.XMPPHandler):
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	390 def getDiscoInfo(self, requestor, target, nodeIdentifier=""):
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	391 return [disco.DiscoFeature(NS_JINGLE_MESSAGE)]
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	392
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	393 def getDiscoItems(self, requestor, target, nodeIdentifier=""):
ecdb3728749e plugin XEP-0353: Jingle Message Initiation implementation: Goffi <goffi@goffi.org> parents: diff changeset	394 return []

Mercurial > libervia-backend

annotate libervia/backend/plugins/plugin_xep_0353.py @ 4212:5f2d496c633f