diff options
author | Christopher Baines <cb15g11@soton.ac.uk> | 2014-04-09 21:51:06 +0100 |
---|---|---|
committer | Christopher Baines <cb15g11@soton.ac.uk> | 2014-04-09 21:51:06 +0100 |
commit | d753b9994986c4a19d60bfe6c49609eb13d7ca7c (patch) | |
tree | bb8c9c7ff1ab3ba73b32527a814f7898c09ba567 /networks/hidden-service | |
parent | ca371c8c818ff4c829337db876fdbe3df325d9a8 (diff) | |
download | chutney-d753b9994986c4a19d60bfe6c49609eb13d7ca7c.tar chutney-d753b9994986c4a19d60bfe6c49609eb13d7ca7c.tar.gz |
Better tests
Diffstat (limited to 'networks/hidden-service')
-rw-r--r-- | networks/hidden-service | 103 |
1 files changed, 0 insertions, 103 deletions
diff --git a/networks/hidden-service b/networks/hidden-service deleted file mode 100644 index e25a224..0000000 --- a/networks/hidden-service +++ /dev/null @@ -1,103 +0,0 @@ -Authority = Node.create(3, { - "tag": "a", - "authority": 1, - "relay": 1, - "torrc": "authority.tmpl" -}) - -Relay = Node.create(5, { - "tag": "r", - "relay": 1, - "torrc": "intro.tmpl" -}) - -Client = Node.create(4, { - "tag": "c", - "torrc": "client.tmpl" -}) - -initialNodes = Authority + Relay + Client - -HiddenService = Node( - tag="h", - hiddenservice=1, - torrc="hidden-service.tmpl", - hiddenservicetarget="127.0.0.1:8081" -) - -initialNodes.append(HiddenService) - -DelayedHiddenService = Node( - tag="h", - hiddenservice=1, - torrc="hidden-service.tmpl", - hiddenservicetarget="127.0.0.1:8082" -) - -# Use twisted to create web servers in this script -class Site(resource.Resource): - isLeaf = True - numberRequests = 0 - - def __init__(self, siteNum): - self.siteNum = siteNum - - def render_GET(self, request): - self.numberRequests += 1 - request.setHeader("content-type", "text/plain") - return str(self.siteNum) - -def start_test(): - print("Starting test") - - port8081 = reactor.listenTCP(8081, server.Site(Site(1))) - port8082 = reactor.listenTCP(8082, server.Site(Site(2))) - - def cleanup(): - port8081.stopListening() - print("stopped 8081") - port8082.stopListening() - print("stopped 8082") - reactor.stop() - print("stopped the reactor") - - def test(): - print("connecting to clients") - responses = {"1": 0, "2": 0} - - for c in Client: - result = c.query("http://2oiifbe3wne4iaqb.onion/"); - - responses[result] += 1 - - print(result) - - print(responses) - cleanup() - - thread.start_new_thread(test, ()) - - print("running reactor") - reactor.run(installSignalHandlers=0) - -def start(): - print("Starting hidden service test") - - if not all([ n.getController().start() for n in initialNodes ]): - return False - else: - print("All initial nodes running") - - def start_listener(logevent): - # Probably after what needs waiting for - if "Successfully uploaded v2 rend descriptors" in logevent.message: - start_test() - - def log_listener(logevent): - if "Successfully uploaded v2 rend descriptors" in logevent.message: - print("log message: " + logevent.message) - DelayedHiddenService.getController().start() - - DelayedHiddenService.getStemController().add_event_listener(start_listener, EventType.INFO) - - HiddenService.getStemController().add_event_listener(log_listener, EventType.INFO) |