|
3904
|
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 sat.core.constants import Const as C |
|
|
24 from sat.core.core_types import SatXMPPEntity |
|
|
25 from sat.core.i18n import _ |
|
|
26 from sat.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.addAdHocCommand( |
|
|
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.getAPAccountFromJidAndNode(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) |
