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