Mercurial > libervia-pubsub

changeset 30:ff7c73b253bf

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Recode backend to match interaces: one big Service that handles everything and several skeleton Services that declare the interface that they implement along with passing on calls to the 'implemented' methods.
author Ralph Meijer <ralphm@ik.nu>
date Tue, 26 Oct 2004 16:28:07 +0000
parents d4fc29bb5381
children fa866793075d
files idavoll/memory_backend.py
diffstat 1 files changed, 143 insertions(+), 105 deletions(-) [+]
line wrap: on
line diff
--- a/idavoll/memory_backend.py	Tue Oct 26 16:25:59 2004 +0000
+++ b/idavoll/memory_backend.py	Tue Oct 26 16:28:07 2004 +0000
@@ -4,141 +4,179 @@
 import backend
 
 class Subscription:
-	def __init__(self, state):
-		self.state = state
+    def __init__(self, state):
+        self.state = state
 
 class NodeConfiguration:
-	def __init__(self):
-		self.persist_items = False
-		self.deliver_payloads = False
+    def __init__(self):
+        self.persist_items = False
+        self.deliver_payloads = False
 
 class Node:
-	def __init__(self, id):
-		self.id = id
-		self.configuration = NodeConfiguration()
-		self.subscriptions = {}
-		self.affiliations = {}
-		self.items = {}
+    def __init__(self, id):
+        self.id = id
+        self.configuration = NodeConfiguration()
+        self.subscriptions = {}
+        self.affiliations = {}
+        self.items = {}
 
-class MemoryBackendService(service.Service):
+class BackendService(backend.BackendService):
 
-	__implements__ = backend.IService,
+    def __init__(self):
+        backend.BackendService.__init__(self)
 
-	def __init__(self):
-		self.nodes = {}
+        self.nodes = {}
 
-		node = Node("ralphm/mood/ralphm@ik.nu")
-		node.subscriptions["ralphm@doe.ik.nu"] = Subscription("subscribed")
-		node.subscriptions["notify@ik.nu/mood_monitor"] = Subscription("subscribed")
-		node.affiliations["ralphm@ik.nu"] = "owner"
-		node.affiliations["ralphm@doe.ik.nu"] = "publisher"
-		node.configuration.persist_items = True
-		node.configuration.deliver_payloads = True
-		self.nodes[node.id] = node
+        node = Node("ralphm/mood/ralphm@ik.nu")
+        node.subscriptions["ralphm@doe.ik.nu"] = Subscription("subscribed")
+        node.subscriptions["notify@ik.nu/mood_monitor"] = Subscription("subscribed")
+        node.affiliations["ralphm@ik.nu"] = "owner"
+        node.affiliations["ralphm@doe.ik.nu"] = "publisher"
+        node.configuration.persist_items = True
+        node.configuration.deliver_payloads = True
+        self.nodes[node.id] = node
+    
+    def get_supported_affiliations(self):
+        return ['none', 'owner', 'outcast', 'publisher']
 
-	def do_publish(self, node_id, publisher, items):
-		try:
-			node = self.nodes[node_id]
-			persist_items = node.configuration.persist_items
-			deliver_payloads = node.configuration.deliver_payloads
-		except KeyError:
-			raise backend.NodeNotFound
+    def create_node(self, node_id, requestor):
+        if not node_id:
+            raise backend.NoInstantNodes
+
+        if node_id in self.nodes:
+            raise backend.NodeExists
+    
+        node = Node(node_id)
+        node.affiliations[requestor.full()] = 'owner'
+        self.nodes[node_id] = node
+
+        return defer.succeed({'node_id': node.id})
 
-		try:
-			if node.affiliations[publisher] not in ['owner', 'publisher']:
-				raise backend.NotAuthorized
-		except KeyError:
-			raise backend.NotAuthorized
+    def publish(self, node_id, items, requestor):
+        try:
+            node = self.nodes[node_id]
+            persist_items = node.configuration.persist_items
+            deliver_payloads = node.configuration.deliver_payloads
+        except KeyError:
+            raise backend.NodeNotFound
 
-		if items and not persist_items and not deliver_payloads:
-			raise backend.NoPayloadAllowed
-		elif not items and (persist_items or deliver_payloads):
-			raise backend.PayloadExpected
+        try:
+            if node.affiliations[requestor.full()] not in \
+               ['owner', 'publisher']:
+                raise backend.NotAuthorized
+        except KeyError:
+            raise backend.NotAuthorized
 
-		print "publish by %s to %s" % (publisher, node_id)
+        if items and not persist_items and not deliver_payloads:
+            raise backend.NoPayloadAllowed
+        elif not items and (persist_items or deliver_payloads):
+            raise backend.PayloadExpected
+
+        print "publish by %s to %s" % (requestor.full(), node_id)
 
-		if persist_items or deliver_payloads:
-			for item in items:
-				if item["id"] is None:
-					item["id"] = 'random'	# FIXME
+        if persist_items or deliver_payloads:
+            for item in items:
+                if item["id"] is None:
+                    item["id"] = 'random'   # FIXME
 
