summaryrefslogtreecommitdiff
path: root/tests/test_stream_xep_0059.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/test_stream_xep_0059.py')
-rw-r--r--tests/test_stream_xep_0059.py163
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)