Function userDataFind

cmd/cql-proxy/api/user_data.go:32–99

(c *gin.Context)

)

func userDataFind(c *gin.Context) {
	r := struct {
		Table      string                 `json:"table" form:"table" uri:"table" binding:"required,max=128"`
		Filter     map[string]interface{} `json:"filter" form:"filter"`
		Projection map[string]interface{} `json:"projection" form:"projection"`
		OrderBy    map[string]interface{} `json:"order" form:"order"`
		Skip       *int64                 `json:"skip" form:"skip" binding:"omitempty,gte=0"`
		Limit      *int64                 `json:"limit" form:"limit" binding:"omitempty,gte=0"`
	}{}

	_ = c.ShouldBindUri(&r)

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

	resolver.CheckAndBindParams(c, &r.Filter, "filter")
	resolver.CheckAndBindParams(c, &r.Projection, "projection")
	resolver.CheckAndBindParams(c, &r.OrderBy, "order")

	db, uid, userState, vars, rules, fieldMap, adminMode, err := buildExecuteContext(c, r.Table)
	if err != nil {
		_ = c.Error(err)
		if err != ErrProjectIsDisabled {
			err = ErrPrepareExecutionContextFailed
		}
		abortWithError(c, http.StatusInternalServerError, err)
		return
	}

	var filter map[string]interface{}

	if !adminMode {
		filter, err = rules.EnforceRulesOnFilter(r.Filter, r.Table, uid, userState, vars, resolver.RuleQueryFind)
		if err != nil {
			_ = c.Error(err)
			abortWithError(c, http.StatusForbidden, ErrEnforceRuleOnQueryFailed)
			return
		}
	} else {
		filter = r.Filter
	}

	stmt, args, _, err := resolver.Find(r.Table, fieldMap, filter, r.Projection, r.OrderBy, r.Skip, r.Limit)
	if err != nil {
		abortWithError(c, http.StatusBadRequest, err)
		return
	}

	var rows *sql.Rows
	rows, err = db.Query(stmt, args...)
	if err != nil {
		_ = c.Error(err)
		abortWithError(c, http.StatusBadRequest, ErrExecuteQueryFailed)
		return
	}