libervia-backend: libervia/backend/plugins/plugin_xep

annotate libervia/backend/plugins/plugin_xep_0471.py @ 4217:b53b6dc1f929

plugin XEP-0373: fix serialisation of `public_key_list`

author	Goffi <goffi@goffi.org>
date	Tue, 05 Mar 2024 17:31:36 +0100
parents	bc898879af34
children	0d7bb4df2343

rev	line source
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1 #!/usr/bin/env python3
3137 559a625a236b fixed shebangs Goffi <goffi@goffi.org> parents: 3136 diff changeset	2
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	3
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	4 # Libervia plugin to handle events
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	5 # Copyright (C) 2009-2022 Jérôme Poisson (goffi@goffi.org)
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	6
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	7 # This program is free software: you can redistribute it and/or modify
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	10 # (at your option) any later version.
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	11
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	12 # This program is distributed in the hope that it will be useful,
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	15 # GNU Affero General Public License for more details.
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	16
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	17 # You should have received a copy of the GNU Affero General Public License
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	19
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	20 from random import seed
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	21 from typing import Optional, Final, Dict, List, Union, Any, Optional
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	22 from attr import attr
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	23
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	24 import shortuuid
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	25 from sqlalchemy.orm.events import event
4071 4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	26 from libervia.backend.core.xmpp import SatXMPPClient
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	27 from libervia.backend.core.i18n import _
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	28 from libervia.backend.core import exceptions
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	29 from libervia.backend.core.constants import Const as C
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	30 from libervia.backend.core.log import getLogger
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	31 from libervia.backend.core.xmpp import SatXMPPEntity
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	32 from libervia.backend.core.core_types import SatXMPPEntity
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	33 from libervia.backend.tools import utils
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	34 from libervia.backend.tools import xml_tools
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	35 from libervia.backend.tools.common import uri as xmpp_uri
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	36 from libervia.backend.tools.common import date_utils
4b842c1fb686 refactoring: renamed `sat` package to `libervia.backend` Goffi <goffi@goffi.org> parents: 4037 diff changeset	37 from libervia.backend.tools.common import data_format
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	38 from twisted.internet import defer
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	39 from twisted.words.protocols.jabber import jid, error
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	40 from twisted.words.xish import domish
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	41 from wokkel import disco, iwokkel
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	42 from zope.interface import implementer
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	43 from twisted.words.protocols.jabber.xmlstream import XMPPHandler
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	44 from wokkel import pubsub, data_form
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	45
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	46 log = getLogger(__name__)
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	47
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	48
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	49 PLUGIN_INFO = {
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	50 C.PI_NAME: "Events",
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	51 C.PI_IMPORT_NAME: "XEP-0471",
26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	52 C.PI_TYPE: "XEP",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	53 C.PI_MODES: C.PLUG_MODE_BOTH,
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	54 C.PI_PROTOCOLS: [],
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	55 C.PI_DEPENDENCIES: [
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	56 "XEP-0060", "XEP-0080", "XEP-0447", "XEP-0470", # "INVITATION", "PUBSUB_INVITATION",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	57 # "LIST_INTEREST"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	58 ],
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	59 C.PI_RECOMMENDATIONS: ["XEP-0277", "EMAIL_INVITATION"],
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	60 C.PI_MAIN: "XEP_0471",
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	61 C.PI_HANDLER: "yes",
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	62 C.PI_DESCRIPTION: _("""Calendar Events"""),
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	63 }
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	64
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	65 NS_EVENT = "org.salut-a-toi.event:0"
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	66 NS_EVENTS: Final = "urn:xmpp:events:0"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	67 NS_RSVP: Final = "urn:xmpp:events:rsvp:0"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	68 NS_EXTRA: Final = "urn:xmpp:events:extra:0"
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	69
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	70
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	71 class XEP_0471:
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	72 namespace = NS_EVENTS
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	73
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	74 def __init__(self, host):
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	75 log.info(_("Events plugin initialization"))
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	76 self.host = host
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	77 self._p = host.plugins["XEP-0060"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	78 self._g = host.plugins["XEP-0080"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	79 self._b = host.plugins.get("XEP-0277")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	80 self._sfs = host.plugins["XEP-0447"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	81 self._a = host.plugins["XEP-0470"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	82 # self._i = host.plugins.get("EMAIL_INVITATION")
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	83 host.register_namespace("events", NS_EVENTS)
3956 3cb9ade2ab84 plugin pubsub signing: pubsub items signature implementation: Goffi <goffi@goffi.org> parents: 3915 diff changeset	84 self._a.register_attachment_handler("rsvp", NS_EVENTS, self.rsvp_get, self.rsvp_set)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	85 # host.plugins["PUBSUB_INVITATION"].register(NS_EVENTS, self)
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	86 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	87 "events_get",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	88 ".plugin",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	89 in_sign="ssasss",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	90 out_sign="s",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	91 method=self._events_get,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	92 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	93 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	94 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	95 "event_create",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	96 ".plugin",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	97 in_sign="sssss",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	98 out_sign="",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	99 method=self._event_create,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	100 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	101 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	102 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	103 "event_modify",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	104 ".plugin",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	105 in_sign="sssss",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	106 out_sign="",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	107 method=self._event_modify,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	108 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	109 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	110 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	111 "event_invitee_get",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	112 ".plugin",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	113 in_sign="sssasss",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	114 out_sign="s",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	115 method=self._event_invitee_get,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	116 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	117 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	118 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	119 "event_invitee_set",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	120 ".plugin",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	121 in_sign="sssss",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	122 out_sign="",
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	123 method=self._event_invitee_set,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	124 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	125 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	126 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	127 "event_invitees_list",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	128 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	129 in_sign="sss",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	130 out_sign="a{sa{ss}}",
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	131 method=self._event_invitees_list,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	132 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	133 ),
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	134 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	135 "event_invite",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	136 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	137 in_sign="sssss",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	138 out_sign="",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	139 method=self._invite,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	140 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	141 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	142 host.bridge.add_method(
524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	143 "event_invite_by_email",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	144 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	145 in_sign="ssssassssssss",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	146 out_sign="",
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	147 method=self._invite_by_email,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	148 async_=True,
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	149 )
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	150
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	151 def get_handler(self, client):
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	152 return EventsHandler(self)
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	153
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	154 def _parse_event_elt(self, event_elt):
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	155 """Helper method to parse event element
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	156
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	157 @param (domish.Element): event_elt
2941 83cbd4545274 plugin events: fixed invitation + set name and thumb_url from event element Goffi <goffi@goffi.org> parents: 2935 diff changeset	158 @return (tuple[int, dict[unicode, unicode]): timestamp, event_data
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	159 """
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	160 try:
2612 3e4e78de9cca tools (date_utils): moved date_parse to common.date_utils, because it can be used in frontends Goffi <goffi@goffi.org> parents: 2562 diff changeset	161 timestamp = date_utils.date_parse(next(event_elt.elements(NS_EVENT, "date")))
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	162 except StopIteration:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	163 timestamp = -1
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	164
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	165 data = {}
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	166
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	167 for key in ("name",):
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	168 try:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	169 data[key] = event_elt[key]
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	170 except KeyError:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	171 continue
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	172
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	173 for elt_name in ("description",):
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	174 try:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	175 elt = next(event_elt.elements(NS_EVENT, elt_name))
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	176 except StopIteration:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	177 continue
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	178 else:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	179 data[elt_name] = str(elt)
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	180
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	181 for elt_name in ("image", "background-image"):
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	182 try:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	183 image_elt = next(event_elt.elements(NS_EVENT, elt_name))
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	184 data[elt_name] = image_elt["src"]
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	185 except StopIteration:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	186 continue
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	187 except KeyError:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	188 log.warning(_("no src found for image"))
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	189
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	190 for uri_type in ("invitees", "blog"):
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	191 try:
2246 e8641b7718dc plugin events: fixed blog/invitees uri handling Goffi <goffi@goffi.org> parents: 2243 diff changeset	192 elt = next(event_elt.elements(NS_EVENT, uri_type))
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	193 uri = data[uri_type + "_uri"] = elt["uri"]
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	194 uri_data = xmpp_uri.parse_xmpp_uri(uri)
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	195 if uri_data["type"] != "pubsub":
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	196 raise ValueError
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	197 except StopIteration:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	198 log.warning(_("no {uri_type} element found!").format(uri_type=uri_type))
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	199 except KeyError:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	200 log.warning(_("incomplete {uri_type} element").format(uri_type=uri_type))
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	201 except ValueError:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	202 log.warning(_("bad {uri_type} element").format(uri_type=uri_type))
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	203 else:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	204 data[uri_type + "_service"] = uri_data["path"]
ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	205 data[uri_type + "_node"] = uri_data["node"]
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	206
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	207 for meta_elt in event_elt.elements(NS_EVENT, "meta"):
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	208 key = meta_elt["name"]
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	209 if key in data:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	210 log.warning(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	211 "Ignoring conflicting meta element: {xml}".format(
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	212 xml=meta_elt.toXml()
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	213 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	214 )
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	215 continue
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	216 data[key] = str(meta_elt)
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	217 if event_elt.link:
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	218 link_elt = event_elt.link
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	219 data["service"] = link_elt["service"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	220 data["node"] = link_elt["node"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	221 data["item"] = link_elt["item"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	222 if event_elt.getAttribute("creator") == "true":
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	223 data["creator"] = True
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	224 return timestamp, data
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	225
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	226 def event_elt_2_event_data(self, event_elt: domish.Element) -> Dict[str, Any]:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	227 """Convert <event/> element to event data
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	228
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	229 @param event_elt: <event/> element
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	230 parent <item/> element can also be used
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	231 @raise exceptions.NotFound: can't find event payload
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	232 @raise ValueError: something is missing or badly formed
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	233 """
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	234 if event_elt.name == "item":
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	235 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	236 event_elt = next(event_elt.elements(NS_EVENTS, "event"))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	237 except StopIteration:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	238 raise exceptions.NotFound("<event/> payload is missing")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	239
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	240 event_data: Dict[str, Any] = {}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	241
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	242 # id
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	243
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	244 parent_elt = event_elt.parent
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	245 if parent_elt is not None and parent_elt.hasAttribute("id"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	246 event_data["id"] = parent_elt["id"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	247
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	248 # name
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	249
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	250 name_data: Dict[str, str] = {}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	251 event_data["name"] = name_data
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	252 for name_elt in event_elt.elements(NS_EVENTS, "name"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	253 lang = name_elt.getAttribute("xml:lang", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	254 if lang in name_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	255 raise ValueError("<name/> elements don't have distinct xml:lang")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	256 name_data[lang] = str(name_elt)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	257
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	258 if not name_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	259 raise exceptions.NotFound("<name/> element is missing")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	260
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	261 # start
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	262
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	263 try:
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	264 start_elt = next(event_elt.elements(NS_EVENTS, "start"))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	265 except StopIteration:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	266 raise exceptions.NotFound("<start/> element is missing")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	267 event_data["start"] = utils.parse_xmpp_date(str(start_elt))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	268
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	269 # end
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	270
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	271 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	272 end_elt = next(event_elt.elements(NS_EVENTS, "end"))
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	273 except StopIteration:
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	274 raise exceptions.NotFound("<end/> element is missing")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	275 event_data["end"] = utils.parse_xmpp_date(str(end_elt))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	276
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	277 # head-picture
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	278
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	279 head_pic_elt = next(event_elt.elements(NS_EVENTS, "head-picture"), None)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	280 if head_pic_elt is not None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	281 event_data["head-picture"] = self._sfs.parse_file_sharing_elt(head_pic_elt)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	282
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	283 # description
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	284
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	285 seen_desc = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	286 for description_elt in event_elt.elements(NS_EVENTS, "description"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	287 lang = description_elt.getAttribute("xml:lang", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	288 desc_type = description_elt.getAttribute("type", "text")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	289 lang_type = (lang, desc_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	290 if lang_type in seen_desc:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	291 raise ValueError(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	292 "<description/> elements don't have distinct xml:lang/type"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	293 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	294 seen_desc.add(lang_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	295 descriptions = event_data.setdefault("descriptions", [])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	296 description_data = {"description": str(description_elt)}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	297 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	298 description_data["language"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	299 if desc_type:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	300 description_data["type"] = desc_type
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	301 descriptions.append(description_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	302
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	303 # categories
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	304
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	305 for category_elt in event_elt.elements(NS_EVENTS, "category"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	306 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	307 category_data = {
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	308 "term": category_elt["term"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	309 }
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	310 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	311 log.warning(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	312 "<category/> element is missing mandatory term: "
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	313 f"{category_elt.toXml()}"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	314 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	315 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	316 wd = category_elt.getAttribute("wd")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	317 if wd:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	318 category_data["wikidata_id"] = wd
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	319 lang = category_elt.getAttribute("xml:lang")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	320 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	321 category_data["language"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	322 event_data.setdefault("categories", []).append(category_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	323
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	324 # locations
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	325
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	326 seen_location_ids = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	327 for location_elt in event_elt.elements(NS_EVENTS, "location"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	328 location_id = location_elt.getAttribute("id", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	329 if location_id in seen_location_ids:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	330 raise ValueError("<location/> elements don't have distinct IDs")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	331 seen_location_ids.add(location_id)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	332 location_data = self._g.parse_geoloc_elt(location_elt)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	333 if location_id:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	334 location_data["id"] = location_id
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	335 lang = location_elt.getAttribute("xml:lang", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	336 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	337 location_data["language"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	338 event_data.setdefault("locations", []).append(location_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	339
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	340 # RSVPs
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	341
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	342 seen_rsvp_lang = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	343 for rsvp_elt in event_elt.elements(NS_EVENTS, "rsvp"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	344 rsvp_lang = rsvp_elt.getAttribute("xml:lang", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	345 if rsvp_lang in seen_rsvp_lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	346 raise ValueError("<rsvp/> elements don't have distinct xml:lang")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	347 seen_rsvp_lang.add(rsvp_lang)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	348 rsvp_form = data_form.findForm(rsvp_elt, NS_RSVP)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	349 if rsvp_form is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	350 log.warning(f"RSVP form is missing: {rsvp_elt.toXml()}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	351 continue
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	352 rsvp_data = xml_tools.data_form_2_data_dict(rsvp_form)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	353 if rsvp_lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	354 rsvp_data["language"] = rsvp_lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	355 event_data.setdefault("rsvp", []).append(rsvp_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	356
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	357 # linked pubsub nodes
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	358
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	359 for name in ("invitees", "comments", "blog", "schedule"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	360 elt = next(event_elt.elements(NS_EVENTS, name), None)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	361 if elt is not None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	362 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	363 event_data[name] = {
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	364 "service": elt["jid"],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	365 "node": elt["node"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	366 }
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	367 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	368 log.warning(f"invalid {name} element: {elt.toXml()}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	369
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	370 # attachments
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	371
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	372 attachments_elt = next(event_elt.elements(NS_EVENTS, "attachments"), None)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	373 if attachments_elt:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	374 attachments = event_data["attachments"] = []
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	375 for file_sharing_elt in attachments_elt.elements(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	376 self._sfs.namespace, "file-sharing"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	377 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	378 file_sharing_data = self._sfs.parse_file_sharing_elt(file_sharing_elt)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	379 except Exception as e:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	380 log.warning(f"invalid attachment: {e}\n{file_sharing_elt.toXml()}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	381 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	382 attachments.append(file_sharing_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	383
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	384 # extra
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	385
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	386 extra_elt = next(event_elt.elements(NS_EVENTS, "extra"), None)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	387 if extra_elt is not None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	388 extra_form = data_form.findForm(extra_elt, NS_EXTRA)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	389 if extra_form is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	390 log.warning(f"extra form is missing: {extra_elt.toXml()}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	391 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	392 extra_data = event_data["extra"] = {}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	393 for name, value in extra_form.items():
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	394 if name.startswith("accessibility:"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	395 extra_data.setdefault("accessibility", {})[name[14:]] = value
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	396 elif name == "accessibility":
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	397 log.warning(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	398 'ignoring "accessibility" key which is not standard: '
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	399 f"{extra_form.toElement().toXml()}"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	400 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	401 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	402 extra_data[name] = value
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	403
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	404 # external
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	405
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	406 external_elt = next(event_elt.elements(NS_EVENTS, "external"), None)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	407 if external_elt:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	408 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	409 event_data["external"] = {
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	410 "jid": external_elt["jid"],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	411 "node": external_elt["node"],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	412 "item": external_elt["item"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	413 }
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	414 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	415 log.warning(f"invalid <external/> element: {external_elt.toXml()}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	416
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	417 return event_data
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	418
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	419 def _events_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	420 self, service: str, node: str, event_ids: List[str], extra: str, profile_key: str
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	421 ):
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	422 client = self.host.get_client(profile_key)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	423 d = defer.ensureDeferred(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	424 self.events_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	425 client,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	426 jid.JID(service) if service else None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	427 node if node else NS_EVENTS,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	428 event_ids,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	429 data_format.deserialise(extra)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	430 )
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	431 )
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	432 d.addCallback(data_format.serialise)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	433 return d
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	434
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	435 async def events_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	436 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	437 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	438 service: Optional[jid.JID],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	439 node: str = NS_EVENTS,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	440 events_ids: Optional[List[str]] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	441 extra: Optional[dict] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	442 ) -> List[Dict[str, Any]]:
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	443 """Retrieve event data
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	444
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	445 @param service: pubsub service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	446 @param node: pubsub node
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	447 @param event_id: pubsub item ID
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	448 @return: event data:
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	449 """
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	450 if service is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	451 service = client.jid.userhostJID()
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	452 items, __ = await self._p.get_items(
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	453 client, service, node, item_ids=events_ids, extra=extra
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	454 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	455 events = []
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	456 for item in items:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	457 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	458 events.append(self.event_elt_2_event_data((item)))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	459 except (ValueError, exceptions.NotFound):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	460 log.warning(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	461 f"Can't parse event for item {item['id']}: {item.toXml()}"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	462 )
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	463
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	464 return events
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	465
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	466 def _event_create(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	467 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	468 data_s: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	469 service: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	470 node: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	471 event_id: str = "",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	472 profile_key: str = C.PROF_KEY_NONE
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	473 ):
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	474 client = self.host.get_client(profile_key)
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	475 return defer.ensureDeferred(
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	476 self.event_create(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	477 client,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	478 data_format.deserialise(data_s),
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	479 jid.JID(service) if service else None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	480 node or None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	481 event_id or None
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	482 )
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	483 )
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	484
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	485 def event_data_2_event_elt(self, event_data: Dict[str, Any]) -> domish.Element:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	486 """Convert Event Data to corresponding Element
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	487
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	488 @param event_data: data of the event with keys as follow:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	489 name (dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	490 map of language to name
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	491 empty string can be used as key if no language is specified
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	492 this key is mandatory
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	493 start (int\|float)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	494 starting time of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	495 this key is mandatory
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	496 end (int\|float)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	497 ending time of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	498 this key is mandatory
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	499 head-picture(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	500 file sharing data for the main picture to use to represent the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	501 description(list[dict])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	502 list of descriptions. If there are several descriptions, they must have
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	503 distinct (language, type).
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	504 Description data is dict which following keys:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	505 description(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	506 the description itself, either in plain text or xhtml
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	507 this key is mandatory
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	508 language(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	509 ISO-639 language code
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	510 type(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	511 type of the description, either "text" (default) or "xhtml"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	512 categories(list[dict])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	513 each category is a dict with following keys:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	514 term(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	515 human readable short text of the category
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	516 this key is mandatory
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	517 wikidata_id(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	518 Entity ID from WikiData
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	519 language(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	520 ISO-639 language code
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	521 locations(list[dict])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	522 list of location dict as used in plugin XEP-0080 [get_geoloc_elt].
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	523 If several locations are used, they must have distinct IDs
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	524 rsvp(list[dict])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	525 RSVP data. The dict is a data dict as used in
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	526 sat.tools.xml_tools.data_dict_2_data_form with some extra keys.
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	527 The "attending" key is automatically added if it's not already present,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	528 except if the "no_default" key is present. Thus, an empty dict can be used
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	529 to use default RSVP.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	530 If several dict are present in the list, they must have different "lang"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	531 keys.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	532 Following extra key can be used:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	533 language(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	534 ISO-639 code for language used in the form
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	535 no_default(bool)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	536 if True, the "attending" field won't be automatically added
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	537 invitees(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	538 link to pubsub node holding invitees list.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	539 Following keys are mandatory:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	540 service(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	541 pubsub service where the node is
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	542 node (str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	543 pubsub node to use
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	544 comments(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	545 link to pubsub node holding XEP-0277 comments on the event itself.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	546 Following keys are mandatory:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	547 service(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	548 pubsub service where the node is
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	549 node (str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	550 pubsub node to use
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	551 blog(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	552 link to pubsub node holding a blog about the event.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	553 Following keys are mandatory:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	554 service(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	555 pubsub service where the node is
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	556 node (str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	557 pubsub node to use
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	558 schedule(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	559 link to pubsub node holding an events node describing the schedule of this
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	560 event.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	561 Following keys are mandatory:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	562 service(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	563 pubsub service where the node is
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	564 node (str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	565 pubsub node to use
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	566 attachments[list[dict]]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	567 list of file sharing data about all kind of attachments of interest for
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	568 the event.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	569 extra(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	570 extra information about the event.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	571 Keys can be:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	572 website(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	573 main website about the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	574 status(str)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	575 status of the event.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	576 Can be one of "confirmed", "tentative" or "cancelled"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	577 languages(list[str])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	578 ISO-639 codes for languages which will be mainly spoken at the
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	579 event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	580 accessibility(dict)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	581 accessibility informations.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	582 Keys can be:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	583 wheelchair
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	584 tell if the event is accessible to wheelchair.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	585 Value can be "full", "partial" or "no"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	586 external(dict):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	587 if present, this event is a link to an external one.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	588 Keys (all mandatory) are:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	589 jid: pubsub service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	590 node: pubsub node
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	591 item: event id
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	592 @return: Event element
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	593 @raise ValueError: some expected data were missing or incorrect
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	594 """
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	595 event_elt = domish.Element((NS_EVENTS, "event"))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	596 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	597 for lang, name in event_data["name"].items():
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	598 name_elt = event_elt.addElement("name", content=name)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	599 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	600 name_elt["xml:lang"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	601 except (KeyError, TypeError):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	602 raise ValueError('"name" field is not a dict mapping language to event name')
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	603 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	604 event_elt.addElement("start", content=utils.xmpp_date(event_data["start"]))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	605 event_elt.addElement("end", content=utils.xmpp_date(event_data["end"]))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	606 except (KeyError, TypeError, ValueError):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	607 raise ValueError('"start" and "end" fields are mandatory')
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	608
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	609 if "head-picture" in event_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	610 head_pic_data = event_data["head-picture"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	611 head_picture_elt = event_elt.addElement("head-picture")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	612 head_picture_elt.addChild(self._sfs.get_file_sharing_elt(**head_pic_data))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	613
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	614 seen_desc = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	615 if "descriptions" in event_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	616 for desc_data in event_data["descriptions"]:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	617 desc_type = desc_data.get("type", "text")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	618 lang = desc_data.get("language") or ""
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	619 lang_type = (lang, desc_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	620 if lang_type in seen_desc:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	621 raise ValueError(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	622 '"xml:lang" and "type" is not unique among descriptions: '
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	623 f"{desc_data}"
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	624 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	625 seen_desc.add(lang_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	626 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	627 description = desc_data["description"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	628 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	629 log.warning(f"description is missing in {desc_data!r}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	630 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	631
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	632 if desc_type == "text":
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	633 description_elt = event_elt.addElement(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	634 "description", content=description
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	635 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	636 elif desc_type == "xhtml":
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	637 description_elt = event_elt.addElement("description")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	638 div_elt = xml_tools.parse(description, namespace=C.NS_XHTML)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	639 description_elt.addChild(div_elt)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	640 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	641 log.warning(f"unknown description type {desc_type!r}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	642 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	643 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	644 description_elt["xml:lang"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	645 for category_data in event_data.get("categories", []):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	646 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	647 category_term = category_data["term"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	648 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	649 log.warning(f'"term" is missing categories data: {category_data}')
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	650 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	651 category_elt = event_elt.addElement("category")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	652 category_elt["term"] = category_term
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	653 category_wd = category_data.get("wikidata_id")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	654 if category_wd:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	655 category_elt["wd"] = category_wd
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	656 category_lang = category_data.get("language")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	657 if category_lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	658 category_elt["xml:lang"] = category_lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	659
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	660 seen_location_ids = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	661 for location_data in event_data.get("locations", []):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	662 location_id = location_data.get("id", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	663 if location_id in seen_location_ids:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	664 raise ValueError("locations must have distinct IDs")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	665 seen_location_ids.add(location_id)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	666 location_elt = event_elt.addElement("location")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	667 location_elt.addChild(self._g.get_geoloc_elt(location_data))
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	668 if location_id:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	669 location_elt["id"] = location_id
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	670
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	671 rsvp_data_list: Optional[List[dict]] = event_data.get("rsvp")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	672 if rsvp_data_list is not None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	673 seen_lang = set()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	674 for rsvp_data in rsvp_data_list:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	675 if not rsvp_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	676 # we use a minimum data if an empty dict is received. It will be later
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	677 # filled with defaut "attending" field.
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	678 rsvp_data = {"fields": []}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	679 rsvp_elt = event_elt.addElement("rsvp")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	680 lang = rsvp_data.get("language", "")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	681 if lang in seen_lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	682 raise ValueError(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	683 "If several RSVP are specified, they must have distinct "
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	684 f"languages. {lang!r} language has been used several times."
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	685 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	686 seen_lang.add(lang)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	687 if lang:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	688 rsvp_elt["xml:lang"] = lang
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	689 if not rsvp_data.get("no_default", False):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	690 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	691 next(f for f in rsvp_data["fields"] if f["name"] == "attending")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	692 except StopIteration:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	693 rsvp_data["fields"].append({
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	694 "type": "list-single",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	695 "name": "attending",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	696 "label": "Attending",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	697 "options": [
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	698 {"label": "maybe", "value": "maybe"},
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	699 {"label": "yes", "value": "yes"},
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	700 {"label": "no", "value": "no"}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	701 ],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	702 "required": True
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	703 })
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	704 rsvp_data["namespace"] = NS_RSVP
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	705 rsvp_form = xml_tools.data_dict_2_data_form(rsvp_data)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	706 rsvp_elt.addChild(rsvp_form.toElement())
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	707
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	708 for node_type in ("invitees", "comments", "blog", "schedule"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	709 node_data = event_data.get(node_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	710 if not node_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	711 continue
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	712 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	713 service, node = node_data["service"], node_data["node"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	714 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	715 log.warning(f"invalid node data for {node_type}: {node_data}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	716 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	717 pub_node_elt = event_elt.addElement(node_type)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	718 pub_node_elt["jid"] = service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	719 pub_node_elt["node"] = node
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	720
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	721 attachments = event_data.get("attachments")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	722 if attachments:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	723 attachments_elt = event_elt.addElement("attachments")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	724 for attachment_data in attachments:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	725 attachments_elt.addChild(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	726 self._sfs.get_file_sharing_elt(**attachment_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	727 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	728
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	729 extra = event_data.get("extra")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	730 if extra:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	731 extra_form = data_form.Form(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	732 "result",
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	733 formNamespace=NS_EXTRA
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	734 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	735 for node_type in ("website", "status"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	736 if node_type in extra:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	737 extra_form.addField(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	738 data_form.Field(var=node_type, value=extra[node_type])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	739 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	740 if "languages" in extra:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	741 extra_form.addField(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	742 data_form.Field(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	743 "list-multi", var="languages", values=extra["languages"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	744 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	745 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	746 for node_type, value in extra.get("accessibility", {}).items():
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	747 extra_form.addField(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	748 data_form.Field(var=f"accessibility:{node_type}", value=value)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	749 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	750
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	751 extra_elt = event_elt.addElement("extra")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	752 extra_elt.addChild(extra_form.toElement())
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	753
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	754 if "external" in event_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	755 external_data = event_data["external"]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	756 external_elt = event_elt.addElement("external")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	757 for node_type in ("jid", "node", "item"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	758 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	759 value = external_data[node_type]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	760 except KeyError:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	761 raise ValueError(f"Invalid external data: {external_data}")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	762 external_elt[node_type] = value
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	763
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	764 return event_elt
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	765
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	766 async def event_create(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	767 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	768 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	769 event_data: Dict[str, Any],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	770 service: Optional[jid.JID] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	771 node: Optional[str] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	772 event_id: Optional[str] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	773 ) -> None:
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	774 """Create or replace an event
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	775
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	776 @param event_data: data of the event (cf. [event_data_2_event_elt])
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	777 @param node: PubSub node of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	778 None to use default node (default namespace for personal agenda)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	779 @param service: PubSub service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	780 None to use profile's PEP
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	781 @param event_id: ID of the item to create.
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	782 """
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	783 if not service:
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	784 service = client.jid.userhostJID()
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	785 if not node:
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	786 node = NS_EVENTS
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	787 if event_id is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	788 event_id = shortuuid.uuid()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	789 event_elt = self.event_data_2_event_elt(event_data)
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	790
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	791 item_elt = pubsub.Item(id=event_id, payload=event_elt)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	792 options = {self._p.OPT_ACCESS_MODEL: self._p.ACCESS_WHITELIST}
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	793 await self._p.create_if_new_node(
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	794 client, service, nodeIdentifier=node, options=options
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	795 )
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	796 await self._p.publish(client, service, node, items=[item_elt])
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	797 if event_data.get("rsvp"):
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	798 await self._a.create_attachments_node(client, service, node, event_id)
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	799
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	800 def _event_modify(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	801 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	802 data_s: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	803 event_id: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	804 service: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	805 node: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	806 profile_key: str = C.PROF_KEY_NONE
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	807 ) -> None:
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	808 client = self.host.get_client(profile_key)
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	809 defer.ensureDeferred(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	810 self.event_modify(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	811 client,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	812 data_format.deserialise(data_s),
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	813 event_id,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	814 jid.JID(service) if service else None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	815 node or None,
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	816 )
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	817 )
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	818
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	819 async def event_modify(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	820 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	821 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	822 event_data: Dict[str, Any],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	823 event_id: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	824 service: Optional[jid.JID] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	825 node: Optional[str] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	826 ) -> None:
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	827 """Update an event
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	828
5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	829 Similar as create instead that it update existing item instead of
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	830 creating or replacing it. Params are the same as for [event_create].
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	831 """
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	832 if not service:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	833 service = client.jid.userhostJID()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	834 if not node:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	835 node = NS_EVENTS
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	836 old_event = (await self.events_get(client, service, node, [event_id]))[0]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	837 old_event.update(event_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	838 event_data = old_event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	839 await self.event_create(client, event_data, service, node, event_id)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	840
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	841 def rsvp_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	842 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	843 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	844 attachments_elt: domish.Element,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	845 data: Dict[str, Any],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	846 ) -> None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	847 """Get RSVP answers from attachments"""
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	848 try:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	849 rsvp_elt = next(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	850 attachments_elt.elements(NS_EVENTS, "rsvp")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	851 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	852 except StopIteration:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	853 pass
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	854 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	855 rsvp_form = data_form.findForm(rsvp_elt, NS_RSVP)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	856 if rsvp_form is not None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	857 data["rsvp"] = rsvp_data = dict(rsvp_form)
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	858 self._a.set_timestamp(rsvp_elt, rsvp_data)
2243 5e12fc5ae52a plugin events: separation of event node and invitees node Goffi <goffi@goffi.org> parents: 2231 diff changeset	859
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	860 def rsvp_set(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	861 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	862 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	863 data: Dict[str, Any],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	864 former_elt: Optional[domish.Element]
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	865 ) -> Optional[domish.Element]:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	866 """update the <reaction> attachment"""
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	867 rsvp_data = data["extra"].get("rsvp")
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	868 if rsvp_data is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	869 return former_elt
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	870 elif rsvp_data:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	871 rsvp_elt = domish.Element(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	872 (NS_EVENTS, "rsvp"),
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	873 attribs = {
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	874 "timestamp": utils.xmpp_date()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	875 }
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	876 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	877 rsvp_form = data_form.Form("submit", formNamespace=NS_RSVP)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	878 rsvp_form.makeFields(rsvp_data)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	879 rsvp_elt.addChild(rsvp_form.toElement())
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	880 return rsvp_elt
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	881 else:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	882 return None
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	883
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	884 def _event_invitee_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	885 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	886 service: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	887 node: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	888 item: str,
4181 bc898879af34 plugin XEP-0471: modify variable name to be linter friendly. Goffi <goffi@goffi.org> parents: 4071 diff changeset	889 invitees: List[str],
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	890 extra: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	891 profile_key: str
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	892 ) -> defer.Deferred:
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	893 client = self.host.get_client(profile_key)
4181 bc898879af34 plugin XEP-0471: modify variable name to be linter friendly. Goffi <goffi@goffi.org> parents: 4071 diff changeset	894 if invitees:
bc898879af34 plugin XEP-0471: modify variable name to be linter friendly. Goffi <goffi@goffi.org> parents: 4071 diff changeset	895 invitees_jid = [jid.JID(i) for i in invitees]
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	896 else:
4181 bc898879af34 plugin XEP-0471: modify variable name to be linter friendly. Goffi <goffi@goffi.org> parents: 4071 diff changeset	897 invitees_jid = None
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	898 d = defer.ensureDeferred(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	899 self.event_invitee_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	900 client,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	901 jid.JID(service) if service else None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	902 node or None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	903 item,
4181 bc898879af34 plugin XEP-0471: modify variable name to be linter friendly. Goffi <goffi@goffi.org> parents: 4071 diff changeset	904 invitees_jid,
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	905 data_format.deserialise(extra)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	906 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	907 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	908 d.addCallback(lambda ret: data_format.serialise(ret))
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	909 return d
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	910
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	911 async def event_invitee_get(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	912 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	913 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	914 service: Optional[jid.JID],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	915 node: Optional[str],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	916 item: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	917 invitees: Optional[List[jid.JID]] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	918 extra: Optional[Dict[str, Any]] = None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	919 ) -> Dict[str, Dict[str, Any]]:
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	920 """Retrieve attendance from event node
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	921
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	922 @param service: PubSub service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	923 @param node: PubSub node of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	924 @param item: PubSub item of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	925 @param invitees: if set, only retrieve RSVPs from those guests
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	926 @param extra: extra data used to retrieve items as for [get_attachments]
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	927 @return: mapping of invitee bare JID to their RSVP
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	928 an empty dict is returned if nothing has been answered yed
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	929 """
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	930 if service is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	931 service = client.jid.userhostJID()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	932 if node is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	933 node = NS_EVENTS
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	934 attachments, metadata = await self._a.get_attachments(
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	935 client, service, node, item, invitees, extra
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	936 )
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	937 ret = {}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	938 for attachment in attachments:
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	939 try:
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	940 rsvp = attachment["rsvp"]
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	941 except KeyError:
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	942 continue
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	943 ret[attachment["from"]] = rsvp
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	944
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	945 return ret
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	946
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	947 def _event_invitee_set(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	948 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	949 service: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	950 node: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	951 item: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	952 rsvp_s: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	953 profile_key: str
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	954 ):
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	955 client = self.host.get_client(profile_key)
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	956 return defer.ensureDeferred(
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	957 self.event_invitee_set(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	958 client,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	959 jid.JID(service) if service else None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	960 node or None,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	961 item,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	962 data_format.deserialise(rsvp_s)
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	963 )
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	964 )
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	965
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	966 async def event_invitee_set(
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	967 self,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	968 client: SatXMPPEntity,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	969 service: Optional[jid.JID],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	970 node: Optional[str],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	971 item: str,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	972 rsvp: Dict[str, Any],
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	973 ) -> None:
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	974 """Set or update attendance data in event node
230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	975
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	976 @param service: PubSub service
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	977 @param node: PubSub node of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	978 @param item: PubSub item of the event
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	979 @param rsvp: RSVP data (values to submit to the form)
2231 230fc5b609a8 plugin event: first draft: Goffi <goffi@goffi.org> parents: diff changeset	980 """
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	981 if service is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	982 service = client.jid.userhostJID()
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	983 if node is None:
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	984 node = NS_EVENTS
3956 3cb9ade2ab84 plugin pubsub signing: pubsub items signature implementation: Goffi <goffi@goffi.org> parents: 3915 diff changeset	985 await self._a.set_attachements(client, {
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	986 "service": service.full(),
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	987 "node": node,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	988 "id": item,
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	989 "extra": {"rsvp": rsvp}
32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	990 })
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	991
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	992 def _event_invitees_list(self, service, node, profile_key):
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	993 service = jid.JID(service) if service else None
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	994 node = node if node else NS_EVENT
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	995 client = self.host.get_client(profile_key)
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	996 return defer.ensureDeferred(
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	997 self.event_invitees_list(client, service, node)
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	998 )
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	999
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1000 async def event_invitees_list(self, client, service, node):
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1001 """Retrieve attendance from event node
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1002
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1003 @param service(unicode, None): PubSub service
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1004 @param node(unicode): PubSub node of the event
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1005 @return (dict): a dict with current attendance status,
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1006 an empty dict is returned if nothing has been answered yed
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1007 """
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1008 items, metadata = await self._p.get_items(client, service, node)
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1009 invitees = {}
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1010 for item in items:
78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1011 try:
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1012 event_elt = next(item.elements(NS_EVENT, "invitee"))
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1013 except StopIteration:
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1014 # no item found, event data are not set yet
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	1015 log.warning(_(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1016 "no data found for {item_id} (service: {service}, node: {node})"
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	1017 .format(item_id=item["id"], service=service, node=node)))
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1018 else:
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1019 data = {}
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1020 for key in ("attend", "guests"):
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1021 try:
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1022 data[key] = event_elt[key]
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1023 except KeyError:
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1024 continue
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1025 invitees[item["id"]] = data
3584 edc79cefe968 plugin XEP-0060: `getItem(s)`, `publish` and `(un)subscribe` are now coroutines Goffi <goffi@goffi.org> parents: 3479 diff changeset	1026 return invitees
2294 78048f002a3c plugin events: added eventInviteesList method to get all R.S.V.P. at once. Goffi <goffi@goffi.org> parents: 2291 diff changeset	1027
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1028 async def invite_preflight(
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1029 self,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1030 client: SatXMPPEntity,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1031 invitee_jid: jid.JID,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1032 service: jid.JID,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1033 node: str,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1034 item_id: Optional[str] = None,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1035 name: str = '',
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1036 extra: Optional[dict] = None,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1037 ) -> None:
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1038 if self._b is None:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1039 raise exceptions.FeatureNotFound(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1040 _('"XEP-0277" (blog) plugin is needed for this feature')
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1041 )
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1042 if item_id is None:
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1043 item_id = extra["default_item_id"] = NS_EVENT
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1044
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	1045 __, event_data = await self.events_get(client, service, node, item_id)
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1046 log.debug(_("got event data"))
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1047 invitees_service = jid.JID(event_data["invitees_service"])
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1048 invitees_node = event_data["invitees_node"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1049 blog_service = jid.JID(event_data["blog_service"])
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1050 blog_node = event_data["blog_node"]
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1051 await self._p.set_node_affiliations(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1052 client, invitees_service, invitees_node, {invitee_jid: "publisher"}
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1053 )
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1054 log.debug(
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1055 f"affiliation set on invitee node (jid: {invitees_service}, "
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1056 f"node: {invitees_node!r})"
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1057 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1058 await self._p.set_node_affiliations(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1059 client, blog_service, blog_node, {invitee_jid: "member"}
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1060 )
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1061 blog_items, __ = await self._b.mb_get(client, blog_service, blog_node, None)
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1062
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1063 for item in blog_items:
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1064 try:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1065 comments_service = jid.JID(item["comments_service"])
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1066 comments_node = item["comments_node"]
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1067 except KeyError:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1068 log.debug(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1069 "no comment service set for item {item_id}".format(
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1070 item_id=item["id"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1071 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1072 )
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1073 else:
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1074 await self._p.set_node_affiliations(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1075 client, comments_service, comments_node, {invitee_jid: "publisher"}
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1076 )
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1077 log.debug(_("affiliation set on blog and comments nodes"))
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1078
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1079 def _invite(self, invitee_jid, service, node, item_id, profile):
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1080 return self.host.plugins["PUBSUB_INVITATION"]._send_pubsub_invitation(
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1081 invitee_jid, service, node, item_id or NS_EVENT, profile_key=profile
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1082 )
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1083
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	1084 def _invite_by_email(self, service, node, id_=NS_EVENT, email="", emails_extra=None,
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1085 name="", host_name="", language="", url_template="",
ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1086 message_subject="", message_body="",
2912 a3faf1c86596 plugin events: refactored invitation and personal lists logic: Goffi <goffi@goffi.org> parents: 2771 diff changeset	1087 profile_key=C.PROF_KEY_NONE):
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1088 client = self.host.get_client(profile_key)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1089 kwargs = {
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1090 "profile": client.profile,
ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1091 "emails_extra": [str(e) for e in emails_extra],
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1092 }
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1093 for key in (
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1094 "email",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1095 "name",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1096 "host_name",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1097 "language",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1098 "url_template",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1099 "message_subject",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1100 "message_body",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1101 ):
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1102 value = locals()[key]
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1103 kwargs[key] = str(value)
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	1104 return defer.ensureDeferred(self.invite_by_email(
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1105 client, jid.JID(service) if service else None, node, id_ or NS_EVENT, **kwargs
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1106 ))
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1107
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	1108 async def invite_by_email(self, client, service, node, id_=NS_EVENT, **kwargs):
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1109 """High level method to create an email invitation to an event
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1110
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1111 @param service(unicode, None): PubSub service
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1112 @param node(unicode): PubSub node of the event
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1113 @param id_(unicode): id_ with even data
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1114 """
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1115 if self._i is None:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1116 raise exceptions.FeatureNotFound(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1117 _('"Invitations" plugin is needed for this feature')
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1118 )
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1119 if self._b is None:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1120 raise exceptions.FeatureNotFound(
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1121 _('"XEP-0277" (blog) plugin is needed for this feature')
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1122 )
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1123 service = service or client.jid.userhostJID()
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1124 event_uri = xmpp_uri.build_xmpp_uri(
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1125 "pubsub", path=service.full(), node=node, item=id_
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1126 )
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1127 kwargs["extra"] = {"event_uri": event_uri}
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1128 invitation_data = await self._i.create(**kwargs)
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1129 invitee_jid = invitation_data["jid"]
ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1130 log.debug(_("invitation created"))
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1131 # now that we have a jid, we can send normal invitation
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1132 await self.invite(client, invitee_jid, service, node, id_)
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1133
4027 26c3e1bc7fb7 plugin XEP-0471: renamed "events" plugin to XEP-0471 now that there is a XEP Goffi <goffi@goffi.org> parents: 3956 diff changeset	1134 def on_invitation_preflight(
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1135 self,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1136 client: SatXMPPEntity,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1137 name: str,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1138 extra: dict,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1139 service: jid.JID,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1140 node: str,
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1141 item_id: Optional[str],
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1142 item_elt: domish.Element
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1143 ) -> None:
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1144 event_elt = item_elt.event
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1145 link_elt = event_elt.addElement("link")
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1146 link_elt["service"] = service.full()
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1147 link_elt["node"] = node
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1148 link_elt["item"] = item_id
4037 524856bd7b19 massive refactoring to switch from camelCase to snake_case: Goffi <goffi@goffi.org> parents: 4027 diff changeset	1149 __, event_data = self._parse_event_elt(event_elt)
3462 12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1150 try:
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1151 name = event_data["name"]
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1152 except KeyError:
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1153 pass
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1154 else:
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1155 extra["name"] = name
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1156 if 'image' in event_data:
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1157 extra["thumb_url"] = event_data['image']
12dc234f698c plugin invitation: pubsub invitations: Goffi <goffi@goffi.org> parents: 3137 diff changeset	1158 extra["element"] = event_elt
2287 ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1159
ea869f30f204 plugin events: added eventInvite command as a helper for the complex invitation workflow: Goffi <goffi@goffi.org> parents: 2272 diff changeset	1160
3028 ab2696e34d29 Python 3 port: Goffi <goffi@goffi.org> parents: 2941 diff changeset	1161 @implementer(iwokkel.IDisco)
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1162 class EventsHandler(XMPPHandler):
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1163
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1164 def __init__(self, plugin_parent):
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1165 self.plugin_parent = plugin_parent
1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1166
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1167 def getDiscoInfo(self, requestor, target, nodeIdentifier=""):
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1168 return [
3902 32b38dd3ac18 plugin events: update following `Events` protoXEP submission: Goffi <goffi@goffi.org> parents: 3709 diff changeset	1169 disco.DiscoFeature(NS_EVENTS),
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1170 ]
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1171
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2616 diff changeset	1172 def getDiscoItems(self, requestor, target, nodeIdentifier=""):
2616 1cc88adb5142 plugin events: invitations improvments + personal list Goffi <goffi@goffi.org> parents: 2612 diff changeset	1173 return []

Mercurial > libervia-backend

annotate libervia/backend/plugins/plugin_xep_0471.py @ 4217:b53b6dc1f929