Tarantool development patches archive
 help / color / mirror / Atom feed
From: Olga Arkhangelskaia <arkholga@tarantool.org>
To: tarantool-patches@dev.tarantool.org
Subject: [Tarantool-patches] [PATCH rfc] lua: expose luaL_serializer to Lua
Date: Tue,  4 Feb 2020 12:00:17 +0300	[thread overview]
Message-ID: <20200204090017.97814-1-arkholga@tarantool.org> (raw)

There are several modules in Lua allowing to transform data from one format to
another (yaml, msgpack, json). They are configured via cfg method. The options
are parts of struct luaL_serializer object in C. That method used to be
implemented via additional table on Lua stack and overriden __call metamethod.
Such implementation had hudge shortcoming: any field could be
changed/added via raw modification. And such change was not visible for
tarantool.
To leave the only one source of information/configuration possibility cfg table
was changed to userdata with index, newindex, pairs, call and serialize
metamethods. And the interface was remained unchanged.
Closes #4521
---
Branch: https://github.com/tarantool/tarantool/tree/OKriw/gh-4521-lua-serializers-should-use-FFI-to-check-and-set-options
 src/lua/utils.c | 193 +++++++++++++++++++++++++++++++++++++++---------
 1 file changed, 160 insertions(+), 33 deletions(-)

diff --git a/src/lua/utils.c b/src/lua/utils.c
index de14c778c..7bb6966b7 100644
--- a/src/lua/utils.c
+++ b/src/lua/utils.c
@@ -311,34 +311,171 @@ luaL_serializer_parse_options(struct lua_State *L,
 }
 
 /**
- * @brief serializer.cfg{} Lua binding for serializers.
- * serializer.cfg is a table that contains current configuration values from
- * luaL_serializer structure. serializer.cfg has overriden __call() method
- * to change configuration keys in internal userdata (like box.cfg{}).
- * Please note that direct change in serializer.cfg.key will not affect
- * internal state of userdata. Changes via cfg() are reflected in
- * both Lua cfg table, and C serializer structure.
+ * @brief serializer.cfg() Lua binding for serializers.
+ * serializer.cfg is a userdata that contains pointer to struct luaL_serializer.
+ * It has __call metamethod, that directly updates  internal state of userdata.
  * @param L lua stack
  * @return 0
  */
 static int
 luaL_serializer_cfg(struct lua_State *L)
 {
-	/* Serializer.cfg */
-	luaL_checktype(L, 1, LUA_TTABLE);
 	/* Updated parameters. */
 	luaL_checktype(L, 2, LUA_TTABLE);
 	struct luaL_serializer *cfg = luaL_checkserializer(L);
 	for (int i = 0; OPTIONS[i].name != NULL; ++i) {
-		if (luaL_serializer_parse_option(L, i, cfg) == NULL)
+		if(luaL_serializer_parse_option(L, i, cfg) == NULL)
 			lua_pop(L, 1);
-		else
-			lua_setfield(L, 1, OPTIONS[i].name);
-	}
+        }
 	trigger_run(&cfg->on_update, cfg);
 	return 0;
 }
 
