test: add initial version of a single instance list-append

test/tarantool/single_instance_list_append_test.lua

@@ -0,0 +1,141 @@
+local fio = require('fio')
+local log = require('log')
+local math = require('math')
+local molly = require('molly')
+
+local runner = molly.runner
+local client = molly.client
+local tests = molly.tests
+
+log.info('Tarantool version:', require('tarantool').version)
+
+local TEST_DIR = fio.abspath('./tarantool_test_dir')
+local SPACE_NAME = 'list_append'
+
+local KEY_COUNT= 3
+local MIN_TXN_LEN = 1
+local MAX_TXN_LEN = 2
+local MAX_WRITES_PER_KEY = 5
+
+local function rmtree(path)
+    log.info('CLEANUP %s', path)
+    if (fio.path.is_file(path) or fio.path.is_link(path)) then
+        fio.unlink(path)
+        return
+    end
+    if fio.path.is_dir(path) then
+        for _, p in pairs(fio.listdir(path)) do
+            rmtree(fio.pathjoin(path, p))
+        end
+    end
+end
+
+local function cleanup_dir(dir)
+    log.info('CLEANUP')
+    if dir ~= nil then
+        rmtree(dir)
+        dir = nil -- luacheck: ignore
+    end
+end
+
+if fio.path.exists(TEST_DIR) then
+    cleanup_dir(TEST_DIR)
+else
+    fio.mkdir(TEST_DIR)
+end
+
+local box_cfg_options = {
+    feedback_enabled = false,
+    log_level = 'verbose',
+    memtx_use_mvcc_engine = true,
+    read_only = false,
+    work_dir = TEST_DIR,
+}
+
+if type(box.cfg) ~= 'table' then
+    box.cfg(box_cfg_options)
+end
+
+local tarantool_list_append = molly.client.new()
+
+tarantool_list_append.open = function(self, _addr)
+    rawset(self, 'conn', box)
+    return true
+end
+
+local function assert_ping(conn)
+    assert(conn)
+end
+
+tarantool_list_append.setup = function(self)
+    assert_ping(self.conn)
+    if self.conn.space[SPACE_NAME] then
+        return
+    end
+
+    local space = self.conn.schema.create_space(SPACE_NAME)
+    assert(space ~= nil)
+    space:format({
+        { 'key', type = 'number' },
+        { 'list', type = 'array' },
+    })
+    space:create_index('pk')
+    return true
+end
+
+local IDX_MOP_TYPE = 1
+local IDX_MOP_KEY = 2
+local IDX_MOP_VAL = 3
+
+tarantool_list_append.invoke = function(self, op)
+    local mop = op.value[1] -- TODO: Support more than one mop in operation.
+    local mop_key = mop[IDX_MOP_KEY]
+    local type = 'ok'
+    if mop[IDX_MOP_TYPE] == 'r' then
+        local space = self.conn.space[SPACE_NAME]
+        mop[IDX_MOP_VAL] = space:select(mop_key, {timeout = 5, limit = 1})
+    elseif mop[IDX_MOP_TYPE] == 'append' then
+        local space = self.conn.space[SPACE_NAME]
+		space:update(mop_key, {{'!', '[2][1]', mop[IDX_MOP_VAL]}})
+    end
+
+    return {
+        value = { mop },
+        f = op.f,
+        process = op.process,
+        type = type,
+    }
+end
+
+tarantool_list_append.teardown = function(self)
+    return true
+end
+
+tarantool_list_append.close = function(self)
+    return true
+end
+
+local test_options = {
+    create_reports = true,
+    threads = 1,
+    nodes = {
+        '127.0.0.1:3301',
+    },
+}
+
+local ok, err = runner.run_test({
+    client = tarantool_list_append,
+    create_reports = true,
+    generator = tests.list_append_gen({
+        key_count = KEY_COUNT,
+        min_txn_len = MIN_TXN_LEN,
+        max_txn_len = MAX_TXN_LEN,
+        max_writes_per_key = MAX_WRITES_PER_KEY,
+	}):take(100),
+}, test_options)
+
+if err then
+    log.info(err)
+end
+
+os.exit(ok and 0 or 1)