parse_uri.c 28 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207
  1. /*
  2. * $Id$
  3. *
  4. * Copyright (C) 2001-2003 Fhg Fokus
  5. *
  6. * This file is part of ser, a free SIP server.
  7. *
  8. * ser is free software; you can redistribute it and/or modify
  9. * it under the terms of the GNU General Public License as published by
  10. * the Free Software Foundation; either version 2 of the License, or
  11. * (at your option) any later version
  12. *
  13. * For a license to use the ser software under conditions
  14. * other than those described here, or to purchase support for this
  15. * software, please contact iptel.org by e-mail at the following addresses:
  16. * [email protected]
  17. *
  18. * ser is distributed in the hope that it will be useful,
  19. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  21. * GNU General Public License for more details.
  22. *
  23. * You should have received a copy of the GNU General Public License
  24. * along with this program; if not, write to the Free Software
  25. * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  26. *
  27. * History:
  28. * --------
  29. * 2003-04-04 convenience inbound-uri parser parse_orig_ruri
  30. * introduced (jiri)
  31. * 2003-04-11 new parse_uri introduced (better, parses also some parameters,
  32. * works in one pass) (andrei)
  33. * 2003-04-11 ser_error is now set in parse_uri (andrei)
  34. * 2003-04-26 ZSW (jiri)
  35. * 2003-07-03 sips:, r2, lr=on support added (andrei)
  36. */
  37. #include "parse_uri.h"
  38. #include <string.h>
  39. #include "../dprint.h"
  40. /* #ifdef PARSE_URI_OLD */ /* ZSW */
  41. #include "../ut.h" /* q_memchr */
  42. /* #endif */
  43. #include "../error.h"
  44. /* buf= pointer to begining of uri (sip:[email protected]:5060;a=b?h=i)
  45. * len= len of uri
  46. * returns: fills uri & returns <0 on error or 0 if ok
  47. */
  48. #ifndef PARSE_URI_OLD
  49. int parse_uri(char* buf, int len, struct sip_uri* uri)
  50. {
  51. enum states { URI_INIT, URI_USER, URI_PASSWORD, URI_PASSWORD_ALPHA,
  52. URI_HOST, URI_HOST_P,
  53. URI_HOST6_P, URI_HOST6_END, URI_PORT,
  54. URI_PARAM, URI_PARAM_P, URI_VAL_P, URI_HEADERS,
  55. /* param states */
  56. /* transport */
  57. PT_T, PT_R, PT_A, PT_N, PT_S, PT_P, PT_O, PT_R2, PT_T2,
  58. PT_eq,
  59. /* ttl */
  60. PTTL_T2, PTTL_L, PTTL_eq,
  61. /* user */
  62. PU_U, PU_S, PU_E, PU_R, PU_eq,
  63. /* method */
  64. PM_M, PM_E, PM_T, PM_H, PM_O, PM_D, PM_eq,
  65. /* maddr */
  66. PMA_A, PMA_D, PMA_D2, PMA_R, PMA_eq,
  67. /* lr */
  68. PLR_L, PLR_R_FIN, PLR_eq,
  69. /* r2 */
  70. PR2_R, PR2_2_FIN, PR2_eq,
  71. /* transport values */
  72. /* udp */
  73. VU_U, VU_D, VU_P_FIN,
  74. /* tcp */
  75. VT_T, VT_C, VT_P_FIN,
  76. /* tls */
  77. VTLS_L, VTLS_S_FIN,
  78. /* sctp */
  79. VS_S, VS_C, VS_T, VS_P_FIN
  80. };
  81. register enum states state;
  82. char* s;
  83. char* b; /* param start */
  84. char *v; /* value start */
  85. str* param; /* current param */
  86. str* param_val; /* current param val */
  87. str user;
  88. str password;
  89. int port_no;
  90. register char* p;
  91. char* end;
  92. char* pass;
  93. int found_user;
  94. int error_headers;
  95. #define case_port( ch, var) \
  96. case ch: \
  97. (var)=(var)*10+ch-'0'; \
  98. break
  99. #define still_at_user \
  100. if (found_user==0){ \
  101. user.s=uri->host.s; \
  102. if (pass){\
  103. user.len=pass-user.s; \
  104. password.s=pass+1; \
  105. password.len=p-password.s; \
  106. }else{ \
  107. user.len=p-user.s; \
  108. }\
  109. /* everything else is 0 */ \
  110. memset(uri, 0, sizeof(struct sip_uri)); \
  111. /* copy user & pass */ \
  112. uri->user=user; \
  113. if (pass) uri->passwd=password; \
  114. s=p+1; \
  115. found_user=1;\
  116. error_headers=0; \
  117. state=URI_HOST; \
  118. }else goto error_bad_char
  119. #define check_host_end \
  120. case ':': \
  121. /* found the host */ \
  122. uri->host.s=s; \
  123. uri->host.len=p-s; \
  124. state=URI_PORT; \
  125. s=p+1; \
  126. break; \
  127. case ';': \
  128. uri->host.s=s; \
  129. uri->host.len=p-s; \
  130. state=URI_PARAM; \
  131. s=p+1; \
  132. break; \
  133. case '?': \
  134. uri->host.s=s; \
  135. uri->host.len=p-s; \
  136. state=URI_HEADERS; \
  137. s=p+1; \
  138. break; \
  139. case '&': \
  140. case '@': \
  141. goto error_bad_char
  142. #define param_set(t_start, v_start) \
  143. param->s=(t_start);\
  144. param->len=(p-(t_start));\
  145. param_val->s=(v_start); \
  146. param_val->len=(p-(v_start))
  147. #define semicolon_case \
  148. case';': \
  149. if (pass){ \
  150. found_user=1;/* no user, pass cannot contain ';'*/ \
  151. pass=0; \
  152. } \
  153. state=URI_PARAM /* new param */
  154. #define question_case \
  155. case '?': \
  156. uri->params.s=s; \
  157. uri->params.len=p-s; \
  158. state=URI_HEADERS; \
  159. s=p+1; \
  160. if (pass){ \
  161. found_user=1;/* no user, pass cannot contain '?'*/ \
  162. pass=0; \
  163. }
  164. #define colon_case \
  165. case ':': \
  166. if (found_user==0){ \
  167. /*might be pass but only if user not found yet*/ \
  168. if (pass){ \
  169. found_user=1; /* no user */ \
  170. pass=0; \
  171. }else{ \
  172. pass=p; \
  173. } \
  174. } \
  175. state=URI_PARAM_P /* generic param */
  176. #define param_common_cases \
  177. case '@': \
  178. /* ughhh, this is still the user */ \
  179. still_at_user; \
  180. break; \
  181. semicolon_case; \
  182. break; \
  183. question_case; \
  184. break; \
  185. colon_case; \
  186. break
  187. #define value_common_cases \
  188. case '@': \
  189. /* ughhh, this is still the user */ \
  190. still_at_user; \
  191. break; \
  192. semicolon_case; \
  193. param_set(b, v); \
  194. break; \
  195. question_case; \
  196. param_set(b, v); \
  197. break; \
  198. colon_case; \
  199. state=URI_VAL_P; \
  200. break
  201. #define param_switch(old_state, c1, c2, new_state) \
  202. case old_state: \
  203. switch(*p){ \
  204. case c1: \
  205. case c2: \
  206. state=(new_state); \
  207. break; \
  208. param_common_cases; \
  209. default: \
  210. state=URI_PARAM_P; \
  211. } \
  212. break
  213. #define param_switch1(old_state, c1, new_state) \
  214. case old_state: \
  215. switch(*p){ \
  216. case c1: \
  217. state=(new_state); \
  218. break; \
  219. param_common_cases; \
  220. default: \
  221. state=URI_PARAM_P; \
  222. } \
  223. break
  224. #define param_switch_big(old_state, c1, c2, d1, d2, new_state_c, new_state_d) \
  225. case old_state : \
  226. switch(*p){ \
  227. case c1: \
  228. case c2: \
  229. state=(new_state_c); \
  230. break; \
  231. case d1: \
  232. case d2: \
  233. state=(new_state_d); \
  234. break; \
  235. param_common_cases; \
  236. default: \
  237. state=URI_PARAM_P; \
  238. } \
  239. break
  240. #define value_switch(old_state, c1, c2, new_state) \
  241. case old_state: \
  242. switch(*p){ \
  243. case c1: \
  244. case c2: \
  245. state=(new_state); \
  246. break; \
  247. value_common_cases; \
  248. default: \
  249. state=URI_VAL_P; \
  250. } \
  251. break
  252. #define value_switch_big(old_state, c1, c2, d1, d2, new_state_c, new_state_d) \
  253. case old_state: \
  254. switch(*p){ \
  255. case c1: \
  256. case c2: \
  257. state=(new_state_c); \
  258. break; \
  259. case d1: \
  260. case d2: \
  261. state=(new_state_d); \
  262. break; \
  263. value_common_cases; \
  264. default: \
  265. state=URI_VAL_P; \
  266. } \
  267. break
  268. #define transport_fin(c_state, proto_no) \
  269. case c_state: \
  270. switch(*p){ \
  271. case '@': \
  272. still_at_user; \
  273. break; \
  274. semicolon_case; \
  275. param_set(b, v); \
  276. uri->proto=(proto_no); \
  277. break; \
  278. question_case; \
  279. param_set(b, v); \
  280. uri->proto=(proto_no); \
  281. break; \
  282. colon_case; \
  283. default: \
  284. state=URI_VAL_P; \
  285. break; \
  286. } \
  287. break
  288. /* init */
  289. end=buf+len;
  290. p=buf+4;
  291. found_user=0;
  292. error_headers=0;
  293. b=v=0;
  294. param=param_val=0;
  295. pass=0;
  296. port_no=0;
  297. state=URI_INIT;
  298. memset(uri, 0, sizeof(struct sip_uri)); /* zero it all, just to be sure*/
  299. /*look for sip:*/
  300. if (len<5) goto error_too_short;
  301. if (! ( ((buf[0]|0x20)=='s')&&((buf[1]|0x20)=='i')&&((buf[2]|0x20)=='p')))
  302. goto error_bad_uri;
  303. if (buf[3]!=':'){
  304. /* parse also sips: */
  305. if (((buf[3]|0x20)=='s')&&(buf[4]==':')) {p++; uri->secure=1;}
  306. else goto error_bad_uri;
  307. }
  308. s=p;
  309. for(;p<end; p++){
  310. switch((unsigned char)state){
  311. case URI_INIT:
  312. switch(*p){
  313. case '[':
  314. /* uri = [ipv6address]... */
  315. state=URI_HOST6_P;
  316. s=p;
  317. break;
  318. case ']':
  319. /* invalid, no uri can start with ']' */
  320. case ':':
  321. /* the same as above for ':' */
  322. goto error_bad_char;
  323. case '@': /* error no user part, or
  324. be forgiving and accept it ? */
  325. default:
  326. state=URI_USER;
  327. }
  328. break;
  329. case URI_USER:
  330. switch(*p){
  331. case '@':
  332. /* found the user*/
  333. uri->user.s=s;
  334. uri->user.len=p-s;
  335. state=URI_HOST;
  336. found_user=1;
  337. s=p+1; /* skip '@' */
  338. break;
  339. case ':':
  340. /* found the user, or the host? */
  341. uri->user.s=s;
  342. uri->user.len=p-s;
  343. state=URI_PASSWORD;
  344. s=p+1; /* skip ':' */
  345. break;
  346. case ';':
  347. /* this could be still the user or
  348. * params?*/
  349. uri->host.s=s;
  350. uri->host.len=p-s;
  351. state=URI_PARAM;
  352. s=p+1;
  353. break;
  354. case '?': /* still user or headers? */
  355. uri->host.s=s;
  356. uri->host.len=p-s;
  357. state=URI_HEADERS;
  358. s=p+1;
  359. break;
  360. /* almost anything permitted in the user part */
  361. case '[':
  362. case ']': /* the user part cannot contain "[]" */
  363. goto error_bad_char;
  364. }
  365. break;
  366. case URI_PASSWORD: /* this can also be the port (missing user)*/
  367. switch(*p){
  368. case '@':
  369. /* found the password*/
  370. uri->passwd.s=s;
  371. uri->passwd.len=p-s;
  372. port_no=0;
  373. state=URI_HOST;
  374. found_user=1;
  375. s=p+1; /* skip '@' */
  376. break;
  377. case ';':
  378. /* upps this is the port */
  379. uri->port.s=s;
  380. uri->port.len=p-s;
  381. uri->port_no=port_no;
  382. /* user contains in fact the host */
  383. uri->host.s=uri->user.s;
  384. uri->host.len=uri->user.len;
  385. uri->user.s=0;
  386. uri->user.len=0;
  387. state=URI_PARAM;
  388. found_user=1; /* there is no user part */
  389. s=p+1;
  390. break;
  391. case '?':
  392. /* upps this is the port */
  393. uri->port.s=s;
  394. uri->port.len=p-s;
  395. uri->port_no=port_no;
  396. /* user contains in fact the host */
  397. uri->host.s=uri->user.s;
  398. uri->host.len=uri->user.len;
  399. uri->user.s=0;
  400. uri->user.len=0;
  401. state=URI_HEADERS;
  402. found_user=1; /* there is no user part */
  403. s=p+1;
  404. break;
  405. case_port('0', port_no);
  406. case_port('1', port_no);
  407. case_port('2', port_no);
  408. case_port('3', port_no);
  409. case_port('4', port_no);
  410. case_port('5', port_no);
  411. case_port('6', port_no);
  412. case_port('7', port_no);
  413. case_port('8', port_no);
  414. case_port('9', port_no);
  415. case '[':
  416. case ']':
  417. case ':':
  418. goto error_bad_char;
  419. default:
  420. /* it can't be the port, non number found */
  421. port_no=0;
  422. state=URI_PASSWORD_ALPHA;
  423. }
  424. break;
  425. case URI_PASSWORD_ALPHA:
  426. switch(*p){
  427. case '@':
  428. /* found the password*/
  429. uri->passwd.s=s;
  430. uri->passwd.len=p-s;
  431. state=URI_HOST;
  432. found_user=1;
  433. s=p+1; /* skip '@' */
  434. break;
  435. case ';': /* contains non-numbers => cannot be port no*/
  436. case '?':
  437. goto error_bad_port;
  438. case '[':
  439. case ']':
  440. case ':':
  441. goto error_bad_char;
  442. }
  443. break;
  444. case URI_HOST:
  445. switch(*p){
  446. case '[':
  447. state=URI_HOST6_P;
  448. break;
  449. case ':':
  450. case ';':
  451. case '?': /* null host name ->invalid */
  452. case '&':
  453. case '@': /*chars not allowed in hosts names */
  454. goto error_bad_host;
  455. default:
  456. state=URI_HOST_P;
  457. }
  458. break;
  459. case URI_HOST_P:
  460. switch(*p){
  461. check_host_end;
  462. }
  463. break;
  464. case URI_HOST6_END:
  465. switch(*p){
  466. check_host_end;
  467. default: /*no chars allowed after [ipv6] */
  468. goto error_bad_host;
  469. }
  470. break;
  471. case URI_HOST6_P:
  472. switch(*p){
  473. case ']':
  474. state=URI_HOST6_END;
  475. break;
  476. case '[':
  477. case '&':
  478. case '@':
  479. case ';':
  480. case '?':
  481. goto error_bad_host;
  482. }
  483. break;
  484. case URI_PORT:
  485. switch(*p){
  486. case ';':
  487. uri->port.s=s;
  488. uri->port.len=p-s;
  489. uri->port_no=port_no;
  490. state=URI_PARAM;
  491. s=p+1;
  492. break;
  493. case '?':
  494. uri->port.s=s;
  495. uri->port.len=p-s;
  496. uri->port_no=port_no;
  497. state=URI_HEADERS;
  498. s=p+1;
  499. break;
  500. case_port('0', port_no);
  501. case_port('1', port_no);
  502. case_port('2', port_no);
  503. case_port('3', port_no);
  504. case_port('4', port_no);
  505. case_port('5', port_no);
  506. case_port('6', port_no);
  507. case_port('7', port_no);
  508. case_port('8', port_no);
  509. case_port('9', port_no);
  510. case '&':
  511. case '@':
  512. case ':':
  513. default:
  514. goto error_bad_port;
  515. }
  516. break;
  517. case URI_PARAM: /* beginning of a new param */
  518. switch(*p){
  519. param_common_cases;
  520. /* recognized params */
  521. case 't':
  522. case 'T':
  523. b=p;
  524. state=PT_T;
  525. break;
  526. case 'u':
  527. case 'U':
  528. b=p;
  529. state=PU_U;
  530. break;
  531. case 'm':
  532. case 'M':
  533. b=p;
  534. state=PM_M;
  535. break;
  536. case 'l':
  537. case 'L':
  538. b=p;
  539. state=PLR_L;
  540. break;
  541. case 'r':
  542. case 'R':
  543. b=p;
  544. state=PR2_R;
  545. default:
  546. state=URI_PARAM_P;
  547. }
  548. break;
  549. case URI_PARAM_P: /* ignore current param */
  550. /* supported params:
  551. * maddr, transport, ttl, lr, user, method, r2 */
  552. switch(*p){
  553. param_common_cases;
  554. };
  555. break;
  556. /* ugly but fast param names parsing */
  557. /*transport */
  558. param_switch_big(PT_T, 'r', 'R', 't', 'T', PT_R, PTTL_T2);
  559. param_switch(PT_R, 'a', 'A', PT_A);
  560. param_switch(PT_A, 'n', 'N', PT_N);
  561. param_switch(PT_N, 's', 'S', PT_S);
  562. param_switch(PT_S, 'p', 'P', PT_P);
  563. param_switch(PT_P, 'o', 'O', PT_O);
  564. param_switch(PT_O, 'r', 'R', PT_R2);
  565. param_switch(PT_R2, 't', 'T', PT_T2);
  566. param_switch1(PT_T2, '=', PT_eq);
  567. /* value parsing */
  568. case PT_eq:
  569. param=&uri->transport;
  570. param_val=&uri->transport_val;
  571. switch (*p){
  572. param_common_cases;
  573. case 'u':
  574. case 'U':
  575. v=p;
  576. state=VU_U;
  577. break;
  578. case 't':
  579. case 'T':
  580. v=p;
  581. state=VT_T;
  582. break;
  583. case 's':
  584. case 'S':
  585. v=p;
  586. state=VS_S;
  587. break;
  588. default:
  589. v=p;
  590. state=URI_VAL_P;
  591. }
  592. break;
  593. /* generic value */
  594. case URI_VAL_P:
  595. switch(*p){
  596. value_common_cases;
  597. }
  598. break;
  599. /* udp */
  600. value_switch(VU_U, 'd', 'D', VU_D);
  601. value_switch(VU_D, 'p', 'P', VU_P_FIN);
  602. transport_fin(VU_P_FIN, PROTO_UDP);
  603. /* tcp */
  604. value_switch_big(VT_T, 'c', 'C', 'l', 'L', VT_C, VTLS_L);
  605. value_switch(VT_C, 'p', 'P', VT_P_FIN);
  606. transport_fin(VT_P_FIN, PROTO_TCP);
  607. /* tls */
  608. value_switch(VTLS_L, 's', 'S', VTLS_S_FIN);
  609. transport_fin(VTLS_S_FIN, PROTO_TLS);
  610. /* sctp */
  611. value_switch(VS_S, 'c', 'C', VS_C);
  612. value_switch(VS_C, 't', 'T', VS_T);
  613. value_switch(VS_T, 'p', 'P', VS_P_FIN);
  614. transport_fin(VS_P_FIN, PROTO_SCTP);
  615. /* ttl */
  616. param_switch(PTTL_T2, 'l', 'L', PTTL_L);
  617. param_switch1(PTTL_L, '=', PTTL_eq);
  618. case PTTL_eq:
  619. param=&uri->ttl;
  620. param_val=&uri->ttl_val;
  621. switch(*p){
  622. param_common_cases;
  623. default:
  624. v=p;
  625. state=URI_VAL_P;
  626. }
  627. break;
  628. /* user param */
  629. param_switch(PU_U, 's', 'S', PU_S);
  630. param_switch(PU_S, 'e', 'E', PU_E);
  631. param_switch(PU_E, 'r', 'R', PU_R);
  632. param_switch1(PU_R, '=', PU_eq);
  633. case PU_eq:
  634. param=&uri->user_param;
  635. param_val=&uri->user_param_val;
  636. switch(*p){
  637. param_common_cases;
  638. default:
  639. v=p;
  640. state=URI_VAL_P;
  641. }
  642. break;
  643. /* method*/
  644. param_switch_big(PM_M, 'e', 'E', 'a', 'A', PM_E, PMA_A);
  645. param_switch(PM_E, 't', 'T', PM_T);
  646. param_switch(PM_T, 'h', 'H', PM_H);
  647. param_switch(PM_H, 'o', 'O', PM_O);
  648. param_switch(PM_O, 'd', 'D', PM_D);
  649. param_switch1(PM_D, '=', PM_eq);
  650. case PM_eq:
  651. param=&uri->method;
  652. param_val=&uri->method_val;
  653. switch(*p){
  654. param_common_cases;
  655. default:
  656. v=p;
  657. state=URI_VAL_P;
  658. }
  659. break;
  660. /*maddr*/
  661. param_switch(PMA_A, 'd', 'D', PMA_D);
  662. param_switch(PMA_D, 'd', 'D', PMA_D2);
  663. param_switch(PMA_D2, 'r', 'R', PMA_R);
  664. param_switch1(PMA_R, '=', PMA_eq);
  665. case PMA_eq:
  666. param=&uri->maddr;
  667. param_val=&uri->maddr_val;
  668. switch(*p){
  669. param_common_cases;
  670. default:
  671. v=p;
  672. state=URI_VAL_P;
  673. }
  674. break;
  675. /* lr */
  676. param_switch(PLR_L, 'r', 'R', PLR_R_FIN);
  677. case PLR_R_FIN:
  678. switch(*p){
  679. case '@':
  680. still_at_user;
  681. break;
  682. case '=':
  683. state=PLR_eq;
  684. break;
  685. semicolon_case;
  686. uri->lr.s=b;
  687. uri->lr.len=(p-b);
  688. break;
  689. question_case;
  690. uri->lr.s=b;
  691. uri->lr.len=(p-b);
  692. break;
  693. colon_case;
  694. break;
  695. default:
  696. state=URI_PARAM_P;
  697. }
  698. break;
  699. /* handle lr=something case */
  700. case PLR_eq:
  701. param=&uri->lr;
  702. param_val=&uri->lr_val;
  703. switch(*p){
  704. param_common_cases;
  705. default:
  706. v=p;
  707. state=URI_VAL_P;
  708. }
  709. break;
  710. /* r2 */
  711. param_switch1(PR2_R, '2', PR2_2_FIN);
  712. case PR2_2_FIN:
  713. switch(*p){
  714. case '@':
  715. still_at_user;
  716. break;
  717. case '=':
  718. state=PR2_eq;
  719. break;
  720. semicolon_case;
  721. uri->r2.s=b;
  722. uri->r2.len=(p-b);
  723. break;
  724. question_case;
  725. uri->r2.s=b;
  726. uri->r2.len=(p-b);
  727. break;
  728. colon_case;
  729. break;
  730. default:
  731. state=URI_PARAM_P;
  732. }
  733. break;
  734. /* handle lr=something case */
  735. case PR2_eq:
  736. param=&uri->r2;
  737. param_val=&uri->r2_val;
  738. switch(*p){
  739. param_common_cases;
  740. default:
  741. v=p;
  742. state=URI_VAL_P;
  743. }
  744. break;
  745. case URI_HEADERS:
  746. /* for now nobody needs them so we completely ignore the
  747. * headers (they are not allowed in request uri) --andrei */
  748. switch(*p){
  749. case '@':
  750. /* yak, we are still at user */
  751. still_at_user;
  752. break;
  753. case ';':
  754. /* we might be still parsing user, try it */
  755. if (found_user) goto error_bad_char;
  756. error_headers=1; /* if this is not the user
  757. we have an error */
  758. /* if pass is set => it cannot be user:pass
  759. * => error (';') is illegal in a header */
  760. if (pass) goto error_headers;
  761. break;
  762. case ':':
  763. if (found_user==0){
  764. /*might be pass but only if user not found yet*/
  765. if (pass){
  766. found_user=1; /* no user */
  767. pass=0;
  768. }else{
  769. pass=p;
  770. }
  771. }
  772. break;
  773. case '?':
  774. if (pass){
  775. found_user=1; /* no user, pass cannot conaint '?'*/
  776. pass=0;
  777. }
  778. break;
  779. }
  780. break;
  781. default:
  782. goto error_bug;
  783. }
  784. }
  785. /*end of uri */
  786. switch (state){
  787. case URI_INIT: /* error empy uri */
  788. goto error_too_short;
  789. case URI_USER:
  790. /* this is the host, it can't be the user */
  791. if (found_user) goto error_bad_uri;
  792. uri->host.s=s;
  793. uri->host.len=p-s;
  794. state=URI_HOST;
  795. break;
  796. case URI_PASSWORD:
  797. /* this is the port, it can't be the passwd */
  798. if (found_user) goto error_bad_port;
  799. uri->port.s=s;
  800. uri->port.len=p-s;
  801. uri->port_no=port_no;
  802. uri->host=uri->user;
  803. uri->user.s=0;
  804. uri->user.len=0;
  805. break;
  806. case URI_PASSWORD_ALPHA:
  807. /* this is the port, it can't be the passwd */
  808. goto error_bad_port;
  809. case URI_HOST_P:
  810. case URI_HOST6_END:
  811. uri->host.s=s;
  812. uri->host.len=p-s;
  813. break;
  814. case URI_HOST: /* error: null host */
  815. case URI_HOST6_P: /* error: unterminated ipv6 reference*/
  816. goto error_bad_host;
  817. case URI_PORT:
  818. uri->port.s=s;
  819. uri->port.len=p-s;
  820. uri->port_no=port_no;
  821. break;
  822. case URI_PARAM:
  823. case URI_PARAM_P:
  824. /* intermediate param states */
  825. case PT_T: /* transport */
  826. case PT_R:
  827. case PT_A:
  828. case PT_N:
  829. case PT_S:
  830. case PT_P:
  831. case PT_O:
  832. case PT_R2:
  833. case PT_T2:
  834. case PT_eq: /* ignore empty transport params */
  835. case PTTL_T2: /* ttl */
  836. case PTTL_L:
  837. case PTTL_eq:
  838. case PU_U: /* user */
  839. case PU_S:
  840. case PU_E:
  841. case PU_R:
  842. case PU_eq:
  843. case PM_M: /* method */
  844. case PM_E:
  845. case PM_T:
  846. case PM_H:
  847. case PM_O:
  848. case PM_D:
  849. case PM_eq:
  850. case PLR_L: /* lr */
  851. case PR2_R: /* r2 */
  852. uri->params.s=s;
  853. uri->params.len=p-s;
  854. break;
  855. /* fin param states */
  856. case PLR_R_FIN:
  857. case PLR_eq:
  858. uri->params.s=s;
  859. uri->params.len=p-s;
  860. uri->lr.s=b;
  861. uri->lr.len=p-b;
  862. break;
  863. case PR2_2_FIN:
  864. case PR2_eq:
  865. uri->params.s=s;
  866. uri->params.len=p-s;
  867. uri->r2.s=b;
  868. uri->r2.len=p-b;
  869. break;
  870. case URI_VAL_P:
  871. /* intermediate value states */
  872. case VU_U:
  873. case VU_D:
  874. case VT_T:
  875. case VT_C:
  876. case VTLS_L:
  877. case VS_S:
  878. case VS_C:
  879. case VS_T:
  880. uri->params.s=s;
  881. uri->params.len=p-s;
  882. param_set(b, v);
  883. break;
  884. /* fin value states */
  885. case VU_P_FIN:
  886. uri->params.s=s;
  887. uri->params.len=p-s;
  888. param_set(b, v);
  889. uri->proto=PROTO_UDP;
  890. break;
  891. case VT_P_FIN:
  892. uri->params.s=s;
  893. uri->params.len=p-s;
  894. param_set(b, v);
  895. uri->proto=PROTO_TCP;
  896. break;
  897. case VTLS_S_FIN:
  898. uri->params.s=s;
  899. uri->params.len=p-s;
  900. param_set(b, v);
  901. uri->proto=PROTO_TLS;
  902. break;
  903. case VS_P_FIN:
  904. uri->params.s=s;
  905. uri->params.len=p-s;
  906. param_set(b, v);
  907. uri->proto=PROTO_SCTP;
  908. break;
  909. /* headers */
  910. case URI_HEADERS:
  911. uri->headers.s=s;
  912. uri->headers.len=p-s;
  913. if (error_headers) goto error_headers;
  914. break;
  915. default:
  916. goto error_bug;
  917. }
  918. #if EXTRA_DEBUG
  919. /* do stuff */
  920. DBG("parsed uri:\n user=<%.*s>(%d)\n passwd=<%.*s>(%d)\n host=<%.*s>(%d)\n"
  921. " port=<%.*s>(%d): %d\n params=<%.*s>(%d)\n headers=<%.*s>(%d)\n",
  922. uri->user.len, ZSW(uri->user.s), uri->user.len,
  923. uri->passwd.len, ZSW(uri->passwd.s), uri->passwd.len,
  924. uri->host.len, ZSW(uri->host.s), uri->host.len,
  925. uri->port.len, ZSW(uri->port.s), uri->port.len, uri->port_no,
  926. uri->params.len, ZSW(uri->params.s), uri->params.len,
  927. uri->headers.len, ZSW(uri->headers.s), uri->headers.len
  928. );
  929. DBG(" uri params:\n transport=<%.*s>, val=<%.*s>, proto=%d\n",
  930. uri->transport.len, ZSW(uri->transport.s), uri->transport_val.len,
  931. ZSW(uri->transport_val.s), uri->proto);
  932. DBG(" user-param=<%.*s>, val=<%.*s>\n",
  933. uri->user_param.len, ZSW(uri->user_param.s),
  934. uri->user_param_val.len, ZSW(uri->user_param_val.s));
  935. DBG(" method=<%.*s>, val=<%.*s>\n",
  936. uri->method.len, ZSW(uri->method.s),
  937. uri->method_val.len, ZSW(uri->method_val.s));
  938. DBG(" ttl=<%.*s>, val=<%.*s>\n",
  939. uri->ttl.len, ZSW(uri->ttl.s),
  940. uri->ttl_val.len, ZSW(uri->ttl_val.s));
  941. DBG(" maddr=<%.*s>, val=<%.*s>\n",
  942. uri->maddr.len, ZSW(uri->maddr.s),
  943. uri->maddr_val.len, ZSW(uri->maddr_val.s));
  944. DBG(" lr=<%.*s>\n", uri->lr.len, ZSW(uri->lr.s));
  945. #endif
  946. return 0;
  947. error_too_short:
  948. LOG(L_ERR, "ERROR: parse_uri: uri too short: <%.*s> (%d)\n",
  949. len, ZSW(buf), len);
  950. ser_error=E_BAD_URI;
  951. return E_BAD_URI;
  952. error_bad_char:
  953. LOG(L_ERR, "ERROR: parse_uri: bad char '%c' in state %d"
  954. " parsed: <%.*s> (%d) / <%.*s> (%d)\n",
  955. *p, state, (int)(p-buf), ZSW(buf), (int)(p-buf), len, ZSW(buf), len);
  956. return E_BAD_URI;
  957. error_bad_host:
  958. LOG(L_ERR, "ERROR: parse_uri: bad host in uri (error at char %c in"
  959. " state %d) parsed: <%.*s>(%d) /<%.*s> (%d)\n",
  960. *p, state, (int)(p-buf), ZSW(buf), (int)(p-buf), len, ZSW(buf), len);
  961. ser_error=E_BAD_URI;
  962. return E_BAD_URI;
  963. error_bad_port:
  964. LOG(L_ERR, "ERROR: parse_uri: bad port in uri (error at char %c in"
  965. " state %d) parsed: <%.*s>(%d) /<%.*s> (%d)\n",
  966. *p, state, (int)(p-buf), ZSW(buf), (int)(p-buf), len, ZSW(buf), len);
  967. ser_error=E_BAD_URI;
  968. return E_BAD_URI;
  969. error_bad_uri:
  970. LOG(L_ERR, "ERROR: parse_uri: bad uri, state %d"
  971. " parsed: <%.*s> (%d) / <%.*s> (%d)\n",
  972. state, (int)(p-buf), ZSW(buf), (int)(p-buf), len, ZSW(buf), len);
  973. ser_error=E_BAD_URI;
  974. return E_BAD_URI;
  975. error_headers:
  976. LOG(L_ERR, "ERROR: parse_uri: bad uri headers: <%.*s>(%d)"
  977. " / <%.*s>(%d)\n",
  978. uri->headers.len, ZSW(uri->headers.s), uri->headers.len,
  979. len, ZSW(buf), len);
  980. ser_error=E_BAD_URI;
  981. return E_BAD_URI;
  982. error_bug:
  983. LOG(L_CRIT, "BUG: parse_uri: bad state %d"
  984. " parsed: <%.*s> (%d) / <%.*s> (%d)\n",
  985. state, (int)(p-buf), ZSW(buf), (int)(p-buf), len, ZSW(buf), len);
  986. ser_error=E_BAD_URI;
  987. return E_BAD_URI;
  988. }
  989. #else /* PARSE_URI_OLD */
  990. int parse_uri(char *buf, int len, struct sip_uri* uri)
  991. {
  992. char* next, *end;
  993. char *user, *passwd, *host, *port, *params, *headers, *ipv6;
  994. int host_len, port_len, params_len, headers_len;
  995. int err;
  996. int ret;
  997. ret=0;
  998. host_len=0;
  999. end=buf+len;
  1000. memset(uri, 0, sizeof(struct sip_uri)); /* zero it all, just to be sure */
  1001. /* look for "sip:"*/;
  1002. next=q_memchr(buf, ':', len);
  1003. if ((next==0)||(strncasecmp(buf,"sip",next-buf)!=0)){
  1004. LOG(L_DBG, "ERROR: parse_uri: bad sip uri\n");
  1005. ser_error=ret=E_BAD_URI;
  1006. return ret;
  1007. }
  1008. buf=next+1; /* next char after ':' */
  1009. if (buf>end){
  1010. LOG(L_DBG, "ERROR: parse_uri: uri too short\n");
  1011. ser_error=ret=E_BAD_URI;
  1012. return ret;
  1013. }
  1014. /*look for '@' */
  1015. next=q_memchr(buf,'@', end-buf);
  1016. if (next==0){
  1017. /* no '@' found, => no userinfo */
  1018. uri->user.s=0;
  1019. uri->passwd.s=0;
  1020. host=buf;
  1021. }else{
  1022. /* found it */
  1023. user=buf;
  1024. /* try to find passwd */
  1025. passwd=q_memchr(user,':', next-user);
  1026. if (passwd==0){
  1027. /* no ':' found => no password */
  1028. uri->passwd.s=0;
  1029. uri->user.s=user;
  1030. uri->user.len=next-user;
  1031. }else{
  1032. uri->user.s=user;
  1033. uri->user.len=passwd-user;
  1034. passwd++; /*skip ':' */
  1035. uri->passwd.s=passwd;
  1036. uri->passwd.len=next-passwd;
  1037. }
  1038. host=next+1; /* skip '@' */
  1039. }
  1040. /* try to find the rest */
  1041. if(host>=end){
  1042. LOG(L_DBG, "ERROR: parse_uri: missing hostport\n");
  1043. ser_error=ret=E_UNSPEC;
  1044. return ret;
  1045. }
  1046. next=host;
  1047. ipv6=q_memchr(host, '[', end-host);
  1048. if (ipv6){
  1049. host=ipv6+1; /* skip '[' in "[3ffe::abbcd]" */
  1050. if (host>=end){
  1051. LOG(L_DBG, "ERROR: parse_uri: bad ipv6 uri\n");
  1052. ret=E_UNSPEC;
  1053. return ret;
  1054. }
  1055. ipv6=q_memchr(host, ']', end-host);
  1056. if ((ipv6==0)||(ipv6==host)){
  1057. LOG(L_DBG, "ERROR: parse_uri: bad ipv6 uri - null address"
  1058. " or missing ']'\n");
  1059. ret=E_UNSPEC;
  1060. return ret;
  1061. }
  1062. host_len=ipv6-host;
  1063. next=ipv6;
  1064. }
  1065. headers=q_memchr(next,'?',end-next);
  1066. params=q_memchr(next,';',end-next);
  1067. port=q_memchr(next,':',end-next);
  1068. if (host_len==0){ /* host not ipv6 addr */
  1069. host_len=(port)?port-host:(params)?params-host:(headers)?headers-host:
  1070. end-host;
  1071. }
  1072. /* get host */
  1073. uri->host.s=host;
  1074. uri->host.len=host_len;
  1075. /* get port*/
  1076. if ((port)&&(port+1<end)){
  1077. port++;
  1078. if ( ((params) &&(params<port))||((headers) &&(headers<port)) ){
  1079. /* error -> invalid uri we found ';' or '?' before ':' */
  1080. LOG(L_DBG, "ERROR: parse_uri: malformed sip uri\n");
  1081. ser_error=ret=E_BAD_URI;
  1082. return ret;
  1083. }
  1084. port_len=(params)?params-port:(headers)?headers-port:end-port;
  1085. uri->port.s=port;
  1086. uri->port.len=port_len;
  1087. }else uri->port.s=0;
  1088. /* get params */
  1089. if ((params)&&(params+1<end)){
  1090. params++;
  1091. if ((headers) && (headers<params)){
  1092. /* error -> invalid uri we found '?' or '?' before ';' */
  1093. LOG(L_DBG, "ERROR: parse_uri: malformed sip uri\n");
  1094. ser_error=ret=E_BAD_URI;
  1095. return ret;
  1096. }
  1097. params_len=(headers)?headers-params:end-params;
  1098. uri->params.s=params;
  1099. uri->params.len=params_len;
  1100. }else uri->params.s=0;
  1101. /*get headers */
  1102. if ((headers)&&(headers+1<end)){
  1103. headers++;
  1104. headers_len=end-headers;
  1105. uri->headers.s=headers;
  1106. uri->headers.len=headers_len;
  1107. }else uri->headers.s=0;
  1108. err=0;
  1109. if (uri->port.s) uri->port_no=str2s(uri->port.s, uri->port.len, &err);
  1110. if (err){
  1111. LOG(L_DBG, "ERROR: parse_uri: bad port number in sip uri: %.*s\n",
  1112. uri->port.len, ZSW(uri->port.s));
  1113. ser_error=ret=E_BAD_URI;
  1114. return ret;
  1115. }
  1116. return ret;
  1117. }
  1118. #endif
  1119. static inline int _parse_ruri(str *uri,
  1120. int *status, struct sip_uri *parsed_uri)
  1121. {
  1122. if (*status) return 1;
  1123. if (parse_uri(uri->s, uri->len, parsed_uri)<0) {
  1124. LOG(L_ERR, "ERROR: _parse_ruri: bad uri <%.*s>\n",
  1125. uri->len, ZSW(uri->s));
  1126. *status=0;
  1127. return -1;
  1128. }
  1129. *status=1;
  1130. return 1;
  1131. }
  1132. int parse_sip_msg_uri(struct sip_msg* msg)
  1133. {
  1134. char* tmp;
  1135. int tmp_len;
  1136. if (msg->parsed_uri_ok) return 1;
  1137. if (msg->new_uri.s){
  1138. tmp=msg->new_uri.s;
  1139. tmp_len=msg->new_uri.len;
  1140. }else{
  1141. tmp=msg->first_line.u.request.uri.s;
  1142. tmp_len=msg->first_line.u.request.uri.len;
  1143. }
  1144. if (parse_uri(tmp, tmp_len, &msg->parsed_uri)<0){
  1145. LOG(L_ERR, "ERROR: parse_sip_msg_uri: bad uri <%.*s>\n",
  1146. tmp_len, tmp);
  1147. msg->parsed_uri_ok=0;
  1148. return -1;
  1149. }
  1150. msg->parsed_uri_ok=1;
  1151. return 1;
  1152. }
  1153. int parse_orig_ruri(struct sip_msg* msg)
  1154. {
  1155. int ret;
  1156. ret=_parse_ruri(&REQ_LINE(msg).uri,
  1157. &msg->parsed_orig_ruri_ok, &msg->parsed_orig_ruri);
  1158. if (ret<0) LOG(L_ERR, "ERROR: parse_orig_ruri failed\n");
  1159. return ret;
  1160. }