Method ServeHTTP

graphql/admin/http.go:223–266

ServeHTTP handles GraphQL queries and mutations that get resolved via GraphQL->Dgraph->GraphQL. It writes a valid GraphQL JSON response to w.

(w http.ResponseWriter, r *http.Request)

// via GraphQL->Dgraph->GraphQL.  It writes a valid GraphQL JSON response
// to w.
func (gh *graphqlHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	ctx, span := trace.StartSpan(r.Context(), "handler")
	defer span.End()

	ns, _ := strconv.ParseUint(r.Header.Get("resolver"), 10, 64)
	glog.V(2).Infof("namespace: %d. Got GraphQL request over HTTP.", ns)
	if err := gh.isValid(ns); err != nil {
		glog.Errorf("namespace: %d. graphqlHandler not initialised: %s", ns, err)
		WriteErrorResponse(w, r, errors.New(resolve.ErrInternal))
		return
	}

	gh.resolverMux.RLock()
	resolver := gh.resolver[ns]
	gh.resolverMux.RUnlock()

	addDynamicHeaders(resolver, r.Header.Get("Origin"), w)
	if r.Method == http.MethodOptions {
		// for OPTIONS, we only need to send the headers
		return
	}

	// Pass in PoorMan's auth, ACL and IP information if present.
	ctx = x.AttachAccessJwt(ctx, r)
	ctx = x.AttachRemoteIP(ctx, r)
	ctx = x.AttachAuthToken(ctx, r)
	ctx = x.AttachJWTNamespace(ctx)

	var res *schema.Response
	gqlReq, err := getRequest(r)

	if err != nil {
		WriteErrorResponse(w, r, err)
		return
	}

	if err = edgraph.ProcessPersistedQuery(ctx, gqlReq); err != nil {
		WriteErrorResponse(w, r, err)
		return
	}

	res = resolver.Resolve(ctx, gqlReq)
	write(w, res, strings.Contains(r.Header.Get("Accept-Encoding"), "gzip"))
}

func (gh *graphqlHandler) isValid(namespace uint64) error {
	gh.resolverMux.RLock()