Mercurial > libervia-backend

comparison libervia/backend/plugins/plugin_comp_ap_gateway/ad_hoc.py @ 4071:4b842c1fb686

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
refactoring: renamed `sat` package to `libervia.backend`
author Goffi <goffi@goffi.org>
date Fri, 02 Jun 2023 11:49:51 +0200
parents sat/plugins/plugin_comp_ap_gateway/ad_hoc.py@524856bd7b19
children 0d7bb4df2343
comparison
equal deleted inserted replaced
4070:d10748475025 4071:4b842c1fb686
1 #!/usr/bin/env python3
2
3 # Libervia ActivityPub Gateway
4 # Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org)
5
6 # This program is free software: you can redistribute it and/or modify
7 # it under the terms of the GNU Affero General Public License as published by
8 # the Free Software Foundation, either version 3 of the License, or
9 # (at your option) any later version.
10
11 # This program is distributed in the hope that it will be useful,
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 # GNU Affero General Public License for more details.
15
16 # You should have received a copy of the GNU Affero General Public License
17 # along with this program. If not, see <http://www.gnu.org/licenses/>.
18
19 from twisted.words.protocols.jabber import jid
20 from twisted.words.xish import domish
21 from wokkel import data_form
22
23 from libervia.backend.core.constants import Const as C
24 from libervia.backend.core.core_types import SatXMPPEntity
25 from libervia.backend.core.i18n import _
26 from libervia.backend.core.log import getLogger
27
28
29 log = getLogger(__name__)
30 NS_XMPP_JID_NODE_2_AP = "https://libervia.org/ap_gateway/xmpp_jid_node_2_ap_actor"
31
32 class APAdHocService:
33 """Ad-Hoc commands for AP Gateway"""
34
35 def __init__(self, apg):
36 self.host = apg.host
37 self.apg = apg
38 self._c = self.host.plugins["XEP-0050"]
39
40 def init(self, client: SatXMPPEntity) -> None:
41 self._c.add_ad_hoc_command(
42 client,
43 self.xmpp_jid_node_2_ap_actor,
44 "Convert XMPP JID/Node to AP actor",
45 node=NS_XMPP_JID_NODE_2_AP,
46 allowed_magics=C.ENTITY_ALL,
47 )
48
49 async def xmpp_jid_node_2_ap_actor(
50 self,
51 client: SatXMPPEntity,
52 command_elt: domish.Element,
53 session_data: dict,
54 action: str,
55 node: str
56 ):
57 try:
58 x_elt = next(command_elt.elements(data_form.NS_X_DATA, "x"))
59 command_form = data_form.Form.fromElement(x_elt)
60 except StopIteration:
61 command_form = None
62 if command_form is None or len(command_form.fields) == 0:
63 # root request
64 status = self._c.STATUS.EXECUTING
65 form = data_form.Form(
66 "form", title="XMPP JID/node to AP actor conversion",
67 formNamespace=NS_XMPP_JID_NODE_2_AP
68 )
69
70 field = data_form.Field(
71 "text-single", "jid", required=True
72 )
73 form.addField(field)
74
75 field = data_form.Field(
76 "text-single", "node", required=False
77 )
78 form.addField(field)
79
80 payload = form.toElement()
81 return payload, status, None, None
82 else:
83 xmpp_jid = jid.JID(command_form["jid"])
84 xmpp_node = command_form.get("node")
85 actor = await self.apg.get_ap_account_from_jid_and_node(xmpp_jid, xmpp_node)
86 note = (self._c.NOTE.INFO, actor)
87 status = self._c.STATUS.COMPLETED
88 payload = None
89 return (payload, status, None, note)