Function UserListV2

api/handler/v2/user.go:28–62

@Id UserListV2 @Description get user list. @Tags user @Success 200 {object} models.UserListResp @Security ApiKeyAuth @Param filter_username query string false "filter user name" @Param filter_tenant query string false "filter tenant" @Router /v2/user/list [get]

(c echo.Context)

// @Param filter_tenant query string false "filter tenant"
// @Router /v2/user/list [get]
func UserListV2(c echo.Context) error {
	logger := handler.NewLogger().Named("UserListV2")
	reqParam := new(models.UserListReq)
	if err := handler.BindAndValidate(logger, c, reqParam); err != nil {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(err))
	}

	storeManager, err := common.NewStoreManager([]string{handler.ConsulAddr}, logger)
	if err != nil {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("consul_addr=%v; connect to consul failed: %v", handler.ConsulAddr, err)))
	}
	userList, err := storeManager.FindUserList(reqParam.FilterTenant)
	if nil != err {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("consul_addr=%v ; get job status list failed: %v", handler.ConsulAddr, err)))
	}

	currentUser, err := getCurrentUser(c)
	if err != nil {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(err))
	}
	users := make([]*common.User, 0)
	for _, user := range userList {
		if !userHasAccess(storeManager, fmt.Sprintf("%s:%s", user.Tenant, user.Username), currentUser) {
			continue
		}
		if strings.HasPrefix(user.Username, reqParam.FilterUsername) {
			users = append(users, user)
		}
	}

	return c.JSON(http.StatusOK, &models.UserListResp{
		UserList: users,
		BaseResp: models.BuildBaseResp(nil),
	})
}

// @Id TenantListV2
// @Description get tenant list.