source: ralphm-patches/pubsub_client_example.patch

new file doc/examples/pubsub_client_create_node.tac

@@ +1 @@
+"""
+An XMPP Publish Subscribe publisher client as an XMPP client.
+
+This client logs in as C{publisher@example.org}, creates a node at
+C{pubsub.example.org} and prints the node identifier.
+
+Note that some services may change the node identifier to adhere to local
+policies. If you set L{NODE_IDENTIFIER} to C{None}, the service will create an
+'instant node', with a unique node identifier.
+"""
+
+from twisted.application import service
+from twisted.internet import reactor, task
+from twisted.python import log
+from twisted.words.protocols.jabber.jid import JID
+from wokkel.client import XMPPClient
+from wokkel.pubsub import PubSubClient
+
+# Configuration parameters
+
+THIS_JID = JID('publisher@example.org')
+SERVICE_JID = JID('pubsub.example.org')
+NODE_IDENTIFIER = 'test_node'
+SECRET = 'secret'
+LOG_TRAFFIC = True
+
+class Publisher(PubSubClient):
+
+    count = None
+    loopingCall = None
+    nodeIdentifier = None
+
+    def connectionInitialized(self):
+        def cb(nodeIdentifier):
+            log.msg("The node %r was successfully created" % nodeIdentifier)
+        d = self.createNode(SERVICE_JID, NODE_IDENTIFIER)
+        d.addCallbacks(cb, log.err)
+        d.addCallback(lambda _: reactor.stop())
+
+
+    def nodeCreated(self, nodeIdentifier):
+        self.nodeIdentifier = nodeIdentifier
+        self.count = 0
+        self.loopingCall = task.LoopingCall(self.doPublish)
+        self.loopingCall.start(5)
+
+# Set up the Twisted application
+
+application = service.Application("Publish Subscribe publisher")
+
+client = XMPPClient(THIS_JID, SECRET)
+client.logTraffic = LOG_TRAFFIC
+client.setServiceParent(application)
+
+pubsubHandler = PubSubClient()
+pubsubHandler.setHandlerParent(client)