Changeset 13:b460ae320c23 for wokkel/pubsub.py

Timestamp:

Feb 20, 2008, 3:44:44 PM (14 years ago)

Author:

Ralph Meijer <ralphm@…>

Branch:

default

Convert:

svn:b33ecbfc-034c-dc11-8662-000475d9059e/trunk@41

Message:

Add support for receiving notifications for item retraction, node deletion and purging.

File:

• wokkel/pubsub.py (modified) (2 diffs)

wokkel/pubsub.py

@@ -13 +13 @@
 from zope.interface import implements
 
-from twisted.internet import defer
+from twisted.internet import defer, reactor
 from twisted.words.protocols.jabber import jid, error, xmlstream
 from twisted.words.xish import domish
@@ -240 +240 @@
 
     def connectionInitialized(self):
-        self.xmlstream.addObserver('/message/event[@xmlns="%s"]/items' %
-                                   NS_PUBSUB_EVENT, self._onItems)
-
-    def _onItems(self, message):
+        self.xmlstream.addObserver('/message/event[@xmlns="%s"]' %
+                                   NS_PUBSUB_EVENT, self._onEvent)
+
+    def _onEvent(self, message):
         try:
             service = jid.JID(message["from"])
             recipient = jid.JID(message["to"])
-            nodeIdentifier = message.event.items["node"]
         except KeyError:
             return
 
-        items = [element for element in message.event.items.elements()
-                         if element.name == 'item']
+        for element in message.event.elements():
+            if element.uri == NS_PUBSUB_EVENT:
+                actionElement = element
+
+        if not actionElement:
+            return
+
+        eventHandler = getattr(self, "_onEvent_%s" % actionElement.name, None)
+
+        if eventHandler:
+            eventHandler(service, recipient, actionElement)
+            message.handled = True
+
+    def _onEvent_items(self, service, recipient, action):
+        nodeIdentifier = action["node"]
+
+        items = [element for element in action.elements()
+                         if element.name in ('item', 'retract')]
 
         self.itemsReceived(recipient, service, nodeIdentifier, items)
 
+    def _onEvent_delete(self, service, recipient, action):
+        nodeIdentifier = action["node"]
+        self.deleteReceived(recipient, service, nodeIdentifier)
+
+    def _onEvent_purge(self, service, recipient, action):
+        nodeIdentifier = action["node"]
+        self.purgeReceived(recipient, service, nodeIdentifier)
+
     def itemsReceived(self, recipient, service, nodeIdentifier, items):
+        pass
+
+    def deleteReceived(self, recipient, service, nodeIdentifier):
+        pass
+
+    def purgeReceived(self, recipient, service, nodeIdentifier):
         pass