Mercurial > libervia-backend
view src/tools/common/data_objects.py @ 2444:30278ea1ca7c
plugin XEP-0060: added node watching methods to bridge:
new methods psNodeWatchAdd and psNodeWatchRemove allows to set a watch for the time of the session on one node, to have a signal called when something change on this node.
This signal (psEventRaw) send raw data (raw XML), in opposition to psEvent which is there to send high level data (e.g. parsed blog data).
Those method are primarely there to let frontends manage local cache for pubsub nodes.
author | Goffi <goffi@goffi.org> |
---|---|
date | Sun, 19 Nov 2017 16:51:39 +0100 |
parents | 8b37a62336c3 |
children | 8788c217a49e |
line wrap: on
line source
#!/usr/bin/env python2 # -*- coding: utf-8 -*- # SAT: a jabber client # Copyright (C) 2009-2017 Jérôme Poisson (goffi@goffi.org) # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Affero General Public License for more details. # 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/>. """Objects handling bridge data, with jinja2 safe markup handling""" from sat.tools.common import data_format try: from jinja2 import Markup as safe except ImportError: safe = unicode class BlogItem(object): def __init__(self, mb_data): self.mb_data = mb_data self._tags = None self._groups = None self._comments = None self._comments_items_list = None @property def id(self): return self.mb_data.get(u'id') @property def atom_id(self): return self.mb_data.get(u'atom_id') @property def published(self): return self.mb_data.get(u'published') @property def updated(self): return self.mb_data.get(u'updated') @property def language(self): return self.mb_data.get(u'language') @property def author(self): return self.mb_data.get(u'author') @property def author_jid(self): return self.mb_data.get(u'author_jid') @property def author_jid_verified(self): return self.mb_data.get(u'author_jid_verified') @property def author_email(self): return self.mb_data.get(u'author_email') @property def tags(self): if self._tags is None: self._tags = data_format.dict2iter('tag', self.mb_data) return self._tags @property def groups(self): if self._groups is None: self._groups = data_format.dict2iter('group', self.mb_data) return self._groups @property def title(self): return self.mb_data.get(u'title') @property def title_xhtml(self): try: return safe(self.mb_data[u'title_xhtml']) except KeyError: return None @property def content(self): return self.mb_data.get(u'content') @property def content_xhtml(self): try: return safe(self.mb_data[u'content_xhtml']) except KeyError: return None @property def comments(self): if self._comments is None: self._comments = data_format.dict2iterdict(u'comments', self.mb_data, (u'node', u'service')) return self._comments @property def comments_service(self): return self.mb_data.get(u'comments_service') @property def comments_node(self): return self.mb_data.get(u'comments_node') @property def comments_items_list(self): return [] if self._comments_items_list is None else self._comments_items_list def appendCommentsItems(self, items): """append comments items to self.comments_items""" if self._comments_items_list is None: self._comments_items_list = [] self._comments_items_list.append(items) class BlogItems(object): def __init__(self, mb_data): self.mb_data = mb_data self.items = [BlogItem(i) for i in mb_data[0]] self.metadata = mb_data[1] @property def service(self): return self.metadata[u'service'] @property def node(self): return self.metadata[u'node'] @property def uri(self): return self.metadata[u'uri'] def __len__(self): return self.items.__len__() def __missing__(self, key): return self.items.__missing__(key) def __getitem__(self, key): return self.items.__getitem__(key) def __iter__(self): return self.items.__iter__() def __reversed__(self): return self.items.__reversed__() def __contains__(self, item): return self.items.__contains__(item) class Identity(object): def __init__(self, jid_str, data=None): self.jid_str = jid_str self.data = data if data is not None else {} @property def nick(self): return self.data.get(u'nick') class Identities(object): def __init__(self): self.identities = {} def __getitem__(self, jid_str): try: return self.identities[jid_str] except KeyError: return None def __setitem__(self, jid_str, data): self.identities[jid_str] = Identity(jid_str, data) def __contains__(self, jid_str): return jid_str in self.identities class OnClick(object): """Class to handle clickable elements targets""" def __init__(self, url=None): self.url = url def formatUrl(self, item): """Use an item to format URL item will be formatted using "item=item" in format() """ return self.url.format(item=item)