Fixing register driver and wrote test for it

+ fix ttl test for vinyl

Author: bigbes

queue/init.lua

@@ -1,18 +1,31 @@
-local function index_unconfigured()
-    error("Please run box.cfg{} first")
-end
-
-local queue = {}
-setmetatable(queue, { __index = index_unconfigured })
+local queue = nil
+queue = setmetatable({
+    driver = {},
+    register_driver = function(driver_name, tube_ctr)
+        if type(tube_ctr.create_space) ~= 'function' or
+           type(tube_ctr.new) ~= 'function' then
+            error('tube control methods must contain functions "create_space" and "new"')
+        end
+        queue.driver[driver_name] = tube_ctr
+    end,
+}, { __index = function() print(debug.traceback()) error("Please run box.cfg{} first") end })
 
 if rawget(box, 'space') == nil then
     local orig_cfg = box.cfg
     box.cfg = function(...)
         local result = { orig_cfg(...) }
 
         local abstract = require 'queue.abstract'
-        for k, v in pairs(abstract) do
-            rawset(queue, k, v)
+        for name, val in pairs(abstract) do
+            if name == 'driver' then
+                for driver_name, driver in pairs(queue.driver) do
+                    if abstract.driver[driver_name] then
+                        error(('overriding default driver "%s"'):format(driver_name))
+                    end
+                    abstract.driver[driver_name] = driver
+                end
+            end
+            rawset(queue, name, val)
         end
         setmetatable(queue, getmetatable(abstract))
         queue.start()

t/001-tube-init.t

@@ -0,0 +1,27 @@
+#!/usr/bin/env tarantool
+local yaml  = require('yaml')
+local fiber = require('fiber')
+
+local tnt  = require('t.tnt')
+
+local test = require('tap').test()
+test:plan(1)
+
+local engine = os.getenv('ENGINE') or 'memtx'
+
+local mock_tube = { create_space = function() end, new = function() end }
+
+test:test('test queue mock addition', function(test)
+    test:plan(2)
+
+    local queue = require('queue')
+    queue.register_driver('mock', mock_tube)
+    test:is(queue.driver.mock, mock_tube)
+    tnt.cfg{}
+
+    test:is(queue.driver.mock, mock_tube)
+end)
+
+tnt.finish()
+os.exit(test:check() == true and 0 or -1)
+-- vim: set ft=lua :

t/050-ttl.t

@@ -6,13 +6,13 @@ test:plan(5)
 
 local queue = require('queue')
 
+local engine = os.getenv('ENGINE') or 'memtx'
+
 local tnt = require('t.tnt')
 tnt.cfg{
-    wal_mode = 'none'
+    wal_mode = (engine == 'memtx' and 'none' or nil)
 }
 
-local engine = os.getenv('ENGINE') or 'memtx'
-
 local ttl = 0.1
 
 test:ok(queue, 'queue is loaded')