app_mono_api.c 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945
  1. /**
  2. * $Id$
  3. *
  4. * Copyright (C) 2011 Daniel-Constantin Mierla (asipto.com)
  5. *
  6. * This file is part of Kamailio, a free SIP server.
  7. *
  8. * Kamailio 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. * Kamailio is distributed in the hope that it will be useful,
  14. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. * GNU General Public License for more details.
  17. *
  18. * You should have received a copy of the GNU General Public License
  19. * along with this program; if not, write to the Free Software
  20. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  21. *
  22. */
  23. #include <stdio.h>
  24. #include <unistd.h>
  25. #include <stdlib.h>
  26. #include <sys/stat.h>
  27. #include "../../sr_module.h"
  28. #include "../../dprint.h"
  29. #include "../../ut.h"
  30. #include "../../mem/mem.h"
  31. #include "../../data_lump.h"
  32. #include "../../data_lump_rpl.h"
  33. #include "../../lib/kcore/cmpapi.h"
  34. #include "app_mono_api.h"
  35. #include <mono/metadata/mono-config.h>
  36. #define SRVERSION "1.0"
  37. /**
  38. *
  39. */
  40. typedef struct _sr_mono_load
  41. {
  42. char *script;
  43. MonoDomain *domain;
  44. MonoAssembly *assembly;
  45. struct _sr_mono_load *next;
  46. } sr_mono_load_t;
  47. static sr_mono_load_t *_sr_mono_load_list = NULL;
  48. int sr_mono_load_class_core();
  49. int sr_mono_load_class_pv();
  50. int sr_mono_load_class_hdr();
  51. /**
  52. *
  53. */
  54. static sr_mono_env_t _sr_M_env;
  55. /**
  56. * @return the static Mono env
  57. */
  58. sr_mono_env_t *sr_mono_env_get(void)
  59. {
  60. return &_sr_M_env;
  61. }
  62. /**
  63. *
  64. */
  65. int sr_mono_load_script(char *script)
  66. {
  67. sr_mono_load_t *mi;
  68. if(_sr_mono_load_list != NULL)
  69. {
  70. LM_ERR("only one assembly can be loaded\n");
  71. return -1;
  72. }
  73. mi = (sr_mono_load_t*)pkg_malloc(sizeof(sr_mono_load_t));
  74. if(mi==NULL)
  75. {
  76. LM_ERR("no more pkg\n");
  77. return -1;
  78. }
  79. memset(mi, 0, sizeof(sr_mono_load_t));
  80. mi->script = script;
  81. mi->next = _sr_mono_load_list;
  82. _sr_mono_load_list = mi;
  83. return 0;
  84. }
  85. /**
  86. *
  87. */
  88. int sr_mono_assembly_loaded(void)
  89. {
  90. if(_sr_mono_load_list != NULL)
  91. return 1;
  92. return 0;
  93. }
  94. /**
  95. *
  96. */
  97. int sr_mono_register_module(char *mname)
  98. {
  99. // if(mono_sr_exp_register_mod(mname)==0)
  100. // return 0;
  101. return -1;
  102. }
  103. /**
  104. *
  105. */
  106. int mono_sr_init_mod(void)
  107. {
  108. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  109. // if(mono_sr_exp_init_mod()<0)
  110. // return -1;
  111. return 0;
  112. }
  113. /**
  114. *
  115. */
  116. int mono_sr_init_load(void)
  117. {
  118. sr_mono_load_t *mi;
  119. if(_sr_mono_load_list == NULL) {
  120. LM_DBG("no assembly to load\n");
  121. return 0;
  122. }
  123. mono_config_parse (NULL);
  124. mi = _sr_mono_load_list;
  125. if(mi->domain != NULL)
  126. {
  127. LM_ERR("worker mono environment already initialized\n");
  128. return 0;
  129. }
  130. while(mi!=NULL)
  131. {
  132. mi->domain = mono_jit_init (mi->script);
  133. if (mi->domain==NULL) {
  134. LM_ERR("failed to init domain for: %s\n", mi->script);
  135. return -1;
  136. }
  137. sr_mono_load_class_core();
  138. sr_mono_load_class_pv();
  139. sr_mono_load_class_hdr();
  140. mi->assembly = mono_domain_assembly_open(mi->domain, mi->script);
  141. if (mi->assembly==NULL) {
  142. LM_ERR("failed to open assembly: %s\n", mi->script);
  143. return -1;
  144. }
  145. mi = mi->next;
  146. /* only one (first) assembly for now */
  147. break;
  148. }
  149. return 0;
  150. }
  151. /**
  152. *
  153. */
  154. int mono_sr_init_probe(void)
  155. {
  156. /* todo: test if assemblies exist */
  157. return 0;
  158. }
  159. /**
  160. *
  161. */
  162. int mono_sr_init_child(void)
  163. {
  164. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  165. /*
  166. * Load the default Mono configuration file, this is needed
  167. * if you are planning on using the dllmaps defined on the
  168. * system configuration
  169. */
  170. mono_config_parse (NULL);
  171. return 0;
  172. }
  173. /**
  174. *
  175. */
  176. void mono_sr_destroy(void)
  177. {
  178. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  179. }
  180. /**
  181. *
  182. */
  183. int mono_sr_initialized(void)
  184. {
  185. if(_sr_M_env.domain==NULL)
  186. return 1;
  187. return 1;
  188. }
  189. /**
  190. *
  191. */
  192. int app_mono_exec(struct sip_msg *msg, char *script, char *param)
  193. {
  194. int ret;
  195. char *argv[2];
  196. int argc;
  197. argc = 1;
  198. argv[0] = script;
  199. if(param!=NULL) {
  200. argc++;
  201. argv[1] = param;
  202. }
  203. LM_DBG("executing Mono assembly: [[%s]]\n", argv[0]);
  204. _sr_M_env.msg = msg;
  205. mono_config_parse (NULL);
  206. /*
  207. * mono_jit_init() creates a domain: each assembly is
  208. * loaded and run in a MonoDomain.
  209. */
  210. _sr_M_env.domain = mono_jit_init (argv[0]);
  211. /*
  212. * We add our special internal functions, so that C# code
  213. * can call us back.
  214. */
  215. sr_mono_load_class_core();
  216. sr_mono_load_class_pv();
  217. sr_mono_load_class_hdr();
  218. _sr_M_env.assembly = mono_domain_assembly_open(_sr_M_env.domain, argv[0]);
  219. if (_sr_M_env.assembly==NULL) {
  220. ret = -1;
  221. goto done;
  222. }
  223. /*
  224. * mono_jit_exec() will run the Main() method in the assembly.
  225. * The return value needs to be looked up from
  226. * System.Environment.ExitCode.
  227. */
  228. mono_jit_exec(_sr_M_env.domain, _sr_M_env.assembly, argc, argv);
  229. ret = mono_environment_exitcode_get();
  230. LM_DBG("returned code from mono environment: %d\n", ret);
  231. done:
  232. mono_jit_cleanup(_sr_M_env.domain);
  233. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  234. return (ret==0)?1:-1;
  235. }
  236. /**
  237. *
  238. */
  239. int app_mono_run(struct sip_msg *msg, char *arg)
  240. {
  241. int ret;
  242. char *argv[2];
  243. int argc;
  244. sr_mono_load_t *mi;
  245. if(_sr_mono_load_list == NULL)
  246. return -1;
  247. mi = _sr_mono_load_list;
  248. LM_DBG("running Mono assembly: [[%s]]\n", mi->script);
  249. _sr_M_env.msg = msg;
  250. _sr_M_env.domain = mi->domain;
  251. _sr_M_env.assembly = mi->assembly;
  252. if (_sr_M_env.assembly==NULL) {
  253. LM_DBG("empty assembly\n");
  254. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  255. return -1;
  256. }
  257. mono_domain_set(_sr_M_env.domain, 0);
  258. argc = 1;
  259. argv[0] = mi->script;
  260. if(arg!=NULL) {
  261. argc++;
  262. argv[1] = arg;
  263. }
  264. mono_jit_exec(_sr_M_env.domain, _sr_M_env.assembly, argc, argv);
  265. ret = mono_environment_exitcode_get();
  266. LM_DBG("returned code from mono environment: %d\n", ret);
  267. memset(&_sr_M_env, 0, sizeof(sr_mono_env_t));
  268. return (ret==0)?1:-1;
  269. }
  270. /**
  271. *
  272. */
  273. static MonoString* sr_mono_api_version() {
  274. return mono_string_new (mono_domain_get(), SRVERSION);
  275. }
  276. static void sr_mono_log(int level, MonoString *text) {
  277. char *logmsg;
  278. logmsg = mono_string_to_utf8(text);
  279. LOG(level, "%s", logmsg);
  280. mono_free(logmsg);
  281. }
  282. static void sr_mono_err(MonoString *text) {
  283. char *logmsg;
  284. logmsg = mono_string_to_utf8(text);
  285. LOG(L_ERR, "%s", logmsg);
  286. mono_free(logmsg);
  287. }
  288. static void sr_mono_dbg(MonoString *text) {
  289. char *logmsg;
  290. logmsg = mono_string_to_utf8(text);
  291. LOG(L_DBG, "%s", logmsg);
  292. mono_free(logmsg);
  293. }
  294. /**
  295. *
  296. */
  297. static int sr_mono_modf(MonoString *nfunc)
  298. {
  299. int ret;
  300. int mod_type;
  301. struct run_act_ctx ra_ctx;
  302. unsigned modver;
  303. struct action *act = NULL;
  304. sr31_cmd_export_t* expf;
  305. sr_mono_env_t *env_M;
  306. char *func = NULL;
  307. env_M = sr_mono_env_get();
  308. if(env_M->msg==NULL)
  309. goto error;
  310. func = mono_string_to_utf8(nfunc);
  311. expf = find_export_record(func, 0, 0, &modver);
  312. if (expf==NULL) {
  313. LM_ERR("function '%s' is not available\n", func);
  314. goto error;
  315. }
  316. /* check fixups */
  317. if (expf->fixup!=NULL && expf->free_fixup==NULL) {
  318. LM_ERR("function '%s' has fixup - cannot be used\n", func);
  319. goto error;
  320. }
  321. mod_type = MODULE0_T;
  322. act = mk_action(mod_type, 1 /* number of (type, value) pairs */,
  323. MODEXP_ST, expf, /* function */
  324. NUMBER_ST, 0, /* parameter number */
  325. STRING_ST, NULL, /* param. 1 */
  326. STRING_ST, NULL, /* param. 2 */
  327. STRING_ST, NULL, /* param. 3 */
  328. STRING_ST, NULL, /* param. 4 */
  329. STRING_ST, NULL, /* param. 5 */
  330. STRING_ST, NULL /* param. 6 */
  331. );
  332. if (act==NULL) {
  333. LM_ERR("action structure could not be created for '%s'\n", func);
  334. goto error;
  335. }
  336. /* handle fixups */
  337. if (expf->fixup) {
  338. /* no parameters */
  339. if(expf->fixup(0, 0)<0)
  340. {
  341. LM_ERR("Error in fixup (0) for '%s'\n", func);
  342. goto error;
  343. }
  344. }
  345. init_run_actions_ctx(&ra_ctx);
  346. ret = do_action(&ra_ctx, act, env_M->msg);
  347. pkg_free(act);
  348. mono_free(func);
  349. return ret;
  350. error:
  351. if(func!=NULL)
  352. mono_free(func);
  353. if(act!=NULL)
  354. pkg_free(act);
  355. return -127;
  356. }
  357. static const sr_M_export_t _sr_M_export_core[] = {
  358. {"SR.Core::APIVersion", sr_mono_api_version},
  359. {"SR.Core::Log", sr_mono_log},
  360. {"SR.Core::Err", sr_mono_err},
  361. {"SR.Core::Dbg", sr_mono_dbg},
  362. {"SR.Core::ModF", sr_mono_modf},
  363. {NULL, NULL}
  364. };
  365. int sr_mono_load_class_core()
  366. {
  367. int i;
  368. for(i=0; _sr_M_export_core[i].name!=NULL; i++)
  369. mono_add_internal_call(_sr_M_export_core[i].name, _sr_M_export_core[i].method);
  370. return 0;
  371. }
  372. /**
  373. *
  374. */
  375. static MonoString *sr_mono_pv_gets (MonoString *pv)
  376. {
  377. str pvn = {0};
  378. pv_spec_t *pvs;
  379. pv_value_t val;
  380. sr_mono_env_t *env_M;
  381. int pl;
  382. env_M = sr_mono_env_get();
  383. pvn.s = mono_string_to_utf8(pv);
  384. if(pvn.s==NULL || env_M->msg==NULL)
  385. goto error;
  386. pvn.len = strlen(pvn.s);
  387. LM_DBG("pv get: %s\n", pvn.s);
  388. pl = pv_locate_name(&pvn);
  389. if(pl != pvn.len)
  390. {
  391. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  392. goto error;
  393. }
  394. pvs = pv_cache_get(&pvn);
  395. if(pvs==NULL)
  396. {
  397. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  398. goto error;
  399. }
  400. memset(&val, 0, sizeof(pv_value_t));
  401. if(pv_get_spec_value(env_M->msg, pvs, &val) != 0)
  402. {
  403. LM_ERR("unable to get pv value for [%s]\n", pvn.s);
  404. goto error;
  405. }
  406. if((val.flags&PV_VAL_NULL) || !(val.flags&PV_VAL_STR))
  407. {
  408. mono_free(pvn.s);
  409. return NULL;
  410. }
  411. mono_free(pvn.s);
  412. return mono_string_new_len (mono_domain_get(), val.rs.s, val.rs.len);
  413. error:
  414. if(pvn.s!=NULL)
  415. mono_free(pvn.s);
  416. return NULL;
  417. }
  418. /**
  419. *
  420. */
  421. static int sr_mono_pv_geti (MonoString *pv)
  422. {
  423. str pvn = {0};
  424. pv_spec_t *pvs;
  425. pv_value_t val;
  426. int pl;
  427. sr_mono_env_t *env_M;
  428. env_M = sr_mono_env_get();
  429. pvn.s = mono_string_to_utf8(pv);
  430. if(pvn.s==NULL || env_M->msg==NULL)
  431. goto error;
  432. pvn.len = strlen(pvn.s);
  433. LM_DBG("pv get: %s\n", pvn.s);
  434. pl = pv_locate_name(&pvn);
  435. if(pl != pvn.len)
  436. {
  437. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  438. goto error;
  439. }
  440. pvs = pv_cache_get(&pvn);
  441. if(pvs==NULL)
  442. {
  443. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  444. goto error;
  445. }
  446. memset(&val, 0, sizeof(pv_value_t));
  447. if(pv_get_spec_value(env_M->msg, pvs, &val) != 0)
  448. {
  449. LM_ERR("unable to get pv value for [%s]\n", pvn.s);
  450. goto error;
  451. }
  452. if((val.flags&PV_VAL_NULL) || !(val.flags&PV_TYPE_INT))
  453. {
  454. mono_free(pvn.s);
  455. return 0;
  456. }
  457. mono_free(pvn.s);
  458. return val.ri;
  459. error:
  460. if(pvn.s!=NULL)
  461. mono_free(pvn.s);
  462. return 0;
  463. }
  464. /**
  465. *
  466. */
  467. static int sr_mono_pv_seti (MonoString *pv, int iv)
  468. {
  469. str pvn = {0};
  470. pv_spec_t *pvs;
  471. pv_value_t val;
  472. int pl;
  473. sr_mono_env_t *env_M;
  474. env_M = sr_mono_env_get();
  475. pvn.s = mono_string_to_utf8(pv);
  476. if(pvn.s==NULL || env_M->msg==NULL)
  477. goto error;
  478. memset(&val, 0, sizeof(pv_value_t));
  479. val.ri = iv;
  480. val.flags |= PV_TYPE_INT|PV_VAL_INT;
  481. pvn.len = strlen(pvn.s);
  482. LM_DBG("pv set: %s\n", pvn.s);
  483. pl = pv_locate_name(&pvn);
  484. if(pl != pvn.len)
  485. {
  486. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  487. goto error;
  488. }
  489. pvs = pv_cache_get(&pvn);
  490. if(pvs==NULL)
  491. {
  492. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  493. goto error;
  494. }
  495. if(pv_set_spec_value(env_M->msg, pvs, 0, &val)<0)
  496. {
  497. LM_ERR("unable to set pv [%s]\n", pvn.s);
  498. goto error;
  499. }
  500. mono_free(pvn.s);
  501. return 0;
  502. error:
  503. if(pvn.s!=NULL)
  504. mono_free(pvn.s);
  505. return -1;
  506. }
  507. /**
  508. *
  509. */
  510. static int sr_mono_pv_sets (MonoString *pv, MonoString *sv)
  511. {
  512. str pvn = {0};
  513. pv_spec_t *pvs;
  514. pv_value_t val;
  515. int pl;
  516. sr_mono_env_t *env_M;
  517. env_M = sr_mono_env_get();
  518. pvn.s = mono_string_to_utf8(pv);
  519. if(pvn.s==NULL || env_M->msg==NULL)
  520. goto error;
  521. memset(&val, 0, sizeof(pv_value_t));
  522. val.rs.s = mono_string_to_utf8(sv);
  523. if(val.rs.s == NULL)
  524. goto error;
  525. val.rs.len = strlen(val.rs.s);
  526. val.flags |= PV_VAL_STR;
  527. pvn.len = strlen(pvn.s);
  528. LM_DBG("pv set: %s\n", pvn.s);
  529. pl = pv_locate_name(&pvn);
  530. if(pl != pvn.len)
  531. {
  532. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  533. goto error;
  534. }
  535. pvs = pv_cache_get(&pvn);
  536. if(pvs==NULL)
  537. {
  538. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  539. goto error;
  540. }
  541. if(pv_set_spec_value(env_M->msg, pvs, 0, &val)<0)
  542. {
  543. LM_ERR("unable to set pv [%s]\n", pvn.s);
  544. return -1;
  545. }
  546. mono_free(pvn.s);
  547. return 0;
  548. error:
  549. if(pvn.s!=NULL)
  550. mono_free(pvn.s);
  551. return -1;
  552. }
  553. /**
  554. *
  555. */
  556. static int sr_mono_pv_unset (MonoString *pv)
  557. {
  558. str pvn = {0};
  559. pv_spec_t *pvs;
  560. pv_value_t val;
  561. int pl;
  562. sr_mono_env_t *env_M;
  563. env_M = sr_mono_env_get();
  564. pvn.s = mono_string_to_utf8(pv);
  565. if(pvn.s==NULL || env_M->msg==NULL)
  566. goto error;
  567. pvn.len = strlen(pvn.s);
  568. LM_DBG("pv unset: %s\n", pvn.s);
  569. pl = pv_locate_name(&pvn);
  570. if(pl != pvn.len)
  571. {
  572. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  573. goto error;
  574. }
  575. pvs = pv_cache_get(&pvn);
  576. if(pvs==NULL)
  577. {
  578. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  579. goto error;
  580. }
  581. memset(&val, 0, sizeof(pv_value_t));
  582. val.flags |= PV_VAL_NULL;
  583. if(pv_set_spec_value(env_M->msg, pvs, 0, &val)<0)
  584. {
  585. LM_ERR("unable to unset pv [%s]\n", pvn.s);
  586. goto error;
  587. }
  588. mono_free(pvn.s);
  589. return 0;
  590. error:
  591. if(pvn.s!=NULL)
  592. mono_free(pvn.s);
  593. return -1;
  594. }
  595. /**
  596. *
  597. */
  598. static int sr_mono_pv_is_null (MonoString *pv)
  599. {
  600. str pvn = {0};
  601. pv_spec_t *pvs;
  602. pv_value_t val;
  603. int pl;
  604. sr_mono_env_t *env_M;
  605. env_M = sr_mono_env_get();
  606. pvn.s = mono_string_to_utf8(pv);
  607. if(pvn.s==NULL || env_M->msg==NULL)
  608. goto error;
  609. pvn.len = strlen(pvn.s);
  610. LM_DBG("pv is null test: %s\n", pvn.s);
  611. pl = pv_locate_name(&pvn);
  612. if(pl != pvn.len)
  613. {
  614. LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len);
  615. goto error;
  616. }
  617. pvs = pv_cache_get(&pvn);
  618. if(pvs==NULL)
  619. {
  620. LM_ERR("cannot get pv spec for [%s]\n", pvn.s);
  621. goto error;
  622. }
  623. memset(&val, 0, sizeof(pv_value_t));
  624. if(pv_get_spec_value(env_M->msg, pvs, &val) != 0)
  625. {
  626. LM_INFO("unable to get pv value for [%s]\n", pvn.s);
  627. goto error;
  628. }
  629. mono_free(pvn.s);
  630. if(val.flags&PV_VAL_NULL)
  631. {
  632. return 1;
  633. }
  634. return 0;
  635. error:
  636. if(pvn.s!=NULL)
  637. mono_free(pvn.s);
  638. return -1;
  639. }
  640. /**
  641. *
  642. */
  643. static const sr_M_export_t _sr_M_export_pv[] = {
  644. {"SR.PV::GetS", sr_mono_pv_gets},
  645. {"SR.PV::GetI", sr_mono_pv_geti},
  646. {"SR.PV::SetI", sr_mono_pv_seti},
  647. {"SR.PV::SetS", sr_mono_pv_sets},
  648. {"SR.PV::Unset", sr_mono_pv_unset},
  649. {"SR.PV::IsNull", sr_mono_pv_is_null},
  650. {NULL, NULL}
  651. };
  652. int sr_mono_load_class_pv()
  653. {
  654. int i;
  655. for(i=0; _sr_M_export_pv[i].name!=NULL; i++)
  656. mono_add_internal_call(_sr_M_export_pv[i].name, _sr_M_export_pv[i].method);
  657. return 0;
  658. }
  659. /**
  660. *
  661. */
  662. static int sr_mono_hdr_append (MonoString *hv)
  663. {
  664. struct lump* anchor;
  665. struct hdr_field *hf;
  666. char *hdr;
  667. str txt = {0};
  668. sr_mono_env_t *env_M;
  669. env_M = sr_mono_env_get();
  670. txt.s = mono_string_to_utf8(hv);
  671. if(txt.s==NULL || env_M->msg==NULL)
  672. goto error;
  673. txt.len = strlen(txt.s);
  674. LM_DBG("append hf: %s\n", txt.s);
  675. if (parse_headers(env_M->msg, HDR_EOH_F, 0) == -1)
  676. {
  677. LM_ERR("error while parsing message\n");
  678. goto error;
  679. }
  680. hf = env_M->msg->last_header;
  681. hdr = (char*)pkg_malloc(txt.len);
  682. if(hdr==NULL)
  683. {
  684. LM_ERR("no pkg memory left\n");
  685. goto error;
  686. }
  687. memcpy(hdr, txt.s, txt.len);
  688. anchor = anchor_lump(env_M->msg,
  689. hf->name.s + hf->len - env_M->msg->buf, 0, 0);
  690. if(insert_new_lump_before(anchor, hdr, txt.len, 0) == 0)
  691. {
  692. LM_ERR("can't insert lump\n");
  693. pkg_free(hdr);
  694. goto error;
  695. }
  696. mono_free(txt.s);
  697. return 0;
  698. error:
  699. if(txt.s!=NULL)
  700. mono_free(txt.s);
  701. return -1;
  702. }
  703. /**
  704. *
  705. */
  706. static int sr_mono_hdr_remove (MonoString *hv)
  707. {
  708. struct lump* anchor;
  709. struct hdr_field *hf;
  710. str hname;
  711. str txt = {0};
  712. sr_mono_env_t *env_M;
  713. env_M = sr_mono_env_get();
  714. txt.s = mono_string_to_utf8(hv);
  715. if(txt.s==NULL || env_M->msg==NULL)
  716. goto error;
  717. txt.len = strlen(txt.s);
  718. LM_DBG("remove hf: %s\n", txt.s);
  719. if (parse_headers(env_M->msg, HDR_EOH_F, 0) == -1) {
  720. LM_ERR("error while parsing message\n");
  721. goto error;
  722. }
  723. hname.s = txt.s;
  724. hname.len = txt.len;
  725. for (hf=env_M->msg->headers; hf; hf=hf->next)
  726. {
  727. if (cmp_hdrname_str(&hf->name, &hname)==0)
  728. {
  729. anchor=del_lump(env_M->msg,
  730. hf->name.s - env_M->msg->buf, hf->len, 0);
  731. if (anchor==0)
  732. {
  733. LM_ERR("cannot remove hdr %s\n", txt.s);
  734. goto error;
  735. }
  736. }
  737. }
  738. mono_free(txt.s);
  739. return 0;
  740. error:
  741. if(txt.s!=NULL)
  742. mono_free(txt.s);
  743. return -1;
  744. }
  745. /**
  746. *
  747. */
  748. static int sr_mono_hdr_insert (MonoString *hv)
  749. {
  750. struct lump* anchor;
  751. struct hdr_field *hf;
  752. char *hdr;
  753. str txt = {0};
  754. sr_mono_env_t *env_M;
  755. env_M = sr_mono_env_get();
  756. txt.s = mono_string_to_utf8(hv);
  757. if(txt.s==NULL || env_M->msg==NULL)
  758. goto error;
  759. txt.len = strlen(txt.s);
  760. LM_DBG("insert hf: %s\n", txt.s);
  761. hf = env_M->msg->headers;
  762. hdr = (char*)pkg_malloc(txt.len);
  763. if(hdr==NULL)
  764. {
  765. LM_ERR("no pkg memory left\n");
  766. goto error;
  767. }
  768. memcpy(hdr, txt.s, txt.len);
  769. anchor = anchor_lump(env_M->msg,
  770. hf->name.s + hf->len - env_M->msg->buf, 0, 0);
  771. if(insert_new_lump_before(anchor, hdr, txt.len, 0) == 0)
  772. {
  773. LM_ERR("can't insert lump\n");
  774. pkg_free(hdr);
  775. goto error;
  776. }
  777. mono_free(txt.s);
  778. return 0;
  779. error:
  780. if(txt.s!=NULL)
  781. mono_free(txt.s);
  782. return -1;
  783. }
  784. /**
  785. *
  786. */
  787. static int sr_mono_hdr_append_to_reply (MonoString *hv)
  788. {
  789. str txt = {0};
  790. sr_mono_env_t *env_M;
  791. env_M = sr_mono_env_get();
  792. txt.s = mono_string_to_utf8(hv);
  793. if(txt.s==NULL || env_M->msg==NULL)
  794. goto error;
  795. txt.len = strlen(txt.s);
  796. LM_DBG("append to reply: %s\n", txt.s);
  797. if(add_lump_rpl(env_M->msg, txt.s, txt.len, LUMP_RPL_HDR)==0)
  798. {
  799. LM_ERR("unable to add reply lump\n");
  800. goto error;
  801. }
  802. mono_free(txt.s);
  803. return 0;
  804. error:
  805. if(txt.s!=NULL)
  806. mono_free(txt.s);
  807. return -1;
  808. }
  809. /**
  810. *
  811. */
  812. static const sr_M_export_t _sr_M_export_hdr[] = {
  813. {"SR.HDR::Append", sr_mono_hdr_append},
  814. {"SR.HDR::Remove", sr_mono_hdr_remove},
  815. {"SR.HDR::Insert", sr_mono_hdr_insert},
  816. {"SR.HDR::AppendToReply", sr_mono_hdr_append_to_reply},
  817. {NULL, NULL}
  818. };
  819. int sr_mono_load_class_hdr()
  820. {
  821. int i;
  822. for(i=0; _sr_M_export_hdr[i].name!=NULL; i++)
  823. mono_add_internal_call(_sr_M_export_hdr[i].name, _sr_M_export_hdr[i].method);
  824. return 0;
  825. }