libervia-backend: libervia/backend/plugins/plugin_xep

annotate libervia/backend/plugins/plugin_xep_0272.py @ 4301:9deb3ddb2921

CLI: add commands to handle gateways: rel 449

author	Goffi <goffi@goffi.org>
date	Fri, 06 Sep 2024 18:03:01 +0200
parents	0d7bb4df2343
children

rev	line source
4245 a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	1 #!/usr/bin/env python3
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	2
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	3 # Copyright (C) 2009-2022 Jérôme Poisson (goffi@goffi.org)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	4
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	5 # This program is free software: you can redistribute it and/or modify
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	6 # it under the terms of the GNU Affero General Public License as published by
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	7 # the Free Software Foundation, either version 3 of the License, or
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	8 # (at your option) any later version.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	9
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	10 # This program is distributed in the hope that it will be useful,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	11 # but WITHOUT ANY WARRANTY; without even the implied warranty of
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	13 # GNU Affero General Public License for more details.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	14
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	15 # You should have received a copy of the GNU Affero General Public License
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	16 # along with this program. If not, see <http://www.gnu.org/licenses/>.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	17
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	18 from twisted.internet import defer
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	19 from twisted.words.protocols.jabber import jid
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	20 from twisted.words.protocols.jabber.xmlstream import XMPPHandler
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	21 from twisted.words.xish import domish
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	22 from wokkel import disco, iwokkel
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	23 from wokkel import muc
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	24 from zope.interface import implementer
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	25
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	26 from libervia.backend.core import exceptions
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	27 from libervia.backend.core.constants import Const as C
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	28 from libervia.backend.core.core_types import SatXMPPEntity
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	29 from libervia.backend.core.i18n import _
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	30 from libervia.backend.core.log import getLogger
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	31 from libervia.backend.plugins import plugin_xep_0166
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	32 from libervia.backend.plugins import plugin_xep_0167
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	33 from libervia.backend.plugins.plugin_xep_0167 import mapping
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	34 from libervia.backend.tools.common import data_format
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	35
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	36 from . import plugin_xep_0045, plugin_xep_0249
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	37
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	38 log = getLogger(__name__)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	39
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	40
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	41 PLUGIN_INFO = {
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	42 C.PI_NAME: "Multiparty Jingle (Muji)",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	43 C.PI_IMPORT_NAME: "XEP-0272",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	44 C.PI_TYPE: "XEP",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	45 C.PI_PROTOCOLS: ["XEP-0272"],
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	46 C.PI_DEPENDENCIES: ["XEP-0045", "XEP-0166", "XEP-0167", "XEP-0249"],
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	47 C.PI_MAIN: "XEP_0272",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	48 C.PI_HANDLER: "yes",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	49 C.PI_DESCRIPTION: _(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	50 "Allow to run A/V conference with several participant using P2P connections. "
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	51 "The number of participant must not be to big to make it work correctly."
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	52 ),
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	53 }
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	54
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	55 NS_MUJI = "http://telepathy.freedesktop.org/muji"
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	56 PRESENCE_MUJI = f'/presence/muji[@xmlns="{NS_MUJI}"]'
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	57
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	58
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	59 class XEP_0272:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	60
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	61 def __init__(self, host):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	62 log.info(f'Plugin "{PLUGIN_INFO[C.PI_NAME]}" initialization')
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	63 self.host = host
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	64 host.register_namespace("muji", NS_MUJI)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	65 self._muc: plugin_xep_0045.XEP_0045 = host.plugins["XEP-0045"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	66 self._muc_invite: plugin_xep_0249.XEP_0249 = host.plugins["XEP-0249"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	67 self._j: plugin_xep_0166.XEP_0166 = host.plugins["XEP-0166"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	68 self._rtp: plugin_xep_0167.XEP_0167 = host.plugins["XEP-0167"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	69 host.bridge.add_method(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	70 "call_group_start",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	71 ".plugin",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	72 in_sign="asss",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	73 out_sign="s",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	74 method=self._call_group_start,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	75 async_=True,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	76 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	77 host.bridge.add_method(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	78 "call_group_data_set",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	79 ".plugin",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	80 in_sign="sss",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	81 out_sign="",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	82 method=self._call_group_data_set,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	83 async_=True,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	84 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	85 host.bridge.add_signal("call_group_setup", ".plugin", signature="sss")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	86
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	87 def get_handler(self, client):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	88 return XEP_0272_handler(self)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	89
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	90 def _call_group_start(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	91 self,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	92 entities_s: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	93 extra_s: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	94 profile_key: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	95 ) -> defer.Deferred[str]:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	96 client = self.host.get_client(profile_key)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	97 d = defer.ensureDeferred(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	98 self.call_group_start(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	99 client, [jid.JID(e) for e in entities_s], data_format.deserialise(extra_s)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	100 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	101 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	102 d.addCallback(data_format.serialise)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	103 return d
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	104
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	105 def _call_group_data_set(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	106 self,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	107 room_jid_s: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	108 call_data_s: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	109 profile_key: str,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	110 ) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	111 client = self.host.get_client(profile_key)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	112 defer.ensureDeferred(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	113 self.call_group_data_set(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	114 client, jid.JID(room_jid_s), data_format.deserialise(call_data_s)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	115 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	116 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	117
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	118 async def on_room_join(self, room: muc.Room, user: muc.User) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	119 pass
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	120
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	121 async def on_room_left(self, room: muc.Room, user: muc.User) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	122 pass
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	123
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	124 def on_muji_request(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	125 self, presence_elt: domish.Element, client: SatXMPPEntity
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	126 ) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	127 from_jid = jid.JID(presence_elt["from"])
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	128 room_jid = from_jid.userhostJID()
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	129 try:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	130 room = self._muc.get_room(client, room_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	131 except exceptions.NotFound:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	132 log.warning(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	133 f"Ignoring MUJI element from an unknown room: {presence_elt.toXml()}"
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	134 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	135 return
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	136 if from_jid == self._muc.get_room_user_jid(client, room_jid):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	137 own_jid = True
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	138 else:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	139 own_jid = False
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	140 muji_data = self.get_muji_data(room)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	141 muji_elt = presence_elt.muji
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	142 assert muji_elt is not None
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	143 try:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	144 next(muji_elt.elements(NS_MUJI, "preparing"))
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	145 except StopIteration:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	146 preparing_state = False
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	147 else:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	148 preparing_state = True
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	149
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	150 if preparing_state:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	151 if own_jid:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	152 # we have received the broadcast of our own preparation message
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	153 muji_data["done_collecting"] = True
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	154 self.try_to_finish_preparation(client, room, muji_data)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	155 elif not muji_data.get("done_collecting", False):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	156 # other entities currently doing preparation
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	157 preparing_jids = muji_data["preparing_jids"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	158 preparing_jids.add(from_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	159 elif not own_jid:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	160 done_preparing = muji_data.get("done_preparing", False)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	161 # if we are still in preparation, we remove the JID from data data we are
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	162 # still waiting for, and we check if we can finish the preparation.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	163 if not done_preparing:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	164 allowed_payloads = muji_data.setdefault("allowed_payloads")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	165 # TODO: check allowed_payloads
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	166 preparing_jids = muji_data["preparing_jids"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	167 preparing_jids.discard(from_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	168 log.debug(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	169 f"[{client.profile}] received call data for {from_jid}.\n"
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	170 f"{preparing_jids=}"
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	171 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	172 muji_data["to_call"].add(from_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	173 self.try_to_finish_preparation(client, room, muji_data)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	174
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	175 def try_to_finish_preparation(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	176 self, client: SatXMPPEntity, room: muc.Room, muji_data: dict
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	177 ) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	178 """Finish preparation if possible.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	179
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	180 This method checks if preparations of other JIDs needs to be waited, and if not,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	181 finishes our own preparation.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	182 """
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	183 preparing_jids = muji_data.get("preparing_jids")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	184 if not preparing_jids:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	185 # No preparation left to wait, we can finish our own.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	186 muji_data = self.get_muji_data(room)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	187 muji_data["done_preparing"] = True
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	188
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	189 log.debug(f"[{client.profile}] Done preparing.")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	190
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	191 # We ask frontend to initiate the session, so we know supported codecs.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	192 self.host.bridge.call_group_setup(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	193 room.roomJID.full(),
4270 0d7bb4df2343 Reformatted code base using black. Goffi <goffi@goffi.org> parents: 4245 diff changeset	194 data_format.serialise(
0d7bb4df2343 Reformatted code base using black. Goffi <goffi@goffi.org> parents: 4245 diff changeset	195 {"to_call": [entity.full() for entity in muji_data["to_call"]]}
0d7bb4df2343 Reformatted code base using black. Goffi <goffi@goffi.org> parents: 4245 diff changeset	196 ),
4245 a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	197 client.profile,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	198 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	199
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	200 async def call_group_data_set(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	201 self,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	202 client: SatXMPPEntity,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	203 room_jid: jid.JID,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	204 call_data: dict,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	205 ) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	206 """Called when frontends has prepared group call.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	207
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	208 Group call data will be advertised on the MUC, and call will be initiated with all
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	209 participant which where in preparing state when we made our own preparation.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	210
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	211 @param client: SatXMPPEntity instance.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	212 @param room_jid: JID of the room used for MUJI coordination.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	213 @param call_data: call data similar to the one used in ``XEP-0167.call_start``.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	214 """
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	215 try:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	216 room = self._muc.get_room(client, room_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	217 except exceptions.NotFound:
4270 0d7bb4df2343 Reformatted code base using black. Goffi <goffi@goffi.org> parents: 4245 diff changeset	218 log.warning(f"Ignoring MUJI element from an unknown room: {room_jid}")
4245 a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	219 return
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	220 sdp_data = mapping.parse_sdp(call_data["sdp"], self._j.ROLE_INITIATOR)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	221 presence_elt, muji_elt = self.generate_presence_and_muji(client, room)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	222 for media_type, media_data in sdp_data.items():
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	223 if media_type in ["audio", "video"]:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	224 application_data = media_data["application_data"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	225 content_elt = muji_elt.addElement("content")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	226 # XXX: the initiator will be actually the last to join, but this attribute
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	227 # will be ignored anyway.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	228 content_elt["creator"] = self._j.ROLE_INITIATOR
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	229 content_elt["name"] = media_data["id"]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	230 description_elt = mapping.build_description(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	231 media_type, application_data, {}
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	232 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	233 content_elt.addChild(description_elt)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	234
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	235 # we only want to keep payload types
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	236 to_remove = []
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	237 for child_elt in description_elt.children:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	238 if child_elt.name != "payload-type":
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	239 to_remove.append(child_elt)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	240 for elt in to_remove:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	241 description_elt.children.remove(elt)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	242
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	243 await client.a_send(presence_elt)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	244
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	245 def get_muji_data(self, room: muc.Room) -> dict:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	246 """Get MUJI related data for this room
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	247
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	248 MUJI data is stored in the room object, so it will be deleted when the room object
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	249 itself will be deleted.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	250 """
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	251 try:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	252 return room._xep_0272_data
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	253 except AttributeError:
4270 0d7bb4df2343 Reformatted code base using black. Goffi <goffi@goffi.org> parents: 4245 diff changeset	254 data = room._xep_0272_data = {"preparing_jids": set(), "to_call": set()}
4245 a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	255 return data
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	256
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	257 def generate_presence_and_muji(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	258 self, client: SatXMPPEntity, room: muc.Room
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	259 ) -> tuple[domish.Element, domish.Element]:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	260 """Generate a <presence> stanza with MUJI element"""
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	261 presence_elt = domish.Element((None, "presence"))
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	262 presence_elt["from"] = client.jid.full()
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	263 presence_elt["to"] = room.roomJID.full()
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	264 muji_elt = presence_elt.addElement((NS_MUJI, "muji"))
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	265 return presence_elt, muji_elt
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	266
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	267 async def start_preparation(self, client: SatXMPPEntity, room: muc.Room) -> None:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	268 """Start preparation of MUJI"""
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	269 presence_elt, muji_elt = self.generate_presence_and_muji(client, room)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	270 muji_elt.addElement("preparing")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	271 await client.a_send(presence_elt)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	272
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	273 async def call_group_start(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	274 self,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	275 client: SatXMPPEntity,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	276 entities: list[jid.JID],
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	277 extra: dict,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	278 ) -> dict:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	279 """Initiate a group call with the given peers.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	280
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	281 A MUC room will be created, and people in ``list_entities`` will be invited. MUJI
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	282 session will then been started which each of them upon they arrival.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	283 @param entities: JID of the peer to initiate a call session with.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	284 @param extra: Extra data.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	285
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	286 @return: group call data, with the following keys:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	287
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	288 ``room_jid``
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	289 MUC room where the MUJI coordination is done. It may also be used for
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	290 normal chatting.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	291
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	292 @raise exceptions.ExternalRequestError: The MUC room can't be created or joined.
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	293 """
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	294 log.debug(f"{client.profile} is starting a MUJI group call with {entities}")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	295 room_jid = self._muc.get_unique_name(client, prefix="_muji_")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	296 room = await self._muc.join(client, room_jid)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	297 log.info(f"[{client.profile}] MUJI room created at {room_jid}")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	298 if not room:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	299 raise exceptions.ExternalRequestError("Can't create or join group chat room.")
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	300 await self.start_preparation(client, room)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	301 room.on_joined_callbacks.append(self.on_room_join)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	302 room.on_left_callbacks.append(self.on_room_left)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	303 for entity in entities:
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	304 self._muc_invite.invite(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	305 client,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	306 entity,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	307 room_jid,
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	308 reason="You have been invited to participate in a group call.",
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	309 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	310 return {"room_jid": room_jid.full()}
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	311
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	312
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	313 @implementer(iwokkel.IDisco)
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	314 class XEP_0272_handler(XMPPHandler):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	315
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	316 def __init__(self, plugin_parent):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	317 self.plugin_parent = plugin_parent
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	318
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	319 def connectionInitialized(self):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	320 self.xmlstream.addObserver(
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	321 PRESENCE_MUJI, self.plugin_parent.on_muji_request, client=self.parent
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	322 )
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	323
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	324 def getDiscoInfo(self, requestor, target, nodeIdentifier=""):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	325 return [disco.DiscoFeature(NS_MUJI)]
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	326
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	327 def getDiscoItems(self, requestor, target, nodeIdentifier=""):
a7d4007a8fa5 plugin XEP-0272: implement XEP-0272: Multiparty Jingle (Muji) Goffi <goffi@goffi.org> parents: diff changeset	328 return []

Mercurial > libervia-backend

annotate libervia/backend/plugins/plugin_xep_0272.py @ 4301:9deb3ddb2921