Method apiV1Rest

serv/http.go:244–331

apiV1Rest returns a handler that handles the REST API requests

(ns *string, ah auth.HandlerFunc)

// apiV1Rest returns a handler that handles the REST API requests
func (s1 *HttpService) apiV1Rest(ns *string, ah auth.HandlerFunc) http.Handler {
	rLen := len(routeREST)
	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 vars json.RawMessage
		var span trace.Span

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

		if len(r.RequestURI) <= rLen {
			err := errors.New("no query name defined")
			spanError(span, err)
			renderErr(w, err)
			return
		}

		queryName := r.RequestURI[rLen:]
		if n := strings.IndexRune(queryName, '?'); n != -1 {
			queryName = queryName[:n]
		}

		switch r.Method {
		case "POST":
			vars, err = parseBody(r)

		case "GET":
			vars = json.RawMessage(r.URL.Query().Get("variables"))
		}

		if err != nil {
			spanError(span, err)
			renderErr(w, err)
			return
		}

		var rc core.RequestConfig

		if rc.Vars == nil && len(s.conf.HeaderVars) != 0 {
			rc.Vars = s.setHeaderVars(r)
		}

		if ns != nil {
			rc.SetNamespace(*ns)