[tor-commits] [stem/master] Add tests for vote and consensus documents
atagar at torproject.org
atagar at torproject.org
Sat Oct 13 18:35:44 UTC 2012
commit 789145ee6ca6dea2617cdd641771cbce1b50296a
Author: Ravi Chandra Padmala <neenaoffline at gmail.com>
Date: Tue Aug 7 10:16:43 2012 +0530
Add tests for vote and consensus documents
---
test/integ/descriptor/data/vote | 2 +-
test/integ/descriptor/networkstatus_descriptor.py | 192 +++++++++++++++++++++
2 files changed, 193 insertions(+), 1 deletions(-)
diff --git a/test/integ/descriptor/data/vote b/test/integ/descriptor/data/vote
index d5f540f..ac2a6fc 100644
--- a/test/integ/descriptor/data/vote
+++ b/test/integ/descriptor/data/vote
@@ -9,7 +9,7 @@ voting-delay 300 300
known-flags Authority BadExit Exit Fast Guard HSDir Running Stable V2Dir Valid
params CircuitPriorityHalflifeMsec=30000 bwauthpid=1
dir-source turtles 27B6B5996C426270A5C95488AA5BCEB6BCC86956 76.73.17.194 76.73.17.194 9030 9090
-contact Mike Perry <mikeperryTAfsckedTODorg>
+contact Mike Perry <email>
dir-key-certificate-version 3
fingerprint 27B6B5996C426270A5C95488AA5BCEB6BCC86956
dir-key-published 2011-11-28 21:51:04
diff --git a/test/integ/descriptor/networkstatus_descriptor.py b/test/integ/descriptor/networkstatus_descriptor.py
index bcdaaf5..46019ea 100644
--- a/test/integ/descriptor/networkstatus_descriptor.py
+++ b/test/integ/descriptor/networkstatus_descriptor.py
@@ -4,6 +4,8 @@ Integration tests for stem.descriptor.server_descriptor.
from __future__ import with_statement
+import os
+import resource
import datetime
import unittest
@@ -34,3 +36,193 @@ class TestNetworkStatusDocument(unittest.TestCase):
self.assertEquals("178.218.213.229", router.ip)
self.assertEquals(80, router.orport)
self.assertEquals(None, router.dirport)
+
+ def test_cached_consensus(self):
+ """
+ Parses the cached-consensus file in our data directory.
+ """
+
+ # lengthy test and uneffected by targets, so only run once
+ if test.runner.only_run_once(self, "test_cached_consensus"): return
+
+ descriptor_path = test.runner.get_runner().get_test_dir("cached-consensus")
+
+ if not os.path.exists(descriptor_path):
+ test.runner.skip(self, "(no cached-consensus)")
+
+ if stem.util.system.is_windows():
+ # might hog memory and hang the system
+ # and we aren't checking for memory usage in windows, so, skip.
+ test.runner.skip(self, "(unavailable on windows)")
+
+ count = 0
+ with open(descriptor_path) as descriptor_file:
+ for desc in stem.descriptor.networkstatus_descriptor.parse_file(descriptor_file):
+ if resource.getrusage(resource.RUSAGE_SELF).ru_maxrss > 100000:
+ # if we're using > 100 MB we should fail
+ self.fail()
+ assert desc.nickname # check that the router has a nickname
+ count += 1
+
+ assert count > 100 # sanity check - assuming atleast 100 relays in the Tor network
+
+ def test_consensus(self):
+ """
+ Checks that consensus documents are properly parsed.
+ """
+
+ descriptor_path = test.integ.descriptor.get_resource("consensus")
+
+ descriptor_file = file(descriptor_path)
+ desc = stem.descriptor.networkstatus_descriptor.NetworkStatusDocument(descriptor_file.read())
+ descriptor_file.close()
+
+ self.assertEquals(True, desc.validated)
+ self.assertEquals("3", desc.network_status_version)
+ self.assertEquals("consensus", desc.vote_status)
+ self.assertEquals([], desc.consensus_methods)
+ self.assertEquals(None, desc.published)
+ self.assertEquals(12, desc.consensus_method)
+ self.assertEquals(_strptime("2012-07-12 10:00:00"), desc.valid_after)
+ self.assertEquals(_strptime("2012-07-12 11:00:00"), desc.fresh_until)
+ self.assertEquals(_strptime("2012-07-12 13:00:00"), desc.valid_until)
+ self.assertEquals(300, desc.vote_delay)
+ self.assertEquals(300, desc.dist_delay)
+ expected_client_versions = [stem.version.Version(version_string) for version_string in ["0.2.2.35",
+ "0.2.2.36", "0.2.2.37", "0.2.3.10-alpha", "0.2.3.11-alpha", "0.2.3.12-alpha",
+ "0.2.3.13-alpha", "0.2.3.14-alpha", "0.2.3.15-alpha", "0.2.3.16-alpha", "0.2.3.17-beta",
+ "0.2.3.18-rc", "0.2.3.19-rc"]]
+ expected_server_versions = [stem.version.Version(version_string) for version_string in ["0.2.2.35",
+ "0.2.2.36", "0.2.2.37", "0.2.3.10-alpha", "0.2.3.11-alpha", "0.2.3.12-alpha",
+ "0.2.3.13-alpha", "0.2.3.14-alpha", "0.2.3.15-alpha", "0.2.3.16-alpha", "0.2.3.17-beta",
+ "0.2.3.18-rc", "0.2.3.19-rc"]]
+ self.assertEquals(expected_client_versions, desc.client_versions)
+ self.assertEquals(expected_server_versions, desc.server_versions)
+ known_flags = ["Authority", "BadExit", "Exit", "Fast", "Guard", "HSDir", "Named", "Running", "Stable", "Unnamed", "V2Dir", "Valid"]
+ self.assertEquals(known_flags, desc.known_flags)
+ expected_params = {"CircuitPriorityHalflifeMsec": 30000, "bwauthpid": 1}
+ self.assertEquals(expected_params, desc.params)
+ router1 = next(desc.router_descriptors)
+ self.assertEquals("sumkledi", router1.nickname)
+ self.assertEquals("ABPSI4nNUNC3hKPkBhyzHozozrU", router1.identity)
+ self.assertEquals("8mCr8Sl7RF4ENU4jb0FZFA/3do8", router1.digest)
+ self.assertEquals(_strptime("2012-07-12 04:01:55"), router1.publication)
+ self.assertEquals("178.218.213.229", router1.ip)
+ self.assertEquals(80, router1.orport)
+ self.assertEquals(None, router1.dirport)
+
+ self.assertEquals(8, len(desc.directory_authorities))
+ self.assertEquals("tor26", desc.directory_authorities[0].nickname)
+ self.assertEquals("14C131DFC5C6F93646BE72FA1401C02A8DF2E8B4", desc.directory_authorities[0].identity)
+ self.assertEquals("86.59.21.38", desc.directory_authorities[0].address)
+ self.assertEquals("86.59.21.38", desc.directory_authorities[0].ip)
+ self.assertEquals(80, desc.directory_authorities[0].dirport)
+ self.assertEquals(443, desc.directory_authorities[0].orport)
+ self.assertEquals("Peter Palfrader", desc.directory_authorities[0].contact)
+ self.assertEquals(None, desc.directory_authorities[0].legacy_dir_key)
+ self.assertEquals(None, desc.directory_authorities[0].key_certificate)
+ self.assertEquals("0B6D1E9A300B895AA2D0B427F92917B6995C3C1C", desc.directory_authorities[0].vote_digest)
+ expected_bandwidth_weights = {
+ "Wbd": 3335, "Wbe": 0, "Wbg": 3536, "Wbm": 10000, "Wdb": 10000, "Web": 10000,
+ "Wed": 3329, "Wee": 10000, "Weg": 3329, "Wem": 10000, "Wgb": 10000, "Wgd": 3335,
+ "Wgg": 6464, "Wgm": 6464, "Wmb": 10000, "Wmd": 3335, "Wme": 0, "Wmg": 3536, "Wmm": 10000
+ }
+ self.assertEquals(expected_bandwidth_weights, desc.bandwidth_weights)
+
+ expected_signature = """HFXB4497LzESysYJ/4jJY83E5vLjhv+igIxD9LU6lf6ftkGeF+lNmIAIEKaMts8H
+mfWcW0b+jsrXcJoCxV5IrwCDF3u1aC3diwZY6yiG186pwWbOwE41188XI2DeYPwE
+I/TJmV928na7RLZe2mGHCAW3VQOvV+QkCfj05VZ8CsY="""
+ self.assertEquals(8, len(desc.directory_signatures))
+ self.assertEquals("14C131DFC5C6F93646BE72FA1401C02A8DF2E8B4", desc.directory_signatures[0].identity)
+ self.assertEquals("BF112F1C6D5543CFD0A32215ACABD4197B5279AD", desc.directory_signatures[0].key_digest)
+ self.assertEquals(expected_signature, desc.directory_signatures[0].signature)
+
+ def test_vote(self):
+ """
+ Checks that vote documents are properly parsed.
+ """
+
+ descriptor_path = test.integ.descriptor.get_resource("vote")
+
+ descriptor_file = file(descriptor_path)
+ desc = stem.descriptor.networkstatus_descriptor.NetworkStatusDocument(descriptor_file.read())
+ descriptor_file.close()
+
+ self.assertEquals(True, desc.validated)
+ self.assertEquals("3", desc.network_status_version)
+ self.assertEquals("vote", desc.vote_status)
+ self.assertEquals(range(1, 13), desc.consensus_methods)
+ self.assertEquals(_strptime("2012-07-11 23:50:01"), desc.published)
+ self.assertEquals(None, desc.consensus_method)
+ self.assertEquals(_strptime("2012-07-12 00:00:00"), desc.valid_after)
+ self.assertEquals(_strptime("2012-07-12 01:00:00"), desc.fresh_until)
+ self.assertEquals(_strptime("2012-07-12 03:00:00"), desc.valid_until)
+ self.assertEquals(300, desc.vote_delay)
+ self.assertEquals(300, desc.dist_delay)
+ self.assertEquals([], desc.client_versions)
+ self.assertEquals([], desc.server_versions)
+ known_flags = ["Authority", "BadExit", "Exit", "Fast", "Guard", "HSDir", "Running", "Stable", "V2Dir", "Valid"]
+ self.assertEquals(known_flags, desc.known_flags)
+ expected_params = {"CircuitPriorityHalflifeMsec": 30000, "bwauthpid": 1}
+ self.assertEquals(expected_params, desc.params)
+ router1 = next(desc.router_descriptors)
+ self.assertEquals("sumkledi", router1.nickname)
+ self.assertEquals("ABPSI4nNUNC3hKPkBhyzHozozrU", router1.identity)
+ self.assertEquals("B5n4BiALAF8B5AqafxohyYiuj7E", router1.digest)
+ self.assertEquals(_strptime("2012-07-11 04:22:53"), router1.publication)
+ self.assertEquals("178.218.213.229", router1.ip)
+ self.assertEquals(80, router1.orport)
+ self.assertEquals(None, router1.dirport)
+
+ self.assertEquals(1, len(desc.directory_authorities))
+ self.assertEquals("turtles", desc.directory_authorities[0].nickname)
+ self.assertEquals("27B6B5996C426270A5C95488AA5BCEB6BCC86956", desc.directory_authorities[0].identity)
+ self.assertEquals("76.73.17.194", desc.directory_authorities[0].address)
+ self.assertEquals("76.73.17.194", desc.directory_authorities[0].ip)
+ self.assertEquals(9030, desc.directory_authorities[0].dirport)
+ self.assertEquals(9090, desc.directory_authorities[0].orport)
+ self.assertEquals("Mike Perry <email>", desc.directory_authorities[0].contact)
+ self.assertEquals(None, desc.directory_authorities[0].legacy_dir_key)
+
+ expected_identity_key = """MIIBigKCAYEA6uSmsoxj2MiJ3qyZq0qYXlRoG8o82SNqg+22m+t1c7MlQOZWPJYn
+XeMcBCt8xrTeIt2ZI+Q/Kt2QJSeD9WZRevTKk/kn5Tg2+xXPogalUU47y5tUohGz
++Q8+CxtRSXpDxBHL2P8rLHvGrI69wbNHGoQkce/7gJy9vw5Ie2qzbyXk1NG6V8Fb
+pr6A885vHo6TbhUnolz2Wqt/kN+UorjLkN2H3fV+iGcQFv42SyHYGDLa0WwL3PJJ
+r/veu36S3VaHBrfhutfioi+d3d4Ya0bKwiWi5Lm2CHuuRTgMpHLU9vlci8Hunuxq
+HsULe2oMsr4VEic7sW5SPC5Obpx6hStHdNv1GxoSEm3/vIuPM8pINpU5ZYAyH9yO
+Ef22ZHeiVMMKmpV9TtFyiFqvlI6GpQn3mNbsQqF1y3XCA3Q4vlRAkpgJVUSvTxFP
+2bNDobOyVCpCM/rwxU1+RCNY5MFJ/+oktUY+0ydvTen3gFdZdgNqCYjKPLfBNm9m
+RGL7jZunMUNvAgMBAAE="""
+ expected_signing_key = """MIGJAoGBAJ5itcJRYNEM3Qf1OVWLRkwjqf84oXPc2ZusaJ5zOe7TVvBMra9GNyc0
+NM9y6zVkHCAePAjr4KbW/8P1olA6FUE2LV9bozaU1jFf6K8B2OELKs5FUEW+n+ic
+GM0x6MhngyXonWOcKt5Gj+mAu5lrno9tpNbPkz2Utr/Pi0nsDhWlAgMBAAE="""
+ expected_key_crosscert = """RHYImGTwg36wmEdAn7qaRg2sAfql7ZCtPIL/O3lU5OIdXXp0tNn/K00Bamqohjk+
+Tz4FKsKXGDlbGv67PQcZPOK6NF0GRkNh4pk89prrDO4XwtEn7rkHHdBH6/qQ7IRG
+GdDZHtZ1a69oFZvPWD3hUaB50xeIe7GoKdKIfdNNJ+8="""
+ expected_key_certification = """fasWOGyUZ3iMCYpDfJ+0JcMiTH25sXPWzvlHorEOyOMbaMqRYpZU4GHzt1jLgdl6
+AAoR6KdamsLg5VE8xzst48a4UFuzHFlklZ5O8om2rcvDd5DhSnWWYZnYJecqB+bo
+dNisPmaIVSAWb29U8BpNRj4GMC9KAgGYUj8aE/KtutAeEekFfFEHTfWZ2fFp4j3m
+9rY8FWraqyiF+Emq1T8pAAgMQ+79R3oZxq0TXS42Z4Anhms735ccauKhI3pDKjbl
+tD5vAzIHOyjAOXj7a6jY/GrnaBNuJ4qe/4Hf9UmzK/jKKwG95BPJtPTT4LoFwEB0
+KG2OUeQUNoCck4nDpsZwFqPlrWCHcHfTV2iDYFV1HQWDTtZz/qf+GtB8NXsq+I1w
+brADmvReM2BD6p/13h0QURCI5hq7ZYlIKcKrBa0jn1d9cduULl7vgKsRCJDls/ID
+emBZ6pUxMpBmV0v+PrA3v9w4DlE7GHAq61FF/zju2kpqj6MInbEvI/E+e438sWsL"""
+ self.assertEquals("3", desc.directory_authorities[0].key_certificate.key_certificate_version)
+ self.assertEquals("27B6B5996C426270A5C95488AA5BCEB6BCC86956", desc.directory_authorities[0].key_certificate.fingerprint)
+ self.assertEquals(_strptime("2011-11-28 21:51:04"), desc.directory_authorities[0].key_certificate.published)
+ self.assertEquals(_strptime("2012-11-28 21:51:04"), desc.directory_authorities[0].key_certificate.expires)
+ self.assertEquals(expected_identity_key, desc.directory_authorities[0].key_certificate.identity_key)
+ self.assertEquals(expected_signing_key, desc.directory_authorities[0].key_certificate.signing_key)
+ self.assertEquals(expected_key_crosscert, desc.directory_authorities[0].key_certificate.crosscert)
+ self.assertEquals(expected_key_certification, desc.directory_authorities[0].key_certificate.certification)
+ self.assertEquals(None, desc.directory_authorities[0].vote_digest)
+ self.assertEquals({}, desc.bandwidth_weights)
+
+ expected_signature = """fskXN84wB3mXfo+yKGSt0AcDaaPuU3NwMR3ROxWgLN0KjAaVi2eV9PkPCsQkcgw3
+JZ/1HL9sHyZfo6bwaC6YSM9PNiiY6L7rnGpS7UkHiFI+M96VCMorvjm5YPs3FioJ
+DnN5aFtYKiTc19qIC7Nmo+afPdDEf0MlJvEOP5EWl3w="""
+ self.assertEquals(1, len(desc.directory_signatures))
+ self.assertEquals("27B6B5996C426270A5C95488AA5BCEB6BCC86956", desc.directory_signatures[0].identity)
+ self.assertEquals("D5C30C15BB3F1DA27669C2D88439939E8F418FCF", desc.directory_signatures[0].key_digest)
+ self.assertEquals(expected_signature, desc.directory_signatures[0].signature)
+
More information about the tor-commits
mailing list