Mercurial > libervia-pubsub
diff idavoll/memory_storage.py @ 167:ef22e4150caa
Move protocol implementations (pubsub, disco, forms) to and depend on wokkel.
Author: ralphm
Fixes: #4
author | Ralph Meijer <ralphm@ik.nu> |
---|---|
date | Wed, 03 Oct 2007 12:41:43 +0000 |
parents | 5191ba7c4df8 |
children | bc269696ef42 |
line wrap: on
line diff
--- a/idavoll/memory_storage.py Thu Jan 18 14:08:32 2007 +0000 +++ b/idavoll/memory_storage.py Wed Oct 03 12:41:43 2007 +0000 @@ -1,18 +1,19 @@ -# Copyright (c) 2003-2006 Ralph Meijer +# Copyright (c) 2003-2007 Ralph Meijer # See LICENSE for details. import copy from zope.interface import implements from twisted.internet import defer from twisted.words.protocols.jabber import jid -import storage + +from idavoll import error, iidavoll default_config = {"pubsub#persist_items": True, "pubsub#deliver_payloads": True} class Storage: - implements(storage.IStorage) + implements(iidavoll.IStorage) def __init__(self): self._nodes = {} @@ -21,7 +22,7 @@ try: node = self._nodes[node_id] except KeyError: - return defer.fail(storage.NodeNotFound()) + return defer.fail(error.NodeNotFound()) return defer.succeed(node) @@ -30,7 +31,7 @@ def create_node(self, node_id, owner, config = None, type='leaf'): if node_id in self._nodes: - return defer.fail(storage.NodeExists()) + return defer.fail(error.NodeExists()) if not config: config = copy.copy(default_config) @@ -47,7 +48,7 @@ try: del self._nodes[node_id] except KeyError: - return defer.fail(storage.NodeNotFound()) + return defer.fail(error.NodeNotFound()) return defer.succeed(None) @@ -70,7 +71,7 @@ class Node: - implements(storage.INode) + implements(iidavoll.INode) def __init__(self, node_id, owner, config): self.id = node_id @@ -110,8 +111,8 @@ def add_subscription(self, subscriber, state): if self._subscriptions.get(subscriber.full()): - return defer.fail(storage.SubscriptionExists()) - + return defer.fail(error.SubscriptionExists()) + subscription = Subscription(state) self._subscriptions[subscriber.full()] = subscription return defer.succeed(None) @@ -120,7 +121,7 @@ try: del self._subscriptions[subscriber.full()] except KeyError: - return defer.fail(storage.SubscriptionNotFound()) + return defer.fail(error.SubscriptionNotFound()) return defer.succeed(None) @@ -208,7 +209,7 @@ class LeafNode(Node, LeafNodeMixin): - implements(storage.ILeafNode) + implements(iidavoll.ILeafNode) def __init__(self, node_id, owner, config): Node.__init__(self, node_id, owner, config) @@ -216,7 +217,5 @@ class Subscription: - implements(storage.ISubscription) - def __init__(self, state): self.state = state