# HG changeset patch
# User Ralph Meijer <ralphm@ik.nu>
# Date 1099490621 0
# Node ID bc7438476a6700eeef1fab658a2332c6e7a2df12
# Parent  9685b7e291eff4643979721d7ba3a45b1cda2bcd
Removed IPersistenceService, this is a feature of the storage facility.
Moved implementation of backend services to their own class, matching the
interfaces.

diff -r 9685b7e291ef -r bc7438476a67 idavoll/backend.py
--- a/idavoll/backend.py	Mon Nov 01 12:37:40 2004 +0000
+++ b/idavoll/backend.py	Wed Nov 03 14:03:41 2004 +0000
@@ -108,12 +108,6 @@
         and subscriptions.
         """
 
-class IPersistenceService(components.Interface):
-    """ A service for persisting published items """
-
-    def store_items(self, node_id, items, publisher):
-        """ Store items for a node, recording the publisher """
-
 class IRetractionService(components.Interface):
     """ A service for retracting published items """
 
@@ -149,9 +143,13 @@
     def get_supported_affiliations(self):
         return ['none', 'owner', 'outcast', 'publisher']
 
+class PublishService(service.Service):
+    
+    __implements__ = IPublishService,
+
     def publish(self, node_id, items, requestor):
-        d1 = self.storage.get_node_configuration(node_id)
-        d2 = self.storage.get_affiliation(node_id, requestor.full())
+        d1 = self.parent.storage.get_node_configuration(node_id)
+        d2 = self.parent.storage.get_affiliation(node_id, requestor.full())
         d = defer.DeferredList([d1, d2], fireOnOneErrback=1)
         d.addErrback(lambda x: x.value[0])
         d.addCallback(self._do_publish, node_id, items, requestor)
@@ -180,7 +178,8 @@
                     item["id"] = 'random'   # FIXME
 
         if persist_items:
-            d = self.store_items(node_id, items, requestor.full())
+            d = self.parent.storage.store_items(node_id, items,
+                                                requestor.full())
         else:
             d = defer.succeed(None)
 
@@ -191,11 +190,15 @@
             for item in items:
                 item.children = []
 
-        self.dispatch({ 'items': items, 'node_id': node_id },
-                      '//event/pubsub/notify')
+        self.parent.dispatch({ 'items': items, 'node_id': node_id },
+                             '//event/pubsub/notify')
+
+class NotificationService(service.Service):
+
+    __implements__ = INotificationService,
 
     def get_notification_list(self, node_id, items):
-        d = self.storage.get_subscribers(node_id)
+        d = self.parent.storage.get_subscribers(node_id)
         d.addCallback(self._magic_filter, node_id, items)
         return d
 
@@ -206,11 +209,6 @@
 
         return list
 
-    def store_items(self, node_id, items, publisher):
-        return self.storage.store_items(node_id, items, publisher)
-
-class NotificationService(service.Service):
-
     def register_notifier(self, observerfn, *args, **kwargs):
         self.parent.addObserver('//event/pubsub/notify', observerfn,
                                 *args, **kwargs)