Module: kamailio Branch: master Commit: 03c3a04bca378082a7e2bda3fa5aaaf117ce4579 URL: https://github.com/kamailio/kamailio/commit/03c3a04bca378082a7e2bda3fa5aaaf… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2018-02-21T09:27:10+01:00 core: kemi - exported functions to match myself for r-uri, from-uri, to-uri - KSR.is_myself_ruri(), KSR.is_myself_furi(), KSR.is_myself_turi() --- Modified: src/core/kemi.c --- Diff: https://github.com/kamailio/kamailio/commit/03c3a04bca378082a7e2bda3fa5aaaf… Patch: https://github.com/kamailio/kamailio/commit/03c3a04bca378082a7e2bda3fa5aaaf… --- diff --git a/src/core/kemi.c b/src/core/kemi.c index a24f1b869d..5aa94e17b9 100644 --- a/src/core/kemi.c +++ b/src/core/kemi.c @@ -33,6 +33,7 @@ #include "strutils.h" #include "mem/shm.h" #include "parser/parse_uri.h" +#include "parser/parse_from.h" #include "parser/parse_hname2.h" #include "parser/parse_methods.h" @@ -157,6 +158,78 @@ static int sr_kemi_core_is_myself(sip_msg_t *msg, str *uri) return SR_KEMI_FALSE; } +/** + * + */ +static int sr_kemi_core_is_myself_ruri(sip_msg_t *msg) +{ + if(msg==NULL) { + LM_WARN("invalid msg parameter\n"); + return SR_KEMI_FALSE; + } + + if(msg->first_line.type == SIP_REPLY) /* REPLY doesn't have a ruri */ + return SR_KEMI_FALSE; + + if (msg->new_uri.s!=NULL) + return sr_kemi_core_is_myself(msg, &msg->new_uri); + return sr_kemi_core_is_myself(msg, &msg->first_line.u.request.uri); +} + +/** + * + */ +static int sr_kemi_core_is_myself_furi(sip_msg_t *msg) +{ + to_body_t *xfrom; + + if(msg==NULL) { + LM_WARN("invalid msg parameter\n"); + return SR_KEMI_FALSE; + } + + if(parse_from_header(msg)<0) { + LM_ERR("cannot parse From header\n"); + return SR_KEMI_FALSE; + } + + if(msg->from==NULL || get_from(msg)==NULL) { + LM_DBG("no From header\n"); + return SR_KEMI_FALSE; + } + + xfrom = get_from(msg); + + return sr_kemi_core_is_myself(msg, &xfrom->uri); +} + +/** + * + */ +static int sr_kemi_core_is_myself_turi(sip_msg_t *msg) +{ + to_body_t *xto; + + if(msg==NULL) { + LM_WARN("invalid msg parameter\n"); + return SR_KEMI_FALSE; + } + + if(parse_to_header(msg)<0) { + LM_ERR("cannot parse To header\n"); + return SR_KEMI_FALSE; + } + + if(msg->to==NULL || get_to(msg)==NULL) { + LM_DBG("no To header\n"); + return SR_KEMI_FALSE; + } + + xto = get_to(msg); + + return sr_kemi_core_is_myself(msg, &xto->uri); +} + /** * */ @@ -806,6 +879,21 @@ static sr_kemi_t _sr_kemi_core[] = { { SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } }, + { str_init(""), str_init("is_myself_ruri"), + SR_KEMIP_BOOL, sr_kemi_core_is_myself_ruri, + { SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init(""), str_init("is_myself_furi"), + SR_KEMIP_BOOL, sr_kemi_core_is_myself_furi, + { SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init(""), str_init("is_myself_turi"), + SR_KEMIP_BOOL, sr_kemi_core_is_myself_turi, + { SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, { str_init(""), str_init("setflag"), SR_KEMIP_BOOL, sr_kemi_core_setflag, { SR_KEMIP_INT, SR_KEMIP_NONE, SR_KEMIP_NONE,