Method ListGroups

backend/store/group.go:99–197

ListGroups list all groups.

(ctx context.Context, find *FindGroupMessage)

// ListGroups list all groups.
func (s *Store) ListGroups(ctx context.Context, find *FindGroupMessage) ([]*GroupMessage, error) {
	with := qb.Q()
	from := qb.Q().Space("user_group")
	where := qb.Q().Space("user_group.workspace = ?", find.Workspace)

	// Build CTE for project filtering if needed
	if v := find.ProjectID; v != nil {
		with.Space(`WITH all_members AS (
			SELECT
				jsonb_array_elements_text(jsonb_array_elements(policy.payload->'bindings')->'members') AS member,
				jsonb_array_elements(policy.payload->'bindings')->>'role' AS role
			FROM policy
			WHERE ((resource_type = ? AND resource = ?) OR resource_type = ?) AND type = ? AND policy.workspace = ?
		),
		project_members AS (
			SELECT ARRAY_AGG(member) AS members FROM all_members WHERE role NOT LIKE 'roles/workspace%'
		)`, storepb.Policy_PROJECT.String(), "projects/"+*v, storepb.Policy_WORKSPACE.String(), storepb.Policy_IAM.String(), find.Workspace)
		from.Space("INNER JOIN project_members ON ?", projectMembersGroupJoinCondition())
	}

	if filterQ := find.FilterQ; filterQ != nil {
		where.And("?", filterQ)
	}
	if v := find.ID; v != nil {
		where.And("id = ?", *v)
	}
	if v := find.Email; v != nil {
		where.And("email = ?", *v)
	}

	q := qb.Q()
	if with.Len() > 0 {
		q.Space("?", with)
	}
	q.Space(`
		SELECT
			user_group.id,
			user_group.workspace,
			user_group.email,
			user_group.name,
			user_group.description,
			user_group.payload
		FROM ?
		WHERE ?
		ORDER BY email
	`, from, where)

	if v := find.Limit; v != nil {
		q.Space("LIMIT ?", *v)
	}
	if v := find.Offset; v != nil {
		q.Space("OFFSET ?", *v)
	}

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}