Function getProjectOAuthCallback

cmd/cql-proxy/api/project.go:429–474

(c *gin.Context)

}

func getProjectOAuthCallback(c *gin.Context) {
	r := struct {
		DB       proto.DatabaseID `json:"db" json:"project" form:"db" form:"project" uri:"db" uri:"project" binding:"required,len=64"`
		Provider string           `json:"provider" form:"provider" uri:"provider" binding:"required,max=256"`
	}{}

	_ = c.ShouldBindUri(&r)

	if err := c.ShouldBind(&r); err != nil {
		abortWithError(c, http.StatusBadRequest, err)
		return
	}

	developer := getDeveloperID(c)

	p, err := model.GetProjectByID(model.GetDB(c), r.DB, developer)
	if err != nil {
		_ = c.Error(err)
		abortWithError(c, http.StatusForbidden, ErrGetProjectFailed)
		return
	}

	cfg := getConfig(c)
	if cfg == nil || len(cfg.Hosts) == 0 {
		abortWithError(c, http.StatusInternalServerError, ErrNoPublicServiceHosts)
		return
	}

	var (
		authorize []string
		callback  []string
	)

	for _, h := range cfg.Hosts {
		// project alias happy and host api.covenantsql.io will produce happy.api.covenantsql.io as service host
		authorize = append(authorize,
			fmt.Sprintf("http://%s.%s/auth/authorize/%s", p.Alias, strings.TrimLeft(h, "."), r.Provider))
		callback = append(callback,
			fmt.Sprintf("http://%s.%s/auth/callback/%s", p.Alias, strings.TrimLeft(h, "."), r.Provider))
	}

	responseWithData(c, http.StatusOK, gin.H{
		"authorizes": authorize,
		"callbacks":  callback,
	})
}

func updateProjectOAuthConfig(c *gin.Context) {
	r := struct {