[sr-dev] git:master:f04c812b: http_async_client: exported query function to kemi interface

Module: kamailio Branch: master Commit: f04c812b2af2d933e61b0d643bd245cc91c5f3eb URL: https://github.com/kamailio/kamailio/commit/f04c812b2af2d933e61b0d643bd245c… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2017-12-06T17:00:41+01:00 http_async_client: exported query function to kemi interface --- Modified: src/modules/http_async_client/http_async_client_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/f04c812b2af2d933e61b0d643bd245c… Patch: https://github.com/kamailio/kamailio/commit/f04c812b2af2d933e61b0d643bd245c… --- diff --git a/src/modules/http_async_client/http_async_client_mod.c b/src/modules/http_async_client/http_async_client_mod.c index 3ec52f4f3b..1799a05fb6 100644 --- a/src/modules/http_async_client/http_async_client_mod.c +++ b/src/modules/http_async_client/http_async_client_mod.c @@ -50,6 +50,7 @@ #include "../../core/pvar.h" #include "../../core/cfg/cfg_struct.h" #include "../../core/fmsg.h" +#include "../../core/kemi.h" #include "../../modules/tm/tm_load.h" #include "../../modules/pv/pv_api.h" @@ -207,19 +208,6 @@ struct module_exports exports = { }; -int mod_register(char *path, int *dlflags, void *p1, void *p2) -{ - pv_register_api_t pvra; - - pvra = (pv_register_api_t)find_export("pv_register_api", NO_SCRIPT, 0); - if (!pvra) { - LM_ERR("Cannot import pv functions (pv module must be loaded before this module)\n"); - return -1; - } - pvra(&pv_api); - return 0; -} - /** * init module function */ @@ -407,7 +395,24 @@ static int w_http_async_query(sip_msg_t *msg, char *query, char* rt) return -1; } return async_send_query(msg, &sdata, &rn); +} +/** + * + */ +static int ki_http_async_query(sip_msg_t *msg, str *sdata, str *rn) +{ + if(msg==NULL) + return -1; + if(sdata==NULL || sdata->len <= 0) { + LM_ERR("invalid data parameter\n"); + return -1; + } + if(rn->s==NULL || rn->len <= 0) { + LM_ERR("invalid route name parameter\n"); + return -1; + } + return async_send_query(msg, sdata, rn); } #define _IVALUE_ERROR(NAME) LM_ERR("invalid parameter '" #NAME "' (must be a number)\n") @@ -724,3 +729,32 @@ static int ah_set_req(struct sip_msg* msg, pv_param_t *param, return 1; } + +/** + * + */ +/* clang-format off */ +static sr_kemi_t sr_kemi_http_async_client_exports[] = { + { str_init("http_async_client"), str_init("query"), + SR_KEMIP_INT, ki_http_async_query, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + + { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } +}; +/* clang-format on */ + +int mod_register(char *path, int *dlflags, void *p1, void *p2) +{ + pv_register_api_t pvra; + + pvra = (pv_register_api_t)find_export("pv_register_api", NO_SCRIPT, 0); + if (!pvra) { + LM_ERR("Cannot import pv functions (pv module must be loaded before this module)\n"); + return -1; + } + pvra(&pv_api); + sr_kemi_modules_add(sr_kemi_http_async_client_exports); + return 0; +} \ No newline at end of file