Mercurial > libervia-pubsub

changeset 68:a3d67cbab9c4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Return deferreds from getFeatures() and getIdentities(). Find out if a node exists for getIdentities(), and return its type.
author Ralph Meijer <ralphm@ik.nu>
date Sat, 06 Nov 2004 22:18:45 +0000
parents cdf17c4d3bf9
children 6c0cc9c6caea
files idavoll/pubsub.py
diffstat 1 files changed, 17 insertions(+), 16 deletions(-) [+]
line wrap: on
line diff
--- a/idavoll/pubsub.py	Sat Nov 06 22:17:18 2004 +0000
+++ b/idavoll/pubsub.py	Sat Nov 06 22:18:45 2004 +0000
@@ -114,14 +114,15 @@
 class ComponentServiceFromService(Service):
 
     def getIdentities(self, node):
-        results = []
-        if not node:
-            results.append({
-                'category': 'pubsub',
-                'type': 'generic',
-                'name': 'Generic Pubsub Service'
-            })
-        return results
+        if node:
+            d = self.backend.get_node_type(node)
+            d.addCallback(lambda x: [{'category': 'pubsub', 'type': x}])
+            d.addErrback(lambda x: [])
+            return d
+        else:
+            return defer.succeed({'category': 'pubsub',
+                                  'type': 'generic',
+                                  'name': 'Generic Pubsub Service'})
 
     def getFeatures(self, node):
         features = []
@@ -136,7 +137,7 @@
             if self.backend.supports_persistent_items():
                 features.append(NS_PUBSUB + "#persistent-items")
 
-        return features
+        return defer.succeed(features)
 
 components.registerAdapter(ComponentServiceFromService, backend.IBackendService, component.IService)
 
@@ -205,7 +206,7 @@
         if not node:
             features.append(NS_PUBSUB + "#subscribe")
 
-        return features
+        return defer.succeed(features)
 
     def onSubscribe(self, iq):
         self.handler_wrapper(self._onSubscribe, iq)
@@ -263,6 +264,11 @@
 
 class ComponentServiceFromNodeCreationService(Service):
 
+    def componentConnected(self, xmlstream):
+        xmlstream.addObserver(PUBSUB_CREATE, self.onCreate)
+        xmlstream.addObserver(PUBSUB_CONFIGURE_GET, self.onConfigureGet)
+        xmlstream.addObserver(PUBSUB_CONFIGURE_SET, self.onConfigureSet)
+
     def getFeatures(self, node):
         features = []
 
@@ -272,12 +278,7 @@
             if self.backend.supports_instant_nodes():
                 features.append(NS_PUBSUB + "#instant-nodes")
 
-        return features
-
-    def componentConnected(self, xmlstream):
-        xmlstream.addObserver(PUBSUB_CREATE, self.onCreate)
-        xmlstream.addObserver(PUBSUB_CONFIGURE_GET, self.onConfigureGet)
-        xmlstream.addObserver(PUBSUB_CONFIGURE_SET, self.onConfigureSet)
+        return defer.succeed(features)
 
     def onCreate(self, iq):
         self.handler_wrapper(self._onCreate, iq)