wip

Author: SudoBobo

test/local/avro_union.test.lua

@@ -0,0 +1,123 @@
+#!/usr/bin/env tarantool
+
+local fio = require('fio')
+
+-- require in-repo version of graphql/ sources despite current working directory
+package.path = fio.abspath(debug.getinfo(1).source:match("@?(.*/)"):
+    gsub('/./', '/'):gsub('/+$', '')) .. '/../../?.lua' .. ';' .. package.path
+
+box.cfg{background = false}
+local json = require('json')
+local yaml = require('yaml')
+local graphql = require('graphql')
+local utils = require('graphql.utils')
+
+local schemas = json.decode([[{
+    "user_collection": {
+        "name": "user_collection",
+        "type": "record",
+        "fields": [
+            { "name": "user_id", "type": "string" },
+            { "name": "name", "type": "string" },
+            { "name": "stuff", "type": [
+                "null",
+                "string",
+                {"name": "balances",
+                 "type": {"type": "array", "items": "string" }
+                },
+                { "type": "map", "values": "string" }
+            ]
+            }
+        ]
+    }
+}]])
+
+local collections = json.decode([[{
+    "user_collection": {
+        "schema_name": "user_collection",
+        "connections": []
+    }
+}]])
+
+local service_fields = {
+    user_collection = {
+        {name = 'expires_on', type = 'long', default = 0}
+    }
+}
+
+local indexes = {
+    user_collection = {
+        user_id_index = {
+            service_fields = {},
+            fields = {'user_id'},
+            index_type = 'tree',
+            unique = true,
+            primary = true,
+        }
+    }
+}
+
+local USER_ID = 2
+
+box.schema.create_space('user_collection')
+box.space.user_collection:create_index('user_id_index',
+    {type = 'tree', unique = true, parts = { USER_ID, 'string' }}
+)
+
+box.space.user_collection:replace(
+    {1827767717, 'user_id_1', 'Ivan', 'Stuffy string'})
+
+box.space.user_collection:replace(
+    {1827767717, 'user_id_2', 'Bob', {'Union stuff str1', 'Union stuff str2'}})
+
+box.space.user_collection:replace(
+    {1827767717, 'user_id_3', 'Alice'})
+
+local accessor = graphql.accessor_space.new({
+    schemas = schemas,
+    collections = collections,
+    service_fields = service_fields,
+    indexes = indexes,
+})
+
+local gql_wrapper = graphql.new({
+    schemas = schemas,
+    collections = collections,
+    accessor = accessor,
+})
+
+--- note that inside mapBox there is an auto-generated name for
+--- avro-schema no-named map (it is necessary as we can not
+--- access no-named fields in GQL)
+local query_1 = [[
+    query user_collection {
+        user_collection {
+            user_id
+            name
+            stuff {
+                ... on stringBox {
+                    string
+                }
+                ... on balancesBox {
+                    balances
+                }
+                ... on mapBox {
+                    map
+                }
+            }
+        }
+    }
+]]
+
+utils.show_trace(function()
+
+    --- extract GQL schema from gql_wrapper.state.nullable_collection_types
+    --- and compare them with expected GQL schema
+    local variables_1 = { }
+    local gql_query_1 = gql_wrapper:compile(query_1)
+    local result = gql_query_1:execute(variables_1)
+    --- Validate result with initial avro-schema
+    print(('RESULT\n%s'):format(yaml.encode(result)))
+end)
+
+box.space.user_collection:drop()