test_dir.c 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098
  1. /* Copyright (c) 2001-2004, Roger Dingledine.
  2. * Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
  3. * Copyright (c) 2007-2009, The Tor Project, Inc. */
  4. /* See LICENSE for licensing information */
  5. #include "orconfig.h"
  6. #define DIRSERV_PRIVATE
  7. #define DIRVOTE_PRIVATE
  8. #define ROUTER_PRIVATE
  9. #include "or.h"
  10. #include "test.h"
  11. static void
  12. test_dir_nicknames(void)
  13. {
  14. test_assert( is_legal_nickname("a"));
  15. test_assert(!is_legal_nickname(""));
  16. test_assert(!is_legal_nickname("abcdefghijklmnopqrst")); /* 20 chars */
  17. test_assert(!is_legal_nickname("hyphen-")); /* bad char */
  18. test_assert( is_legal_nickname("abcdefghijklmnopqrs")); /* 19 chars */
  19. test_assert(!is_legal_nickname("$AAAAAAAA01234AAAAAAAAAAAAAAAAAAAAAAAAAAA"));
  20. /* valid */
  21. test_assert( is_legal_nickname_or_hexdigest(
  22. "$AAAAAAAA01234AAAAAAAAAAAAAAAAAAAAAAAAAAA"));
  23. test_assert( is_legal_nickname_or_hexdigest(
  24. "$AAAAAAAA01234AAAAAAAAAAAAAAAAAAAAAAAAAAA=fred"));
  25. test_assert( is_legal_nickname_or_hexdigest(
  26. "$AAAAAAAA01234AAAAAAAAAAAAAAAAAAAAAAAAAAA~fred"));
  27. /* too short */
  28. test_assert(!is_legal_nickname_or_hexdigest(
  29. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"));
  30. /* illegal char */
  31. test_assert(!is_legal_nickname_or_hexdigest(
  32. "$AAAAAAzAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"));
  33. /* hex part too long */
  34. test_assert(!is_legal_nickname_or_hexdigest(
  35. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"));
  36. test_assert(!is_legal_nickname_or_hexdigest(
  37. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=fred"));
  38. /* Bad nickname */
  39. test_assert(!is_legal_nickname_or_hexdigest(
  40. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA="));
  41. test_assert(!is_legal_nickname_or_hexdigest(
  42. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA~"));
  43. test_assert(!is_legal_nickname_or_hexdigest(
  44. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA~hyphen-"));
  45. test_assert(!is_legal_nickname_or_hexdigest(
  46. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA~"
  47. "abcdefghijklmnoppqrst"));
  48. /* Bad extra char. */
  49. test_assert(!is_legal_nickname_or_hexdigest(
  50. "$AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA!"));
  51. test_assert(is_legal_nickname_or_hexdigest("xyzzy"));
  52. test_assert(is_legal_nickname_or_hexdigest("abcdefghijklmnopqrs"));
  53. test_assert(!is_legal_nickname_or_hexdigest("abcdefghijklmnopqrst"));
  54. done:
  55. ;
  56. }
  57. /** Run unit tests for router descriptor generation logic. */
  58. static void
  59. test_dir_formats(void)
  60. {
  61. char buf[8192], buf2[8192];
  62. char platform[256];
  63. char fingerprint[FINGERPRINT_LEN+1];
  64. char *pk1_str = NULL, *pk2_str = NULL, *pk3_str = NULL, *cp;
  65. size_t pk1_str_len, pk2_str_len, pk3_str_len;
  66. routerinfo_t *r1=NULL, *r2=NULL;
  67. crypto_pk_env_t *pk1 = NULL, *pk2 = NULL, *pk3 = NULL;
  68. routerinfo_t *rp1 = NULL;
  69. addr_policy_t *ex1, *ex2;
  70. routerlist_t *dir1 = NULL, *dir2 = NULL;
  71. pk1 = pk_generate(0);
  72. pk2 = pk_generate(1);
  73. pk3 = pk_generate(2);
  74. test_assert(pk1 && pk2 && pk3);
  75. get_platform_str(platform, sizeof(platform));
  76. r1 = tor_malloc_zero(sizeof(routerinfo_t));
  77. r1->address = tor_strdup("18.244.0.1");
  78. r1->addr = 0xc0a80001u; /* 192.168.0.1 */
  79. r1->cache_info.published_on = 0;
  80. r1->or_port = 9000;
  81. r1->dir_port = 9003;
  82. r1->onion_pkey = crypto_pk_dup_key(pk1);
  83. r1->identity_pkey = crypto_pk_dup_key(pk2);
  84. r1->bandwidthrate = 1000;
  85. r1->bandwidthburst = 5000;
  86. r1->bandwidthcapacity = 10000;
  87. r1->exit_policy = NULL;
  88. r1->nickname = tor_strdup("Magri");
  89. r1->platform = tor_strdup(platform);
  90. ex1 = tor_malloc_zero(sizeof(addr_policy_t));
  91. ex2 = tor_malloc_zero(sizeof(addr_policy_t));
  92. ex1->policy_type = ADDR_POLICY_ACCEPT;
  93. tor_addr_from_ipv4h(&ex1->addr, 0);
  94. ex1->maskbits = 0;
  95. ex1->prt_min = ex1->prt_max = 80;
  96. ex2->policy_type = ADDR_POLICY_REJECT;
  97. tor_addr_from_ipv4h(&ex2->addr, 18<<24);
  98. ex2->maskbits = 8;
  99. ex2->prt_min = ex2->prt_max = 24;
  100. r2 = tor_malloc_zero(sizeof(routerinfo_t));
  101. r2->address = tor_strdup("1.1.1.1");
  102. r2->addr = 0x0a030201u; /* 10.3.2.1 */
  103. r2->platform = tor_strdup(platform);
  104. r2->cache_info.published_on = 5;
  105. r2->or_port = 9005;
  106. r2->dir_port = 0;
  107. r2->onion_pkey = crypto_pk_dup_key(pk2);
  108. r2->identity_pkey = crypto_pk_dup_key(pk1);
  109. r2->bandwidthrate = r2->bandwidthburst = r2->bandwidthcapacity = 3000;
  110. r2->exit_policy = smartlist_create();
  111. smartlist_add(r2->exit_policy, ex2);
  112. smartlist_add(r2->exit_policy, ex1);
  113. r2->nickname = tor_strdup("Fred");
  114. test_assert(!crypto_pk_write_public_key_to_string(pk1, &pk1_str,
  115. &pk1_str_len));
  116. test_assert(!crypto_pk_write_public_key_to_string(pk2 , &pk2_str,
  117. &pk2_str_len));
  118. test_assert(!crypto_pk_write_public_key_to_string(pk3 , &pk3_str,
  119. &pk3_str_len));
  120. memset(buf, 0, 2048);
  121. test_assert(router_dump_router_to_string(buf, 2048, r1, pk2)>0);
  122. strlcpy(buf2, "router Magri 18.244.0.1 9000 0 9003\n"
  123. "platform Tor "VERSION" on ", sizeof(buf2));
  124. strlcat(buf2, get_uname(), sizeof(buf2));
  125. strlcat(buf2, "\n"
  126. "opt protocols Link 1 2 Circuit 1\n"
  127. "published 1970-01-01 00:00:00\n"
  128. "opt fingerprint ", sizeof(buf2));
  129. test_assert(!crypto_pk_get_fingerprint(pk2, fingerprint, 1));
  130. strlcat(buf2, fingerprint, sizeof(buf2));
  131. strlcat(buf2, "\nuptime 0\n"
  132. /* XXX the "0" above is hard-coded, but even if we made it reflect
  133. * uptime, that still wouldn't make it right, because the two
  134. * descriptors might be made on different seconds... hm. */
  135. "bandwidth 1000 5000 10000\n"
  136. "opt extra-info-digest 0000000000000000000000000000000000000000\n"
  137. "onion-key\n", sizeof(buf2));
  138. strlcat(buf2, pk1_str, sizeof(buf2));
  139. strlcat(buf2, "signing-key\n", sizeof(buf2));
  140. strlcat(buf2, pk2_str, sizeof(buf2));
  141. strlcat(buf2, "opt hidden-service-dir\n", sizeof(buf2));
  142. strlcat(buf2, "reject *:*\nrouter-signature\n", sizeof(buf2));
  143. buf[strlen(buf2)] = '\0'; /* Don't compare the sig; it's never the same
  144. * twice */
  145. test_streq(buf, buf2);
  146. test_assert(router_dump_router_to_string(buf, 2048, r1, pk2)>0);
  147. cp = buf;
  148. rp1 = router_parse_entry_from_string((const char*)cp,NULL,1,0,NULL);
  149. test_assert(rp1);
  150. test_streq(rp1->address, r1->address);
  151. test_eq(rp1->or_port, r1->or_port);
  152. //test_eq(rp1->dir_port, r1->dir_port);
  153. test_eq(rp1->bandwidthrate, r1->bandwidthrate);
  154. test_eq(rp1->bandwidthburst, r1->bandwidthburst);
  155. test_eq(rp1->bandwidthcapacity, r1->bandwidthcapacity);
  156. test_assert(crypto_pk_cmp_keys(rp1->onion_pkey, pk1) == 0);
  157. test_assert(crypto_pk_cmp_keys(rp1->identity_pkey, pk2) == 0);
  158. //test_assert(rp1->exit_policy == NULL);
  159. #if 0
  160. /* XXX Once we have exit policies, test this again. XXX */
  161. strlcpy(buf2, "router tor.tor.tor 9005 0 0 3000\n", sizeof(buf2));
  162. strlcat(buf2, pk2_str, sizeof(buf2));
  163. strlcat(buf2, "signing-key\n", sizeof(buf2));
  164. strlcat(buf2, pk1_str, sizeof(buf2));
  165. strlcat(buf2, "accept *:80\nreject 18.*:24\n\n", sizeof(buf2));
  166. test_assert(router_dump_router_to_string(buf, 2048, &r2, pk2)>0);
  167. test_streq(buf, buf2);
  168. cp = buf;
  169. rp2 = router_parse_entry_from_string(&cp,1);
  170. test_assert(rp2);
  171. test_streq(rp2->address, r2.address);
  172. test_eq(rp2->or_port, r2.or_port);
  173. test_eq(rp2->dir_port, r2.dir_port);
  174. test_eq(rp2->bandwidth, r2.bandwidth);
  175. test_assert(crypto_pk_cmp_keys(rp2->onion_pkey, pk2) == 0);
  176. test_assert(crypto_pk_cmp_keys(rp2->identity_pkey, pk1) == 0);
  177. test_eq(rp2->exit_policy->policy_type, EXIT_POLICY_ACCEPT);
  178. test_streq(rp2->exit_policy->string, "accept *:80");
  179. test_streq(rp2->exit_policy->address, "*");
  180. test_streq(rp2->exit_policy->port, "80");
  181. test_eq(rp2->exit_policy->next->policy_type, EXIT_POLICY_REJECT);
  182. test_streq(rp2->exit_policy->next->string, "reject 18.*:24");
  183. test_streq(rp2->exit_policy->next->address, "18.*");
  184. test_streq(rp2->exit_policy->next->port, "24");
  185. test_assert(rp2->exit_policy->next->next == NULL);
  186. /* Okay, now for the directories. */
  187. {
  188. fingerprint_list = smartlist_create();
  189. crypto_pk_get_fingerprint(pk2, buf, 1);
  190. add_fingerprint_to_dir("Magri", buf, fingerprint_list);
  191. crypto_pk_get_fingerprint(pk1, buf, 1);
  192. add_fingerprint_to_dir("Fred", buf, fingerprint_list);
  193. }
  194. {
  195. char d[DIGEST_LEN];
  196. const char *m;
  197. /* XXXX NM re-enable. */
  198. /* Make sure routers aren't too far in the past any more. */
  199. r1->cache_info.published_on = time(NULL);
  200. r2->cache_info.published_on = time(NULL)-3*60*60;
  201. test_assert(router_dump_router_to_string(buf, 2048, r1, pk2)>0);
  202. test_eq(dirserv_add_descriptor(buf,&m,""), ROUTER_ADDED_NOTIFY_GENERATOR);
  203. test_assert(router_dump_router_to_string(buf, 2048, r2, pk1)>0);
  204. test_eq(dirserv_add_descriptor(buf,&m,""), ROUTER_ADDED_NOTIFY_GENERATOR);
  205. get_options()->Nickname = tor_strdup("DirServer");
  206. test_assert(!dirserv_dump_directory_to_string(&cp,pk3, 0));
  207. crypto_pk_get_digest(pk3, d);
  208. test_assert(!router_parse_directory(cp));
  209. test_eq(2, smartlist_len(dir1->routers));
  210. tor_free(cp);
  211. }
  212. #endif
  213. dirserv_free_fingerprint_list();
  214. done:
  215. if (r1)
  216. routerinfo_free(r1);
  217. if (r2)
  218. routerinfo_free(r2);
  219. tor_free(pk1_str);
  220. tor_free(pk2_str);
  221. tor_free(pk3_str);
  222. if (pk1) crypto_free_pk_env(pk1);
  223. if (pk2) crypto_free_pk_env(pk2);
  224. if (pk3) crypto_free_pk_env(pk3);
  225. if (rp1) routerinfo_free(rp1);
  226. tor_free(dir1); /* XXXX And more !*/
  227. tor_free(dir2); /* And more !*/
  228. }
  229. static void
  230. test_dir_versions(void)
  231. {
  232. tor_version_t ver1;
  233. /* Try out version parsing functionality */
  234. test_eq(0, tor_version_parse("0.3.4pre2-cvs", &ver1));
  235. test_eq(0, ver1.major);
  236. test_eq(3, ver1.minor);
  237. test_eq(4, ver1.micro);
  238. test_eq(VER_PRE, ver1.status);
  239. test_eq(2, ver1.patchlevel);
  240. test_eq(0, tor_version_parse("0.3.4rc1", &ver1));
  241. test_eq(0, ver1.major);
  242. test_eq(3, ver1.minor);
  243. test_eq(4, ver1.micro);
  244. test_eq(VER_RC, ver1.status);
  245. test_eq(1, ver1.patchlevel);
  246. test_eq(0, tor_version_parse("1.3.4", &ver1));
  247. test_eq(1, ver1.major);
  248. test_eq(3, ver1.minor);
  249. test_eq(4, ver1.micro);
  250. test_eq(VER_RELEASE, ver1.status);
  251. test_eq(0, ver1.patchlevel);
  252. test_eq(0, tor_version_parse("1.3.4.999", &ver1));
  253. test_eq(1, ver1.major);
  254. test_eq(3, ver1.minor);
  255. test_eq(4, ver1.micro);
  256. test_eq(VER_RELEASE, ver1.status);
  257. test_eq(999, ver1.patchlevel);
  258. test_eq(0, tor_version_parse("0.1.2.4-alpha", &ver1));
  259. test_eq(0, ver1.major);
  260. test_eq(1, ver1.minor);
  261. test_eq(2, ver1.micro);
  262. test_eq(4, ver1.patchlevel);
  263. test_eq(VER_RELEASE, ver1.status);
  264. test_streq("alpha", ver1.status_tag);
  265. test_eq(0, tor_version_parse("0.1.2.4", &ver1));
  266. test_eq(0, ver1.major);
  267. test_eq(1, ver1.minor);
  268. test_eq(2, ver1.micro);
  269. test_eq(4, ver1.patchlevel);
  270. test_eq(VER_RELEASE, ver1.status);
  271. test_streq("", ver1.status_tag);
  272. #define tt_versionstatus_op(vs1, op, vs2) \
  273. tt_assert_test_type(vs1,vs2,#vs1" "#op" "#vs2,version_status_t, \
  274. (_val1 op _val2),"%d")
  275. #define test_v_i_o(val, ver, lst) \
  276. tt_versionstatus_op(val, ==, tor_version_is_obsolete(ver, lst))
  277. /* make sure tor_version_is_obsolete() works */
  278. test_v_i_o(VS_OLD, "0.0.1", "Tor 0.0.2");
  279. test_v_i_o(VS_OLD, "0.0.1", "0.0.2, Tor 0.0.3");
  280. test_v_i_o(VS_OLD, "0.0.1", "0.0.2,Tor 0.0.3");
  281. test_v_i_o(VS_OLD, "0.0.1","0.0.3,BetterTor 0.0.1");
  282. test_v_i_o(VS_RECOMMENDED, "0.0.2", "Tor 0.0.2,Tor 0.0.3");
  283. test_v_i_o(VS_NEW_IN_SERIES, "0.0.2", "Tor 0.0.2pre1,Tor 0.0.3");
  284. test_v_i_o(VS_OLD, "0.0.2", "Tor 0.0.2.1,Tor 0.0.3");
  285. test_v_i_o(VS_NEW, "0.1.0", "Tor 0.0.2,Tor 0.0.3");
  286. test_v_i_o(VS_RECOMMENDED, "0.0.7rc2", "0.0.7,Tor 0.0.7rc2,Tor 0.0.8");
  287. test_v_i_o(VS_OLD, "0.0.5.0", "0.0.5.1-cvs");
  288. test_v_i_o(VS_NEW_IN_SERIES, "0.0.5.1-cvs", "0.0.5, 0.0.6");
  289. /* Not on list, but newer than any in same series. */
  290. test_v_i_o(VS_NEW_IN_SERIES, "0.1.0.3",
  291. "Tor 0.1.0.2,Tor 0.0.9.5,Tor 0.1.1.0");
  292. /* Series newer than any on list. */
  293. test_v_i_o(VS_NEW, "0.1.2.3", "Tor 0.1.0.2,Tor 0.0.9.5,Tor 0.1.1.0");
  294. /* Series older than any on list. */
  295. test_v_i_o(VS_OLD, "0.0.1.3", "Tor 0.1.0.2,Tor 0.0.9.5,Tor 0.1.1.0");
  296. /* Not on list, not newer than any on same series. */
  297. test_v_i_o(VS_UNRECOMMENDED, "0.1.0.1",
  298. "Tor 0.1.0.2,Tor 0.0.9.5,Tor 0.1.1.0");
  299. /* On list, not newer than any on same series. */
  300. test_v_i_o(VS_UNRECOMMENDED,
  301. "0.1.0.1", "Tor 0.1.0.2,Tor 0.0.9.5,Tor 0.1.1.0");
  302. test_eq(0, tor_version_as_new_as("Tor 0.0.5", "0.0.9pre1-cvs"));
  303. test_eq(1, tor_version_as_new_as(
  304. "Tor 0.0.8 on Darwin 64-121-192-100.c3-0."
  305. "sfpo-ubr1.sfrn-sfpo.ca.cable.rcn.com Power Macintosh",
  306. "0.0.8rc2"));
  307. test_eq(0, tor_version_as_new_as(
  308. "Tor 0.0.8 on Darwin 64-121-192-100.c3-0."
  309. "sfpo-ubr1.sfrn-sfpo.ca.cable.rcn.com Power Macintosh", "0.0.8.2"));
  310. /* Now try svn revisions. */
  311. test_eq(1, tor_version_as_new_as("Tor 0.2.1.0-dev (r100)",
  312. "Tor 0.2.1.0-dev (r99)"));
  313. test_eq(1, tor_version_as_new_as("Tor 0.2.1.0-dev (r100) on Banana Jr",
  314. "Tor 0.2.1.0-dev (r99) on Hal 9000"));
  315. test_eq(1, tor_version_as_new_as("Tor 0.2.1.0-dev (r100)",
  316. "Tor 0.2.1.0-dev on Colossus"));
  317. test_eq(0, tor_version_as_new_as("Tor 0.2.1.0-dev (r99)",
  318. "Tor 0.2.1.0-dev (r100)"));
  319. test_eq(0, tor_version_as_new_as("Tor 0.2.1.0-dev (r99) on MCP",
  320. "Tor 0.2.1.0-dev (r100) on AM"));
  321. test_eq(0, tor_version_as_new_as("Tor 0.2.1.0-dev",
  322. "Tor 0.2.1.0-dev (r99)"));
  323. test_eq(1, tor_version_as_new_as("Tor 0.2.1.1",
  324. "Tor 0.2.1.0-dev (r99)"));
  325. /* Now try git revisions */
  326. test_eq(0, tor_version_parse("0.5.6.7 (git-ff00ff)", &ver1));
  327. test_eq(0, ver1.major);
  328. test_eq(5, ver1.minor);
  329. test_eq(6, ver1.micro);
  330. test_eq(7, ver1.patchlevel);
  331. test_eq(3, ver1.git_tag_len);
  332. test_memeq(ver1.git_tag, "\xff\x00\xff", 3);
  333. test_eq(-1, tor_version_parse("0.5.6.7 (git-ff00xx)", &ver1));
  334. test_eq(-1, tor_version_parse("0.5.6.7 (git-ff00fff)", &ver1));
  335. test_eq(0, tor_version_parse("0.5.6.7 (git ff00fff)", &ver1));
  336. done:
  337. ;
  338. }
  339. /** Run unit tests for misc directory functions. */
  340. static void
  341. test_dir_util(void)
  342. {
  343. smartlist_t *sl = smartlist_create();
  344. fp_pair_t *pair;
  345. dir_split_resource_into_fingerprint_pairs(
  346. /* Two pairs, out of order, with one duplicate. */
  347. "73656372657420646174612E0000000000FFFFFF-"
  348. "557365204145532d32353620696e73746561642e+"
  349. "73656372657420646174612E0000000000FFFFFF-"
  350. "557365204145532d32353620696e73746561642e+"
  351. "48657861646563696d616c2069736e277420736f-"
  352. "676f6f6420666f7220686964696e6720796f7572.z", sl);
  353. test_eq(smartlist_len(sl), 2);
  354. pair = smartlist_get(sl, 0);
  355. test_memeq(pair->first, "Hexadecimal isn't so", DIGEST_LEN);
  356. test_memeq(pair->second, "good for hiding your", DIGEST_LEN);
  357. pair = smartlist_get(sl, 1);
  358. test_memeq(pair->first, "secret data.\0\0\0\0\0\xff\xff\xff", DIGEST_LEN);
  359. test_memeq(pair->second, "Use AES-256 instead.", DIGEST_LEN);
  360. done:
  361. SMARTLIST_FOREACH(sl, fp_pair_t *, pair, tor_free(pair));
  362. smartlist_free(sl);
  363. }
  364. static void
  365. test_dir_measured_bw(void)
  366. {
  367. measured_bw_line_t mbwl;
  368. int i;
  369. const char *lines_pass[] = {
  370. "node_id=$557365204145532d32353620696e73746561642e bw=1024\n",
  371. "node_id=$557365204145532d32353620696e73746561642e\t bw=1024 \n",
  372. " node_id=$557365204145532d32353620696e73746561642e bw=1024\n",
  373. "\tnoise\tnode_id=$557365204145532d32353620696e73746561642e "
  374. "bw=1024 junk=007\n",
  375. "misc=junk node_id=$557365204145532d32353620696e73746561642e "
  376. "bw=1024 junk=007\n",
  377. "end"
  378. };
  379. const char *lines_fail[] = {
  380. /* Test possible python stupidity on input */
  381. "node_id=None bw=1024\n",
  382. "node_id=$None bw=1024\n",
  383. "node_id=$557365204145532d32353620696e73746561642e bw=None\n",
  384. "node_id=$557365204145532d32353620696e73746561642e bw=1024.0\n",
  385. "node_id=$557365204145532d32353620696e73746561642e bw=.1024\n",
  386. "node_id=$557365204145532d32353620696e73746561642e bw=1.024\n",
  387. "node_id=$557365204145532d32353620696e73746561642e bw=1024 bw=0\n",
  388. "node_id=$557365204145532d32353620696e73746561642e bw=1024 bw=None\n",
  389. "node_id=$557365204145532d32353620696e73746561642e bw=-1024\n",
  390. /* Test incomplete writes due to race conditions, partial copies, etc */
  391. "node_i",
  392. "node_i\n",
  393. "node_id=",
  394. "node_id=\n",
  395. "node_id=$557365204145532d32353620696e73746561642e bw=",
  396. "node_id=$557365204145532d32353620696e73746561642e bw=1024",
  397. "node_id=$557365204145532d32353620696e73746561642e bw=\n",
  398. "node_id=$557365204145532d32353620696e7374",
  399. "node_id=$557365204145532d32353620696e7374\n",
  400. "",
  401. "\n",
  402. " \n ",
  403. " \n\n",
  404. /* Test assorted noise */
  405. " node_id= ",
  406. "node_id==$557365204145532d32353620696e73746561642e bw==1024\n",
  407. "node_id=$55736520414552d32353620696e73746561642e bw=1024\n",
  408. "node_id=557365204145532d32353620696e73746561642e bw=1024\n",
  409. "node_id= $557365204145532d32353620696e73746561642e bw=0.23\n",
  410. "end"
  411. };
  412. for (i = 0; strcmp(lines_fail[i], "end"); i++) {
  413. //fprintf(stderr, "Testing: %s\n", lines_fail[i]);
  414. test_assert(measured_bw_line_parse(&mbwl, lines_fail[i]) == -1);
  415. }
  416. for (i = 0; strcmp(lines_pass[i], "end"); i++) {
  417. //fprintf(stderr, "Testing: %s %d\n", lines_pass[i], TOR_ISSPACE('\n'));
  418. test_assert(measured_bw_line_parse(&mbwl, lines_pass[i]) == 0);
  419. test_assert(mbwl.bw == 1024);
  420. test_assert(strcmp(mbwl.node_hex,
  421. "557365204145532d32353620696e73746561642e") == 0);
  422. }
  423. done:
  424. return;
  425. }
  426. static void
  427. test_dir_param_voting(void)
  428. {
  429. networkstatus_t vote1, vote2, vote3, vote4;
  430. smartlist_t *votes = smartlist_create();
  431. char *res = NULL;
  432. /* dirvote_compute_params only looks at the net_params field of the votes,
  433. so that's all we need to set.
  434. */
  435. memset(&vote1, 0, sizeof(vote1));
  436. memset(&vote2, 0, sizeof(vote2));
  437. memset(&vote3, 0, sizeof(vote3));
  438. memset(&vote4, 0, sizeof(vote4));
  439. vote1.net_params = smartlist_create();
  440. vote2.net_params = smartlist_create();
  441. vote3.net_params = smartlist_create();
  442. vote4.net_params = smartlist_create();
  443. smartlist_split_string(vote1.net_params,
  444. "ab=90 abcd=20 cw=50 x-yz=-99", NULL, 0, 0);
  445. smartlist_split_string(vote2.net_params,
  446. "ab=27 cw=5 x-yz=88", NULL, 0, 0);
  447. smartlist_split_string(vote3.net_params,
  448. "abcd=20 c=60 cw=500 x-yz=-9 zzzzz=101", NULL, 0, 0);
  449. smartlist_split_string(vote4.net_params,
  450. "ab=900 abcd=200 c=1 cw=51 x-yz=100", NULL, 0, 0);
  451. test_eq(100, networkstatus_get_param(&vote4, "x-yz", 50));
  452. test_eq(222, networkstatus_get_param(&vote4, "foobar", 222));
  453. smartlist_add(votes, &vote1);
  454. smartlist_add(votes, &vote2);
  455. smartlist_add(votes, &vote3);
  456. smartlist_add(votes, &vote4);
  457. res = dirvote_compute_params(votes);
  458. test_streq(res,
  459. "ab=90 abcd=20 c=1 cw=50 x-yz=-9 zzzzz=101");
  460. done:
  461. tor_free(res);
  462. SMARTLIST_FOREACH(vote1.net_params, char *, cp, tor_free(cp));
  463. SMARTLIST_FOREACH(vote2.net_params, char *, cp, tor_free(cp));
  464. SMARTLIST_FOREACH(vote3.net_params, char *, cp, tor_free(cp));
  465. SMARTLIST_FOREACH(vote4.net_params, char *, cp, tor_free(cp));
  466. smartlist_free(vote1.net_params);
  467. smartlist_free(vote2.net_params);
  468. smartlist_free(vote3.net_params);
  469. smartlist_free(vote4.net_params);
  470. return;
  471. }
  472. extern const char AUTHORITY_CERT_1[];
  473. extern const char AUTHORITY_SIGNKEY_1[];
  474. extern const char AUTHORITY_CERT_2[];
  475. extern const char AUTHORITY_SIGNKEY_2[];
  476. extern const char AUTHORITY_CERT_3[];
  477. extern const char AUTHORITY_SIGNKEY_3[];
  478. /** Helper: Test that two networkstatus_voter_info_t do in fact represent the
  479. * same voting authority, and that they do in fact have all the same
  480. * information. */
  481. static void
  482. test_same_voter(networkstatus_voter_info_t *v1,
  483. networkstatus_voter_info_t *v2)
  484. {
  485. test_streq(v1->nickname, v2->nickname);
  486. test_memeq(v1->identity_digest, v2->identity_digest, DIGEST_LEN);
  487. test_streq(v1->address, v2->address);
  488. test_eq(v1->addr, v2->addr);
  489. test_eq(v1->dir_port, v2->dir_port);
  490. test_eq(v1->or_port, v2->or_port);
  491. test_streq(v1->contact, v2->contact);
  492. test_memeq(v1->vote_digest, v2->vote_digest, DIGEST_LEN);
  493. done:
  494. ;
  495. }
  496. /** Helper: Make a new routerinfo containing the right information for a
  497. * given vote_routerstatus_t. */
  498. static routerinfo_t *
  499. generate_ri_from_rs(const vote_routerstatus_t *vrs)
  500. {
  501. routerinfo_t *r;
  502. const routerstatus_t *rs = &vrs->status;
  503. static time_t published = 0;
  504. r = tor_malloc_zero(sizeof(routerinfo_t));
  505. memcpy(r->cache_info.identity_digest, rs->identity_digest, DIGEST_LEN);
  506. memcpy(r->cache_info.signed_descriptor_digest, rs->descriptor_digest,
  507. DIGEST_LEN);
  508. r->cache_info.do_not_cache = 1;
  509. r->cache_info.routerlist_index = -1;
  510. r->cache_info.signed_descriptor_body =
  511. tor_strdup("123456789012345678901234567890123");
  512. r->cache_info.signed_descriptor_len =
  513. strlen(r->cache_info.signed_descriptor_body);
  514. r->exit_policy = smartlist_create();
  515. r->cache_info.published_on = ++published + time(NULL);
  516. return r;
  517. }
  518. /** Run unit tests for generating and parsing V3 consensus networkstatus
  519. * documents. */
  520. static void
  521. test_dir_v3_networkstatus(void)
  522. {
  523. authority_cert_t *cert1=NULL, *cert2=NULL, *cert3=NULL;
  524. crypto_pk_env_t *sign_skey_1=NULL, *sign_skey_2=NULL, *sign_skey_3=NULL;
  525. crypto_pk_env_t *sign_skey_leg1=NULL;
  526. const char *msg=NULL;
  527. time_t now = time(NULL);
  528. networkstatus_voter_info_t *voter;
  529. networkstatus_t *vote=NULL, *v1=NULL, *v2=NULL, *v3=NULL, *con=NULL;
  530. vote_routerstatus_t *vrs;
  531. routerstatus_t *rs;
  532. char *v1_text=NULL, *v2_text=NULL, *v3_text=NULL, *consensus_text=NULL, *cp;
  533. smartlist_t *votes = smartlist_create();
  534. /* For generating the two other consensuses. */
  535. char *detached_text1=NULL, *detached_text2=NULL;
  536. char *consensus_text2=NULL, *consensus_text3=NULL;
  537. networkstatus_t *con2=NULL, *con3=NULL;
  538. ns_detached_signatures_t *dsig1=NULL, *dsig2=NULL;
  539. /* Parse certificates and keys. */
  540. cert1 = authority_cert_parse_from_string(AUTHORITY_CERT_1, NULL);
  541. test_assert(cert1);
  542. test_assert(cert1->is_cross_certified);
  543. cert2 = authority_cert_parse_from_string(AUTHORITY_CERT_2, NULL);
  544. test_assert(cert2);
  545. cert3 = authority_cert_parse_from_string(AUTHORITY_CERT_3, NULL);
  546. test_assert(cert3);
  547. sign_skey_1 = crypto_new_pk_env();
  548. sign_skey_2 = crypto_new_pk_env();
  549. sign_skey_3 = crypto_new_pk_env();
  550. sign_skey_leg1 = pk_generate(4);
  551. test_assert(!crypto_pk_read_private_key_from_string(sign_skey_1,
  552. AUTHORITY_SIGNKEY_1));
  553. test_assert(!crypto_pk_read_private_key_from_string(sign_skey_2,
  554. AUTHORITY_SIGNKEY_2));
  555. test_assert(!crypto_pk_read_private_key_from_string(sign_skey_3,
  556. AUTHORITY_SIGNKEY_3));
  557. test_assert(!crypto_pk_cmp_keys(sign_skey_1, cert1->signing_key));
  558. test_assert(!crypto_pk_cmp_keys(sign_skey_2, cert2->signing_key));
  559. /*
  560. * Set up a vote; generate it; try to parse it.
  561. */
  562. vote = tor_malloc_zero(sizeof(networkstatus_t));
  563. vote->type = NS_TYPE_VOTE;
  564. vote->published = now;
  565. vote->valid_after = now+1000;
  566. vote->fresh_until = now+2000;
  567. vote->valid_until = now+3000;
  568. vote->vote_seconds = 100;
  569. vote->dist_seconds = 200;
  570. vote->supported_methods = smartlist_create();
  571. smartlist_split_string(vote->supported_methods, "1 2 3", NULL, 0, -1);
  572. vote->client_versions = tor_strdup("0.1.2.14,0.1.2.15");
  573. vote->server_versions = tor_strdup("0.1.2.14,0.1.2.15,0.1.2.16");
  574. vote->known_flags = smartlist_create();
  575. smartlist_split_string(vote->known_flags,
  576. "Authority Exit Fast Guard Running Stable V2Dir Valid",
  577. 0, SPLIT_SKIP_SPACE|SPLIT_IGNORE_BLANK, 0);
  578. vote->voters = smartlist_create();
  579. voter = tor_malloc_zero(sizeof(networkstatus_voter_info_t));
  580. voter->nickname = tor_strdup("Voter1");
  581. voter->address = tor_strdup("1.2.3.4");
  582. voter->addr = 0x01020304;
  583. voter->dir_port = 80;
  584. voter->or_port = 9000;
  585. voter->contact = tor_strdup("voter@example.com");
  586. crypto_pk_get_digest(cert1->identity_key, voter->identity_digest);
  587. smartlist_add(vote->voters, voter);
  588. vote->cert = authority_cert_dup(cert1);
  589. vote->net_params = smartlist_create();
  590. smartlist_split_string(vote->net_params, "circuitwindow=101 foo=990",
  591. NULL, 0, 0);
  592. vote->routerstatus_list = smartlist_create();
  593. /* add the first routerstatus. */
  594. vrs = tor_malloc_zero(sizeof(vote_routerstatus_t));
  595. rs = &vrs->status;
  596. vrs->version = tor_strdup("0.1.2.14");
  597. rs->published_on = now-1500;
  598. strlcpy(rs->nickname, "router2", sizeof(rs->nickname));
  599. memset(rs->identity_digest, 3, DIGEST_LEN);
  600. memset(rs->descriptor_digest, 78, DIGEST_LEN);
  601. rs->addr = 0x99008801;
  602. rs->or_port = 443;
  603. rs->dir_port = 8000;
  604. /* all flags but running cleared */
  605. rs->is_running = 1;
  606. smartlist_add(vote->routerstatus_list, vrs);
  607. test_assert(router_add_to_routerlist(generate_ri_from_rs(vrs), &msg,0,0)>=0);
  608. /* add the second routerstatus. */
  609. vrs = tor_malloc_zero(sizeof(vote_routerstatus_t));
  610. rs = &vrs->status;
  611. vrs->version = tor_strdup("0.2.0.5");
  612. rs->published_on = now-1000;
  613. strlcpy(rs->nickname, "router1", sizeof(rs->nickname));
  614. memset(rs->identity_digest, 5, DIGEST_LEN);
  615. memset(rs->descriptor_digest, 77, DIGEST_LEN);
  616. rs->addr = 0x99009901;
  617. rs->or_port = 443;
  618. rs->dir_port = 0;
  619. rs->is_exit = rs->is_stable = rs->is_fast = rs->is_running =
  620. rs->is_valid = rs->is_v2_dir = rs->is_possible_guard = 1;
  621. smartlist_add(vote->routerstatus_list, vrs);
  622. test_assert(router_add_to_routerlist(generate_ri_from_rs(vrs), &msg,0,0)>=0);
  623. /* add the third routerstatus. */
  624. vrs = tor_malloc_zero(sizeof(vote_routerstatus_t));
  625. rs = &vrs->status;
  626. vrs->version = tor_strdup("0.1.0.3");
  627. rs->published_on = now-1000;
  628. strlcpy(rs->nickname, "router3", sizeof(rs->nickname));
  629. memset(rs->identity_digest, 33, DIGEST_LEN);
  630. memset(rs->descriptor_digest, 79, DIGEST_LEN);
  631. rs->addr = 0xAA009901;
  632. rs->or_port = 400;
  633. rs->dir_port = 9999;
  634. rs->is_authority = rs->is_exit = rs->is_stable = rs->is_fast =
  635. rs->is_running = rs->is_valid = rs->is_v2_dir = rs->is_possible_guard = 1;
  636. smartlist_add(vote->routerstatus_list, vrs);
  637. test_assert(router_add_to_routerlist(generate_ri_from_rs(vrs), &msg,0,0)>=0);
  638. /* add a fourth routerstatus that is not running. */
  639. vrs = tor_malloc_zero(sizeof(vote_routerstatus_t));
  640. rs = &vrs->status;
  641. vrs->version = tor_strdup("0.1.6.3");
  642. rs->published_on = now-1000;
  643. strlcpy(rs->nickname, "router4", sizeof(rs->nickname));
  644. memset(rs->identity_digest, 34, DIGEST_LEN);
  645. memset(rs->descriptor_digest, 48, DIGEST_LEN);
  646. rs->addr = 0xC0000203;
  647. rs->or_port = 500;
  648. rs->dir_port = 1999;
  649. /* Running flag (and others) cleared */
  650. smartlist_add(vote->routerstatus_list, vrs);
  651. test_assert(router_add_to_routerlist(generate_ri_from_rs(vrs), &msg,0,0)>=0);
  652. /* dump the vote and try to parse it. */
  653. v1_text = format_networkstatus_vote(sign_skey_1, vote);
  654. test_assert(v1_text);
  655. v1 = networkstatus_parse_vote_from_string(v1_text, NULL, NS_TYPE_VOTE);
  656. test_assert(v1);
  657. /* Make sure the parsed thing was right. */
  658. test_eq(v1->type, NS_TYPE_VOTE);
  659. test_eq(v1->published, vote->published);
  660. test_eq(v1->valid_after, vote->valid_after);
  661. test_eq(v1->fresh_until, vote->fresh_until);
  662. test_eq(v1->valid_until, vote->valid_until);
  663. test_eq(v1->vote_seconds, vote->vote_seconds);
  664. test_eq(v1->dist_seconds, vote->dist_seconds);
  665. test_streq(v1->client_versions, vote->client_versions);
  666. test_streq(v1->server_versions, vote->server_versions);
  667. test_assert(v1->voters && smartlist_len(v1->voters));
  668. voter = smartlist_get(v1->voters, 0);
  669. test_streq(voter->nickname, "Voter1");
  670. test_streq(voter->address, "1.2.3.4");
  671. test_eq(voter->addr, 0x01020304);
  672. test_eq(voter->dir_port, 80);
  673. test_eq(voter->or_port, 9000);
  674. test_streq(voter->contact, "voter@example.com");
  675. test_assert(v1->cert);
  676. test_assert(!crypto_pk_cmp_keys(sign_skey_1, v1->cert->signing_key));
  677. cp = smartlist_join_strings(v1->known_flags, ":", 0, NULL);
  678. test_streq(cp, "Authority:Exit:Fast:Guard:Running:Stable:V2Dir:Valid");
  679. tor_free(cp);
  680. test_eq(smartlist_len(v1->routerstatus_list), 4);
  681. /* Check the first routerstatus. */
  682. vrs = smartlist_get(v1->routerstatus_list, 0);
  683. rs = &vrs->status;
  684. test_streq(vrs->version, "0.1.2.14");
  685. test_eq(rs->published_on, now-1500);
  686. test_streq(rs->nickname, "router2");
  687. test_memeq(rs->identity_digest,
  688. "\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3",
  689. DIGEST_LEN);
  690. test_memeq(rs->descriptor_digest, "NNNNNNNNNNNNNNNNNNNN", DIGEST_LEN);
  691. test_eq(rs->addr, 0x99008801);
  692. test_eq(rs->or_port, 443);
  693. test_eq(rs->dir_port, 8000);
  694. test_eq(vrs->flags, U64_LITERAL(16)); // no flags except "running"
  695. /* Check the second routerstatus. */
  696. vrs = smartlist_get(v1->routerstatus_list, 1);
  697. rs = &vrs->status;
  698. test_streq(vrs->version, "0.2.0.5");
  699. test_eq(rs->published_on, now-1000);
  700. test_streq(rs->nickname, "router1");
  701. test_memeq(rs->identity_digest,
  702. "\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5",
  703. DIGEST_LEN);
  704. test_memeq(rs->descriptor_digest, "MMMMMMMMMMMMMMMMMMMM", DIGEST_LEN);
  705. test_eq(rs->addr, 0x99009901);
  706. test_eq(rs->or_port, 443);
  707. test_eq(rs->dir_port, 0);
  708. test_eq(vrs->flags, U64_LITERAL(254)); // all flags except "authority."
  709. {
  710. measured_bw_line_t mbw;
  711. memset(mbw.node_id, 33, sizeof(mbw.node_id));
  712. mbw.bw = 1024;
  713. test_assert(measured_bw_line_apply(&mbw,
  714. v1->routerstatus_list) == 1);
  715. vrs = smartlist_get(v1->routerstatus_list, 2);
  716. test_assert(vrs->status.has_measured_bw &&
  717. vrs->status.measured_bw == 1024);
  718. }
  719. /* Generate second vote. It disagrees on some of the times,
  720. * and doesn't list versions, and knows some crazy flags */
  721. vote->published = now+1;
  722. vote->fresh_until = now+3005;
  723. vote->dist_seconds = 300;
  724. authority_cert_free(vote->cert);
  725. vote->cert = authority_cert_dup(cert2);
  726. vote->net_params = smartlist_create();
  727. smartlist_split_string(vote->net_params, "bar=2000000000 circuitwindow=20",
  728. NULL, 0, 0);
  729. tor_free(vote->client_versions);
  730. tor_free(vote->server_versions);
  731. voter = smartlist_get(vote->voters, 0);
  732. tor_free(voter->nickname);
  733. tor_free(voter->address);
  734. voter->nickname = tor_strdup("Voter2");
  735. voter->address = tor_strdup("2.3.4.5");
  736. voter->addr = 0x02030405;
  737. crypto_pk_get_digest(cert2->identity_key, voter->identity_digest);
  738. smartlist_add(vote->known_flags, tor_strdup("MadeOfCheese"));
  739. smartlist_add(vote->known_flags, tor_strdup("MadeOfTin"));
  740. smartlist_sort_strings(vote->known_flags);
  741. vrs = smartlist_get(vote->routerstatus_list, 2);
  742. smartlist_del_keeporder(vote->routerstatus_list, 2);
  743. tor_free(vrs->version);
  744. tor_free(vrs);
  745. vrs = smartlist_get(vote->routerstatus_list, 0);
  746. vrs->status.is_fast = 1;
  747. /* generate and parse. */
  748. v2_text = format_networkstatus_vote(sign_skey_2, vote);
  749. test_assert(v2_text);
  750. v2 = networkstatus_parse_vote_from_string(v2_text, NULL, NS_TYPE_VOTE);
  751. test_assert(v2);
  752. /* Check that flags come out right.*/
  753. cp = smartlist_join_strings(v2->known_flags, ":", 0, NULL);
  754. test_streq(cp, "Authority:Exit:Fast:Guard:MadeOfCheese:MadeOfTin:"
  755. "Running:Stable:V2Dir:Valid");
  756. tor_free(cp);
  757. vrs = smartlist_get(v2->routerstatus_list, 1);
  758. /* 1023 - authority(1) - madeofcheese(16) - madeoftin(32) */
  759. test_eq(vrs->flags, U64_LITERAL(974));
  760. /* Generate the third vote. */
  761. vote->published = now;
  762. vote->fresh_until = now+2003;
  763. vote->dist_seconds = 250;
  764. authority_cert_free(vote->cert);
  765. vote->cert = authority_cert_dup(cert3);
  766. vote->net_params = smartlist_create();
  767. smartlist_split_string(vote->net_params, "circuitwindow=80 foo=660",
  768. NULL, 0, 0);
  769. smartlist_add(vote->supported_methods, tor_strdup("4"));
  770. vote->client_versions = tor_strdup("0.1.2.14,0.1.2.17");
  771. vote->server_versions = tor_strdup("0.1.2.10,0.1.2.15,0.1.2.16");
  772. voter = smartlist_get(vote->voters, 0);
  773. tor_free(voter->nickname);
  774. tor_free(voter->address);
  775. voter->nickname = tor_strdup("Voter3");
  776. voter->address = tor_strdup("3.4.5.6");
  777. voter->addr = 0x03040506;
  778. crypto_pk_get_digest(cert3->identity_key, voter->identity_digest);
  779. /* This one has a legacy id. */
  780. memset(voter->legacy_id_digest, (int)'A', DIGEST_LEN);
  781. vrs = smartlist_get(vote->routerstatus_list, 0);
  782. smartlist_del_keeporder(vote->routerstatus_list, 0);
  783. tor_free(vrs->version);
  784. tor_free(vrs);
  785. vrs = smartlist_get(vote->routerstatus_list, 0);
  786. memset(vrs->status.descriptor_digest, (int)'Z', DIGEST_LEN);
  787. test_assert(router_add_to_routerlist(generate_ri_from_rs(vrs), &msg,0,0)>=0);
  788. v3_text = format_networkstatus_vote(sign_skey_3, vote);
  789. test_assert(v3_text);
  790. v3 = networkstatus_parse_vote_from_string(v3_text, NULL, NS_TYPE_VOTE);
  791. test_assert(v3);
  792. /* Compute a consensus as voter 3. */
  793. smartlist_add(votes, v3);
  794. smartlist_add(votes, v1);
  795. smartlist_add(votes, v2);
  796. consensus_text = networkstatus_compute_consensus(votes, 3,
  797. cert3->identity_key,
  798. sign_skey_3,
  799. "AAAAAAAAAAAAAAAAAAAA",
  800. sign_skey_leg1);
  801. test_assert(consensus_text);
  802. con = networkstatus_parse_vote_from_string(consensus_text, NULL,
  803. NS_TYPE_CONSENSUS);
  804. test_assert(con);
  805. //log_notice(LD_GENERAL, "<<%s>>\n<<%s>>\n<<%s>>\n",
  806. // v1_text, v2_text, v3_text);
  807. /* Check consensus contents. */
  808. test_assert(con->type == NS_TYPE_CONSENSUS);
  809. test_eq(con->published, 0); /* this field only appears in votes. */
  810. test_eq(con->valid_after, now+1000);
  811. test_eq(con->fresh_until, now+2003); /* median */
  812. test_eq(con->valid_until, now+3000);
  813. test_eq(con->vote_seconds, 100);
  814. test_eq(con->dist_seconds, 250); /* median */
  815. test_streq(con->client_versions, "0.1.2.14");
  816. test_streq(con->server_versions, "0.1.2.15,0.1.2.16");
  817. cp = smartlist_join_strings(v2->known_flags, ":", 0, NULL);
  818. test_streq(cp, "Authority:Exit:Fast:Guard:MadeOfCheese:MadeOfTin:"
  819. "Running:Stable:V2Dir:Valid");
  820. tor_free(cp);
  821. cp = smartlist_join_strings(con->net_params, ":", 0, NULL);
  822. test_streq(cp, "bar=2000000000:circuitwindow=80:foo=660");
  823. tor_free(cp);
  824. test_eq(4, smartlist_len(con->voters)); /*3 voters, 1 legacy key.*/
  825. /* The voter id digests should be in this order. */
  826. test_assert(memcmp(cert2->cache_info.identity_digest,
  827. cert1->cache_info.identity_digest,DIGEST_LEN)<0);
  828. test_assert(memcmp(cert1->cache_info.identity_digest,
  829. cert3->cache_info.identity_digest,DIGEST_LEN)<0);
  830. test_same_voter(smartlist_get(con->voters, 1),
  831. smartlist_get(v2->voters, 0));
  832. test_same_voter(smartlist_get(con->voters, 2),
  833. smartlist_get(v1->voters, 0));
  834. test_same_voter(smartlist_get(con->voters, 3),
  835. smartlist_get(v3->voters, 0));
  836. test_assert(!con->cert);
  837. test_eq(2, smartlist_len(con->routerstatus_list));
  838. /* There should be two listed routers: one with identity 3, one with
  839. * identity 5. */
  840. /* This one showed up in 2 digests. */
  841. rs = smartlist_get(con->routerstatus_list, 0);
  842. test_memeq(rs->identity_digest,
  843. "\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3\x3",
  844. DIGEST_LEN);
  845. test_memeq(rs->descriptor_digest, "NNNNNNNNNNNNNNNNNNNN", DIGEST_LEN);
  846. test_assert(!rs->is_authority);
  847. test_assert(!rs->is_exit);
  848. test_assert(!rs->is_fast);
  849. test_assert(!rs->is_possible_guard);
  850. test_assert(!rs->is_stable);
  851. test_assert(rs->is_running); /* If it wasn't running it wouldn't be here */
  852. test_assert(!rs->is_v2_dir);
  853. test_assert(!rs->is_valid);
  854. test_assert(!rs->is_named);
  855. /* XXXX check version */
  856. rs = smartlist_get(con->routerstatus_list, 1);
  857. /* This one showed up in 3 digests. Twice with ID 'M', once with 'Z'. */
  858. test_memeq(rs->identity_digest,
  859. "\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5\x5",
  860. DIGEST_LEN);
  861. test_streq(rs->nickname, "router1");
  862. test_memeq(rs->descriptor_digest, "MMMMMMMMMMMMMMMMMMMM", DIGEST_LEN);
  863. test_eq(rs->published_on, now-1000);
  864. test_eq(rs->addr, 0x99009901);
  865. test_eq(rs->or_port, 443);
  866. test_eq(rs->dir_port, 0);
  867. test_assert(!rs->is_authority);
  868. test_assert(rs->is_exit);
  869. test_assert(rs->is_fast);
  870. test_assert(rs->is_possible_guard);
  871. test_assert(rs->is_stable);
  872. test_assert(rs->is_running);
  873. test_assert(rs->is_v2_dir);
  874. test_assert(rs->is_valid);
  875. test_assert(!rs->is_named);
  876. /* XXXX check version */
  877. // x231
  878. // x213
  879. /* Check signatures. the first voter is a pseudo-entry with a legacy key.
  880. * The second one hasn't signed. The fourth one has signed: validate it. */
  881. voter = smartlist_get(con->voters, 1);
  882. test_assert(!voter->signature);
  883. test_assert(!voter->good_signature);
  884. test_assert(!voter->bad_signature);
  885. voter = smartlist_get(con->voters, 3);
  886. test_assert(voter->signature);
  887. test_assert(!voter->good_signature);
  888. test_assert(!voter->bad_signature);
  889. test_assert(!networkstatus_check_voter_signature(con,
  890. smartlist_get(con->voters, 3),
  891. cert3));
  892. test_assert(voter->signature);
  893. test_assert(voter->good_signature);
  894. test_assert(!voter->bad_signature);
  895. {
  896. const char *msg=NULL;
  897. /* Compute the other two signed consensuses. */
  898. smartlist_shuffle(votes);
  899. consensus_text2 = networkstatus_compute_consensus(votes, 3,
  900. cert2->identity_key,
  901. sign_skey_2, NULL,NULL);
  902. smartlist_shuffle(votes);
  903. consensus_text3 = networkstatus_compute_consensus(votes, 3,
  904. cert1->identity_key,
  905. sign_skey_1, NULL,NULL);
  906. test_assert(consensus_text2);
  907. test_assert(consensus_text3);
  908. con2 = networkstatus_parse_vote_from_string(consensus_text2, NULL,
  909. NS_TYPE_CONSENSUS);
  910. con3 = networkstatus_parse_vote_from_string(consensus_text3, NULL,
  911. NS_TYPE_CONSENSUS);
  912. test_assert(con2);
  913. test_assert(con3);
  914. /* All three should have the same digest. */
  915. test_memeq(con->networkstatus_digest, con2->networkstatus_digest,
  916. DIGEST_LEN);
  917. test_memeq(con->networkstatus_digest, con3->networkstatus_digest,
  918. DIGEST_LEN);
  919. /* Extract a detached signature from con3. */
  920. detached_text1 = networkstatus_get_detached_signatures(con3);
  921. tor_assert(detached_text1);
  922. /* Try to parse it. */
  923. dsig1 = networkstatus_parse_detached_signatures(detached_text1, NULL);
  924. tor_assert(dsig1);
  925. /* Are parsed values as expected? */
  926. test_eq(dsig1->valid_after, con3->valid_after);
  927. test_eq(dsig1->fresh_until, con3->fresh_until);
  928. test_eq(dsig1->valid_until, con3->valid_until);
  929. test_memeq(dsig1->networkstatus_digest, con3->networkstatus_digest,
  930. DIGEST_LEN);
  931. test_eq(1, smartlist_len(dsig1->signatures));
  932. voter = smartlist_get(dsig1->signatures, 0);
  933. test_memeq(voter->identity_digest, cert1->cache_info.identity_digest,
  934. DIGEST_LEN);
  935. /* Try adding it to con2. */
  936. detached_text2 = networkstatus_get_detached_signatures(con2);
  937. test_eq(1, networkstatus_add_detached_signatures(con2, dsig1, &msg));
  938. tor_free(detached_text2);
  939. detached_text2 = networkstatus_get_detached_signatures(con2);
  940. //printf("\n<%s>\n", detached_text2);
  941. dsig2 = networkstatus_parse_detached_signatures(detached_text2, NULL);
  942. test_assert(dsig2);
  943. /*
  944. printf("\n");
  945. SMARTLIST_FOREACH(dsig2->signatures, networkstatus_voter_info_t *, vi, {
  946. char hd[64];
  947. base16_encode(hd, sizeof(hd), vi->identity_digest, DIGEST_LEN);
  948. printf("%s\n", hd);
  949. });
  950. */
  951. test_eq(2, smartlist_len(dsig2->signatures));
  952. /* Try adding to con2 twice; verify that nothing changes. */
  953. test_eq(0, networkstatus_add_detached_signatures(con2, dsig1, &msg));
  954. /* Add to con. */
  955. test_eq(2, networkstatus_add_detached_signatures(con, dsig2, &msg));
  956. /* Check signatures */
  957. test_assert(!networkstatus_check_voter_signature(con,
  958. smartlist_get(con->voters, 1),
  959. cert2));
  960. test_assert(!networkstatus_check_voter_signature(con,
  961. smartlist_get(con->voters, 2),
  962. cert1));
  963. }
  964. done:
  965. smartlist_free(votes);
  966. tor_free(v1_text);
  967. tor_free(v2_text);
  968. tor_free(v3_text);
  969. tor_free(consensus_text);
  970. if (vote)
  971. networkstatus_vote_free(vote);
  972. if (v1)
  973. networkstatus_vote_free(v1);
  974. if (v2)
  975. networkstatus_vote_free(v2);
  976. if (v3)
  977. networkstatus_vote_free(v3);
  978. if (con)
  979. networkstatus_vote_free(con);
  980. if (sign_skey_1)
  981. crypto_free_pk_env(sign_skey_1);
  982. if (sign_skey_2)
  983. crypto_free_pk_env(sign_skey_2);
  984. if (sign_skey_3)
  985. crypto_free_pk_env(sign_skey_3);
  986. if (sign_skey_leg1)
  987. crypto_free_pk_env(sign_skey_leg1);
  988. if (cert1)
  989. authority_cert_free(cert1);
  990. if (cert2)
  991. authority_cert_free(cert2);
  992. if (cert3)
  993. authority_cert_free(cert3);
  994. tor_free(consensus_text2);
  995. tor_free(consensus_text3);
  996. tor_free(detached_text1);
  997. tor_free(detached_text2);
  998. if (con2)
  999. networkstatus_vote_free(con2);
  1000. if (con3)
  1001. networkstatus_vote_free(con3);
  1002. if (dsig1)
  1003. ns_detached_signatures_free(dsig1);
  1004. if (dsig2)
  1005. ns_detached_signatures_free(dsig2);
  1006. }
  1007. #define DIR_LEGACY(name) \
  1008. { #name, legacy_test_helper, 0, &legacy_setup, test_dir_ ## name }
  1009. struct testcase_t dir_tests[] = {
  1010. DIR_LEGACY(nicknames),
  1011. DIR_LEGACY(formats),
  1012. DIR_LEGACY(versions),
  1013. DIR_LEGACY(util),
  1014. DIR_LEGACY(measured_bw),
  1015. DIR_LEGACY(param_voting),
  1016. DIR_LEGACY(v3_networkstatus),
  1017. END_OF_TESTCASES
  1018. };