routerparse.c 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554
  1. /* Copyright 2001 Matej Pfajfar.
  2. * Copyright 2001-2004 Roger Dingledine.
  3. * Copyright 2004 Roger Dingledine, Nick Mathewson. */
  4. /* See LICENSE for licensing information */
  5. /* $Id$ */
  6. const char routerparse_c_id[] = "$Id$";
  7. /**
  8. * \file routerparse.c
  9. *
  10. * \brief Code to parse and validate router descriptors and directories.
  11. **/
  12. #include "or.h"
  13. /****************************************************************************/
  14. /** Enumeration of possible token types. The ones starting with K_
  15. * correspond to directory 'keywords'. _UNRECOGNIZED is for an
  16. * unrecognized keyword; _ERR is an error in the tokenizing process,
  17. * _EOF is an end-of-file marker, and _NIL is used to encode
  18. * not-a-token.
  19. */
  20. typedef enum {
  21. K_ACCEPT,
  22. K_DIRECTORY_SIGNATURE,
  23. K_RECOMMENDED_SOFTWARE,
  24. K_REJECT,
  25. K_ROUTER,
  26. K_SIGNED_DIRECTORY,
  27. K_SIGNING_KEY,
  28. K_ONION_KEY,
  29. K_ROUTER_SIGNATURE,
  30. K_PUBLISHED,
  31. K_RUNNING_ROUTERS,
  32. K_ROUTER_STATUS,
  33. K_PLATFORM,
  34. K_OPT,
  35. K_BANDWIDTH,
  36. K_PORTS,
  37. K_DIRCACHEPORT,
  38. K_CONTACT,
  39. K_NETWORK_STATUS,
  40. K_UPTIME,
  41. K_DIR_SIGNING_KEY,
  42. K_FAMILY,
  43. _UNRECOGNIZED,
  44. _ERR,
  45. _EOF,
  46. _NIL
  47. } directory_keyword;
  48. /** Structure to hold a single directory token.
  49. *
  50. * We parse a directory by breaking it into "tokens", each consisting
  51. * of a keyword, a line full of arguments, and a binary object. The
  52. * arguments and object are both optional, depending on the keyword
  53. * type.
  54. */
  55. typedef struct directory_token_t {
  56. directory_keyword tp; /**< Type of the token. */
  57. int n_args; /**< Number of elements in args */
  58. char **args; /**< Array of arguments from keyword line. */
  59. char *object_type; /**< -----BEGIN [object_type]-----*/
  60. size_t object_size; /**< Bytes in object_body */
  61. char *object_body; /**< Contents of object, base64-decoded. */
  62. crypto_pk_env_t *key; /**< For public keys only. */
  63. const char *error; /**< For _ERR tokens only. */
  64. } directory_token_t;
  65. /* ********************************************************************** */
  66. /** We use a table of rules to decide how to parse each token type. */
  67. /** Rules for how many arguments a keyword can take. */
  68. typedef enum {
  69. NO_ARGS, /**< (1) no arguments, ever */
  70. ARGS, /**< (2) a list of arguments separated by spaces */
  71. CONCAT_ARGS, /**< or (3) the rest of the line, treated as a single argument. */
  72. } arg_syntax;
  73. /** Rules for whether the keyword needs an object. */
  74. typedef enum {
  75. NO_OBJ, /**< (1) no object, ever */
  76. NEED_OBJ, /**< (2) object is required */
  77. NEED_KEY, /**< (3) object is required, and must be a public key. */
  78. OBJ_OK, /**< or (4) object is optional. */
  79. } obj_syntax;
  80. /** Rules for where a keyword can appear. */
  81. typedef enum {
  82. ANY = 0, /**< Appears in router descriptor or in directory sections. */
  83. DIR_ONLY, /**< Appears only in directory. */
  84. RTR_ONLY, /**< Appears only in router descriptor or runningrouters */
  85. } where_syntax;
  86. /** Table mapping keywords to token value and to argument rules. */
  87. static struct {
  88. const char *t; int v; arg_syntax s; obj_syntax os; where_syntax ws;
  89. } token_table[] = {
  90. { "accept", K_ACCEPT, ARGS, NO_OBJ, RTR_ONLY },
  91. { "directory-signature", K_DIRECTORY_SIGNATURE, ARGS, NEED_OBJ,DIR_ONLY},
  92. { "reject", K_REJECT, ARGS, NO_OBJ, RTR_ONLY },
  93. { "router", K_ROUTER, ARGS, NO_OBJ, RTR_ONLY },
  94. { "recommended-software",K_RECOMMENDED_SOFTWARE,ARGS, NO_OBJ, DIR_ONLY },
  95. { "signed-directory", K_SIGNED_DIRECTORY, NO_ARGS, NO_OBJ, DIR_ONLY },
  96. { "signing-key", K_SIGNING_KEY, NO_ARGS, NEED_KEY,RTR_ONLY },
  97. { "onion-key", K_ONION_KEY, NO_ARGS, NEED_KEY,RTR_ONLY },
  98. { "router-signature", K_ROUTER_SIGNATURE, NO_ARGS, NEED_OBJ,RTR_ONLY },
  99. { "running-routers", K_RUNNING_ROUTERS, ARGS, NO_OBJ, DIR_ONLY },
  100. { "router-status", K_ROUTER_STATUS, ARGS, NO_OBJ, DIR_ONLY },
  101. { "ports", K_PORTS, ARGS, NO_OBJ, RTR_ONLY },
  102. { "bandwidth", K_BANDWIDTH, ARGS, NO_OBJ, RTR_ONLY },
  103. { "platform", K_PLATFORM, CONCAT_ARGS, NO_OBJ, RTR_ONLY },
  104. { "published", K_PUBLISHED, CONCAT_ARGS, NO_OBJ, ANY },
  105. { "opt", K_OPT, CONCAT_ARGS, OBJ_OK, ANY },
  106. { "dircacheport", K_DIRCACHEPORT, ARGS, NO_OBJ, RTR_ONLY },
  107. { "contact", K_CONTACT, CONCAT_ARGS, NO_OBJ, ANY },
  108. { "network-status", K_NETWORK_STATUS, NO_ARGS, NO_OBJ, DIR_ONLY },
  109. { "uptime", K_UPTIME, ARGS, NO_OBJ, RTR_ONLY },
  110. { "dir-signing-key", K_DIR_SIGNING_KEY, ARGS, OBJ_OK, DIR_ONLY },
  111. { "family", K_FAMILY, ARGS, NO_OBJ, RTR_ONLY },
  112. { NULL, -1, NO_ARGS, NO_OBJ, ANY }
  113. };
  114. /* static function prototypes */
  115. static int router_add_exit_policy(routerinfo_t *router,directory_token_t *tok);
  116. static addr_policy_t *router_parse_addr_policy(directory_token_t *tok);
  117. static int router_get_hash_impl(const char *s, char *digest,
  118. const char *start_str, const char *end_str);
  119. static void token_free(directory_token_t *tok);
  120. static smartlist_t *find_all_exitpolicy(smartlist_t *s);
  121. static directory_token_t *find_first_by_keyword(smartlist_t *s,
  122. directory_keyword keyword);
  123. static int tokenize_string(const char *start, const char *end,
  124. smartlist_t *out, int is_dir);
  125. static directory_token_t *get_next_token(const char **s, where_syntax where);
  126. static int check_directory_signature(const char *digest,
  127. directory_token_t *tok,
  128. crypto_pk_env_t *pkey,
  129. crypto_pk_env_t *declared_key);
  130. static crypto_pk_env_t *find_dir_signing_key(const char *str);
  131. /* static */ int is_obsolete_version(const char *myversion,
  132. const char *versionlist);
  133. /** Set <b>digest</b> to the SHA-1 digest of the hash of the directory in
  134. * <b>s</b>. Return 0 on success, nonzero on failure.
  135. */
  136. int router_get_dir_hash(const char *s, char *digest)
  137. {
  138. return router_get_hash_impl(s,digest,
  139. "signed-directory","\ndirectory-signature");
  140. }
  141. /** Set <b>digest</b> to the SHA-1 digest of the hash of the first router in
  142. * <b>s</b>. Return 0 on success, nonzero on failure.
  143. */
  144. int router_get_router_hash(const char *s, char *digest)
  145. {
  146. return router_get_hash_impl(s,digest,
  147. "router ","\nrouter-signature");
  148. }
  149. /** Set <b>digest</b> to the SHA-1 digest of the hash of the running-routers
  150. * string in <b>s</b>. Return 0 on success, nonzero on failure.
  151. */
  152. int router_get_runningrouters_hash(const char *s, char *digest)
  153. {
  154. return router_get_hash_impl(s,digest,
  155. "network-status","\ndirectory-signature");
  156. }
  157. /**
  158. * Find the first instance of "recommended-software ...\n" at the start of
  159. * a line; return a newly allocated string containing the "..." portion.
  160. * Return NULL if no such instance was found.
  161. */
  162. static char *
  163. get_recommended_software_from_directory(const char *str)
  164. {
  165. #define REC "recommended-software "
  166. const char *cp = str, *eol;
  167. size_t len = strlen(REC);
  168. cp = str;
  169. if (strcmpstart(str, REC)==0) {
  170. cp += len;
  171. } else {
  172. cp = strstr(str, "\n"REC);
  173. if (!cp)
  174. return NULL;
  175. cp += len+1;
  176. }
  177. eol = strchr(cp, '\n');
  178. if (!eol)
  179. return NULL;
  180. return tor_strndup(cp, eol-cp);
  181. #undef REC
  182. }
  183. /** Return 1 if <b>myversion</b> is not in <b>versionlist</b>, and if at least
  184. * one version of Tor on <b>versionlist</b> is newer than <b>myversion</b>.
  185. * Otherwise return 0.
  186. * (versionlist is a comma-separated list of version strings,
  187. * optionally prefixed with "Tor". Versions that can't be parsed are
  188. * ignored.) */
  189. /* static */ int is_obsolete_version(const char *myversion,
  190. const char *versionlist) {
  191. const char *vl;
  192. tor_version_t mine, other;
  193. int found_newer = 0, r, ret;
  194. static int warned_too_new=0;
  195. smartlist_t *version_sl;
  196. vl = versionlist;
  197. log_fn(LOG_DEBUG,"Checking whether version '%s' is in '%s'", myversion, versionlist);
  198. if (tor_version_parse(myversion, &mine)) {
  199. log_fn(LOG_ERR, "I couldn't parse my own version (%s)", myversion);
  200. tor_assert(0);
  201. }
  202. version_sl = smartlist_create();
  203. smartlist_split_string(version_sl, versionlist, ",", SPLIT_SKIP_SPACE, 0);
  204. SMARTLIST_FOREACH(version_sl, const char *, cp, {
  205. if (!strcmpstart(cp, "Tor "))
  206. cp += 4;
  207. if (tor_version_parse(cp, &other)) {
  208. /* Couldn't parse other; it can't be a match. */
  209. } else {
  210. r = tor_version_compare(&mine, &other);
  211. if (r==0) {
  212. ret = 0;
  213. goto done;
  214. } else if (r<0) {
  215. found_newer = 1;
  216. }
  217. }
  218. });
  219. if (!found_newer) {
  220. if (!warned_too_new) {
  221. log(LOG_WARN, "This version of Tor (%s) is newer than any on the recommended list (%s)",
  222. myversion, versionlist);
  223. warned_too_new=1;
  224. }
  225. ret = 0;
  226. } else {
  227. ret = 1;
  228. }
  229. done:
  230. SMARTLIST_FOREACH(version_sl, char *, version, tor_free(version));
  231. smartlist_free(version_sl);
  232. return ret;
  233. }
  234. /* Return 0 if myversion is supported; else log a message and return
  235. * -1 (or exit if ignoreversions is false) */
  236. int check_software_version_against_directory(const char *directory,
  237. int ignoreversion)
  238. {
  239. char *v;
  240. v = get_recommended_software_from_directory(directory);
  241. if (!v) {
  242. log_fn(LOG_WARN, "No recommended-versions string found in directory");
  243. return -1;
  244. }
  245. if (!is_obsolete_version(VERSION, v)) {
  246. tor_free(v);
  247. return 0;
  248. }
  249. log(ignoreversion ? LOG_WARN : LOG_ERR,
  250. "You are running Tor version %s, which will not work with this network.\n"
  251. "Please use %s%s.",
  252. VERSION, strchr(v,',') ? "one of " : "", v);
  253. tor_free(v);
  254. if (ignoreversion) {
  255. log(LOG_WARN, "IgnoreVersion is set. If it breaks, we told you so.");
  256. return -1;
  257. } else {
  258. fflush(0);
  259. tor_cleanup();
  260. exit(0);
  261. return -1; /* never reached */
  262. }
  263. }
  264. /** Parse a directory from <b>str</b> and, when done, store the
  265. * resulting routerlist in *<b>dest</b>, freeing the old value if necessary.
  266. * If <b>pkey</b> is provided, we check the directory signature with pkey.
  267. */
  268. int /* Should be static; exposed for unit tests */
  269. router_parse_routerlist_from_directory(const char *str,
  270. routerlist_t **dest,
  271. crypto_pk_env_t *pkey,
  272. int check_version)
  273. {
  274. directory_token_t *tok;
  275. char digest[DIGEST_LEN];
  276. routerlist_t *new_dir = NULL;
  277. char *versions = NULL;
  278. smartlist_t *good_nickname_list = NULL;
  279. time_t published_on;
  280. int i, r;
  281. const char *end, *cp;
  282. smartlist_t *tokens = NULL;
  283. char dirnickname[MAX_NICKNAME_LEN+1];
  284. crypto_pk_env_t *declared_key = NULL;
  285. if (router_get_dir_hash(str, digest)) {
  286. log_fn(LOG_WARN, "Unable to compute digest of directory");
  287. goto err;
  288. }
  289. log_fn(LOG_DEBUG,"Received directory hashes to %s",hex_str(digest,4));
  290. /* Check signature first, before we try to tokenize. */
  291. cp = str;
  292. while (cp && (end = strstr(cp+1, "\ndirectory-signature")))
  293. cp = end;
  294. if (cp == str || !cp) {
  295. log_fn(LOG_WARN, "No signature found on directory."); goto err;
  296. }
  297. ++cp;
  298. tokens = smartlist_create();
  299. if (tokenize_string(cp,strchr(cp,'\0'),tokens,1)) {
  300. log_fn(LOG_WARN, "Error tokenizing directory signature"); goto err;
  301. }
  302. if (smartlist_len(tokens) != 1) {
  303. log_fn(LOG_WARN, "Unexpected number of tokens in signature"); goto err;
  304. }
  305. tok=smartlist_get(tokens,0);
  306. if (tok->tp != K_DIRECTORY_SIGNATURE) {
  307. log_fn(LOG_WARN,"Expected a single directory signature"); goto err;
  308. }
  309. declared_key = find_dir_signing_key(str);
  310. if (check_directory_signature(digest, tok, pkey, declared_key)<0)
  311. goto err;
  312. /* now we know tok->n_args == 1, so it's safe to access tok->args[0] */
  313. if (!is_legal_nickname(tok->args[0])) {
  314. log_fn(LOG_WARN, "Directory nickname '%s' is misformed", tok->args[0]);
  315. goto err;
  316. }
  317. strlcpy(dirnickname, tok->args[0], sizeof(dirnickname));
  318. SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
  319. smartlist_free(tokens);
  320. tokens = NULL;
  321. /* Now that we know the signature is okay, check the version. */
  322. if (check_version)
  323. check_software_version_against_directory(str, get_options()->IgnoreVersion);
  324. /* Now try to parse the first part of the directory. */
  325. if ((end = strstr(str,"\nrouter "))) {
  326. ++end;
  327. } else if ((end = strstr(str, "\ndirectory-signature"))) {
  328. ++end;
  329. } else {
  330. end = str + strlen(str);
  331. }
  332. tokens = smartlist_create();
  333. if (tokenize_string(str,end,tokens,1)) {
  334. log_fn(LOG_WARN, "Error tokenizing directory"); goto err;
  335. }
  336. if (smartlist_len(tokens) < 1) {
  337. log_fn(LOG_WARN, "Impossibly short directory header"); goto err;
  338. }
  339. if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
  340. log_fn(LOG_WARN, "Unrecognized keyword \"%s\" in directory header; can't parse directory.",
  341. tok->args[0]);
  342. goto err;
  343. }
  344. tok = smartlist_get(tokens,0);
  345. if (tok->tp != K_SIGNED_DIRECTORY) {
  346. log_fn(LOG_WARN, "Directory doesn't start with signed-directory.");
  347. goto err;
  348. }
  349. if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
  350. log_fn(LOG_WARN, "Missing published time on directory.");
  351. goto err;
  352. }
  353. tor_assert(tok->n_args == 1);
  354. if (parse_iso_time(tok->args[0], &published_on) < 0) {
  355. goto err;
  356. }
  357. /* Now that we know the signature is okay, and we have a
  358. * publication time, cache the directory. */
  359. if (!get_options()->AuthoritativeDir)
  360. dirserv_set_cached_directory(str, published_on, 0);
  361. if (!(tok = find_first_by_keyword(tokens, K_RECOMMENDED_SOFTWARE))) {
  362. log_fn(LOG_WARN, "Missing recommended-software line from directory.");
  363. goto err;
  364. }
  365. if (tok->n_args > 1) {
  366. log_fn(LOG_WARN, "Invalid recommended-software line");
  367. goto err;
  368. }
  369. versions = tok->n_args ? tor_strdup(tok->args[0]) : tor_strdup("");
  370. /* Prefer router-status, then running-routers. */
  371. if (!(tok = find_first_by_keyword(tokens, K_ROUTER_STATUS))) {
  372. if (!(tok = find_first_by_keyword(tokens, K_RUNNING_ROUTERS))) {
  373. log_fn(LOG_WARN,
  374. "Missing running-routers/router-status line from directory.");
  375. goto err;
  376. }
  377. }
  378. good_nickname_list = smartlist_create();
  379. for (i=0; i<tok->n_args; ++i) {
  380. smartlist_add(good_nickname_list, tok->args[i]);
  381. }
  382. tok->n_args = 0; /* Don't free the strings in good_nickname_list yet. */
  383. /* Read the router list from s, advancing s up past the end of the last
  384. * router. */
  385. str = end;
  386. if (router_parse_list_from_string(&str, &new_dir,
  387. good_nickname_list,
  388. tok->tp==K_RUNNING_ROUTERS,
  389. published_on)) {
  390. log_fn(LOG_WARN, "Error reading routers from directory");
  391. goto err;
  392. }
  393. /* Determine if my routerinfo is considered verified. */
  394. {
  395. static int have_warned_about_unverified_status = 0;
  396. routerinfo_t *me = router_get_my_routerinfo();
  397. if (me) {
  398. if (router_update_status_from_smartlist(me,
  399. published_on, good_nickname_list, tok->tp==K_RUNNING_ROUTERS)==1 &&
  400. me->is_verified == 0 && !have_warned_about_unverified_status) {
  401. log_fn(LOG_WARN,"Dirserver '%s' lists your server as unverified. Please consider sending your identity fingerprint to the tor-ops.", dirnickname);
  402. have_warned_about_unverified_status = 1;
  403. }
  404. }
  405. }
  406. new_dir->software_versions = versions; versions = NULL;
  407. new_dir->published_on = published_on;
  408. SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
  409. smartlist_free(tokens);
  410. tokens = NULL;
  411. if (*dest)
  412. routerlist_free(*dest);
  413. *dest = new_dir;
  414. r = 0;
  415. goto done;
  416. err:
  417. r = -1;
  418. if (new_dir)
  419. routerlist_free(new_dir);
  420. tor_free(versions);
  421. done:
  422. if (declared_key) crypto_free_pk_env(declared_key);
  423. if (tokens) {
  424. SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
  425. smartlist_free(tokens);
  426. }
  427. if (good_nickname_list) {
  428. SMARTLIST_FOREACH(good_nickname_list, char *, n, tor_free(n));
  429. smartlist_free(good_nickname_list);
  430. }
  431. return r;
  432. }
  433. /* DOCDOC */
  434. running_routers_t *
  435. router_parse_runningrouters(const char *str)
  436. {
  437. char digest[DIGEST_LEN];
  438. running_routers_t *new_list = NULL;
  439. directory_token_t *tok;
  440. time_t published_on;
  441. int i;
  442. crypto_pk_env_t *declared_key = NULL;
  443. smartlist_t *tokens = NULL;
  444. if (router_get_runningrouters_hash(str, digest)) {
  445. log_fn(LOG_WARN, "Unable to compute digest of directory");
  446. goto err;
  447. }
  448. tokens = smartlist_create();
  449. if (tokenize_string(str,str+strlen(str),tokens,1)) {
  450. log_fn(LOG_WARN, "Error tokenizing directory"); goto err;
  451. }
  452. if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
  453. log_fn(LOG_WARN, "Unrecognized keyword '%s'; can't parse running-routers",
  454. tok->args[0]);
  455. goto err;
  456. }
  457. tok = smartlist_get(tokens,0);
  458. if (tok->tp != K_NETWORK_STATUS) {
  459. log_fn(LOG_WARN, "Network-status starts with wrong token");
  460. goto err;
  461. }
  462. if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
  463. log_fn(LOG_WARN, "Missing published time on directory.");
  464. goto err;
  465. }
  466. tor_assert(tok->n_args == 1);
  467. if (parse_iso_time(tok->args[0], &published_on) < 0) {
  468. goto err;
  469. }
  470. /* Now that we know the signature is okay, and we have a
  471. * publication time, cache the list. */
  472. if (!get_options()->AuthoritativeDir)
  473. dirserv_set_cached_directory(str, published_on, 1);
  474. if (!(tok = find_first_by_keyword(tokens, K_ROUTER_STATUS))) {
  475. if (!(tok = find_first_by_keyword(tokens, K_RUNNING_ROUTERS))) {
  476. log_fn(LOG_WARN,
  477. "Missing running-routers/router-status line from directory.");
  478. goto err;
  479. }
  480. }
  481. new_list = tor_malloc_zero(sizeof(running_routers_t));
  482. new_list->published_on = published_on;
  483. new_list->running_routers = smartlist_create();
  484. new_list->is_running_routers_format = (tok->tp == K_RUNNING_ROUTERS);
  485. for (i=0;i<tok->n_args;++i) {
  486. smartlist_add(new_list->running_routers, tok->args[i]);
  487. }
  488. tok->n_args = 0; /* Don't free the elements of tok->args. */
  489. if (!(tok = find_first_by_keyword(tokens, K_DIRECTORY_SIGNATURE))) {
  490. log_fn(LOG_WARN, "Missing signature on running-routers");
  491. goto err;
  492. }
  493. declared_key = find_dir_signing_key(str);
  494. if (check_directory_signature(digest, tok, NULL, declared_key) < 0)
  495. goto err;
  496. goto done;
  497. err:
  498. if (new_list) {
  499. running_routers_free(new_list);
  500. new_list = NULL;
  501. }
  502. done:
  503. if (declared_key) crypto_free_pk_env(declared_key);
  504. if (tokens) {
  505. SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
  506. smartlist_free(tokens);
  507. }
  508. return new_list;
  509. }
  510. /** Given a directory or running-routers string in <b>str</b>, try to
  511. * find the its dir-signing-key token (if any). If this token is
  512. * present, extract and return the key. Return NULL on failure. */
  513. static crypto_pk_env_t *find_dir_signing_key(const char *str)
  514. {
  515. const char *cp;
  516. directory_token_t *tok;
  517. crypto_pk_env_t *key = NULL;
  518. /* Is there a dir-signing-key in the directory? */
  519. cp = strstr(str, "\nopt dir-signing-key");
  520. if (!cp)
  521. cp = strstr(str, "\ndir-signing-key");
  522. if (!cp)
  523. return NULL;
  524. ++cp; /* Now cp points to the start of the token. */
  525. tok = get_next_token(&cp, DIR_ONLY);
  526. if (!tok) {
  527. log_fn(LOG_WARN, "Unparseable dir-signing-key token");
  528. return NULL;
  529. }
  530. if (tok->tp != K_DIR_SIGNING_KEY) {
  531. log_fn(LOG_WARN, "Dir-signing-key token did not parse as expected");
  532. return NULL;
  533. }
  534. if (tok->key) {
  535. key = tok->key;
  536. tok->key = NULL; /* steal reference. */
  537. } else if (tok->n_args >= 1) {
  538. key = crypto_pk_DER64_decode_public_key(tok->args[0]);
  539. if (!key) {
  540. log_fn(LOG_WARN, "Unparseable dir-signing-key argument");
  541. return NULL;
  542. }
  543. } else {
  544. log_fn(LOG_WARN, "Dir-signing-key token contained no key");
  545. return NULL;
  546. }
  547. token_free(tok);
  548. return key;
  549. }
  550. /** Return true iff <b>key</b> is allowed to sign directories.
  551. */
  552. static int dir_signing_key_is_trusted(crypto_pk_env_t *key)
  553. {
  554. char digest[DIGEST_LEN];
  555. if (!key) return 0;
  556. if (crypto_pk_get_digest(key, digest) < 0) {
  557. log_fn(LOG_WARN, "Error computing dir-signing-key digest");
  558. return 0;
  559. }
  560. if (!router_digest_is_trusted_dir(digest)) {
  561. log_fn(LOG_WARN, "Listed dir-signing-key is not trusted");
  562. return 0;
  563. }
  564. return 1;
  565. }
  566. /** Check whether the K_DIRECTORY_SIGNATURE token in <b>tok</b> has a
  567. * good signature for <b>digest</b>.
  568. *
  569. * If <b>declared_key</b> is set, the directory has declared what key
  570. * was used to sign it, so we will use that key only if it is an
  571. * authoritative directory signing key.
  572. *
  573. * Otherwise, if pkey is provided, try to use it.
  574. *
  575. * (New callers should always use <b>declared_key</b> when possible;
  576. * <b>pkey is only for debugging.)
  577. */
  578. static int check_directory_signature(const char *digest,
  579. directory_token_t *tok,
  580. crypto_pk_env_t *pkey,
  581. crypto_pk_env_t *declared_key)
  582. {
  583. char signed_digest[PK_BYTES];
  584. crypto_pk_env_t *_pkey = NULL;
  585. if (tok->n_args != 1) {
  586. log_fn(LOG_WARN, "Too many or too few arguments to directory-signature");
  587. return -1;
  588. }
  589. if (declared_key) {
  590. if (dir_signing_key_is_trusted(declared_key))
  591. _pkey = declared_key;
  592. }
  593. if (!_pkey && pkey) {
  594. /* pkey provided for debugging purposes */
  595. _pkey = pkey;
  596. }
  597. if (!_pkey) {
  598. log_fn(LOG_WARN, "Found directory in old (before 0.0.9pre3) format--rejecting.");
  599. return -1;
  600. }
  601. if (strcmp(tok->object_type, "SIGNATURE") || tok->object_size != 128) {
  602. log_fn(LOG_WARN, "Bad object type or length on directory signature");
  603. return -1;
  604. }
  605. tor_assert(_pkey);
  606. if (crypto_pk_public_checksig(_pkey, signed_digest, tok->object_body, 128)
  607. != 20) {
  608. log_fn(LOG_WARN, "Error reading directory: invalid signature.");
  609. return -1;
  610. }
  611. log_fn(LOG_DEBUG,"Signed directory hash starts %s", hex_str(signed_digest,4));
  612. if (memcmp(digest, signed_digest, 20)) {
  613. log_fn(LOG_WARN, "Error reading directory: signature does not match.");
  614. return -1;
  615. }
  616. return 0;
  617. }
  618. /** Given a string *<b>s</b> containing a concatenated sequence of router
  619. * descriptors, parses them and stores the result in *<b>dest</b>. If
  620. * good_nickname_list is provided, then routers are marked as
  621. * running/nonrunning and verified/unverified based on their status in the
  622. * list. Otherwise, all routers are marked running and verified. Advances
  623. * *s to a point immediately following the last router entry. Returns 0 on
  624. * success and -1 on failure.
  625. */
  626. int
  627. router_parse_list_from_string(const char **s, routerlist_t **dest,
  628. smartlist_t *good_nickname_list,
  629. int rr_format, time_t published_on)
  630. {
  631. routerinfo_t *router;
  632. smartlist_t *routers;
  633. const char *end;
  634. tor_assert(s);
  635. tor_assert(*s);
  636. routers = smartlist_create();
  637. while (1) {
  638. *s = eat_whitespace(*s);
  639. /* Don't start parsing the rest of *s unless it contains a router. */
  640. if (strcmpstart(*s, "router ")!=0)
  641. break;
  642. if ((end = strstr(*s+1, "\nrouter "))) {
  643. end++;
  644. } else if ((end = strstr(*s+1, "\ndirectory-signature"))) {
  645. end++;
  646. } else {
  647. end = *s+strlen(*s);
  648. }
  649. router = router_parse_entry_from_string(*s, end);
  650. *s = end;
  651. if (!router) {
  652. log_fn(LOG_WARN, "Error reading router; skipping");
  653. continue;
  654. }
  655. if (!good_nickname_list) {
  656. router->is_running = 1; /* start out assuming all dirservers are up */
  657. router->is_verified = 1;
  658. router->status_set_at = time(NULL);
  659. }
  660. smartlist_add(routers, router);
  661. // log_fn(LOG_DEBUG,"just added router #%d.",smartlist_len(routers));
  662. }
  663. if (good_nickname_list) {
  664. SMARTLIST_FOREACH(good_nickname_list, const char *, cp,
  665. routers_update_status_from_entry(routers, published_on,
  666. cp, rr_format));
  667. }
  668. if (*dest)
  669. routerlist_free(*dest);
  670. *dest = tor_malloc_zero(sizeof(routerlist_t));
  671. (*dest)->routers = routers;
  672. return 0;
  673. }
  674. /** Helper function: reads a single router entry from *<b>s</b> ...
  675. * *<b>end</b>. Mallocs a new router and returns it if all goes well, else
  676. * returns NULL.
  677. */
  678. routerinfo_t *router_parse_entry_from_string(const char *s,
  679. const char *end) {
  680. routerinfo_t *router = NULL;
  681. char signed_digest[128];
  682. char digest[128];
  683. smartlist_t *tokens = NULL, *exit_policy_tokens = NULL;
  684. directory_token_t *tok;
  685. int t;
  686. int ports_set, bw_set;
  687. if (!end) {
  688. end = s + strlen(s);
  689. }
  690. if (router_get_router_hash(s, digest) < 0) {
  691. log_fn(LOG_WARN, "Couldn't compute router hash.");
  692. return NULL;
  693. }
  694. tokens = smartlist_create();
  695. if (tokenize_string(s,end,tokens,0)) {
  696. log_fn(LOG_WARN, "Error tokeninzing router descriptor."); goto err;
  697. }
  698. if (smartlist_len(tokens) < 2) {
  699. log_fn(LOG_WARN, "Impossibly short router descriptor.");
  700. goto err;
  701. }
  702. if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
  703. log_fn(LOG_WARN, "Unrecognized keyword '%s'; skipping descriptor.",
  704. tok->args[0]);
  705. goto err;
  706. }
  707. tok = smartlist_get(tokens,0);
  708. if (tok->tp != K_ROUTER) {
  709. log_fn(LOG_WARN,"Entry does not start with \"router\"");
  710. goto err;
  711. }
  712. router = tor_malloc_zero(sizeof(routerinfo_t));
  713. ports_set = bw_set = 0;
  714. if (tok->n_args == 2 || tok->n_args == 5 || tok->n_args == 6) {
  715. router->nickname = tor_strdup(tok->args[0]);
  716. if (!is_legal_nickname(router->nickname)) {
  717. log_fn(LOG_WARN,"Router nickname is invalid");
  718. goto err;
  719. }
  720. router->address = tor_strdup(tok->args[1]);
  721. router->addr = 0;
  722. if (tok->n_args >= 5) {
  723. router->or_port = (uint16_t) tor_parse_long(tok->args[2],10,0,65535,NULL,NULL);
  724. router->socks_port = (uint16_t) tor_parse_long(tok->args[3],10,0,65535,NULL,NULL);
  725. router->dir_port = (uint16_t) tor_parse_long(tok->args[4],10,0,65535,NULL,NULL);
  726. ports_set = 1;
  727. }
  728. } else {
  729. log_fn(LOG_WARN,"Wrong # of arguments to \"router\" (%d)",tok->n_args);
  730. goto err;
  731. }
  732. tok = find_first_by_keyword(tokens, K_PORTS);
  733. if (tok && ports_set) {
  734. log_fn(LOG_WARN,"Redundant ports line");
  735. goto err;
  736. } else if (tok) {
  737. if (tok->n_args != 3) {
  738. log_fn(LOG_WARN,"Wrong # of arguments to \"ports\"");
  739. goto err;
  740. }
  741. router->or_port = (uint16_t) tor_parse_long(tok->args[0],10,0,65535,NULL,NULL);
  742. router->socks_port = (uint16_t) tor_parse_long(tok->args[1],10,0,65535,NULL,NULL);
  743. router->dir_port = (uint16_t) tor_parse_long(tok->args[2],10,0,65535,NULL,NULL);
  744. ports_set = 1;
  745. }
  746. tok = find_first_by_keyword(tokens, K_DIRCACHEPORT);
  747. if (tok) {
  748. if (router->dir_port)
  749. log_fn(LOG_WARN,"Redundant dircacheport line");
  750. if (tok->n_args != 1) {
  751. log_fn(LOG_WARN,"Wrong # of arguments to \"dircacheport\"");
  752. goto err;
  753. }
  754. router->dir_port = (uint16_t) tor_parse_long(tok->args[0],10,1,65535,NULL,NULL);
  755. }
  756. tok = find_first_by_keyword(tokens, K_BANDWIDTH);
  757. if (tok && bw_set) {
  758. log_fn(LOG_WARN,"Redundant bandwidth line");
  759. goto err;
  760. } else if (tok) {
  761. if (tok->n_args < 3) {
  762. /* XXXX Once 0.0.7 is *really* dead, restore this warning to its old form*/
  763. log_fn(LOG_WARN,"Not enough arguments to \"bandwidth\": must be an obsolete server. Rejecting one server (nickname '%s').", router->nickname);
  764. goto err;
  765. }
  766. router->bandwidthrate = tor_parse_long(tok->args[0],10,0,INT_MAX,NULL,NULL);
  767. router->bandwidthburst = tor_parse_long(tok->args[1],10,0,INT_MAX,NULL,NULL);
  768. router->bandwidthcapacity = tor_parse_long(tok->args[2],10,0,INT_MAX,NULL,NULL);
  769. bw_set = 1;
  770. }
  771. if ((tok = find_first_by_keyword(tokens, K_UPTIME))) {
  772. if (tok->n_args != 1) {
  773. log_fn(LOG_WARN, "Unrecognized number of args on K_UPTIME; skipping.");
  774. } else {
  775. router->uptime = tor_parse_long(tok->args[0],10,0,LONG_MAX,NULL,NULL);
  776. }
  777. }
  778. if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
  779. log_fn(LOG_WARN, "Missing published time"); goto err;
  780. }
  781. tor_assert(tok->n_args == 1);
  782. if (parse_iso_time(tok->args[0], &router->published_on) < 0)
  783. goto err;
  784. if (!(tok = find_first_by_keyword(tokens, K_ONION_KEY))) {
  785. log_fn(LOG_WARN, "Missing onion key"); goto err;
  786. }
  787. if (crypto_pk_keysize(tok->key) != PK_BYTES) {
  788. log_fn(LOG_WARN, "Wrong size on onion key: %d bits!",
  789. crypto_pk_keysize(tok->key)*8);
  790. goto err;
  791. }
  792. router->onion_pkey = tok->key;
  793. tok->key = NULL; /* Prevent free */
  794. if (!(tok = find_first_by_keyword(tokens, K_SIGNING_KEY))) {
  795. log_fn(LOG_WARN, "Missing identity key"); goto err;
  796. }
  797. if (crypto_pk_keysize(tok->key) != PK_BYTES) {
  798. log_fn(LOG_WARN, "Wrong size on identity key: %d bits!",
  799. crypto_pk_keysize(tok->key)*8);
  800. goto err;
  801. }
  802. router->identity_pkey = tok->key;
  803. tok->key = NULL; /* Prevent free */
  804. if (crypto_pk_get_digest(router->identity_pkey,router->identity_digest)) {
  805. log_fn(LOG_WARN, "Couldn't calculate key digest"); goto err;
  806. }
  807. if ((tok = find_first_by_keyword(tokens, K_PLATFORM))) {
  808. router->platform = tor_strdup(tok->args[0]);
  809. }
  810. exit_policy_tokens = find_all_exitpolicy(tokens);
  811. SMARTLIST_FOREACH(exit_policy_tokens, directory_token_t *, t,
  812. if (router_add_exit_policy(router,t)<0) {
  813. log_fn(LOG_WARN,"Error in exit policy"); goto err;}
  814. );
  815. if ((tok = find_first_by_keyword(tokens, K_FAMILY)) && tok->n_args) {
  816. int i;
  817. router->declared_family = smartlist_create();
  818. for (i=0;i<tok->n_args;++i) {
  819. if (!is_legal_nickname_or_hexdigest(tok->args[i])) {
  820. log_fn(LOG_WARN, "Illegal nickname '%s' in family line", tok->args[i]);
  821. goto err;
  822. }
  823. smartlist_add(router->declared_family, tor_strdup(tok->args[i]));
  824. }
  825. }
  826. if (!(tok = find_first_by_keyword(tokens, K_ROUTER_SIGNATURE))) {
  827. log_fn(LOG_WARN, "Missing router signature"); goto err;
  828. }
  829. if (strcmp(tok->object_type, "SIGNATURE") || tok->object_size != 128) {
  830. log_fn(LOG_WARN, "Bad object type or length on router signature");
  831. goto err;
  832. }
  833. if ((t=crypto_pk_public_checksig(router->identity_pkey, signed_digest,
  834. tok->object_body, 128)) != 20) {
  835. log_fn(LOG_WARN, "Invalid signature %d",t); goto err;
  836. }
  837. if (memcmp(digest, signed_digest, 20)) {
  838. log_fn(LOG_WARN, "Mismatched signature"); goto err;
  839. }
  840. if (!ports_set) {
  841. log_fn(LOG_WARN,"No ports declared; failing."); goto err;
  842. }
  843. if (!bw_set) {
  844. log_fn(LOG_WARN,"No bandwidth declared; failing."); goto err;
  845. }
  846. if (!router->or_port) {
  847. log_fn(LOG_WARN,"or_port unreadable or 0. Failing.");
  848. goto err;
  849. }
  850. if (!router->bandwidthrate) {
  851. log_fn(LOG_WARN,"bandwidthrate unreadable or 0. Failing.");
  852. goto err;
  853. }
  854. if (!router->platform) {
  855. router->platform = tor_strdup("<unknown>");
  856. }
  857. // log_fn(LOG_DEBUG,"or_port %d, socks_port %d, dir_port %d, bandwidthrate %u, bandwidthburst %u.",
  858. // router->or_port, router->socks_port, router->dir_port,
  859. // (unsigned) router->bandwidthrate, (unsigned) router->bandwidthburst);
  860. goto done;
  861. return router;
  862. err:
  863. routerinfo_free(router);
  864. router = NULL;
  865. done:
  866. if (tokens) {
  867. SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
  868. smartlist_free(tokens);
  869. }
  870. if (exit_policy_tokens) {
  871. smartlist_free(exit_policy_tokens);
  872. }
  873. return router;
  874. }
  875. /** Parse the exit policy in the string <b>s</b> and return it.
  876. */
  877. addr_policy_t *
  878. router_parse_addr_policy_from_string(const char *s)
  879. {
  880. directory_token_t *tok = NULL;
  881. const char *cp;
  882. char *tmp;
  883. addr_policy_t *r;
  884. size_t len, idx;
  885. /* *s might not end with \n, so we need to extend it with one. */
  886. len = strlen(s);
  887. cp = tmp = tor_malloc(len+2);
  888. for (idx = 0; idx < len; ++idx) {
  889. tmp[idx] = tolower(s[idx]);
  890. }
  891. tmp[len]='\n';
  892. tmp[len+1]='\0';
  893. tok = get_next_token(&cp, RTR_ONLY);
  894. if (tok->tp == _ERR) {
  895. log_fn(LOG_WARN, "Error reading exit policy: %s", tok->error);
  896. goto err;
  897. }
  898. if (tok->tp != K_ACCEPT && tok->tp != K_REJECT) {
  899. log_fn(LOG_WARN, "Expected 'accept' or 'reject'.");
  900. goto err;
  901. }
  902. /* Now that we've gotten an exit policy, add it to the router. */
  903. r = router_parse_addr_policy(tok);
  904. goto done;
  905. err:
  906. r = NULL;
  907. done:
  908. tor_free(tmp);
  909. token_free(tok);
  910. return r;
  911. }
  912. int
  913. router_add_exit_policy_from_string(routerinfo_t *router, const char *s)
  914. {
  915. addr_policy_t *newe, *tmpe;
  916. newe = router_parse_addr_policy_from_string(s);
  917. if (!newe)
  918. return -1;
  919. for (tmpe = router->exit_policy; tmpe; tmpe=tmpe->next)
  920. ;
  921. tmpe->next = newe;
  922. return 0;
  923. }
  924. static int
  925. router_add_exit_policy(routerinfo_t *router,directory_token_t *tok)
  926. {
  927. addr_policy_t *newe, **tmpe;
  928. newe = router_parse_addr_policy(tok);
  929. if (!newe)
  930. return -1;
  931. for (tmpe = &router->exit_policy; *tmpe; tmpe=&((*tmpe)->next))
  932. ;
  933. *tmpe = newe;
  934. return 0;
  935. }
  936. /** Given a K_ACCEPT or K_REJECT token and a router, create and return
  937. * a new exit_policy_t corresponding to the token. */
  938. static addr_policy_t *
  939. router_parse_addr_policy(directory_token_t *tok) {
  940. addr_policy_t *newe;
  941. struct in_addr in;
  942. char *arg, *address;
  943. tor_assert(tok->tp == K_REJECT || tok->tp == K_ACCEPT);
  944. if (tok->n_args != 1)
  945. return NULL;
  946. arg = tok->args[0];
  947. newe = tor_malloc_zero(sizeof(addr_policy_t));
  948. newe->string = tor_malloc(8+strlen(arg));
  949. /* XXX eventually, use the code from router.c:727 to generate this */
  950. tor_snprintf(newe->string, 8+strlen(arg), "%s %s",
  951. (tok->tp == K_REJECT) ? "reject" : "accept", arg);
  952. newe->policy_type = (tok->tp == K_REJECT) ? ADDR_POLICY_REJECT
  953. : ADDR_POLICY_ACCEPT;
  954. if (parse_addr_and_port_range(arg, &newe->addr, &newe->msk,
  955. &newe->prt_min, &newe->prt_max))
  956. goto policy_read_failed;
  957. in.s_addr = htonl(newe->addr);
  958. address = tor_strdup(inet_ntoa(in));
  959. // in.s_addr = htonl(newe->msk);
  960. // log_fn(LOG_DEBUG,"%s %s/%s:%d-%d",
  961. // newe->policy_type == ADDR_POLICY_REJECT ? "reject" : "accept",
  962. // address, inet_ntoa(in), newe->prt_min, newe->prt_max);
  963. tor_free(address);
  964. return newe;
  965. policy_read_failed:
  966. tor_assert(newe->string);
  967. log_fn(LOG_WARN,"Couldn't parse line '%s'. Dropping", newe->string);
  968. tor_free(newe->string);
  969. tor_free(newe);
  970. return NULL;
  971. }
  972. void
  973. assert_addr_policy_ok(addr_policy_t *t)
  974. {
  975. addr_policy_t *t2;
  976. while (t) {
  977. tor_assert(t->policy_type == ADDR_POLICY_REJECT ||
  978. t->policy_type == ADDR_POLICY_ACCEPT);
  979. tor_assert(t->prt_min <= t->prt_max);
  980. t2 = router_parse_addr_policy_from_string(t->string);
  981. tor_assert(t2);
  982. tor_assert(t2->policy_type == t->policy_type);
  983. tor_assert(t2->addr == t->addr);
  984. tor_assert(t2->msk == t->msk);
  985. tor_assert(t2->prt_min == t->prt_min);
  986. tor_assert(t2->prt_max == t->prt_max);
  987. tor_assert(!strcmp(t2->string, t->string));
  988. tor_assert(t2->next == NULL);
  989. addr_policy_free(t2);
  990. t = t->next;
  991. }
  992. }
  993. /*
  994. * Low-level tokenizer for router descriptors and directories.
  995. */
  996. /** Free all resources allocated for <b>tok</b> */
  997. static void
  998. token_free(directory_token_t *tok)
  999. {
  1000. int i;
  1001. tor_assert(tok);
  1002. if (tok->args) {
  1003. for (i = 0; i < tok->n_args; ++i) {
  1004. tor_free(tok->args[i]);
  1005. }
  1006. tor_free(tok->args);
  1007. }
  1008. tor_free(tok->object_type);
  1009. tor_free(tok->object_body);
  1010. if (tok->key)
  1011. crypto_free_pk_env(tok->key);
  1012. tor_free(tok);
  1013. }
  1014. /** Helper function: read the next token from *s, advance *s to the end
  1015. * of the token, and return the parsed token. If 'where' is DIR_ONLY
  1016. * or RTR_ONLY, reject all tokens of the wrong type.
  1017. */
  1018. static directory_token_t *
  1019. get_next_token(const char **s, where_syntax where) {
  1020. const char *next, *obstart;
  1021. int i, done, allocated, is_opt;
  1022. directory_token_t *tok;
  1023. arg_syntax a_syn;
  1024. obj_syntax o_syn = NO_OBJ;
  1025. #define RET_ERR(msg) \
  1026. do { if (tok) token_free(tok); \
  1027. tok = tor_malloc_zero(sizeof(directory_token_t));\
  1028. tok->tp = _ERR; \
  1029. tok->error = msg; \
  1030. goto done_tokenizing; } while (0)
  1031. tok = tor_malloc_zero(sizeof(directory_token_t));
  1032. tok->tp = _ERR;
  1033. *s = eat_whitespace(*s);
  1034. if (!**s) {
  1035. tok->tp = _EOF;
  1036. return tok;
  1037. }
  1038. next = find_whitespace(*s);
  1039. if (!next) {
  1040. tok->error = "Unexpected EOF"; return tok;
  1041. }
  1042. /* It's a keyword... but which one? */
  1043. is_opt = !strncmp("opt", *s, next-*s);
  1044. if (is_opt) {
  1045. *s = eat_whitespace(next);
  1046. next = NULL;
  1047. if (**s)
  1048. next = find_whitespace(*s);
  1049. if (!**s || !next) {
  1050. RET_ERR("opt without keyword");
  1051. }
  1052. }
  1053. for (i = 0; token_table[i].t ; ++i) {
  1054. if (!strncmp(token_table[i].t, *s, next-*s)) {
  1055. /* We've found the keyword. */
  1056. tok->tp = token_table[i].v;
  1057. a_syn = token_table[i].s;
  1058. o_syn = token_table[i].os;
  1059. if (token_table[i].ws != ANY && token_table[i].ws != where) {
  1060. if (where == DIR_ONLY) {
  1061. RET_ERR("Found a router-only token in a directory section");
  1062. } else {
  1063. RET_ERR("Found a directory-only token in a router descriptor");
  1064. }
  1065. }
  1066. if (a_syn == ARGS) {
  1067. /* This keyword takes multiple arguments. */
  1068. i = 0;
  1069. done = (*next == '\n');
  1070. allocated = 32;
  1071. tok->args = tor_malloc(sizeof(char*)*32);
  1072. *s = eat_whitespace_no_nl(next);
  1073. while (**s != '\n' && !done) {
  1074. next = find_whitespace(*s);
  1075. if (*next == '\n')
  1076. done = 1;
  1077. if (i == allocated) {
  1078. allocated *= 2;
  1079. tok->args = tor_realloc(tok->args,sizeof(char*)*allocated);
  1080. }
  1081. tok->args[i++] = tor_strndup(*s,next-*s);
  1082. *s = eat_whitespace_no_nl(next+1);
  1083. }
  1084. tok->n_args = i;
  1085. } else if (a_syn == CONCAT_ARGS) {
  1086. /* The keyword takes the line as a single argument */
  1087. *s = eat_whitespace_no_nl(next);
  1088. next = strchr(*s, '\n');
  1089. if (!next)
  1090. RET_ERR("Unexpected EOF");
  1091. tok->args = tor_malloc(sizeof(char*));
  1092. tok->args[0] = tor_strndup(*s,next-*s);
  1093. tok->n_args = 1;
  1094. *s = eat_whitespace_no_nl(next+1);
  1095. } else {
  1096. /* The keyword takes no arguments. */
  1097. tor_assert(a_syn == NO_ARGS);
  1098. *s = eat_whitespace_no_nl(next);
  1099. if (**s != '\n') {
  1100. RET_ERR("Unexpected arguments");
  1101. }
  1102. tok->n_args = 0;
  1103. *s = eat_whitespace_no_nl(*s+1);
  1104. }
  1105. break;
  1106. }
  1107. }
  1108. if (tok->tp == _ERR) {
  1109. if (is_opt) {
  1110. tok->tp = K_OPT;
  1111. *s = eat_whitespace_no_nl(next);
  1112. next = strchr(*s,'\n');
  1113. if (!next)
  1114. RET_ERR("Unexpected EOF");
  1115. tok->args = tor_malloc(sizeof(char*));
  1116. tok->args[0] = tor_strndup(*s,next-*s);
  1117. tok->n_args = 1;
  1118. *s = eat_whitespace_no_nl(next+1);
  1119. o_syn = OBJ_OK;
  1120. } else {
  1121. tok->tp = _UNRECOGNIZED;
  1122. next = strchr(*s, '\n');
  1123. if (!next) {
  1124. RET_ERR("Unexpected EOF");
  1125. }
  1126. tok->args = tor_malloc(sizeof(char*));
  1127. tok->args[0] = tor_strndup(*s,next-*s);
  1128. tok->n_args = 1;
  1129. *s = next+1;
  1130. o_syn = OBJ_OK;
  1131. }
  1132. }
  1133. *s = eat_whitespace(*s);
  1134. if (strcmpstart(*s, "-----BEGIN ")) {
  1135. goto done_tokenizing;
  1136. }
  1137. obstart = *s;
  1138. *s += 11; /* length of "-----BEGIN ". */
  1139. next = strchr(*s, '\n');
  1140. if (next-*s < 6 || strcmpstart(next-5, "-----\n")) {
  1141. RET_ERR("Malformed object: bad begin line");
  1142. }
  1143. tok->object_type = tor_strndup(*s, next-*s-5);
  1144. *s = next+1;
  1145. next = strstr(*s, "-----END ");
  1146. if (!next) {
  1147. RET_ERR("Malformed object: missing end line");
  1148. }
  1149. if (!strcmp(tok->object_type, "RSA PUBLIC KEY")) {
  1150. if (strcmpstart(next, "-----END RSA PUBLIC KEY-----\n"))
  1151. RET_ERR("Malformed object: mismatched end line");
  1152. next = strchr(next,'\n')+1;
  1153. tok->key = crypto_new_pk_env();
  1154. if (crypto_pk_read_public_key_from_string(tok->key, obstart, next-obstart))
  1155. RET_ERR("Couldn't parse public key.");
  1156. *s = next;
  1157. } else {
  1158. tok->object_body = tor_malloc(next-*s); /* really, this is too much RAM. */
  1159. i = base64_decode(tok->object_body, 256, *s, next-*s);
  1160. if (i<0) {
  1161. RET_ERR("Malformed object: bad base64-encoded data");
  1162. }
  1163. tok->object_size = i;
  1164. *s = next + 9; /* length of "-----END ". */
  1165. i = strlen(tok->object_type);
  1166. if (strncmp(*s, tok->object_type, i) || strcmpstart(*s+i, "-----\n")) {
  1167. RET_ERR("Malformed object: mismatched end tag");
  1168. }
  1169. *s += i+6;
  1170. }
  1171. switch (o_syn)
  1172. {
  1173. case NO_OBJ:
  1174. if (tok->object_body)
  1175. RET_ERR("Unexpected object for keyword");
  1176. if (tok->key)
  1177. RET_ERR("Unexpected public key for keyword");
  1178. break;
  1179. case NEED_OBJ:
  1180. if (!tok->object_body)
  1181. RET_ERR("Missing object for keyword");
  1182. break;
  1183. case NEED_KEY:
  1184. if (!tok->key)
  1185. RET_ERR("Missing public key for keyword");
  1186. break;
  1187. case OBJ_OK:
  1188. break;
  1189. }
  1190. done_tokenizing:
  1191. #if 0
  1192. for (i = 0; token_table[i].t ; ++i) {
  1193. if (token_table[i].v == tok->tp) {
  1194. fputs(token_table[i].t, stdout);
  1195. break;
  1196. i = -1;
  1197. }
  1198. }
  1199. if (i) {
  1200. if (tok->tp == _UNRECOGNIZED) fputs("UNRECOGNIZED", stdout);
  1201. if (tok->tp == _ERR) fputs("ERR",stdout);
  1202. if (tok->tp == _EOF) fputs("EOF",stdout);
  1203. if (tok->tp == _NIL) fputs("_NIL",stdout);
  1204. }
  1205. for (i = 0; i < tok->n_args; ++i) {
  1206. fprintf(stdout," \"%s\"", tok->args[i]);
  1207. }
  1208. if (tok->error) { fprintf(stdout," *%s*", tok->error); }
  1209. fputs("\n",stdout);
  1210. #endif
  1211. return tok;
  1212. #undef RET_ERR
  1213. }
  1214. /** Read all tokens from a string between <b>start</b> and <b>end</b>, and add
  1215. * them to <b>out</b>. If <b>is_dir</b> is true, reject all non-directory
  1216. * tokens; else reject all non-routerdescriptor tokens.
  1217. */
  1218. static int
  1219. tokenize_string(const char *start, const char *end, smartlist_t *out,
  1220. int is_dir)
  1221. {
  1222. const char **s;
  1223. directory_token_t *tok = NULL;
  1224. where_syntax where = is_dir ? DIR_ONLY : RTR_ONLY;
  1225. s = &start;
  1226. while (*s < end && (!tok || tok->tp != _EOF)) {
  1227. tok = get_next_token(s, where);
  1228. if (tok->tp == _ERR) {
  1229. log_fn(LOG_WARN, "parse error: %s", tok->error);
  1230. return -1;
  1231. }
  1232. smartlist_add(out, tok);
  1233. *s = eat_whitespace(*s);
  1234. }
  1235. return 0;
  1236. }
  1237. /** Find the first token in <b>s</b> whose keyword is <b>keyword</b>; return
  1238. * NULL if no such keyword is found.
  1239. */
  1240. static directory_token_t *
  1241. find_first_by_keyword(smartlist_t *s, directory_keyword keyword)
  1242. {
  1243. SMARTLIST_FOREACH(s, directory_token_t *, t, if (t->tp == keyword) return t);
  1244. return NULL;
  1245. }
  1246. /** Return a newly allocated smartlist of all accept or reject tokens in
  1247. * <b>s</b>.
  1248. */
  1249. static smartlist_t *
  1250. find_all_exitpolicy(smartlist_t *s)
  1251. {
  1252. smartlist_t *out = smartlist_create();
  1253. SMARTLIST_FOREACH(s, directory_token_t *, t,
  1254. if (t->tp == K_ACCEPT || t->tp == K_REJECT)
  1255. smartlist_add(out,t));
  1256. return out;
  1257. }
  1258. /** Compute the SHA digest of the substring of <b>s</b> taken from the first
  1259. * occurrence of <b>start_str</b> through the first newline after the first
  1260. * subsequent occurrence of <b>end_str</b>; store the 20-byte result in
  1261. * <b>digest</b>; return 0 on success.
  1262. *
  1263. * If no such substring exists, return -1.
  1264. */
  1265. static int router_get_hash_impl(const char *s, char *digest,
  1266. const char *start_str,
  1267. const char *end_str)
  1268. {
  1269. char *start, *end;
  1270. start = strstr(s, start_str);
  1271. if (!start) {
  1272. log_fn(LOG_WARN,"couldn't find \"%s\"",start_str);
  1273. return -1;
  1274. }
  1275. if (start != s && *(start-1) != '\n') {
  1276. log_fn(LOG_WARN, "first occurrence of \"%s\" is not at the start of a line",
  1277. start_str);
  1278. return -1;
  1279. }
  1280. end = strstr(start+strlen(start_str), end_str);
  1281. if (!end) {
  1282. log_fn(LOG_WARN,"couldn't find \"%s\"",end_str);
  1283. return -1;
  1284. }
  1285. end = strchr(end+strlen(end_str), '\n');
  1286. if (!end) {
  1287. log_fn(LOG_WARN,"couldn't find EOL");
  1288. return -1;
  1289. }
  1290. ++end;
  1291. if (crypto_digest(digest, start, end-start)) {
  1292. log_fn(LOG_WARN,"couldn't compute digest");
  1293. return -1;
  1294. }
  1295. return 0;
  1296. }
  1297. /** Parse the Tor version of the platform string <b>platform</b>,
  1298. * and compare it to the version in <b>cutoff</b>. Return 1 if
  1299. * the router is at least as new as the cutoff, else return 0.
  1300. */
  1301. int tor_version_as_new_as(const char *platform, const char *cutoff) {
  1302. tor_version_t cutoff_version, router_version;
  1303. char *s, *start;
  1304. char tmp[128];
  1305. if (tor_version_parse(cutoff, &cutoff_version)<0) {
  1306. log_fn(LOG_WARN,"Bug: cutoff version '%s' unparseable.",cutoff);
  1307. return 0;
  1308. }
  1309. if (strcmpstart(platform,"Tor ")) /* nonstandard Tor; be safe and say yes */
  1310. return 1;
  1311. start = (char *)eat_whitespace(platform+3);
  1312. if (!*start) return 0;
  1313. s = (char *)find_whitespace(start); /* also finds '\0', which is fine */
  1314. if ((size_t)(s-start+1) >= sizeof(tmp)) /* too big, no */
  1315. return 0;
  1316. strlcpy(tmp, start, s-start+1);
  1317. if (tor_version_parse(tmp, &router_version)<0) {
  1318. log_fn(LOG_INFO,"Router version '%s' unparseable.",tmp);
  1319. return 1; /* be safe and say yes */
  1320. }
  1321. return tor_version_compare(&router_version, &cutoff_version) >= 0;
  1322. }
  1323. /** Parse a tor version from <b>s</b>, and store the result in <b>out</b>.
  1324. * Return 0 on success, -1 on failure. */
  1325. int tor_version_parse(const char *s, tor_version_t *out)
  1326. {
  1327. char *eos=NULL, *cp=NULL;
  1328. /* Format is:
  1329. * NUM dot NUM dot NUM [ ( pre | rc | dot ) NUM [ -cvs ] ]
  1330. */
  1331. tor_assert(s);
  1332. tor_assert(out);
  1333. memset(out, 0, sizeof(tor_version_t));
  1334. /* Get major. */
  1335. out->major = strtol(s,&eos,10);
  1336. if (!eos || eos==s || *eos != '.') return -1;
  1337. cp = eos+1;
  1338. /* Get minor */
  1339. out->minor = strtol(cp,&eos,10);
  1340. if (!eos || eos==cp || *eos != '.') return -1;
  1341. cp = eos+1;
  1342. /* Get micro */
  1343. out->micro = strtol(cp,&eos,10);
  1344. if (!eos || eos==cp) return -1;
  1345. if (!*eos) {
  1346. out->status = VER_RELEASE;
  1347. out->patchlevel = 0;
  1348. out->cvs = IS_NOT_CVS;
  1349. return 0;
  1350. }
  1351. cp = eos;
  1352. /* Get status */
  1353. if (*cp == '.') {
  1354. out->status = VER_RELEASE;
  1355. ++cp;
  1356. } else if (0==strncmp(cp, "pre", 3)) {
  1357. out->status = VER_PRE;
  1358. cp += 3;
  1359. } else if (0==strncmp(cp, "rc", 2)) {
  1360. out->status = VER_RC;
  1361. cp += 2;
  1362. } else {
  1363. return -1;
  1364. }
  1365. /* Get patchlevel */
  1366. out->patchlevel = strtol(cp,&eos,10);
  1367. if (!eos || eos==cp) return -1;
  1368. cp = eos;
  1369. /* Get cvs status and status tag. */
  1370. if (*cp == '-' || *cp == '.')
  1371. ++cp;
  1372. strlcpy(out->status_tag, cp, sizeof(out->status_tag));
  1373. if (0==strcmp(cp, "cvs")) {
  1374. out->cvs = IS_CVS;
  1375. } else {
  1376. out->cvs = IS_NOT_CVS;
  1377. }
  1378. return 0;
  1379. }
  1380. /** Compare two tor versions; Return <0 if a < b; 0 if a ==b, >0 if a >
  1381. * b. */
  1382. int tor_version_compare(tor_version_t *a, tor_version_t *b)
  1383. {
  1384. int i;
  1385. tor_assert(a);
  1386. tor_assert(b);
  1387. if ((i = a->major - b->major))
  1388. return i;
  1389. else if ((i = a->minor - b->minor))
  1390. return i;
  1391. else if ((i = a->micro - b->micro))
  1392. return i;
  1393. else if ((i = a->status - b->status))
  1394. return i;
  1395. else if ((i = a->patchlevel - b->patchlevel))
  1396. return i;
  1397. if (a->major > 0 || a->minor > 0) {
  1398. return strcmp(a->status_tag, b->status_tag);
  1399. } else {
  1400. return (a->cvs - b->cvs);
  1401. }
  1402. }