Merge branch 'master' into master

Author: chris-ramon

examples/crud/Readme.md

@@ -1,25 +1,25 @@
 # Go GraphQL CRUD example
 
-Implementation create, read, update and delete on Go    
+Implement create, read, update and delete on Go.
 
-To run the program, go to the directory    
-`cd examples/crud`
+To run the program:
 
-Run the example    
-`go run main.go`
+1. go to the directory: `cd examples/crud`
+2. Run the example: `go run main.go`
 
 ## Create
+
 `http://localhost:8080/product?query=mutation+_{create(name:"Inca Kola",info:"Inca Kola is a soft drink that was created in Peru in 1935 by British immigrant Joseph Robinson Lindley using lemon verbena (wiki)",price:1.99){id,name,info,price}}`
 
 ## Read
-Get single product by id    
-`http://localhost:8080/product?query={product(id:1){name,info,price}}`
 
-Get product list    
-`http://localhost:8080/product?query={list{id,name,info,price}}`
+* Get single product by id: `http://localhost:8080/product?query={product(id:1){name,info,price}}`
+* Get product list: `http://localhost:8080/product?query={list{id,name,info,price}}`
 
 ## Update
+
 `http://localhost:8080/product?query=mutation+_{update(id:1,price:3.95){id,name,info,price}}`
 
 ## Delete
+
 `http://localhost:8080/product?query=mutation+_{delete(id:1){id,name,info,price}}`

examples/crud/main.go

@@ -10,14 +10,34 @@ import (
 	"github.com/graphql-go/graphql"
 )
 
+// Product contains information about one product
 type Product struct {
 	ID    int64   `json:"id"`
 	Name  string  `json:"name"`
 	Info  string  `json:"info,omitempty"`
 	Price float64 `json:"price"`
 }
 
-var products []Product
+var products = []Product{
+	{
+		ID:    1,
+		Name:  "Chicha Morada",
+		Info:  "Chicha morada is a beverage originated in the Andean regions of Perú but is actually consumed at a national level (wiki)",
+		Price: 7.99,
+	},
+	{
+		ID:    2,
+		Name:  "Chicha de jora",
+		Info:  "Chicha de jora is a corn beer chicha prepared by germinating maize, extracting the malt sugars, boiling the wort, and fermenting it in large vessels (traditionally huge earthenware vats) for several days (wiki)",
+		Price: 5.95,
+	},
+	{
+		ID:    3,
+		Name:  "Pisco",
+		Info:  "Pisco is a colorless or yellowish-to-amber colored brandy produced in winemaking regions of Peru and Chile (wiki)",
+		Price: 9.95,
+	},
+}
 
 var productType = graphql.NewObject(
 	graphql.ObjectConfig{
@@ -204,17 +224,7 @@ func executeQuery(query string, schema graphql.Schema) *graphql.Result {
 	return result
 }
 
-func initProductsData(p *[]Product) {
-	product1 := Product{ID: 1, Name: "Chicha Morada", Info: "Chicha morada is a beverage originated in the Andean regions of Perú but is actually consumed at a national level (wiki)", Price: 7.99}
-	product2 := Product{ID: 2, Name: "Chicha de jora", Info: "Chicha de jora is a corn beer chicha prepared by germinating maize, extracting the malt sugars, boiling the wort, and fermenting it in large vessels (traditionally huge earthenware vats) for several days (wiki)", Price: 5.95}
-	product3 := Product{ID: 3, Name: "Pisco", Info: "Pisco is a colorless or yellowish-to-amber colored brandy produced in winemaking regions of Peru and Chile (wiki)", Price: 9.95}
-	*p = append(*p, product1, product2, product3)
-}
-
 func main() {
-	// Primary data initialization
-	initProductsData(&products)
-
 	http.HandleFunc("/product", func(w http.ResponseWriter, r *http.Request) {
 		result := executeQuery(r.URL.Query().Get("query"), schema)
 		json.NewEncoder(w).Encode(result)

executor.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"reflect"
+	"sort"
 	"strings"
 
 	"github.com/graphql-go/graphql/gqlerrors"
@@ -254,7 +255,9 @@ func executeFieldsSerially(p executeFieldsParams) *Result {
 	}
 
 	finalResults := make(map[string]interface{}, len(p.Fields))
-	for responseName, fieldASTs := range p.Fields {
+	for _, orderedField := range orderedFields(p.Fields) {
+		responseName := orderedField.responseName
+		fieldASTs := orderedField.fieldASTs
 		fieldPath := p.Path.WithKey(responseName)
 		resolved, state := resolveField(p.ExecutionContext, p.ParentType, p.Source, fieldASTs, fieldPath)
 		if state.hasNoFieldDefs {
@@ -650,15 +653,15 @@ func resolveField(eCtx *executionContext, parentType *Object, source interface{}
 		Context: eCtx.Context,
 	})
 
-	if resolveFnError != nil {
-		panic(resolveFnError)
-	}
-
 	extErrs = resolveFieldFinishFn(result, resolveFnError)
 	if len(extErrs) != 0 {
 		eCtx.Errors = append(eCtx.Errors, extErrs...)
 	}
 
+	if resolveFnError != nil {
+		panic(resolveFnError)
+	}
+
 	completed := completeValueCatchingError(eCtx, returnType, fieldASTs, info, path, result)
 	return completed, resultState
 }
@@ -1038,3 +1041,39 @@ func getFieldDef(schema Schema, parentType *Object, fieldName string) *FieldDefi
 	}
 	return parentType.Fields()[fieldName]
 }
+
+// contains field information that will be placed in an ordered slice
+type orderedField struct {
+	responseName string
+	fieldASTs    []*ast.Field
+}
+
+// orders fields from a fields map by location in the source
+func orderedFields(fields map[string][]*ast.Field) []*orderedField {
+	orderedFields := []*orderedField{}
+	fieldMap := map[int]*orderedField{}
+	startLocs := []int{}
+
+	for responseName, fieldASTs := range fields {
+		// find the lowest location in the current fieldASTs
+		lowest := -1
+		for _, fieldAST := range fieldASTs {
+			loc := fieldAST.GetLoc().Start
+			if lowest == -1 || loc < lowest {
+				lowest = loc
+			}
+		}
+		startLocs = append(startLocs, lowest)
+		fieldMap[lowest] = &orderedField{
+			responseName: responseName,
+			fieldASTs:    fieldASTs,
+		}
+	}
+
+	sort.Ints(startLocs)
+	for _, startLoc := range startLocs {
+		orderedFields = append(orderedFields, fieldMap[startLoc])
+	}
+
+	return orderedFields
+}

extensions_test.go

@@ -23,6 +23,12 @@ func tinit(t *testing.T) graphql.Schema {
 						return "foo", nil
 					},
 				},
+				"erred": &graphql.Field{
+					Type: graphql.String,
+					Resolve: func(p graphql.ResolveParams) (interface{}, error) {
+						return "", errors.New("ooops")
+					},
+				},
 			},
 		}),
 	})
