execute query-schema

Author: neomatrixcode

README.md

@@ -34,7 +34,7 @@ Roadmap
  + graphql client
 
 #### Version 0.1.0
-  + Update to julia 0.7
+  + Update to julia 1.0
   + Creation of schemas / types
   + Validator
   + Schemas / Types
@@ -47,7 +47,7 @@ Roadmap
 - [x] Query validation
 - [x] Schemas / Types
   - [ ]Schemas validation
-- [WIP] Query execution
+- [x] Query execution
   - [x] Arguments
   - [ ] Scalar types
   - [ ] Multiple forms of resolution
@@ -416,11 +416,13 @@ schema {
 """
 
 resolvers=Dict(
- "Query_neomatrix" => (ctx)->(return Dict("nombre"=>"josue","edad"=>5) )
-,"Query_persona" => (ctx)->(return Dict("nombre"=>"Diana","edad"=>15))
-,"Persona_nombre" => (ctx)->(return ctx["nombre"])
-,"Persona_edad" => (ctx)->(return ctx["edad"])
-)
+        "Query_neomatrix" => (obj,args,ctx,info)->(return Dict("nombre"=>"josue","edad"=>5) )
+        ,"Query_persona" => (obj,args,ctx,info)->begin
+        return Dict("nombre"=>"Diana","edad"=>15)
+        end
+        ,"Persona_nombre" => (obj,args,ctx,info)->(return ctx["nombre"])
+        ,"Persona_edad" => (obj,args,ctx,info)->(return ctx["edad"])
+        )
 
 my_schema = Schema(schema, resolvers)
 

src/Schema.jl

@@ -5,12 +5,12 @@ mutable struct schema
 end
 
 function Schema(_schema, resolvers)
-#my_schema = Parse(_schema)
-
+my_schema = Parse(_schema)
+tnb = gettypes(my_schema)
     function execute(query::String)
       myquery = Parse(query)
       Validatequery(myquery)
-      return JSON.json(ExecuteQuery(myquery, resolvers))
+      return JSON.json(ExecuteQuery(myquery, resolvers, tnb))
       #=Validatequery(Parse(query))
       validatelosdos()
       operationName = GetOperation(document, operationName)

src/Validate.jl

@@ -1,5 +1,6 @@
 include("Visitor.jl")
 include("rules/consultas.jl")
+include("rules/schema.jl")
 
 import Base.length
 function length(x::Node)
@@ -14,6 +15,12 @@ function Base.iterate(l::Node, isdone::Any)
     return l
 end
 
+function deepquery(documentAST)
+	gd =getdeep()
+    visitante(documentAST,gd)
+    return gd.valordeep()
+end
+
 function Validatequery(documentAST)
 	queryRules=[NotExtensionOnOperation(),NotTypeOnOperation(),NotSchemaOnOperation(),FragmentSubscription(),FragmentNames(),OperationNames(),OperationAnonymous(),SubscriptionFields(),FragmentUnknowNotUsed(),FragmentCycles()]
 
@@ -33,3 +40,10 @@ function Validatequery(documentAST)
 				}"""
       end
 end
+
+function gettypes(schema)
+	gt=getfield_types()
+    visitante(schema,gt)
+    return gt.notbasic_types
+end
+

src/execute.jl

@@ -2,9 +2,9 @@ struct resol
 	exec_root
 	exec_foil
 	argstodict
-	function resol(resolvers)
-		n_campos=["query","persona","neomatrix"]
-		tipos   =["Query","Persona","Persona"]
+	function resol(resolvers,tipos)
+		n_campos= tipos[1]
+		tipos   = tipos[2]
 		ctx = Dict()
 		args = Dict()
 		obj= ""
@@ -41,14 +41,14 @@ struct executor
 	enter
 	leave
 	salida
-	function executor(exec_resol)
+	function executor(exec_resol,deep)
 		nivel=1
 		salida=Dict()
 		salida["datos"]=Dict()
 		ex= :($salida["datos"])
-		expresiones = Array{Expr}(undef, 4)
+		expresiones = Array{Expr}(undef, deep)
 		expresiones[1]= ex
-		nombres=Array{String}(undef, 4)
+		nombres=Array{String}(undef, deep)
 		nombres[1]="query"
 		function enter(node)
 			if (node.kind=="Field")
@@ -86,8 +86,9 @@ struct executor
 	end
 end
 
-function ExecuteQuery(query, myresolvers)
-	exec= executor(resol(myresolvers))
+function ExecuteQuery(query, myresolvers, types_nb)
+	r = deepquery(query)
+	exec= executor(resol(myresolvers,types_nb),r)
 	visitante(query,exec)
 	return exec.salida
 end

src/rules/consultas.jl

@@ -3,6 +3,39 @@ struct GraphqlError <: Exception
            msg
        end
 
+
+struct getdeep
+	enter
+	leave
+	valordeep
+	function getdeep()
+		valor=1
+		nivel=1
+		function valordeep()
+			return valor
+		end
+		function enter(node)
+			if (node.kind=="Field")
+				if (typeof(node.selectionSet)<:Node)
+					nivel = nivel+1
+					if(nivel>valor)
+						valor = nivel
+					end
+				end
+			end
+
+		end
+		function leave(node)
+			if (node.kind=="Field")
+				if (typeof(node.selectionSet)<:Node)
+					nivel = nivel-1
+				end
+			end
+		end
+		new(enter,leave,valordeep)
+	end
+end
+
 struct NotExtensionOnOperation
 	enter
 	leave

src/rules/schema.jl

@@ -0,0 +1,30 @@
+struct getfield_types
+	enter
+	leave
+	basic_types
+	notbasic_types
+	function getfield_types()
+		scalars_types=["String", "Int", "Float", "Boolean"]
+		basic_types=[[],[]]
+		notbasic_types=[[],[]]
+		function enter(node)
+			if (node.kind == "FieldDefinition")
+				type = node.tipe.name.value
+				if(type in scalars_types)
+				    push!(basic_types[1],node.name.value)
+				    push!(basic_types[2],type)
+				else
+					push!(notbasic_types[1],node.name.value)
+				    push!(notbasic_types[2],type)
+				end
+			end
+			if (node.kind == "OperationTypeDefinition")
+				push!(notbasic_types[1],node.operation)
+				push!(notbasic_types[2],node.tipe.name.value)
+			end
+		end
+		function leave(node)
+		end
+		new(enter,leave,basic_types,notbasic_types)
+	end
+end