routerparse.c 45 KB

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