Mercurial > libervia-pubsub
changeset 24:4f3bbefc6fad
Moved memory backend to its own file.
Cleaned up exceptions, naming.
author | Ralph Meijer <ralphm@ik.nu> |
---|---|
date | Sun, 17 Oct 2004 13:51:34 +0000 (2004-10-17) |
parents | 884268687229 |
children | 256dcda26752 |
files | idavoll/backend.py |
diffstat | 1 files changed, 15 insertions(+), 162 deletions(-) [+] |
line wrap: on
line diff
--- 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