Skip to content
Permalink
Branch: master
Find file Copy path
Find file Copy path
7 contributors

Users who have contributed to this file

@sogko @chris-ramon @lenaten @Fugiman @Fontinalis @exklamationmark @augustoroman
117 lines (96 sloc) 2.84 KB
package graphql
import (
"context"
"github.com/graphql-go/graphql/gqlerrors"
"github.com/graphql-go/graphql/language/parser"
"github.com/graphql-go/graphql/language/source"
)
type Params struct {
// The GraphQL type system to use when validating and executing a query.
Schema Schema
// A GraphQL language formatted string representing the requested operation.
RequestString string
// The value provided as the first argument to resolver functions on the top
// level type (e.g. the query object type).
RootObject map[string]interface{}
// A mapping of variable name to runtime value to use for all variables
// defined in the requestString.
VariableValues map[string]interface{}
// The name of the operation to use if requestString contains multiple
// possible operations. Can be omitted if requestString contains only
// one operation.
OperationName string
// Context may be provided to pass application-specific per-request
// information to resolve functions.
Context context.Context
}
func Do(p Params) *Result {
source := source.NewSource(&source.Source{
Body: []byte(p.RequestString),
Name: "GraphQL request",
})
// run init on the extensions
extErrs := handleExtensionsInits(&p)
if len(extErrs) != 0 {
return &Result{
Errors: extErrs,
}
}
extErrs, parseFinishFn := handleExtensionsParseDidStart(&p)
if len(extErrs) != 0 {
return &Result{
Errors: extErrs,
}
}
// parse the source
AST, err := parser.Parse(parser.ParseParams{Source: source})
if err != nil {
// run parseFinishFuncs for extensions
extErrs = parseFinishFn(err)
// merge the errors from extensions and the original error from parser
extErrs = append(extErrs, gqlerrors.FormatErrors(err)...)
return &Result{
Errors: extErrs,
}
}
// run parseFinish functions for extensions
extErrs = parseFinishFn(err)
if len(extErrs) != 0 {
return &Result{
Errors: extErrs,
}
}
// notify extensions abput the start of the validation
extErrs, validationFinishFn := handleExtensionsValidationDidStart(&p)
if len(extErrs) != 0 {
return &Result{
Errors: extErrs,
}
}
// validate document
validationResult := ValidateDocument(&p.Schema, AST, nil)
if !validationResult.IsValid {
// run validation finish functions for extensions
extErrs = validationFinishFn(validationResult.Errors)
// merge the errors from extensions and the original error from parser
extErrs = append(extErrs, validationResult.Errors...)
return &Result{
Errors: extErrs,
}
}
// run the validationFinishFuncs for extensions
extErrs = validationFinishFn(validationResult.Errors)
if len(extErrs) != 0 {
return &Result{
Errors: extErrs,
}
}
return Execute(ExecuteParams{
Schema: p.Schema,
Root: p.RootObject,
AST: AST,
OperationName: p.OperationName,
Args: p.VariableValues,
Context: p.Context,
})
}
You can’t perform that action at this time.