Function updateProjectOAuthConfig

cmd/cql-proxy/api/project.go:476–551

(c *gin.Context)

}

func updateProjectOAuthConfig(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"`
		model.ProjectOAuthConfig
		// additional parameters, see ProjectOAuthConfig structure
	}{}

	_ = c.ShouldBindUri(&r)

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

	_, projectDB, err := getProjectDB(c, r.DB)
	if err != nil {
		_ = c.Error(err)
		abortWithError(c, http.StatusForbidden, ErrLoadProjectDatabaseFailed)
		return
	}

	cfg := &r.ProjectOAuthConfig

	if cfg.ClientID == "" && cfg.ClientSecret == "" {
		// update nothing
		_ = c.Error(err)
		abortWithError(c, http.StatusBadRequest, ErrIncompleteOAuthConfig)
		return
	}

	var (
		p   *model.ProjectConfig
		poc *model.ProjectOAuthConfig
	)

	p, poc, err = model.GetProjectOAuthConfig(projectDB, r.Provider)
	if err != nil {
		// not exists, create
		if cfg.ClientID == "" || cfg.ClientSecret == "" {
			abortWithError(c, http.StatusBadRequest, ErrIncompleteOAuthConfig)
			return
		}
		p, err = model.AddProjectConfig(projectDB, model.ProjectConfigOAuth, r.Provider, cfg)
		if err != nil {
			_ = c.Error(err)
			abortWithError(c, http.StatusInternalServerError, ErrAddProjectOAuthConfigFailed)
			return
		}
		poc = cfg
	} else {
		// update config
		if cfg.ClientID != "" {
			poc.ClientID = cfg.ClientID
		}
		if cfg.ClientSecret != "" {
			poc.ClientSecret = cfg.ClientSecret
		}