Test publishing a single item.

1 files changed, 35 insertions, 2 deletions

diff --git a/tests/test_stream_xep_0060.py b/tests/test_stream_xep_0060.py
index e128eff5..048e41eb 100644
--- a/tests/test_stream_xep_0060.py
+++ b/tests/test_stream_xep_0060.py
@@ -3,6 +3,8 @@ import time
 import threading
 
 from sleekxmpp.test import *
+from sleekxmpp.stanza.atom import AtomEntry
+from sleekxmpp.xmlstream import register_stanza_plugin
 
 
 class TestStreamPubsub(SleekTest):
@@ -381,12 +383,43 @@ class TestStreamPubsub(SleekTest):
 
     def testPublishSingle(self):
         """Test publishing a single item."""
-        pass
+        payload = AtomEntry()
+        payload['title'] = 'Test'
+
+        register_stanza_plugin(self.xmpp['xep_0060'].stanza.Item, AtomEntry)
+
+        t = threading.Thread(name='publish_single',
+                             target=self.xmpp['xep_0060'].publish,
+                             args=('pubsub.example.com', 'somenode'),
+                             kwargs={'item_id': 'ID42',
+                                     'payload': payload})
+        t.start()
+
+        self.send("""
+          <iq type="set" id="1" to="pubsub.example.com">
+            <pubsub xmlns="http://jabber.org/protocol/pubsub">
+              <publish node="somenode">
+                <item id="ID42">
+                  <entry xmlns="http://www.w3.org/2005/Atom">
+                    <title>Test</title>
+                  </entry>
+                </item>
+              </publish>
+            </pubsub>
+          </iq>
+        """)
+
+        self.recv("""
+          <iq type="result" id="1"
+              to="tester@localhost" from="pubsub.example.com" />
+        """)
+
+        t.join()
+
 
     def testPublishSingleOptions(self):
         """Test publishing a single item, with options."""
 
-
     def testPublishMulti(self):
         """Test publishing multiple items."""
         pass