Function projectIDInject

cmd/cql-proxy/api/user_oauth.go:291–342

(c *gin.Context)

}

func projectIDInject(c *gin.Context) {
	// load project alias
	cfg := getConfig(c)
	if cfg == nil || len(cfg.Hosts) == 0 {
		abortWithError(c, http.StatusInternalServerError, ErrNoPublicServiceHosts)
		return
	}

	host := c.Request.Host
	var (
		p   *model.Project
		err error
	)

	for _, h := range cfg.Hosts {
		if strings.HasSuffix(host, h) {
			// treat prefix as string
			projectAlias := strings.TrimRight(host[:len(host)-len(h)], ".")
			p, err = model.GetProject(model.GetDB(c), projectAlias)
			if err == nil {
				break
			}
		}
	}

	// try use uri/json/form arguments
	if p == nil {
		r := struct {
			Project string `form:"project" uri:"project" binding:"required,len=64"`
		}{}

		_ = c.ShouldBindUri(&r)

		// should not use ShouldBind, json form bind is not repeatable
		if err = c.ShouldBindQuery(&r); err != nil {
			abortWithError(c, http.StatusBadRequest, err)
			return
		}

		p, err = model.GetProject(model.GetDB(c), r.Project)
	}

	if p != nil {
		c.Set("project", p)
	} else {
		_ = c.Error(err)
		abortWithError(c, http.StatusBadRequest, ErrGetProjectFailed)
		return
	}

	c.Next()
}

func getUserInfo(c *gin.Context) {
	projectDB, err := getCurrentProjectDB(c)