Function dbconsumer_getargs

lua/sp.c:755–796

}

static void dbconsumer_getargs(Lua L, dbconsumer_t *consumer)
{
    luaL_checktype(L, -1, LUA_TTABLE);
    lua_pushnil(L);
    while (lua_next(L, -2)) {
        const char *key;
        int type = luabb_type(L, -2);
        if (type == DBTYPES_LSTRING || type == DBTYPES_CSTRING) {
            key = luabb_tostring(L, -2);
            if (strcasecmp(key, "with_tid") == 0) {
                if (luabb_type(L, -1) == DBTYPES_LBOOLEAN) {
                    consumer->push_tid = lua_toboolean(L, -1);
                } else {
                    luaL_error(L, "bad argument for 'with_tid'");
                    return;
                }
            } else if (strcasecmp(key, "with_sequence") == 0) {
                if (luabb_type(L, -1) == DBTYPES_LBOOLEAN) {
                    consumer->push_seq = lua_toboolean(L, -1);
                } else {
                    luaL_error(L, "bad argument for 'with_sequence'");
                    return;
                }
            } else if (strcasecmp(key, "with_epoch") == 0) {
                if (luabb_type(L, -1) == DBTYPES_LBOOLEAN) {
                    consumer->push_epoch = lua_toboolean(L, -1);
                } else {
                    luaL_error(L, "bad argument for 'with_epoch'");
                    return;
                }
            } else if (strcasecmp(key, "register_timeout") == 0) {
                long long timeoutms = 0;
                luabb_tointeger(L, -1, &timeoutms);
                if (timeoutms > 0) {
                    consumer->register_timeoutms = timeoutms;
                }
            }
        }
        lua_pop(L, 1);
    }
    lua_pop(L, 1);
}

static int dbconsumer_get(Lua L)
{