[sr-dev] git:master:d0436602: core: foundation for config interpreter engine via kemi

[Daniel-Constantin Mierla]

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

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2016-04-12T12:21:56+02:00

core: foundation for config interpreter engine via kemi

- to allow execution of a config file written in an embedded language

---

Modified: kemi.c
Modified: kemi.h

---

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

---

diff --git a/kemi.c b/kemi.c
index 305d066..22f55c0 100644
--- a/kemi.c
+++ b/kemi.c
@@ -145,3 +145,71 @@ sr_kemi_t* sr_kemi_lookup(str *mname, int midx, str *fname)
 	}
 	return NULL;
 }
+
+/**
+ *
+ */
+
+#define SR_KEMI_ENG_LIST_MAX_SIZE	8
+static sr_kemi_eng_t _sr_kemi_eng_list[SR_KEMI_ENG_LIST_MAX_SIZE];
+sr_kemi_eng_t *_sr_kemi_eng = NULL;
+static int _sr_kemi_eng_list_size=0;
+
+/**
+ *
+ */
+int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute)
+{
+	int i;
+
+	for(i=0; i<_sr_kemi_eng_list_size; i++) {
+		if(_sr_kemi_eng_list[i].ename.len==ename->len
+				&& strncasecmp(_sr_kemi_eng_list[i].ename.s, ename->s,
+					ename->len)==0) {
+			/* found */
+			return 1;
+		}
+	}
+	if(_sr_kemi_eng_list_size>=SR_KEMI_ENG_LIST_MAX_SIZE) {
+		LM_ERR("too many config routing engines registered\n");
+		return -1;
+	}
+	if(ename->len>=SR_KEMI_BNAME_SIZE) {
+		LM_ERR("config routing engine name too long\n");
+		return -1;
+	}
+	strncpy(_sr_kemi_eng_list[_sr_kemi_eng_list_size].bname,
+			ename->s, ename->len);
+	_sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.s
+			= _sr_kemi_eng_list[_sr_kemi_eng_list_size].bname;
+	_sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.len = ename->len;
+	_sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.s[ename->len] = 0;
+	_sr_kemi_eng_list[_sr_kemi_eng_list_size].froute = froute;
+	_sr_kemi_eng_list_size++;
+
+	return 0;
+}
+
+/**
+ *
+ */
+int sr_kemi_eng_set(str *ename, str *cpath)
+{
+	int i;
+
+	for(i=0; i<_sr_kemi_eng_list_size; i++) {
+		if(_sr_kemi_eng_list[i].ename.len==ename->len
+				&& strncasecmp(_sr_kemi_eng_list[i].ename.s, ename->s,
+					ename->len)==0) {
+			/* found */
+			_sr_kemi_eng = &_sr_kemi_eng_list[i];
+			return 0;
+		}
+	}
+	return -1;
+}
+
+sr_kemi_eng_t* sr_kemi_eng_get(void)
+{
+	return _sr_kemi_eng;
+}
diff --git a/kemi.h b/kemi.h
index 45b98a2..c0087c6 100644
--- a/kemi.h
+++ b/kemi.h
@@ -89,4 +89,17 @@ int sr_kemi_modules_add(sr_kemi_t *klist);
 int sr_kemi_modules_size_get(void);
 sr_kemi_module_t* sr_kemi_modules_get(void);
 
+typedef int (*sr_kemi_eng_route_f)(sip_msg_t*, int, str *);
+
+#define SR_KEMI_BNAME_SIZE	256
+typedef struct sr_kemi_eng {
+	char bname[SR_KEMI_BNAME_SIZE];
+	str  ename;
+	sr_kemi_eng_route_f froute;
+} sr_kemi_eng_t;
+
+int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute);
+int sr_kemi_eng_set(str *ename, str *cpath);
+sr_kemi_eng_t* sr_kemi_eng_get(void);
+
 #endif