kamailio-call-control-application.diff

commit 3e47feac838d9c4498d03681a80a9f3f292fc4be
Author: David M. Lee <[email protected]>
Date:   Mon Feb 10 15:22:11 2014 -0600

    call_control: Passthrough sip_application
    
    Current patches being submitted to CDRTool and the call_control daemon
    allow for SIP application type to be specified. This allows audio or
    video services to be rated differently, or even different ratings for
    application subtypes (audio.inbound vs. audio.outbound).
    
    This patch allows the sip_application value to be passed through to the
    call_control daemon.

diff --git a/modules/call_control/call_control.c b/modules/call_control/call_control.c
index 2ba7a50..d340ae5 100644
--- a/modules/call_control/call_control.c
+++ b/modules/call_control/call_control.c
@@ -59,6 +59,7 @@ MODULE_VERSION
 
 #define CANONICAL_URI_AVP_SPEC "$avp(s:can_uri)"
 #define SIGNALING_IP_AVP_SPEC  "$avp(s:signaling_ip)"
+#define SIP_APPLICATION_AVP_SPEC "$avp(s:sip_application)"
 
 // Although `AF_LOCAL' is mandated by POSIX.1g, `AF_UNIX' is portable to
 // more systems.  `AF_UNIX' was the traditional name stemming from BSD, so
@@ -134,6 +135,9 @@ static AVP_Param canonical_uri_avp = {str_init(CANONICAL_URI_AVP_SPEC), {0}, 0};
 /* The AVP where the caller signaling IP is stored (if defined) */
 static AVP_Param signaling_ip_avp = {str_init(SIGNALING_IP_AVP_SPEC), {0}, 0};
 
+/* The AVP where the SIP application type is stored (if defined) */
+static AVP_Param sip_application_avp = {str_init(SIP_APPLICATION_AVP_SPEC), {0}, 0};
+
 
 struct dlg_binds dlg_api;
 static int dialog_flag = -1;
@@ -157,6 +161,7 @@ static param_export_t parameters[] = {
     {"diverter_avp_id",     INT_PARAM, &diverter_avp_id},
     {"canonical_uri_avp",   STR_PARAM, &(canonical_uri_avp.spec.s)},
     {"signaling_ip_avp",    STR_PARAM, &(signaling_ip_avp.spec.s)},
+    {"sip_application_avp", STR_PARAM, &(sip_application_avp.spec.s)},
     {0, 0, 0}
 };
 
@@ -204,6 +209,7 @@ typedef struct CallInfo {
     str callid;
     str from;
     str from_tag;
+    str sip_application;
 } CallInfo;
 
 
@@ -416,6 +422,22 @@ get_signaling_ip(struct sip_msg* msg)
     return value.s;
 }
 
+// Get SIP application type
+static str
+get_sip_application(struct sip_msg* msg)
+{
+    int_str value;
+
+    if (!search_first_avp(sip_application_avp.type | AVP_VAL_STR,
+                          sip_application_avp.name, &value, NULL) ||
+        !value.s.s || value.s.len==0) {
+
+        value.s.s = "audio";
+        value.s.len = strlen(value.s.s);
+    }
+
+    return value.s;
+}
 
 static str
 get_diverter(struct sip_msg *msg)
@@ -534,6 +556,7 @@ get_call_info(struct sip_msg *msg, CallControlAction action)
         call_info.ruri = get_canonical_request_uri(msg);
         call_info.diverter = get_diverter(msg);
         call_info.source_ip = get_signaling_ip(msg);
+        call_info.sip_application = get_sip_application(msg);
     }
 
     call_info.action = action;
@@ -604,13 +627,15 @@ make_default_request(CallInfo *call)
                        "callid: %.*s\r\n"
                        "from: %.*s\r\n"
                        "fromtag: %.*s\r\n"
+                       "application: %.*s\r\n"
                        "\r\n",
                        call->ruri.len, call->ruri.s,
                        call->diverter.len, call->diverter.s,
                        call->source_ip.len, call->source_ip.s,
                        call->callid.len, call->callid.s,
                        call->from.len, call->from.s,
-                       call->from_tag.len, call->from_tag.s);
+                       call->from_tag.len, call->from_tag.s,
+                       call->sip_application.len, call->sip_application.s);
 
         if (len >= sizeof(request)) {
             LOG(L_ERR, "callcontrol request is longer than %ld bytes\n", (unsigned long)sizeof(request));
@@ -1073,6 +1098,21 @@ mod_init(void)
         return -1;
     }
 
+    // initialize the sip_application_avp structure
+    if (sip_application_avp.spec.s==NULL || *(sip_application_avp.spec.s)==0) {
+        LOG(L_ERR, "missing/empty sip_application_avp parameter. using default.\n");
+        sip_application_avp.spec.s = SIP_APPLICATION_AVP_SPEC;
+    }
+    sip_application_avp.spec.len = strlen(sip_application_avp.spec.s);
+    if (pv_parse_spec(&(sip_application_avp.spec), &avp_spec)==0 || avp_spec.type!=PVT_AVP) {
+        LOG(L_CRIT, "invalid AVP specification for sip_application_avp: `%s'\n", sip_application_avp.spec.s);
+        return -1;
+    }
+    if (pv_get_avp_name(0, &(avp_spec.pvp), &(sip_application_avp.name), &(sip_application_avp.type))!=0) {
+        LOG(L_CRIT, "invalid AVP specification for sip_application_avp: `%s'\n", sip_application_avp.spec.s);
+        return -1;
+    }
+
     // bind to the dialog API
     if (load_dlg_api(&dlg_api)!=0) {
         LOG(L_CRIT, "cannot load the dialog module API\n");