refactored init.lua

Signed-off-by: Lorenz Herzberger <lorenzherzberger@gmail.com>

planetmint/backend/tarantool/init.lua

@@ -1,5 +1,7 @@
 box.cfg{listen = 3303}
 
+function init()
+    -- ABCI chains
     abci_chains = box.schema.create_space('abci_chains', { if_not_exists = true })
     abci_chains:format({
         { name = 'id', type = 'string' },
@@ -18,7 +20,7 @@ transactions:format({
         { name = 'version', type = 'string' },
         { name = 'metadata', type = 'string' },
         { name = 'assets', type = 'array' },
-    { name = 'inputs', type = 'array', is_nullable = true },
+        { name = 'inputs', type = 'array' },
         { name = 'scripts', type = 'map', is_nullable = true }
     })
     transactions:create_index('id', { parts = {{ field = 'id', type = 'string' }}})
@@ -40,10 +42,10 @@ outputs:format({
         { name = 'public_keys', type = 'array' },
         { name = 'condition', type = 'map' },
         { name = 'output_index', type = 'number' },
-    { name = 'transaction_id' , foreign_key = { space = 'transactions', field = 'id' }}
+        { name = 'transaction_id' , type = 'string' }
     })
     outputs:create_index('id', { parts = {{ field = 'id', type = 'string' }}})
-outputs:create_index('transaction_id', { parts = {{ field = 'id', type = 'string' }}})
+    outputs:create_index('transaction_id', { unique = false, parts = {{ field = 'id', type = 'string' }}})
     outputs:create_index('public_keys', { unique = false, parts = {{field = 'public_keys[*]', type  = 'string' }}})
 
 
@@ -75,7 +77,7 @@ blocks:create_index('block_by_transaction_id', { parts = {{ field = 'transaction
     utxos = box.schema.create_space('utxos', { if_not_exists = true })
     utxos:format({
         { name = 'id', type = 'string' },
-    { name = 'transaction_id', foreign_key = { space = 'transactions', field = 'id' } },
+        { name = 'transaction_id', type = 'string' },
         { name = 'output_index', type = 'unsigned' },
         { name = 'utxo', type = 'map' }
     })
@@ -105,3 +107,92 @@ validator_sets:format({
         { name = 'set', type = 'array' }
     })
     validator_sets:create_index('id', { parts = {{ field = 'id', type = 'string' }}})
+end
+
+function drop()
+    box.space.abci_chains:drop()
+    box.space.blocks:drop()
+    box.space.elections:drop()
+    box.space.pre_commits:drop()
+    box.space.utxos:drop()
+    box.space.validator_sets:drop()
+    box.space.transactions:drop()
+    box.space.outputs:drop()
+end
+
+function indexed_pattern_search(space_name, field_no, pattern)
+    if (box.space[space_name] == nil) then
+        print("Error: Failed to find the specified space")
+        return nil
+    end
+    local index_no = -1
+    for i=0,box.schema.INDEX_MAX,1 do
+        if (box.space[space_name].index[i] == nil) then break end
+        if (box.space[space_name].index[i].type == "TREE"
+            and box.space[space_name].index[i].parts[1].fieldno == field_no
+            and (box.space[space_name].index[i].parts[1].type == "scalar"
+            or box.space[space_name].index[i].parts[1].type == "string")) then
+        index_no = i
+        break
+        end
+    end
+    if (index_no == -1) then
+        print("Error: Failed to find an appropriate index")
+        return nil
+    end
+    local index_search_key = ""
+    local index_search_key_length = 0
+    local last_character = ""
+    local c = ""
+    local c2 = ""
+    for i=1,string.len(pattern),1 do
+        c = string.sub(pattern, i, i)
+        if (last_character ~= "%") then
+        if (c == '^' or c == "$" or c == "(" or c == ")" or c == "."
+                        or c == "[" or c == "]" or c == "*" or c == "+"
+                        or c == "-" or c == "?") then
+            break
+        end
+        if (c == "%") then
+            c2 = string.sub(pattern, i + 1, i + 1)
+            if (string.match(c2, "%p") == nil) then break end
+            index_search_key = index_search_key .. c2
+        else
+            index_search_key = index_search_key .. c
+        end
+        end
+        last_character = c
+    end
+    index_search_key_length = string.len(index_search_key)
+    local result_set = {}
+    local number_of_tuples_in_result_set = 0
+    local previous_tuple_field = ""
+    while true do
+        local number_of_tuples_since_last_yield = 0
+        local is_time_for_a_yield = false
+        for _,tuple in box.space[space_name].index[index_no]:
+        pairs(index_search_key,{iterator = box.index.GE}) do
+        if (string.sub(tuple[field_no], 1, index_search_key_length)
+        > index_search_key) then
+            break
+        end
+        number_of_tuples_since_last_yield = number_of_tuples_since_last_yield + 1
+        if (number_of_tuples_since_last_yield >= 10
+            and tuple[field_no] ~= previous_tuple_field) then
+            index_search_key = tuple[field_no]
+            is_time_for_a_yield = true
+            break
+            end
+        previous_tuple_field = tuple[field_no]
+        if (string.match(tuple[field_no], pattern) ~= nil) then
+            number_of_tuples_in_result_set = number_of_tuples_in_result_set + 1
+            result_set[number_of_tuples_in_result_set] = tuple
+        end
+        end
+        if (is_time_for_a_yield ~= true) then
+        break
+        end
+        require('fiber').yield()
+    end
+    return result_set
+end