Method ListMembers

app/controlplane/pkg/data/group.go:128–181

ListMembers retrieves the members of a group, optionally filtering by maintainers.

(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, opts *biz.ListMembersOpts, paginationOpts *pagination.OffsetPaginationOpts)

// ListMembers retrieves the members of a group, optionally filtering by maintainers.
func (g GroupRepo) ListMembers(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, opts *biz.ListMembersOpts, paginationOpts *pagination.OffsetPaginationOpts) ([]*biz.GroupMembership, int, error) {
	ctx, span := otelx.Start(ctx, groupRepoTracer, "GroupRepo.ListMembers")
	defer span.End()

	if paginationOpts == nil {
		paginationOpts = pagination.NewDefaultOffsetPaginationOpts()
	}

	// Check the group exists in the organization
	_, err := g.data.DB.Group.Query().
		Where(group.ID(groupID), group.OrganizationIDEQ(orgID), group.DeletedAtIsNil()).
		Only(ctx)
	if err != nil {
		if ent.IsNotFound(err) {
			return nil, 0, biz.NewErrNotFound("group")
		}
		return nil, 0, err
	}

	// Build the query to list members of the group
	query := g.data.DB.GroupMembership.Query().
		Where(groupmembership.GroupID(groupID), groupmembership.DeletedAtIsNil())

	if opts != nil && opts.Maintainers != nil {
		query.Where(groupmembership.MaintainerEQ(*opts.Maintainers))
	}

	if opts != nil && opts.MemberEmail != nil {
		query.Where(groupmembership.HasUserWith(user.EmailContains(*opts.MemberEmail)))
	}

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

	members, err := query.
		Order(ent.Desc(workflow.FieldCreatedAt)).
		WithUser().
		Limit(paginationOpts.Limit()).
		Offset(paginationOpts.Offset()).
		All(ctx)
	if err != nil {
		return nil, 0, err
	}

	bizMembers := make([]*biz.GroupMembership, 0, len(members))
	for _, member := range members {
		bizMembers = append(bizMembers, entGroupMembershipToBiz(member))
	}

	return bizMembers, count, nil
}

// ListPendingInvitationsByGroup retrieves pending invitations for a specific group in an organization.
func (g GroupRepo) ListPendingInvitationsByGroup(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, paginationOpts *pagination.OffsetPaginationOpts) ([]*biz.OrgInvitation, int, error) {