Adding function for checking existence/getting all tube names from client

queue.tube('name') checks for existence and returns true/false
queue.tube()       returnts all available queues

closes gh-58

Author: bigbes

.gitignore

@@ -1,4 +1,3 @@
-*~
 t/var
 VERSION
 # cmake
@@ -10,3 +9,10 @@ Makefile
 # ctest
 Testing
 CTestTestfile.cmake
+# tarantool garbage
+*.snap
+*.xlog
+*.vylog
+# vim
+*~
+.*.swp

queue/abstract.lua

@@ -9,7 +9,23 @@ local str_type = require('queue.compat').str_type
 local session = box.session
 
 local queue = {
-    tube = {},
+    tube = setmetatable({}, {
+        __call = function(self, tube_name)
+            if tube_name and type(tube_name) ~= 'string' then
+                error('argument #1 should be string or nil')
+            end
+            -- return all names of tubes
+            if tube_name == nil then
+                local rv = {}
+                for name, _ in pairs(self) do
+                    table.insert(rv, name)
+                end
+                return rv
+            end
+            -- return true/false if tube name is provided
+            return not (self[tube_name] == nil)
+        end
+    }),
     stat = {}
 }
 local MAX_TIMEOUT      = 365 * 86400 * 100       -- MAX_TIMEOUT == 100 years

t/090-grant-check.t

@@ -1,6 +1,6 @@
 #!/usr/bin/env tarantool
 local test = require('tap').test()
-test:plan(2)
+test:plan(3)
 
 local test_user = 'test'
 local test_pass = '1234'
@@ -111,6 +111,37 @@ test:test('check for call grants', function(test)
     tube:drop()
 end)
 
+test:test('check tube existence', function(test)
+    test:plan(14)
+    local queue = require('queue')
+    test:is(#queue.tube(), 0, 'checking for empty tube list')
+    assert(#queue.tube() == 0)
+
+    local tube1 = queue.create_tube('test1', 'fifo')
+    test:is(#queue.tube(), 1, 'checking for not empty tube list')
+
+    local tube2 = queue.create_tube('test2', 'fifo')
+    test:is(#queue.tube(), 2, 'checking for not empty tube list')
+
+    test:is(queue.tube('test1'), true, 'checking for tube existence')
+    test:is(queue.tube('test2'), true, 'checking for tube existence')
+    test:is(queue.tube('test3'), false, 'checking for tube nonexistence')
+
+    tube2:drop()
+    test:is(#queue.tube(), 1, 'checking for not empty tube list')
+
+    test:is(queue.tube('test1'), true, 'checking for tube existence')
+    test:is(queue.tube('test2'), false, 'checking for tube nonexistence')
+    test:is(queue.tube('test3'), false, 'checking for tube nonexistence')
+
+    tube1:drop()
+    test:is(#queue.tube(), 0, 'checking for empty tube list')
+
+    test:is(queue.tube('test1'), false, 'checking for tube nonexistence')
+    test:is(queue.tube('test2'), false, 'checking for tube nonexistence')
+    test:is(queue.tube('test3'), false, 'checking for tube nonexistence')
+end)
+
 tnt.finish()
 
 os.exit(test:check() == true and 0 or -1)