Method apiV1GraphQL

serv/http.go:116–241

apiV1GraphQLHandler handles the GraphQL API requests

(ns *string, ah auth.HandlerFunc)

// apiV1GraphQLHandler handles the GraphQL API requests
func (s1 *HttpService) apiV1GraphQL(ns *string, ah auth.HandlerFunc) http.Handler {
	dtrace := otel.GetTextMapPropagator()

	h := func(w http.ResponseWriter, r *http.Request) {
		var err error

		start := time.Now()
		s := s1.Load().(*graphjinService)

		w.Header().Set("Content-Type", "application/json")

		if isWebSocketUpgrade(r) {
			s.apiV1Ws(w, r, ah)
			return
		}

		var req gqlReq

		ctx, opts := newDTrace(dtrace, r)
		ctx, span := s.spanStart(ctx, "GraphQL Request", opts...)
		defer span.End()

		switch r.Method {
		case "POST":
			if isMultipartRequest(r) {
				if !s.conf.Uploads.Enabled {
					err = errMultipartDisabled
					break
				}
				var backend fstable.Backend
				if name := s.conf.Uploads.Storage; name != "" {
					b, ok := s.gj.FilesystemBackend(name)
					if !ok {
						err = fmt.Errorf("uploads: storage filesystem %q not configured", name)
						break
					}
					backend = b
				}
				req, err = parseMultipartGraphQL(r, s.conf.Uploads, backend)
				break
			}
			var b []byte
			b, err = io.ReadAll(io.LimitReader(r.Body, maxReadBytes))
			if err == nil {
				defer r.Body.Close() //nolint:errcheck
				err = json.Unmarshal(b, &req)
			}

		case "GET":
			q := r.URL.Query()
			req.Query = q.Get("query")
			req.OpName = q.Get("operationName")
			req.Vars = json.RawMessage(q.Get("variables"))

			if ext := q.Get("extensions"); ext != "" {
				err = json.Unmarshal([]byte(ext), &req.Ext)
			}
		}