package schema import ( "fmt" "strings" "text/scanner" "github.com/vektah/gqlgen/neelance/common" "github.com/vektah/gqlgen/neelance/errors" ) type Schema struct { EntryPoints map[string]NamedType Types map[string]NamedType Directives map[string]*DirectiveDecl entryPointNames map[string]string objects []*Object unions []*Union enums []*Enum } var defaultEntrypoints = map[string]string{ "query": "Query", "mutation": "Mutation", "subscription": "Subscription", } func (s *Schema) Resolve(name string) common.Type { return s.Types[name] } type NamedType interface { common.Type TypeName() string Description() string } type Scalar struct { Name string Desc string } type Object struct { Name string Interfaces []*Interface Fields FieldList Desc string interfaceNames []string } type Interface struct { Name string PossibleTypes []*Object Fields FieldList Desc string } type Union struct { Name string PossibleTypes []*Object Desc string typeNames []string } type Enum struct { Name string Values []*EnumValue Desc string } type EnumValue struct { Name string Directives common.DirectiveList Desc string } type InputObject struct { Name string Desc string Values common.InputValueList } type FieldList []*Field func (l FieldList) Get(name string) *Field { for _, f := range l { if f.Name == name { return f } } return nil } func (l FieldList) Names() []string { names := make([]string, len(l)) for i, f := range l { names[i] = f.Name } return names } type DirectiveDecl struct { Name string Desc string Locs []string Args common.InputValueList } func (*Scalar) Kind() string { return "SCALAR" } func (*Object) Kind() string { return "OBJECT" } func (*Interface) Kind() string { return "INTERFACE" } func (*Union) Kind() string { return "UNION" } func (*Enum) Kind() string { return "ENUM" } func (*InputObject) Kind() string { return "INPUT_OBJECT" } func (t *Scalar) String() string { return t.Name } func (t *Object) String() string { return t.Name } func (t *Interface) String() string { return t.Name } func (t *Union) String() string { return t.Name } func (t *Enum) String() string { return t.Name } func (t *InputObject) String() string { return t.Name } func (t *Scalar) TypeName() string { return t.Name } func (t *Object) TypeName() string { return t.Name } func (t *Interface) TypeName() string { return t.Name } func (t *Union) TypeName() string { return t.Name } func (t *Enum) TypeName() string { return t.Name } func (t *InputObject) TypeName() string { return t.Name } func (t *Scalar) Description() string { return t.Desc } func (t *Object) Description() string { return t.Desc } func (t *Interface) Description() string { return t.Desc } func (t *Union) Description() string { return t.Desc } func (t *Enum) Description() string { return t.Desc } func (t *InputObject) Description() string { return t.Desc } type Field struct { Name string Args common.InputValueList Type common.Type Directives common.DirectiveList Desc string } func MustParse(str string) *Schema { s := New() err := s.Parse(str) if err != nil { panic(err) } return s } func New() *Schema { s := &Schema{ entryPointNames: make(map[string]string), Types: make(map[string]NamedType), Directives: make(map[string]*DirectiveDecl), } for n, t := range Meta.Types { s.Types[n] = t } for n, d := range Meta.Directives { s.Directives[n] = d } return s } func (s *Schema) Parse(schemaString string) error { sc := &scanner.Scanner{ Mode: scanner.ScanIdents | scanner.ScanInts | scanner.ScanFloats | scanner.ScanStrings, } sc.Init(strings.NewReader(schemaString)) l := common.New(sc) err := l.CatchSyntaxError(func() { parseSchema(s, l) }) if err != nil { return err } for _, t := range s.Types { if err := resolveNamedType(s, t); err != nil { return err } } for _, d := range s.Directives { for _, arg := range d.Args { t, err := common.ResolveType(arg.Type, s.Resolve) if err != nil { return err } arg.Type = t } } s.EntryPoints = make(map[string]NamedType) for key, name := range s.entryPointNames { t, ok := s.Types[name] if !ok { if !ok { return errors.Errorf("type %q not found", name) } } s.EntryPoints[key] = t } for entrypointName, typeName := range defaultEntrypoints { if _, ok := s.EntryPoints[entrypointName]; ok { continue } if _, ok := s.Types[typeName]; !ok { continue } s.EntryPoints[entrypointName] = s.Types[typeName] } for _, obj := range s.objects { obj.Interfaces = make([]*Interface, len(obj.interfaceNames)) for i, intfName := range obj.interfaceNames { t, ok := s.Types[intfName] if !ok { return errors.Errorf("interface %q not found", intfName) } intf, ok := t.(*Interface) if !ok { return errors.Errorf("type %q is not an interface", intfName) } obj.Interfaces[i] = intf intf.PossibleTypes = append(intf.PossibleTypes, obj) } } for _, union := range s.unions { union.PossibleTypes = make([]*Object, len(union.typeNames)) for i, name := range union.typeNames { t, ok := s.Types[name] if !ok { return errors.Errorf("object type %q not found", name) } obj, ok := t.(*Object) if !ok { return errors.Errorf("type %q is not an object", name) } union.PossibleTypes[i] = obj } } for _, enum := range s.enums { for _, value := range enum.Values { if err := resolveDirectives(s, value.Directives); err != nil { return err } } } return nil } func resolveNamedType(s *Schema, t NamedType) error { switch t := t.(type) { case *Object: for _, f := range t.Fields { if err := resolveField(s, f); err != nil { return err } } case *Interface: for _, f := range t.Fields { if err := resolveField(s, f); err != nil { return err } } case *InputObject: if err := resolveInputObject(s, t.Values); err != nil { return err } } return nil } func resolveField(s *Schema, f *Field) error { t, err := common.ResolveType(f.Type, s.Resolve) if err != nil { return err } f.Type = t if err := resolveDirectives(s, f.Directives); err != nil { return err } return resolveInputObject(s, f.Args) } func resolveDirectives(s *Schema, directives common.DirectiveList) error { for _, d := range directives { dirName := d.Name.Name dd, ok := s.Directives[dirName] if !ok { return errors.Errorf("directive %q not found", dirName) } for _, arg := range d.Args { if dd.Args.Get(arg.Name.Name) == nil { return errors.Errorf("invalid argument %q for directive %q", arg.Name.Name, dirName) } } for _, arg := range dd.Args { if _, ok := d.Args.Get(arg.Name.Name); !ok { d.Args = append(d.Args, common.Argument{Name: arg.Name, Value: arg.Default}) } } } return nil } func resolveInputObject(s *Schema, values common.InputValueList) error { for _, v := range values { t, err := common.ResolveType(v.Type, s.Resolve) if err != nil { return err } v.Type = t } return nil } func parseSchema(s *Schema, l *common.Lexer) { for l.Peek() != scanner.EOF { desc := l.DescComment() switch x := l.ConsumeIdent(); x { case "schema": l.ConsumeToken('{') for l.Peek() != '}' { name := l.ConsumeIdent() l.ConsumeToken(':') typ := l.ConsumeIdent() s.entryPointNames[name] = typ } l.ConsumeToken('}') case "type": obj := parseObjectDecl(l) obj.Desc = desc s.Types[obj.Name] = obj s.objects = append(s.objects, obj) case "interface": intf := parseInterfaceDecl(l) intf.Desc = desc s.Types[intf.Name] = intf case "union": union := parseUnionDecl(l) union.Desc = desc s.Types[union.Name] = union s.unions = append(s.unions, union) case "enum": enum := parseEnumDecl(l) enum.Desc = desc s.Types[enum.Name] = enum s.enums = append(s.enums, enum) case "input": input := parseInputDecl(l) input.Desc = desc s.Types[input.Name] = input case "scalar": name := l.ConsumeIdent() s.Types[name] = &Scalar{Name: name, Desc: desc} case "directive": directive := parseDirectiveDecl(l) directive.Desc = desc s.Directives[directive.Name] = directive default: l.SyntaxError(fmt.Sprintf(`unexpected %q, expecting "schema", "type", "enum", "interface", "union", "input", "scalar" or "directive"`, x)) } } } func parseObjectDecl(l *common.Lexer) *Object { o := &Object{} o.Name = l.ConsumeIdent() if l.Peek() == scanner.Ident { l.ConsumeKeyword("implements") for { o.interfaceNames = append(o.interfaceNames, l.ConsumeIdent()) if l.Peek() == '{' { break } } } l.ConsumeToken('{') o.Fields = parseFields(l) l.ConsumeToken('}') return o } func parseInterfaceDecl(l *common.Lexer) *Interface { i := &Interface{} i.Name = l.ConsumeIdent() l.ConsumeToken('{') i.Fields = parseFields(l) l.ConsumeToken('}') return i } func parseUnionDecl(l *common.Lexer) *Union { union := &Union{} union.Name = l.ConsumeIdent() l.ConsumeToken('=') union.typeNames = []string{l.ConsumeIdent()} for l.Peek() == '|' { l.ConsumeToken('|') union.typeNames = append(union.typeNames, l.ConsumeIdent()) } return union } func parseInputDecl(l *common.Lexer) *InputObject { i := &InputObject{} i.Name = l.ConsumeIdent() l.ConsumeToken('{') for l.Peek() != '}' { i.Values = append(i.Values, common.ParseInputValue(l)) } l.ConsumeToken('}') return i } func parseEnumDecl(l *common.Lexer) *Enum { enum := &Enum{} enum.Name = l.ConsumeIdent() l.ConsumeToken('{') for l.Peek() != '}' { v := &EnumValue{} v.Desc = l.DescComment() v.Name = l.ConsumeIdent() v.Directives = common.ParseDirectives(l) enum.Values = append(enum.Values, v) } l.ConsumeToken('}') return enum } func parseDirectiveDecl(l *common.Lexer) *DirectiveDecl { d := &DirectiveDecl{} l.ConsumeToken('@') d.Name = l.ConsumeIdent() if l.Peek() == '(' { l.ConsumeToken('(') for l.Peek() != ')' { v := common.ParseInputValue(l) d.Args = append(d.Args, v) } l.ConsumeToken(')') } l.ConsumeKeyword("on") for { loc := l.ConsumeIdent() d.Locs = append(d.Locs, loc) if l.Peek() != '|' { break } l.ConsumeToken('|') } return d } func parseFields(l *common.Lexer) FieldList { var fields FieldList for l.Peek() != '}' { f := &Field{} f.Desc = l.DescComment() f.Name = l.ConsumeIdent() if l.Peek() == '(' { l.ConsumeToken('(') for l.Peek() != ')' { f.Args = append(f.Args, common.ParseInputValue(l)) } l.ConsumeToken(')') } l.ConsumeToken(':') f.Type = common.ParseType(l) f.Directives = common.ParseDirectives(l) fields = append(fields, f) } return fields }