[sr-dev] git:master:51505a0f: corex: new function is_faked_msg()

[Daniel-Constantin Mierla]

Module: kamailio
Branch: master
Commit: 51505a0f5eadcdb8ca4aa3108b060802d7a55972
URL: https://github.com/kamailio/kamailio/commit/51505a0f5eadcdb8ca4aa3108b060802d7a55972

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2020-04-16T16:44:17+02:00

corex: new function is_faked_msg()

- return 1 (native cfg true) if the message under processing is faked (a
static sip message structure used internally by kamailio)
- return -1 (native cfg false) if it is a received sip message
- useful for checking in event routes or async route blocks when can be
both types of messages

---

Modified: src/modules/corex/corex_mod.c

---

Diff:  https://github.com/kamailio/kamailio/commit/51505a0f5eadcdb8ca4aa3108b060802d7a55972.diff
Patch: https://github.com/kamailio/kamailio/commit/51505a0f5eadcdb8ca4aa3108b060802d7a55972.patch

---

diff --git a/src/modules/corex/corex_mod.c b/src/modules/corex/corex_mod.c
index febd97f0f3..e23aae325d 100644
--- a/src/modules/corex/corex_mod.c
+++ b/src/modules/corex/corex_mod.c
@@ -29,6 +29,7 @@
 #include "../../core/resolve.h"
 #include "../../core/lvalue.h"
 #include "../../core/pvar.h"
+#include "../../core/fmsg.h"
 #include "../../core/kemi.h"
 #include "../../core/parser/parse_uri.h"
 
@@ -61,6 +62,7 @@ static int w_set_source_address(sip_msg_t *msg, char *paddr, char *p2);
 static int w_via_add_srvid(sip_msg_t *msg, char *pflags, char *p2);
 static int w_via_add_xavp_params(sip_msg_t *msg, char *pflags, char *p2);
 static int w_via_use_xavp_fields(sip_msg_t *msg, char *pflags, char *p2);
+static int w_is_faked_msg(sip_msg_t *msg, char *p1, char *p2);
 
 static int fixup_file_op(void** param, int param_no);
 
@@ -130,6 +132,8 @@ static cmd_export_t cmds[]={
 		0, ANY_ROUTE },
 	{"via_use_xavp_fields", (cmd_function)w_via_use_xavp_fields, 1, fixup_igp_null,
 		0, ANY_ROUTE },
+	{"is_faked_msg", (cmd_function)w_is_faked_msg, 0, 0,
+		0, ANY_ROUTE },
 
 	{0, 0, 0, 0, 0, 0}
 };
@@ -927,6 +931,28 @@ static int ki_has_user_agent(sip_msg_t *msg)
 	return -1;
 }
 
+/**
+ *
+ */
+static int ki_is_faked_msg(sip_msg_t *msg)
+{
+	if(faked_msg_match(msg)) {
+		return 1;
+	}
+	return -1;
+}
+
+/**
+ *
+ */
+static int w_is_faked_msg(sip_msg_t *msg, char *p1, char *p2)
+{
+	if(faked_msg_match(msg)) {
+		return 1;
+	}
+	return -1;
+}
+
 /**
  *
  */
@@ -1022,6 +1048,11 @@ static sr_kemi_t sr_kemi_corex_exports[] = {
 		{ SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_STR,
 			SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE }
 	},
+	{ str_init("corex"), str_init("is_faked_msg"),
+		SR_KEMIP_INT, ki_is_faked_msg,
+		{ SR_KEMIP_NONE, 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 } }
 };