[sr-dev] git:master: sdpops: new module for SDP operations

Module: sip-router Branch: master Commit: f772c256238596f3df1755cf31b31606c33ee064 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=f772c25… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Sun Mar 13 10:20:20 2011 +0100 sdpops: new module for SDP operations - the module is intended to export functions that will allow easier management of SDP from configuration file - first function: spd_remove_codecs_by_id(list) - remove the codecs by their numeric IDs given in a comma separated list as paramter - codecs attributes are not removed yet --- modules/sdpops/Makefile | 14 +++ modules/sdpops/sdpops_mod.c | 257 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 271 insertions(+), 0 deletions(-) diff --git a/modules/sdpops/Makefile b/modules/sdpops/Makefile new file mode 100644 index 0000000..2ade2d9 --- /dev/null +++ b/modules/sdpops/Makefile @@ -0,0 +1,14 @@ +# $Id$ +# +# +# WARNING: do not run this directly, it should be run by the master Makefile + +include ../../Makefile.defs +auto_gen= +NAME=sdpops.so +DEFS += +LIBS += + +DEFS+=-DOPENSER_MOD_INTERFACE + +include ../../Makefile.modules diff --git a/modules/sdpops/sdpops_mod.c b/modules/sdpops/sdpops_mod.c new file mode 100644 index 0000000..bc118ca --- /dev/null +++ b/modules/sdpops/sdpops_mod.c @@ -0,0 +1,257 @@ +/* + * $Id$ + * + * Copyright (C) 2011 Daniel-Constantin Mierla (asipto.com) + * + * This file is part of Kamailio, a free SIP server. + * + * Kamailio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version + * + * Kamailio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + * + */ + + +#include <string.h> +#include <stdlib.h> +#include <stdio.h> + +#include "../../sr_module.h" +#include "../../dprint.h" +#include "../../mod_fix.h" +#include "../../pvar.h" +#include "../../trim.h" +#include "../../parser/sdp/sdp.h" +#include "../../data_lump.h" + + +MODULE_VERSION + +static int w_sdp_remove_codecs_by_id(sip_msg_t* msg, char* codecs, char *bar); +static int fixup_sdp_remove_codecs_by_id(void** param, int param_no); + +static int mod_init(void); + +static cmd_export_t cmds[] = { + {"sdp_remove_codecs_by_id", (cmd_function)w_sdp_remove_codecs_by_id, + 1, fixup_sdp_remove_codecs_by_id, 0, ANY_ROUTE}, + {0, 0, 0, 0, 0} +}; + +static pv_export_t mod_pvs[] = { +#if 0 + {{"sdp", (sizeof("sdp")-1)}, /* */ + PVT_OTHER, pv_get_sdp, 0, + 0, 0, 0, 0}, +#endif + + { {0, 0}, 0, 0, 0, 0, 0, 0, 0 } +}; + +static param_export_t params[] = { + {0, 0, 0} +}; + +/** module exports */ +struct module_exports exports= { + "sdpops", + DEFAULT_DLFLAGS, /* dlopen flags */ + cmds, + params, + 0, /* exported statistics */ + 0 , /* exported MI functions */ + mod_pvs, /* exported pseudo-variables */ + 0, /* extra processes */ + mod_init, /* module initialization function */ + 0, + 0, + 0 /* per-child init function */ +}; + +/** + * + */ +static int mod_init(void) +{ + LM_DBG("sdpops module loaded\n"); + return 0; +} + + +/** + * + */ +int str_find_token(str *text, str *result, char delim) +{ + int i; + if(text==NULL || result==NULL) + return -1; + if(text->s[0] == delim) + { + text->s += 1; + text->len -= 1; + } + trim_leading(text); + result->s = text->s; + result->len = 0; + for (i=0; i<text->len; i++) + { + if(result->s[i]==delim || result->s[i]=='\0' + || result->s[i]=='\r' || result->s[i]=='\n') + return 0; + result->len++; + } + return 0; +} + + +int sdp_remove_str_codec_id(sip_msg_t* msg, str *allcodecs, str* rmcodec) +{ + int i; + int cmp; + struct lump *anchor; + + if(msg==NULL || allcodecs==NULL || rmcodec==NULL + || allcodecs->len<=0 || rmcodec->len<=0) + return -1; + + cmp = 1; + for(i=0; i<allcodecs->len; i++) { + if(cmp==1) { + if(rmcodec->len <= allcodecs->len-i) { + if(strncmp(&allcodecs->s[i], rmcodec->s, rmcodec->len)==0) { + if(&allcodecs->s[i+rmcodec->len] + == &allcodecs->s[allcodecs->len] + || allcodecs->s[i+rmcodec->len] == ' ') { + /* match - remove also the space before codec id */ + LM_DBG("found codec [%.*s] inside [%.*s]\n", + rmcodec->len, rmcodec->s, + allcodecs->len, allcodecs->s); + anchor = del_lump(msg, &allcodecs->s[i-1] - msg->buf, + rmcodec->len+1, 0); + if (anchor == NULL) { + LM_ERR("failed to remove [%.*s] inside [%.*s]\n", + rmcodec->len, rmcodec->s, + allcodecs->len, allcodecs->s); + return -1; + } + return 0; + } + } + } + } + if(allcodecs->s[i]==' ') + cmp = 1; + else + cmp = 0; + } + + return 0; +} + +/** + * + */ +int sdp_remove_codecs_by_id(sip_msg_t* msg, str* codecs) +{ + sdp_info_t *sdp = NULL; + int sdp_session_num; + int sdp_stream_num; + sdp_session_cell_t* sdp_session; + sdp_stream_cell_t* sdp_stream; + str sdp_codecs; + str tmp_codecs; + str rm_codec; + + if(parse_sdp(msg) < 0) { + LM_ERR("Unable to parse sdp\n"); + return -1; + } + + LM_ERR("attempting to remove codecs from sdp: [%.*s]\n", + codecs->len, codecs->s); + + sdp = (sdp_info_t*)msg->body; + + print_sdp(sdp, L_DBG); + + sdp_session_num = 0; + for(;;) + { + sdp_session = get_sdp_session(msg, sdp_session_num); + if(!sdp_session) break; + sdp_stream_num = 0; + for(;;) + { + sdp_stream = get_sdp_stream(msg, sdp_session_num, sdp_stream_num); + if(!sdp_stream) break; + + LM_DBG("stream %d of %d - payloads [%.*s]\n", + sdp_stream_num, sdp_session_num, + sdp_stream->payloads.len, sdp_stream->payloads.s); + sdp_codecs = sdp_stream->payloads; + tmp_codecs = *codecs; + while(str_find_token(&tmp_codecs, &rm_codec, ',')==0 + && rm_codec.len>0) + { + tmp_codecs.len -=(int)(&rm_codec.s[rm_codec.len]-tmp_codecs.s); + tmp_codecs.s = rm_codec.s + rm_codec.len; + + LM_DBG("codecs [%.*s] - remove [%.*s]\n", + sdp_codecs.len, sdp_codecs.s, + rm_codec.len, rm_codec.s); + sdp_remove_str_codec_id(msg, &sdp_codecs, &rm_codec); + } + sdp_stream_num++; + } + sdp_session_num++; + } + + return 0; +} + +/** + * + */ +static int w_sdp_remove_codecs_by_id(sip_msg_t* msg, char* codecs, char* bar) +{ + str lcodecs = {0, 0}; + + if(codecs==0) + { + LM_ERR("invalid parameters\n"); + return -1; + } + + if(fixup_get_svalue(msg, (gparam_p)codecs, &lcodecs)!=0) + { + LM_ERR("unable to get the list of codecs\n"); + return -1; + } + + if(sdp_remove_codecs_by_id(msg, &lcodecs)<0) + return -1; + return 1; +} + + +/** + * + */ +static int fixup_sdp_remove_codecs_by_id(void** param, int param_no) +{ + if (param_no == 1) { + return fixup_spve_null(param, 1); + } + return 0; +}