[sr-dev] git:master:72c361fd: pv: config function to shift xavps to left with rotation

Module: kamailio Branch: master Commit: 72c361fd80ba0f3d017591e4bb3fb883f7dec490 URL: https://github.com/kamailio/kamailio/commit/72c361fd80ba0f3d017591e4bb3fb88… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2022-05-10T19:35:52+02:00 pv: config function to shift xavps to left with rotation --- Modified: src/modules/pv/pv.c --- Diff: https://github.com/kamailio/kamailio/commit/72c361fd80ba0f3d017591e4bb3fb88… Patch: https://github.com/kamailio/kamailio/commit/72c361fd80ba0f3d017591e4bb3fb88… --- diff --git a/src/modules/pv/pv.c b/src/modules/pv/pv.c index cdd34ce5b9..685c0ef9f0 100644 --- a/src/modules/pv/pv.c +++ b/src/modules/pv/pv.c @@ -608,6 +608,8 @@ static int w_xavi_child_sets(sip_msg_t *msg, char *prname, char *pcname, static int w_xavi_rm(sip_msg_t *msg, char *prname, char *p2); static int w_xavi_child_rm(sip_msg_t *msg, char *prname, char *pcname); +static int w_xavp_lshift(sip_msg_t *msg, char *pxname, char *pidx); + int pv_xavp_copy_fixup(void** param, int param_no); int pv_evalx_fixup(void** param, int param_no); int w_pv_evalx(struct sip_msg *msg, char *dst, str *fmt); @@ -684,6 +686,9 @@ static cmd_export_t cmds[]={ {"xavi_child_rm", (cmd_function)w_xavi_child_rm, 2, fixup_spve_spve, fixup_free_spve_spve, ANY_ROUTE}, + {"xavp_lshift", (cmd_function)w_xavp_lshift, + 2, fixup_spve_igp, fixup_free_spve_igp, + ANY_ROUTE}, {"sbranch_set_ruri", (cmd_function)w_sbranch_set_ruri, 0, 0, 0, ANY_ROUTE }, {"sbranch_append", (cmd_function)w_sbranch_append, 0, 0, 0, @@ -904,6 +909,38 @@ static int ki_xavp_print(sip_msg_t* msg) return 1; } +/** + * + */ +static int ki_xavp_lshift(sip_msg_t *msg, str *xname, int idx) +{ + int ret; + + ret = xavp_lshift(xname, NULL, idx); + + return (ret==0)?1:ret; +} + +/** + * + */ +static int w_xavp_lshift(sip_msg_t *msg, char *pxname, char *pidx) +{ + str xname = STR_NULL; + int idx = 0; + + if(fixup_get_svalue(msg, (gparam_t*)pxname, &xname)<0) { + LM_ERR("failed to get the xavp name\n"); + return -1; + } + if(fixup_get_svalue(msg, (gparam_t*)pidx, &idx)<0) { + LM_ERR("failed to get the xavp index\n"); + return -1; + } + + return ki_xavp_lshift(msg, &xname, idx); +} + static int ki_xavu_print(sip_msg_t* msg) { xavu_print_list(NULL); @@ -3173,6 +3210,11 @@ static sr_kemi_t sr_kemi_pvx_exports[] = { { SR_KEMIP_STR, SR_KEMIP_INT, SR_KEMIP_STR, SR_KEMIP_INT, SR_KEMIP_NONE, SR_KEMIP_NONE } }, + { str_init("pvx"), str_init("xavp_lshift"), + SR_KEMIP_INT, ki_xavp_lshift, + { SR_KEMIP_STR, SR_KEMIP_INT, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } };