Method List

app/controlplane/pkg/data/group.go:59–125

(ctx context.Context, orgID uuid.UUID, filterOpts *biz.ListGroupOpts, paginationOpts *pagination.OffsetPaginationOpts)

}

func (g GroupRepo) List(ctx context.Context, orgID uuid.UUID, filterOpts *biz.ListGroupOpts, paginationOpts *pagination.OffsetPaginationOpts) ([]*biz.Group, int, error) {
	ctx, span := otelx.Start(ctx, groupRepoTracer, "GroupRepo.List")
	defer span.End()

	if filterOpts == nil {
		filterOpts = &biz.ListGroupOpts{}
	}

	query := g.data.DB.Group.Query().
		Where(group.DeletedAtIsNil(), group.OrganizationIDEQ(orgID)).
		WithGroupMemberships().WithOrganization()

	// filter by UserID if provided. It will be applied on top of rest of filters
	if filterOpts.UserID != nil {
		query.Where(group.HasGroupMembershipsWith(
			groupmembership.UserID(*filterOpts.UserID),
			groupmembership.DeletedAtIsNil(),
		))
	}

	// Apply filters as ORs if any additional filter is provided
	var predicates []predicate.Group
	if filterOpts.Name != "" {
		predicates = append(predicates, group.NameContains(filterOpts.Name))
	}

	if filterOpts.Description != "" {
		predicates = append(predicates, group.DescriptionContains(filterOpts.Description))
	}

	if filterOpts.MemberEmail != "" {
		predicates = append(predicates,
			group.HasGroupMembershipsWith(
				groupmembership.DeletedAtIsNil(),
				groupmembership.HasUserWith(user.EmailContains(filterOpts.MemberEmail)),
			),
		)
	}

	// Apply OR predicates if any exist
	if len(predicates) > 0 {
		query.Where(group.Or(predicates...))
	}

	// Get the count of all filtered rows without the limit and offset
	count, err := query.Count(ctx)
	if err != nil {
		return nil, 0, err
	}

	// Apply pagination options and execute the query
	groups, err := query.
		Order(ent.Desc(group.FieldCreatedAt)).
		Limit(paginationOpts.Limit()).
		Offset(paginationOpts.Offset()).
		All(ctx)
	if err != nil {
		return nil, 0, err