uac: added uac_event_callback for kemi

src/modules/uac/doc/uac_admin.xml

@@ -593,6 +593,38 @@ modparam("uac", "reg_gc_interval", 60)
 		</example>
 	</section>
 
+	<section id="uac.p.event_callback">
+		<title><varname>event_callback</varname> (str)</title>
+		<para>
+			The name of the function in the kemi configuration file (embedded
+			scripting language such as Lua, Python, ...) to be executed instead
+			of event_route[uac:reply] block.
+		</para>
+		<para>
+			The function receives a string parameter with the name of the event,
+			the value can be: 'uac:reply'.
+		</para>
+		<para>
+		<emphasis>
+			Default value is 'empty' (no function is executed for events).
+		</emphasis>
+		</para>
+		<example>
+		<title>Set <varname>event_callback</varname> parameter</title>
+ <programlisting format="linespecific">
+ ...
+modparam("uac", "event_callback", "ksr_uac_event")
+
+function ksr_uac_event(evname)
+	KSR.info("===== uac module triggered event: " .. evname .. "\n");
+	return 1;
+end
+ ...
+ </programlisting>
+		</example>
+	</section>
+  
+  
 	</section>
 
 	<section>

src/modules/uac/uac.c

@@ -93,6 +93,8 @@ pv_spec_t auth_password_spec;
 str uac_default_socket = STR_NULL;
 struct socket_info * uac_default_sockinfo = NULL;
 
+str uac_event_callback = STR_NULL;
+
 static int w_replace_from(struct sip_msg* msg, char* p1, char* p2);
 static int w_restore_from(struct sip_msg* msg, char* p1, char* p2);
 static int w_replace_to(struct sip_msg* msg, char* p1, char* p2);
@@ -178,6 +180,7 @@ static param_export_t params[] = {
 	{"reg_active",	INT_PARAM,			&reg_active_param      },
 	{"reg_gc_interval",		INT_PARAM,	&_uac_reg_gc_interval	},
 	{"default_socket",	PARAM_STR, &uac_default_socket},
+	{"event_callback",	PARAM_STR,	&uac_event_callback},
 	{0, 0, 0}
 };
 

src/modules/uac/uac_send.c

@@ -36,6 +36,7 @@
 #include "../../core/parser/parse_to.h"
 #include "../../core/parser/contact/parse_contact.h"
 #include "../../core/fmsg.h"
+#include "../../core/kemi.h"
 
 #include "auth.h"
 #include "auth_hdr.h"
@@ -82,6 +83,8 @@ typedef struct _uac_send_info {
 
 static struct _uac_send_info _uac_req;
 
+extern str uac_event_callback;
+
 void uac_send_info_copy(uac_send_info_t *src, uac_send_info_t *dst)
 {
 	memcpy(dst, src, sizeof(uac_send_info_t));
@@ -630,12 +633,27 @@ void uac_req_run_event_route(sip_msg_t *msg, uac_send_info_t *tp, int rcode)
 	int rt, backup_rt;
 	struct run_act_ctx ctx;
 	sip_msg_t *fmsg;
+	sr_kemi_eng_t *keng = NULL;
+	int kemi_evroute = 0;
+
+	if(uac_event_callback.s!=NULL && uac_event_callback.len>0) {
+		keng = sr_kemi_eng_get();
+		if(keng==NULL) {
+			LM_DBG("event callback (%s) set, but no cfg engine\n",
+					uac_event_callback.s);
+			return;
+		} else {
+			kemi_evroute = 1;
+		}
+	}
 
-	rt = route_get(&event_rt, evrtname);
-	if (rt < 0 || event_rt.rlist[rt] == NULL)
-	{
-		LM_DBG("event_route[uac:reply] does not exist\n");
-		return;
+	if (kemi_evroute==0) {
+		rt = route_get(&event_rt, evrtname);
+		if (rt < 0 || event_rt.rlist[rt] == NULL)
+		{
+			LM_DBG("event_route[uac:reply] does not exist\n");
+			return;
+		}
 	}
 
 	uac_send_info_copy(tp, &_uac_req);
@@ -652,7 +670,17 @@ void uac_req_run_event_route(sip_msg_t *msg, uac_send_info_t *tp, int rcode)
 	backup_rt = get_route_type();
 	set_route_type(REQUEST_ROUTE);
 	init_run_actions_ctx(&ctx);
-	run_top_route(event_rt.rlist[rt], fmsg, 0);
+
+	if (kemi_evroute==1) {
+		str evrtname = str_init("uac:reply");
+
+		if(sr_kemi_route(keng, fmsg, EVENT_ROUTE,
+					&uac_event_callback, &evrtname)<0) {
+			LM_ERR("error running event route kemi callback\n");
+		}
+	} else {
+		run_top_route(event_rt.rlist[rt], fmsg, 0);
+	}
 	set_route_type(backup_rt);
 }