Function GetProjects

backend/server/services/project.go:54–100

GetProjects returns a paginated list of Projects based on `query`

(query *ProjectQuery)

// GetProjects returns a paginated list of Projects based on `query`
func GetProjects(query *ProjectQuery) ([]*models.ApiOutputProject, int64, errors.Error) {
	// verify input
	if err := VerifyStruct(query); err != nil {
		return nil, 0, err
	}
	clauses := []dal.Clause{
		dal.From(&models.Project{}),
	}
	if query.Keyword != nil {
		clauses = append(clauses, dal.Where("LOWER(name) LIKE ?", "%"+query.GetKeyword()+"%"))
	}

	count, err := db.Count(clauses...)
	if err != nil {
		return nil, 0, errors.Default.Wrap(err, "error getting DB count of project")
	}

	clauses = append(clauses,
		dal.Orderby("created_at DESC"),
		dal.Offset(query.GetSkip()),
		dal.Limit(query.GetPageSize()),
	)
	projects := make([]*models.Project, count)
	err = db.All(&projects, clauses...)
	if err != nil {
		return nil, 0, errors.Default.Wrap(err, "error finding DB project")
	}
	apiOutProjects := make([]*models.ApiOutputProject, len(projects))
	g := new(errgroup.Group)
	for idx, project := range projects {
		tmpProject := *project
		tmpIdx := idx
		g.Go(func() error {
			apiOutputProject, err := makeProjectOutput(&tmpProject, true)
			if err != nil {
				logger.Error(err, "makeProjectOutput, name: %s", tmpProject.Name)
				return errors.Default.Wrap(err, "error making project output")
			}
			apiOutProjects[tmpIdx] = apiOutputProject
			return nil
		})
	}
	if err := g.Wait(); err != nil {
		return nil, 0, errors.Convert(err)
	}
	return apiOutProjects, count, nil
}

// CreateProject accepts a project instance and insert it to database
func CreateProject(projectInput *models.ApiInputProject) (*models.ApiOutputProject, errors.Error) {