libervia-pubsub: idavoll/backend.py comparison

Implemented ItemRetrievalService.

comparison

equal deleted inserted replaced

-:c40ccc30dfb7
+:ec354aab3949
 """ Removes all items in node from persistent storage """
 class IItemRetrievalService(components.Interface):
 """ A service for retrieving previously published items. """
-def get_items(self, node_id, max_items=None, item_ids=[],
+def get_items(self, node_id, requestor, max_items=None, item_ids=[]):
-requestor=None):
 """ Retrieve items from persistent storage
 If C{max_items} is given, return the C{max_items} last published
 items, else if C{item_ids} is not empty, return the items requested.
 If neither is given, return all items.
 'jid': subscriber,
 'affiliation': None,
 'subscription': subscription}
 return new_affiliations.values()
+class ItemRetrievalService(service.Service):
+__implements__ = IItemRetrievalService
+def get_items(self, node_id, requestor, max_items=None, item_ids=[]):
+d = self.parent.storage.is_subscribed(node_id, requestor)
+d.addCallback(self._do_get_items, node_id, max_items, item_ids)
+return d
+def _do_get_items(self, result, node_id, max_items, item_ids):
+def q(r):
+print r
+return r
+if not result:
+raise NotAuthorized
+if item_ids:
+d = self.parent.storage.get_items_by_ids(node_id, item_ids)
+d.addCallback(q)
+d.addErrback(q)
+return d
+else:
+return self.parent.storage.get_items(node_id, max_items)

Mercurial > libervia-pubsub