@@ -306,6 +312,35 @@ func TestExtensionResolveFieldFinishFuncPanic(t *testing.T) {
 	}
 }
 
+func TestExtensionResolveFieldFinishFuncAfterError(t *testing.T) {
+	var fnErrs int
+	ext := newtestExt("testExt")
+	ext.resolveFieldDidStartFn = func(ctx context.Context, i *graphql.ResolveInfo) (context.Context, graphql.ResolveFieldFinishFunc) {
+		return ctx, func(v interface{}, err error) {
+			if err != nil {
+				fnErrs++
+			}
+		}
+	}
+
+	schema := tinit(t)
+	query := `query Example { erred }`
+	schema.AddExtensions(ext)
+
+	result := graphql.Do(graphql.Params{
+		Schema:        schema,
+		RequestString: query,
+	})
+
+	if resErrs := len(result.Errors); resErrs != 1 {
+		t.Errorf("Incorrect number of returned result errors: %d", resErrs)
+	}
+
+	if fnErrs != 1 {
+		t.Errorf("Incorrect number of errors captured: %d", fnErrs)
+	}
+}
+
 func TestExtensionGetResultPanic(t *testing.T) {
 	ext := newtestExt("testExt")
 	ext.getResultFn = func(context.Context) interface{} {

introspection.go

@@ -312,6 +312,14 @@ func init() {
 			},
 			"deprecationReason": &Field{
 				Type: String,
+				Resolve: func(p ResolveParams) (interface{}, error) {
+					if field, ok := p.Source.(*FieldDefinition); ok {
+						if field.DeprecationReason != "" {
+							return field.DeprecationReason, nil
+						}
+					}
+					return nil, nil
+				},
 			},
 		},
 	})
@@ -497,6 +505,14 @@ func init() {
 			},
 			"deprecationReason": &Field{
 				Type: String,
+				Resolve: func(p ResolveParams) (interface{}, error) {
+					if field, ok := p.Source.(*EnumValueDefinition); ok {
+						if field.DeprecationReason != "" {
+							return field.DeprecationReason, nil
+						}
+					}
+					return nil, nil
+				},
 			},
 		},
 	})