libervia-backend: sat/plugins/plugin_exp_list_of

comparison sat/plugins/plugin_exp_list_of_interest.py @ 3350:cc6164a4973b

plugin list of interests: normalize item ID + added `get` method

author	Goffi <goffi@goffi.org>
date	Sat, 05 Sep 2020 20:22:23 +0200
parents	7515e1878004
children	be6d91572633

comparison

equal deleted inserted replaced

-:2a7e36b69fd2
+:cc6164a4973b
 # You should have received a copy of the GNU Affero General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 from sat.core.i18n import _
 from sat.core.constants import Const as C
+from sat.core.xmpp import SatXMPPEntity
+from sat.core import exceptions
 from sat.core.log import getLogger
 from sat.tools.common import data_format
 from sat.tools.common import uri
 from wokkel import disco, iwokkel, pubsub
 from zope.interface import implementer
 PLUGIN_INFO = {
 C.PI_NAME: "List of Interest",
 C.PI_IMPORT_NAME: "LIST_INTEREST",
 C.PI_TYPE: "EXP",
 C.PI_PROTOCOLS: [],
-C.PI_DEPENDENCIES: ["XEP-0060", "XEP-0329"],
+C.PI_DEPENDENCIES: ["XEP-0060", "XEP-0329", "XEP-0106"],
 C.PI_RECOMMENDATIONS: [],
 C.PI_MAIN: "ListInterest",
 C.PI_HANDLER: "yes",
 C.PI_DESCRIPTION: _("Experimental handling of interesting XMPP locations"),
 }
 return defer.ensureDeferred(self.registerFileSharing(
 client, jid.JID(service), repos_type or None, namespace or None, path or None,
 name or None, extra
 ))
+def normaliseFileSharingService(self, client, service):
+# FIXME: Q&D fix as the bare file sharing service JID will lead to user own
+#   repository, which thus would not be the same for the host and the guest.
+#   By specifying the user part, we for the use of the host repository.
+#   A cleaner way should be implemented
+if service.user is None:
+service.user = self.host.plugins['XEP-0106'].escape(client.jid.user)
+def getFileSharingId(self, service, namespace, path):
+return f"{service}_{namespace or ''}_{path or ''}"
 async def registerFileSharing(
 self, client, service, repos_type=None, namespace=None, path=None, name=None,
 extra=None):
 """Register an interesting file repository in personal list
 @param name(unicode, None): name of the repository
 @param extra(dict, None): same as [registerPubsub]
 """
 if extra is None:
 extra = {}
+self.normaliseFileSharingService(client, service)
 await self.createNode(client)
+item_id = self.getFileSharingId(service, namespace, path)
 interest_elt = domish.Element((NS_LIST_INTEREST, "interest"))
 interest_elt["namespace"] = self.host.getNamespace("fis")
 if name is not None:
 interest_elt['name'] = name
 thumb_url = extra.get('thumb_url')
 if thumb_url:
 interest_elt['thumb_url'] = thumb_url
 file_sharing_elt = interest_elt.addElement("file_sharing")
 file_sharing_elt["service"] = service.full()
 if repos_type is not None:
 file_sharing_elt["type"] = repos_type
 if namespace is not None:
 file_sharing_elt["namespace"] = namespace
 if path is not None:
 file_sharing_elt["path"] = path
-item_id = f"{service}_{namespace or ''}_{path or ''}"
 item_elt = pubsub.Item(item_id, payload=interest_elt)
 await self._p.publish(
 client, client.jid.userhostJID(), NS_LIST_INTEREST, items=[item_elt]
 )
 d = self._p._retractItem(
 service_s, NS_LIST_INTEREST, item_id, True, profile_key)
 d.addCallback(lambda __: None)
 return d
+async def get(self, client: SatXMPPEntity, item_id: str) -> dict:
+"""Retrieve a specific interest in profile's list"""
+items_data = await self._p.getItems(client, None, NS_LIST_INTEREST, item_ids=[item_id])
+try:
+return self._listInterestsSerialise(items_data)[0]
+except IndexError:
+raise exceptions.NotFound
 @implementer(iwokkel.IDisco)
 class ListInterestHandler(XMPPHandler):
 def __init__(self, plugin_parent):

Mercurial > libervia-backend

comparison sat/plugins/plugin_exp_list_of_interest.py @ 3350:cc6164a4973b