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

13 Mar 2011

Module: sip-router
Branch: master
Commit: f772c256238596f3df1755cf31b31606c33ee064
URL:    http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=f772c256...
Author: Daniel-Constantin Mierla miconda@gmail.com
Committer: Daniel-Constantin Mierla miconda@gmail.com
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;
+}

    