-		if persist_items:
-			self.storeItems(node_id, publisher, items)
+        if persist_items:
+            self.store_items(node_id, items, requestor)
 
-		if items and not deliver_payloads:
-			for item in items:
-				item.children = []
+        if items and not deliver_payloads:
+            for item in items:
+                item.children = []
 
-		recipients = self.get_subscribers(node_id)
-		recipients.addCallback(self.magic_filter, node_id, items)
-		recipients.addCallback(self.pubsub_service.do_notification, node_id)
+        self.dispatch({ 'items': items, 'node_id': node_id },
+                             '//event/pubsub/notify')
+        return defer.succeed(None)
 
-		return defer.succeed(None)
+    def get_notification_list(self, node_id, items):
+        
+        try:
+            d = defer.succeed(self.nodes[node_id].subscriptions.keys())
+        except:
+            d = defer.fail()
 
-	def do_subscribe(self, node_id, subscriber, requestor):
-		# expect subscriber and requestor to be a jid.JID 
-		try:
-			node = self.nodes[node_id]
-		except KeyError:
-			raise backend.NodeNotFound
+        d.addCallback(self._magic_filter, node_id, items)
+
+        return d
 
-		affiliation = node.affiliations.get(requestor.full(), 'none')
+    def _magic_filter(self, subscribers, node_id, items):
+        list = {}
+        for subscriber in subscribers:
+            list[subscriber] = items
 
-		if affiliation == 'banned':
-			raise backend.NotAuthorized
+        return list
 
-		print subscriber.full()
-		print subscriber.userhostJID().full()
-		print requestor.full()
+    def subscribe(self, node_id, subscriber, requestor):
+        # expect subscriber and requestor to be a jid.JID 
+        try:
+            node = self.nodes[node_id]
+        except KeyError:
+            raise backend.NodeNotFound
 
-		if subscriber.userhostJID() != requestor:
-			raise backend.NotAuthorized
+        if subscriber.userhostJID() != requestor:
+            raise backend.NotAuthorized
 
-		try:
-			subscription = node.subscriptions[subscriber.full()]
-		except KeyError:
-			subscription = Subscription('subscribed')
-			node.subscriptions[subscriber.full()] = subscription
+        affiliation = node.affiliations.get(subscriber.full(), 'none')
+
+        if affiliation == 'outcast':
+            raise backend.NotAuthorized
 
-		print node.subscriptions
+        try:
+            subscription = node.subscriptions[subscriber.full()]
+        except KeyError:
+            subscription = Subscription('subscribed')
+            node.subscriptions[subscriber.full()] = subscription
+
+        print node.subscriptions
 
-		return defer.succeed({
-				'affiliation': affiliation,
-				'node': node_id,
-				'jid': subscriber,
-				'subscription': subscription.state})
-		
-	def magic_filter(self, subscribers, node_id, items):
-		list = {}
-		for subscriber in subscribers:
-			list[subscriber] = items
+        return defer.succeed({
+                'affiliation': affiliation,
+                'node': node_id,
+                'jid': subscriber,
+                'subscription': subscription.state})
+    
+    def store_items(self, node_id, items, publisher):
+        for item in items:
+            self.nodes[node_id].items[item["id"]] = item
+            print self.nodes[node_id].items
 
-		return list
+class NodeCreationService(service.Service):
+
+    __implements__ = backend.INodeCreationService,
 
-	def get_subscribers(self, node_id):
-		d = defer.Deferred()
-		try:
-			return defer.succeed(self.nodes[node_id].subscriptions.keys())
-		except:
-			return defer.fail()
+    def create_node(self, node_id, requestor):
+        return self.parent.create_node(node_id, requestor)
+
+class PublishService(service.Service):
 
-	def storeItems(self, node_id, publisher, items):
-		for item in items:
-			self.nodes[node_id].items[item["id"]] = item
+    __implements__ = backend.IPublishService,
+    
+    def publish(self, node_id, items, requestor):
+        return self.parent.publish(node_id, items, requestor)
+    
+class NotificationService(backend.NotificationService):
 
-		print self.nodes[node_id].items
+    __implements__ = backend.INotificationService,
 
-	def create_node(self, node_id, owner):
-		result = {}
+    def get_notification_list(self, node_id, items):
+        return self.parent.get_notification_list(node_id, items)
+
+class SubscriptionService(service.Service):
 
-		if not node_id:
-			raise backend.NoInstantNodes
+    __implements__ = backend.ISubscriptionService,
+
+    def subscribe(self, node_id, subscriber, requestor):
+        return self.parent.subscribe(node_id, subscriber, requestor)
+
+    def unsubscribe(self, node_id, subscriber, requestor):
+        raise backend.NotImplemented
 
-		if node_id in self.nodes:
-			raise backend.NodeExists
-	
-		node = Node(node_id)
-		node.affiliations[owner.full()] = 'owner'
-		self.nodes[node_id] = node
+class PersistenceService(service.Service):
+
+    __implements__ = backend.IPersistenceService,
 
-		return defer.succeed({'node_id': node.id})
+    def store_items(self, node_id, items, publisher):
+        return self.parent.store_items(node_id, items, publisher)
+