Update the test suite.

- monkey-patch our own monkey-patched idle_call to run events immediatly
  rather than adding them to the event queue, and add a fake transport
  with a fake socket.
- remove the test file related to xep_0059 as it relies on blocking
  behavior, and comment out one xep_0030 test uses xep_0059
- remove many instances of threading and sleep()s because they do
  nothing except waste time and introduce race conditions.
- keep exactly two sleep() in IoT xeps because they rely on timeouts

1 files changed, 0 insertions, 163 deletions

diff --git a/tests/test_stream_xep_0059.py b/tests/test_stream_xep_0059.py
deleted file mode 100644
index 6f929e8c..00000000
--- a/tests/test_stream_xep_0059.py
+++ /dev/null
@@ -1,163 +0,0 @@
-import threading
-
-import unittest
-from slixmpp.test import SlixTest
-from slixmpp.xmlstream import register_stanza_plugin
-from slixmpp.plugins.xep_0030 import DiscoItems
-from slixmpp.plugins.xep_0059 import ResultIterator, Set
-
-
-class TestStreamSet(SlixTest):
-
-    def setUp(self):
-        register_stanza_plugin(DiscoItems, Set)
-
-    def tearDown(self):
-        self.stream_close()
-
-    def iter(self, rev=False):
-        q = self.xmpp.Iq()
-        q['type'] = 'get'
-        it = ResultIterator(q, 'disco_items', amount='1', reverse=rev)
-        for i in it:
-            for j in i['disco_items']['items']:
-                self.items.append(j[0])
-
-    def testResultIterator(self):
-        self.items = []
-        self.stream_start(mode='client')
-        t = threading.Thread(target=self.iter)
-        t.start()
-        self.send("""
-          <iq type="get" id="2">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="2">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item1" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <last>item1</last>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.send("""
-          <iq type="get" id="3">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-                <after>item1</after>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="3">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item2" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <last>item2</last>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.send("""
-          <iq type="get" id="4">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-                <after>item2</after>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="4">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item2" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-              </set>
-            </query>
-          </iq>
-        """)
-        t.join()
-        self.failUnless(self.items == ['item1', 'item2'])
-
-    def testResultIteratorReverse(self):
-        self.items = []
-        self.stream_start(mode='client')
-
-        t = threading.Thread(target=self.iter, args=(True,))
-        t.start()
-
-        self.send("""
-          <iq type="get" id="2">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-                <before />
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="2">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item2" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <first>item2</first>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.send("""
-          <iq type="get" id="3">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-                <before>item2</before>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="3">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item1" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <first>item1</first>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.send("""
-          <iq type="get" id="4">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <set xmlns="http://jabber.org/protocol/rsm">
-                <max>1</max>
-                <before>item1</before>
-              </set>
-            </query>
-          </iq>
-        """)
-        self.recv("""
-          <iq type="result" id="4">
-            <query xmlns="http://jabber.org/protocol/disco#items">
-              <item jid="item1" />
-              <set xmlns="http://jabber.org/protocol/rsm">
-              </set>
-            </query>
-          </iq>
-        """)
-
-        t.join()
-        self.failUnless(self.items == ['item2', 'item1'])
-
-
-suite = unittest.TestLoader().loadTestsFromTestCase(TestStreamSet)