[sr-dev] git:master:9853d9b4: sipcapture: added sip_capture_forward(uri)

Module: kamailio Branch: master Commit: 9853d9b4d3e7ee863170aa22acccfe8de810b435 URL: https://github.com/kamailio/kamailio/commit/9853d9b4d3e7ee863170aa22acccfe8… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2018-05-02T12:10:45+02:00 sipcapture: added sip_capture_forward(uri) - forward the hep packet to another address - the address has to bbe provided as parameter in sip uri format - the function should be used inside event_route[sipcapture:request] event_route[sipcapture:request] { if(src_ip==1.2.3.4) { sip_capture_forward("sip:2.3.4.5:5090"); return 0; } } --- Modified: src/modules/sipcapture/sipcapture.c --- Diff: https://github.com/kamailio/kamailio/commit/9853d9b4d3e7ee863170aa22acccfe8… Patch: https://github.com/kamailio/kamailio/commit/9853d9b4d3e7ee863170aa22acccfe8… --- diff --git a/src/modules/sipcapture/sipcapture.c b/src/modules/sipcapture/sipcapture.c index 53735000f1..6f0108a055 100644 --- a/src/modules/sipcapture/sipcapture.c +++ b/src/modules/sipcapture/sipcapture.c @@ -67,6 +67,7 @@ #include "../../core/parser/parse_uri.h" #include "../../core/parser/digest/digest.h" #include "../../core/parser/parse_ppi_pai.h" +#include "../../core/forward.h" #include "../../core/pvar.h" #include "../../core/str.h" #include "../../core/onsend.h" @@ -158,6 +159,8 @@ static int w_report_capture3(sip_msg_t *_m, char *_table, char *_corr, char *_data); static int w_float2int(sip_msg_t *_m, char *_val, char *_coof); +static int w_sip_capture_forward(sip_msg_t *_m, char *_dst, char *_p2); + static int sipcapture_parse_aleg_callid_headers(); int parse_aleg_callid_headers(str *headers_str, str *headers); @@ -310,6 +313,8 @@ static cmd_export_t cmds[] = { reportcapture_fixup, 0, ANY_ROUTE}, {"float2int", (cmd_function)w_float2int, 2, float2int_fixup, 0, ANY_ROUTE}, + {"sip_capture_forward", (cmd_function)w_sip_capture_forward, 1, + fixup_spve_null, 0, ANY_ROUTE}, {0, 0, 0, 0, 0, 0}}; @@ -2895,11 +2900,10 @@ static int nosip_hep_msg(sr_event_param_t *evp) int rtb; sr_kemi_eng_t *keng = NULL; str evname = str_init("sipcapture:request"); + struct hep_hdr *heph; msg = (sip_msg_t *)evp->data; - struct hep_hdr *heph; - buf = msg->buf; len = msg->len; @@ -3097,6 +3101,98 @@ static int pv_get_hep(struct sip_msg *msg, pv_param_t *param, pv_value_t *res) return 0; } +/** + * + */ +static int ki_sip_capture_forward(sip_msg_t *msg, str *puri) +{ + dest_info_t dst; + sip_uri_t next_hop; + str pdata; + int ret = 0; + char proto; + + if(parse_uri(puri->s, puri->len, &next_hop)<0) { + LM_ERR("bad dst sip uri <%.*s>\n", puri->len, puri->s); + return -1; + } + + init_dest_info(&dst); + LM_DBG("sending data to sip uri <%.*s>\n", puri->len, puri->s); + proto = next_hop.proto; + if(sip_hostport2su(&dst.to, &next_hop.host, next_hop.port_no, + &proto)!=0) { + LM_ERR("failed to resolve [%.*s]\n", next_hop.host.len, + ZSW(next_hop.host.s)); + return -1; + } + dst.proto = proto; + if(dst.proto==PROTO_NONE) dst.proto = PROTO_UDP; + + pdata.s = msg->buf; + pdata.len = msg->len; + + if (dst.proto == PROTO_UDP) { + dst.send_sock=get_send_socket(0, &dst.to, PROTO_UDP); + if (dst.send_sock!=0) { + ret=udp_send(&dst, pdata.s, pdata.len); + } else { + LM_ERR("no socket for dst sip uri <%.*s>\n", puri->len, puri->s); + ret=-1; + } + } +#ifdef USE_TCP + else if(dst.proto == PROTO_TCP) { + /*tcp*/ + dst.id=0; + ret=tcp_send(&dst, 0, pdata.s, pdata.len); + } +#endif +#ifdef USE_TLS + else if(dst.proto == PROTO_TLS) { + /*tls*/ + dst.id=0; + ret=tcp_send(&dst, 0, pdata.s, pdata.len); + } +#endif +#ifdef USE_SCTP + else if(dst.proto == PROTO_SCTP) { + /*sctp*/ + dst.send_sock=get_send_socket(0, &dst.to, PROTO_SCTP); + if (dst.send_sock!=0) { + ret=sctp_core_msg_send(&dst, pdata.s, pdata.len); + } else { + LM_ERR("no socket for dst sip uri <%.*s>\n", puri->len, puri->s); + ret=-1; + } + } +#endif + else { + LM_ERR("unknown proto [%d] for dst sip uri <%.*s>\n", + dst.proto, puri->len, puri->s); + ret=-1; + } + + if (ret>=0) ret=1; + + return ret; +} + +/** + * + */ +static int w_sip_capture_forward(sip_msg_t *_m, char *_dst, char *_p2) +{ + str sdst; + + if(fixup_get_svalue(_m, (gparam_t*)_dst, &sdst)<0) { + LM_ERR("failed to get the destination address\n"); + return -1; + } + + return ki_sip_capture_forward(_m, &sdst); +} + /** * */ @@ -3137,6 +3233,11 @@ static sr_kemi_t sr_kemi_sipcapture_exports[] = { { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } }, + { str_init("sipcapture"), str_init("sip_capture_forward"), + SR_KEMIP_INT, ki_sip_capture_forward, + { SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } };