* Closes #8.

Author: Khatskevich

README.md

@@ -97,7 +97,8 @@ make test
 
 * For use: tarantool, lulpeg, >=tarantool/shard-1.1-91-gfa88bf8 (optional),
   tarantool/avro-schema.
-* For test (additionally to 'for use'): python 2.7, virtualenv, luacheck.
+* For test (additionally to 'for use'): python 2.7, virtualenv, luacheck,
+  >=tarantool/shard-1.1-92-gec1a27e.
 * For building apidoc (additionally to 'for use'): ldoc.
 
 ## License

graphql/accessor_general.lua

@@ -47,9 +47,16 @@ local function shouldIncludeNode(selection, context)
 end
 
 local function doesFragmentApply(fragment, type, context)
+
+  --print('print from doesFragmentApply - 51')
+  --print('fragment')
+  --require('pl.pretty').dump(fragment)
+
   if not fragment.typeCondition then return true end
 
   local innerType = typeFromAST(fragment.typeCondition, context.schema)
+  --print('innerType')
+  --require('pl.pretty').dump(innerType)
 
   if innerType == type then
     return true
@@ -156,6 +163,13 @@ local function completeValue(fieldType, result, subSelections, context)
     local completedResult = completeValue(innerType, result, subSelections, context)
 
     if completedResult == nil then
+        --@todo remove comments
+      --print('print from completeValue')
+      --print('result')
+      --require('pl.pretty').dump(result)
+      --print('fieldType')
+      --require('pl.pretty').dump(fieldType)
+
       error('No value provided for non-null ' .. (innerType.name or innerType.__type))
     end
 
@@ -175,6 +189,15 @@ local function completeValue(fieldType, result, subSelections, context)
 
     local values = {}
     for i, value in ipairs(result) do
+        --@todo remove comments
+      --print('print for ipairs(result) 195')
+      --require('pl.pretty').dump(result)
+      --print('value')
+      --require('pl.pretty').dump(value)
+      --print('subSelections')
+      --require('pl.pretty').dump(subSelections)
+
+
       values[i] = completeValue(innerType, value, subSelections, context)
     end
 
@@ -200,6 +223,11 @@ local function getFieldEntry(objectType, object, fields, context)
   local firstField = fields[1]
   local fieldName = firstField.name.value
   local responseKey = getFieldResponseKey(firstField)
+  --print('print from getFieldEntry')
+  --print('objectType')
+  --require('pl.pretty').dump(objectType)
+  --print('object itself')
+  --require('pl.pretty').dump(object)
   local fieldType = introspection.fieldMap[fieldName] or objectType.fields[fieldName]
 
   if fieldType == nil then
@@ -236,6 +264,16 @@ local function getFieldEntry(objectType, object, fields, context)
 end
 
 evaluateSelections = function(objectType, object, selections, context)
+
+  --@todo remove debug
+  --print('EVALUETE SELECTIONS')
+  ----print('objectType')
+  ----require('pl.pretty').dump(objectType)
+  --print('object')
+  --require('pl.pretty').dump(object)
+  --
+  --print('EVALUETE SELECTIONS CLOSE')
+
   local groupedFieldSet = collectFields(objectType, selections, {}, {}, context)
 
   return util.map(groupedFieldSet, function(fields)

graphql/core/execute.lua

@@ -280,7 +280,7 @@ local convert_simple_connection = function(state, c, collection_name)
         error('unknown connection type: ' .. tostring(c.type))
     end
 
-    local c_list_args = state.list_arguments[c.destination_collection]
+            local c_list_args = state.list_arguments[c.destination_collection]
 
     local field = {
         name = c.name,
@@ -631,6 +631,45 @@ gql_type = function(state, avro_schema, collection, collection_name)
     end
 end
 
+--- Create virtual root collection `Query`, which has connections to any
+--- collection.
+---
+--- Actually, each GQL query starts its execution from the `Query` collection.
+--- That is why it shoult contain connections to any collection.
+---
+--- @tparam table state dictionary which contains all information about the
+--- schema, arguments, types...
+local function create_root_collection(state)
+    local root_connections = {}
+    -- The fake connections have 1:N mechanics.
+    -- Create one connection for each collection.
+    for collection_name, collection in pairs(state.collections) do
+        table.insert(root_connections, {
+            parts = {},
+            name = collection_name,
+            destination_collection = collection_name,
+            type = "1:N"
+        })
+    end
+    local root_schema = {
+        type = "record",
+        name = "Query",
+        -- The fake root has no fields.
+        fields = {}
+    }
+    local root_collection = {
+        name = "Query",
+        connections = root_connections
+    }
+
+    -- `gql_type` is designed to create GQL type corresponding to a real schema
+    -- and connections. However it also works with the fake schema.
+    local root_type = gql_type(state, root_schema, root_collection, "Query")
+    state.schema = schema.create({
+        query = root_type
+    })
+end
+
 local function parse_cfg(cfg)
     local state = {}
     state.types = utils.gen_booking_table({})
@@ -649,8 +688,11 @@ local function parse_cfg(cfg)
     local collections = table.copy(cfg.collections)
     state.collections = collections
 
-    local fields = {}
-
+    -- Prepare types which represents:
+    --  - Avro schemas (collections)
+    --  - scalar field arguments (used to filter objects by value stored in it's
+    --    field)
+    --  - list arguments (offset, limit...)
     for collection_name, collection in pairs(state.collections) do
         collection.name = collection_name
         assert(collection.schema_name ~= nil,
@@ -683,43 +725,9 @@ local function parse_cfg(cfg)
         state.list_arguments[collection_name] = list_args
         state.all_arguments[collection_name] = args
 
-        -- create entry points from collection names
-        fields[collection_name] = {
-            kind = types.nonNull(types.list(state.types[collection_name])),
-            arguments = state.all_arguments[collection_name],
-            resolve = function(rootValue, args_instance, info)
-                local object_args_instance = {} -- passed to 'filter'
-                local list_args_instance = {} -- passed to 'args'
-                for k, v in pairs(args_instance) do
-                    if list_args[k] ~= nil then
-                        list_args_instance[k] = v
-                    elseif state.object_arguments[k] ~= nil then
-                        object_args_instance[k] = v
-                    else
-                        error(('cannot found "%s" field ("%s" value) ' ..
-                            'within allowed fields'):format(tostring(k),
-                            tostring(v)))
-                    end
-                end
-                local from = nil
-
-                local extra = {
-                    qcontext = info.qcontext
-                }
-                return accessor:select(rootValue, collection_name, from,
-                    object_args_instance, list_args_instance, extra)
-            end,
-        }
     end
-
-    local schema = schema.create({
-        query = types.object({
-            name = 'Query',
-            fields = fields,
-        })
-    })
-    state.schema = schema
-
+    -- create fake root `Query` collection
+    create_root_collection(state)
     return state
 end
 

graphql/tarantool_graphql.lua

@@ -30,13 +30,6 @@ end
 
 local function shard_cleanup(test_run, servers)
     test_run:drop_cluster(servers)
-    -- crutch!!
-    -- test_run.lua do not delete servers
-    -- todo: should be removed after #83 is fixed in test-run
-    local drop_cluster_cmd3 = 'delete server %s'
-    for _, name in ipairs(servers) do
-        test_run:cmd(drop_cluster_cmd3:format(name))
-    end
 end
 
 local function for_each_server(shard, func)

test-run

@@ -0,0 +1,72 @@
+#!/usr/bin/env tarantool
+local multirunner = require('multirunner')
+local data = require('test_data_user_order')
+local test_run = require('test_run').new()
+local tap = require('tap')
+local graphql = require('graphql')
+
+box.cfg({})
+local test = tap.test('result cnt')
+test:plan(3)
+
+-- require in-repo version of graphql/ sources despite current working directory
+local fio = require('fio')
+package.path = fio.abspath(debug.getinfo(1).source:match("@?(.*/)")
+    :gsub('/./', '/'):gsub('/+$', '')) .. '/../../?.lua' .. ';' .. package.path
+
+local function run(setup_name, shard)
+    print(setup_name)
+    local accessor_class
+    local virtbox
+    -- SHARD
+    if shard ~= nil then
+        accessor_class = graphql.accessor_shard
+        virtbox = shard
+    else
+        accessor_class = graphql.accessor_space
+        virtbox = box.space
+    end
+    local accessor = accessor_class.new({
+        schemas = data.meta.schemas,
+        collections = data.meta.collections,
+        service_fields = data.meta.service_fields,
+        indexes = data.meta.indexes,
+        timeout_ms = 0.001
+    })
+
+    local gql_wrapper = graphql.new({
+        schemas = data.meta.schemas,
+        collections = data.meta.collections,
+        accessor = accessor,
+    })
+    data.fill_test_data(virtbox)
+    local query = [[
+        query object_result_max {
+            user_collection {
+                id
+                last_name
+                first_name
+                order_connection {
+                    id
+                    user_id
+                    description
+                }
+            }
+        }
+    ]]
+
+    local gql_query = gql_wrapper:compile(query)
+    local variables = {
+    }
+    local ok, result = pcall(gql_query.execute, gql_query, variables)
+    assert(ok == false, 'this test should fail')
+    test:like(result, 'query execution timeout exceeded', 'timeout test')
+
+end
+
+multirunner.run(test_run,
+                data.init_spaces,
+                data.drop_spaces,
+                run)
+
+os.exit(test:check() == true and 0 or 1)