Changeset 63:b8139f79276f for wokkel/test/test_compat.py

Timestamp:

Jul 6, 2009, 9:26:47 AM (13 years ago)

Author:

Ralph Meijer <ralphm@…>

Branch:

default

Convert:

svn:b33ecbfc-034c-dc11-8662-000475d9059e/trunk@175

Message:

Make IQ timeouts work for InternalComponents?.

This introduces wokkel.compat.IQ to work with older Twisted versions, too.

Author: ralphm.
Fixes #53.

File:

• wokkel/test/test_compat.py (modified) (2 diffs)

wokkel/test/test_compat.py

@@ -7 +7 @@
 """
 
+from zope.interface import implements
 from zope.interface.verify import verifyObject
-from twisted.internet import defer, protocol
-from twisted.internet.interfaces import IProtocolFactory
+from twisted.internet import protocol, task
+from twisted.internet.interfaces import IProtocolFactory, IReactorTime
 from twisted.trial import unittest
-from twisted.words.xish import domish, utility
+from twisted.words.xish import utility
 from twisted.words.protocols.jabber import xmlstream
-from wokkel.compat import BootstrapMixin, XmlStreamServerFactory
+from wokkel.compat import BootstrapMixin, IQ, XmlStreamServerFactory
 
 class DummyProtocol(protocol.Protocol, utility.EventDispatcher):
@@ -166 +167 @@
         xs = self.factory.buildProtocol(None)
         self.assertIdentical(self.factory, xs.factory)
+
+
+
+class FakeReactor(object):
+
+    implements(IReactorTime)
+    def __init__(self):
+        self.clock = task.Clock()
+        self.callLater = self.clock.callLater
+        self.getDelayedCalls = self.clock.getDelayedCalls
+
+
+
+class IQTest(unittest.TestCase):
+    """
+    Tests for L{IQ}.
+    """
+
+    def setUp(self):
+        self.reactor = FakeReactor()
+        self.clock = self.reactor.clock
+
+
+    def testRequestTimingOutEventDispatcher(self):
+        """
+        Test that an iq request with a defined timeout times out.
+        """
+        from twisted.words.xish import utility
+        output = []
+        xs = utility.EventDispatcher()
+        xs.send = output.append
+
+        self.iq = IQ(xs, reactor=self.reactor)
+        self.iq.timeout = 60
+        d = self.iq.send()
+        self.assertFailure(d, xmlstream.TimeoutError)
+
+        self.clock.pump([1, 60])
+        self.assertFalse(self.reactor.getDelayedCalls())
+        self.assertFalse(xs.iqDeferreds)
+        return d