# HG changeset patch
# User Ralph Meijer <ralphm@ik.nu>
# Date 1098021094 0
# Node ID 4f3bbefc6fad0caef6a16575f43de933b9d02844
# Parent  88426868722929345ced1d9a9c4d9fca99453ee9
Moved memory backend to its own file.
Cleaned up exceptions, naming.

diff -r 884268687229 -r 4f3bbefc6fad idavoll/backend.py
--- a/idavoll/backend.py	Thu Oct 07 15:57:05 2004 +0000
+++ b/idavoll/backend.py	Sun Oct 17 13:51:34 2004 +0000
@@ -1,178 +1,31 @@
-from twisted.application import service
-from twisted.python import components, failure
-from twisted.internet import defer, reactor
-from twisted.protocols.jabber import jid
+from twisted.python import components
 
-class IBackendService(components.Interface):
+class IService(components.Interface):
 	""" Interface to a backend service of a pubsub service """
 
 	def do_publish(self, node, publisher, item):
 		""" Returns a deferred that returns """
 
-class BackendException(Exception):
-	def __init__(self, msg = ''):
-		self.msg = msg
+class Error(Exception):
+	msg = ''
 
 	def __str__(self):
 		return self.msg
 	
-class NodeNotFound(BackendException):
-	def __init__(self, msg = 'Node not found'):
-		BackendException.__init__(self, msg)
-
-class NotAuthorized(BackendException):
-	pass
+class NodeNotFound(Error):
+	msg = 'Node not found'
 
-class PayloadExpected(BackendException):
-	def __init__(self, msg = 'Payload expected'):
-		BackendException.__init__(self, msg)
-
-class NoPayloadAllowed(BackendException):
-	def __init__(self, msg = 'No payload allowed'):
-		BackendException.__init__(self, msg)
-
-class NoInstantNodes(BackendException):
-	pass
-
-class NodeExists(BackendException):
+class NotAuthorized(Error):
 	pass
 
-class Subscription:
-	def __init__(self, state):
-		self.state = state
-
-class NodeConfiguration:
-	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 = {}
-
-class MemoryBackendService(service.Service):
-
-	__implements__ = IBackendService,
-
-	def __init__(self):
-		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
+class PayloadExpected(Error):
+	msg = 'Payload expected'
 
-	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 NodeNotFound
-
-		try:
-			if node.affiliations[publisher] not in ['owner', 'publisher']:
-				raise NotAuthorized
-		except KeyError:
-			raise NotAuthorized()
-
-		if items and not persist_items and not deliver_payloads:
-			raise NoPayloadAllowed
-		elif not items and (persist_items or deliver_payloads):
-			raise PayloadExpected
-
-		print "publish by %s to %s" % (publisher, node_id)
-
-		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 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)
+class NoPayloadAllowed(Error):
+	msg = 'No payload allowed'
 
-		return defer.succeed(None)
-
-	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 NodeNotFound
-
-		affiliation = node.affiliations.get(requestor.full(), 'none')
-
-		if affiliation == 'banned':
-			raise NotAuthorized
-
-		print subscriber.full()
-		print subscriber.userhostJID().full()
-		print requestor.full()
-
-		if subscriber.userhostJID() != requestor:
-			raise NotAuthorized
-
-		try:
-			subscription = node.subscriptions[subscriber.full()]
-		except KeyError:
-			subscription = Subscription('subscribed')
-			node.subscriptions[subscriber.full()] = subscription
-
-		print node.subscriptions
+class NoInstantNodes(Error):
+	pass
 
-		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 list
-
-	def get_subscribers(self, node_id):
-		d = defer.Deferred()
-		try:
-			return defer.succeed(self.nodes[node_id].subscriptions.keys())
-		except:
-			return defer.fail()
-
-	def storeItems(self, node_id, publisher, items):
-		for item in items:
-			self.nodes[node_id].items[item["id"]] = item
-
-		print self.nodes[node_id].items
-
-	def create_node(self, node_id, owner):
-		result = {}
-
-		if not node_id:
-			raise NoInstantNodes
-
-		if node_id in self.nodes:
-			raise NodeExists
-	
-		node = Node(node_id)
-		node.affiliations[owner.full()] = 'owner'
-		self.nodes[node_id] = node
-
-		return defer.succeed({'node_id': node.id})
+class NodeExists(Error):
+	pass