Function RedisProtocolToLuaTypeAggregate

src/storage/scripting.cc:1157–1197

}

const char *RedisProtocolToLuaTypeAggregate(lua_State *lua, const char *reply, int atype) {
  const char *p = strchr(reply + 1, '\r');
  int64_t mbulklen = ParseInt<int64_t>(std::string(reply + 1, p - reply - 1), 10).ValueOr(0);
  int j = 0;

  p += 2;
  if (mbulklen == -1) {
    lua_pushboolean(lua, 0);
    return p;
  }
  if (atype == '*') {
    lua_newtable(lua);
    for (j = 0; j < mbulklen; j++) {
      lua_pushnumber(lua, j + 1);
      p = RedisProtocolToLuaType(lua, p);
      lua_settable(lua, -3);
    }
    return p;
  }

  CHECK(atype == '%' || atype == '~');
  if (atype == '%' || atype == '~') {
    lua_newtable(lua);
    lua_pushstring(lua, atype == '%' ? "map" : "set");
    lua_newtable(lua);
    for (j = 0; j < mbulklen; j++) {
      p = RedisProtocolToLuaType(lua, p);
      if (atype == '%') {  // map
        p = RedisProtocolToLuaType(lua, p);
      } else {  // set
        lua_pushboolean(lua, 1);
      }
      lua_settable(lua, -3);
    }
    lua_settable(lua, -3);
    return p;
  }

  // Unreachable, return the original position if it did reach here.
  return reply;
}

const char *RedisProtocolToLuaTypeNull(lua_State *lua, const char *reply) {
  const char *p = strchr(reply + 1, '\r');