+/**
+ * @brief __serialize metamethod for serializer.cfg.
+ * Converts userdata to table for console output.
+ * @param L lua stack
+ * @return 0
+ */
+static int
+luaL_serialize_info(lua_State *L)
+{
+    struct luaL_serializer *cfg =  lua_touserdata(L, lua_upvalueindex(1));
+    lua_newtable(L);
+    for(int i = 0; OPTIONS[i].name != NULL; i++){
+        lua_pushstring(L, OPTIONS[i].name);
+        int *pval = (int *) ((char *) cfg + OPTIONS[i].offset);
+        switch (OPTIONS[i].type) {
+        case LUA_TBOOLEAN:
+            lua_pushboolean(L, *pval);
+            break;
+        case LUA_TNUMBER:
+            lua_pushnumber(L, *pval);
+            break;
+        }
+        lua_settable(L, -3);
+    }
+	return 1;
+}
+
+static int
+luaL_serializer_name_to_pos(const char *name)
+{
+	if (name == NULL)
+		return -1;
+	for(int i = 0; OPTIONS[i].name != NULL; i++) {
+		if(strcmp(OPTIONS[i].name, name) == 0) {
+			return i;
+		}
+	}
+	return -2;
+}
+
+/**
+ * @brief __index metamethod for serializer.cfg.
+ * @param L lua stack
+ * @return 0
+ */
+static int
+luaL_serializer_cfg_index(lua_State *L)
+{
+	struct luaL_serializer *cfg = luaL_checkserializer(L);
+	const char* name = lua_tostring(L, 2);
+	int i = luaL_serializer_name_to_pos(name);
+	if (i > -1) {
+		int *pval = (int *) ((char *) cfg + OPTIONS[i].offset);
+		switch (OPTIONS[i].type){
+		case LUA_TBOOLEAN:
+			lua_pushboolean(L, *pval);
+			break;
+		case LUA_TNUMBER:
+			lua_pushnumber(L, *pval);
+			break;
+		}
+	} else  if (strcmp(name, "__serialize") == 0) {
+			lua_pushlightuserdata(L, cfg);
+			lua_pushcclosure(L, luaL_serialize_info, 1);
+			return 1;
+	} else {
+			lua_pushnil(L);
+			return 1;
+	}
+	return 1;
+}
+
+/**
+ * @brief __newindex metamethod for serializer.cfg.
+ * protects serializer.cfg fro, row modification.
+ * @param L lua stack
+ * @return 0
+ */
+static int
+luaL_serializer_cfg_newindex(lua_State *L)
+{
+	luaL_error(L, "incorrect way of setting configuration, please use cfg()");
+	printf("__newindex \n");
+	return 1;
+}
+
+/**
+ * @brief lua_next for userdata.
+ * @param L lua stack
+ * @return 0
+ */
+static int
+luaL_serializer_next(lua_State *L)
+{
+	luaL_checktype(L, 1, LUA_TLIGHTUSERDATA);
+	struct luaL_serializer *cfg = (struct luaL_serializer*)lua_touserdata(L, 1);
+	const char *name = lua_tostring(L, 2);
+	int j = luaL_serializer_name_to_pos(name);
+	if (j > -2 && OPTIONS[j+1].name != NULL) {
+		lua_pushstring(L, OPTIONS[j+1].name);
+		int *pval = (int *) ((char *) cfg + OPTIONS[j+1].offset);
+		switch (OPTIONS[j+1].type){
+		case LUA_TBOOLEAN:
+			lua_pushboolean(L, *pval);
+			break;
+		case LUA_TNUMBER:
+			lua_pushnumber(L, *pval);
+			break;
+		}
+		return 2;
+	} else
+		lua_pushnil(L);
+	return 1;
+}
+
+/**
+ * @brief __pairs metamethod for serializer.cfg.
+ * Traverses userdata like a table.
+ * @param L lua stack
+ * @return 0
+ */
+static int
+luaL_serializer_cfg_pairs(lua_State *L)
+{
+	struct luaL_serializer *cfg = luaL_checkserializer(L);
+	lua_pushcfunction(L, luaL_serializer_next);
+	lua_pushlightuserdata(L, cfg);
+	lua_pushstring(L, NULL);
+	return 3;
+}
+
+/**
+ * To get configure/change/get setting of serializer
+ * we directly write to struct luaL_serializer using
+ * userdata and  metatable desctibed here.
+ */
+static const luaL_Reg serializermeta[] = {
+        {"__serialize", luaL_serialize_info},
+        {"__index",luaL_serializer_cfg_index},
+        {"__newindex",luaL_serializer_cfg_newindex},
+        {"__call", luaL_serializer_cfg},
+	{"__pairs", luaL_serializer_cfg_pairs},
+		{NULL, NULL},
+	};
+
 /**
  * @brief serializer.new() Lua binding.
  * @param L stack
@@ -369,28 +506,17 @@ luaL_newserializer(struct lua_State *L, const char *modname, const luaL_Reg *reg
 		lua_setfield(L, -3, reg->name);
 	}
 
-	/* Add cfg{} */
+	/* Add cfg userdata with pointer */
+	lua_newuserdata(L, sizeof(*serializer));
+	/* Add cfg methods */
 	lua_newtable(L); /* cfg */
-	lua_newtable(L); /* metatable */
-	lua_pushvalue(L, -3); /* luaL_serializer */
-	lua_pushcclosure(L, luaL_serializer_cfg, 1);
-	lua_setfield(L, -2, "__call");
-	lua_setmetatable(L, -2);
-	/* Save configuration values to serializer.cfg */
-	for (int i = 0; OPTIONS[i].name != NULL; i++) {
-		int *pval = (int *) ((char *) serializer + OPTIONS[i].offset);
-		switch (OPTIONS[i].type) {
-		case LUA_TBOOLEAN:
-			lua_pushboolean(L, *pval);
-			break;
-		case LUA_TNUMBER:
-			lua_pushinteger(L, *pval);
-			break;
-		default:
-			unreachable();
-		}
-		lua_setfield(L, -2, OPTIONS[i].name);
+	const luaL_Reg *ser_info = serializermeta;
+	for (; ser_info->name != NULL; ser_info++) {
+		lua_pushvalue(L, -3);
+		lua_pushcclosure(L, ser_info->func, 1);
+		lua_setfield(L, -2, ser_info->name);
 	}
+	lua_setmetatable(L, -2);
 	lua_setfield(L, -3, "cfg");
 
 	lua_pop(L, 1);  /* remove upvalues */
@@ -421,6 +547,7 @@ lua_gettable_wrapper(lua_State *L)
 	return 1;
 }
 
+
 static void
 lua_field_inspect_ucdata(struct lua_State *L, struct luaL_serializer *cfg,
 			int idx, struct luaL_field *field)
-- 
2.20.1 (Apple Git-117)

             reply	other threads:[~2020-02-04  9:00 UTC|newest]

Thread overview: 2+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2020-02-04  9:00 Olga Arkhangelskaia [this message]
2020-02-20 11:23 ` Igor Munkin

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=20200204090017.97814-1-arkholga@tarantool.org \
    --to=arkholga@tarantool.org \
    --cc=tarantool-patches@dev.tarantool.org \
    --subject='Re: [Tarantool-patches] [PATCH rfc] lua: expose luaL_serializer to Lua' \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox