open.source/magic-wormhole
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

tests: internal changes

Browse Source
This commit is contained in:
Brian Warner 2016-04-18 17:57:14 -07:00
parent efc23bd078
commit 2e2b869ec2
4 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/common.py
View File

@ -15,7 +15,7 @@ class ServerBase:
"tcp:%s:interface=127.0.0.1" % transitport,
__version__)
s.setServiceParent(self.sp)
self._relay_server = s._rendezvous
self._rendezvous = s._rendezvous
self._transit_server = s._transit
self.relayurl = u"http://127.0.0.1:%d/wormhole-relay/" % relayport
self.transit = u"tcp:127.0.0.1:%d" % transitport

8
tests/test_blocking.py
View File

@ -52,14 +52,14 @@ class Channel(ServerBase, unittest.TestCase):
# deallocating one side is not enough to destroy the channel
d.addCallback(lambda _: deferToThread(c2.deallocate))
def _not_yet(_):
self._relay_server.prune()
self.failUnlessEqual(len(self._relay_server._apps), 1)
self._rendezvous.prune()
self.failUnlessEqual(len(self._rendezvous._apps), 1)
d.addCallback(_not_yet)
# but deallocating both will make the messages go away
d.addCallback(lambda _: deferToThread(c1.deallocate, u"sad"))
def _gone(_):
self._relay_server.prune()
self.failUnlessEqual(len(self._relay_server._apps), 0)
self._rendezvous.prune()
self.failUnlessEqual(len(self._rendezvous._apps), 0)
d.addCallback(_gone)
return d

2
tests/test_server.py
View File

@ -53,7 +53,7 @@ class Reachable(ServerBase, unittest.TestCase):
def unjson(data):
return json.loads(data.decode("utf-8"))
class API(ServerBase, unittest.TestCase):
class WebAPI(ServerBase, unittest.TestCase):
def build_url(self, path, appid, channelid):
url = self.relayurl+path
queryargs = []

8
tests/test_twisted.py
View File

@ -51,14 +51,14 @@ class Channel(ServerBase, unittest.TestCase):
# deallocating one side is not enough to destroy the channel
d.addCallback(lambda _: c2.deallocate())
def _not_yet(_):
self._relay_server.prune()
self.failUnlessEqual(len(self._relay_server._apps), 1)
self._rendezvous.prune()
self.failUnlessEqual(len(self._rendezvous._apps), 1)
d.addCallback(_not_yet)
# but deallocating both will make the messages go away
d.addCallback(lambda _: c1.deallocate(u"sad"))
def _gone(_):
self._relay_server.prune()
self.failUnlessEqual(len(self._relay_server._apps), 0)
self._rendezvous.prune()
self.failUnlessEqual(len(self._rendezvous._apps), 0)
d.addCallback(_gone)
d.addCallback(lambda _: cm1.shutdown())