Method Create

app/controlplane/pkg/data/group.go:242–305

Create creates a new group in the specified organization.

(ctx context.Context, orgID uuid.UUID, opts *biz.CreateGroupOpts)

// Create creates a new group in the specified organization.
func (g GroupRepo) Create(ctx context.Context, orgID uuid.UUID, opts *biz.CreateGroupOpts) (*biz.Group, error) {
	ctx, span := otelx.Start(ctx, groupRepoTracer, "GroupRepo.Create")
	defer span.End()

	if opts == nil {
		return nil, biz.NewErrValidationStr("create group options cannot be nil")
	}

	var entGroup ent.Group

	err := WithTx(ctx, g.data.DB, func(tx *ent.Tx) error {
		// Create the group with the provided options
		gr, err := tx.Group.Create().
			SetName(opts.Name).
			SetDescription(opts.Description).
			SetOrganizationID(orgID).Save(ctx)
		if err != nil {
			if ent.IsConstraintError(err) {
				return biz.NewErrAlreadyExistsStr("group with the same name already exists")
			}
			return err
		}

		// Only add memberships if userID is not nil
		if opts.UserID != nil {
			// Set user as group maintainer
			if _, err = tx.GroupMembership.Create().
				SetGroupID(gr.ID).
				SetUserID(*opts.UserID).
				SetMaintainer(true).
				Save(ctx); err != nil {
				return err
			}

			// Update the user membership with the role of maintainer
			_, err = tx.Membership.Create().
				SetUserID(*opts.UserID).
				SetOrganizationID(orgID).
				SetRole(authz.RoleGroupMaintainer).
				SetMembershipType(authz.MembershipTypeUser).
				SetMemberID(*opts.UserID).
				SetResourceType(authz.ResourceTypeGroup).
				SetResourceID(gr.ID).
				Save(ctx)
			if err != nil {
				return fmt.Errorf("failed to create membership for user %s in group %s: %w", *opts.UserID, gr.ID, err)
			}
		}

		entGroup = *gr

		return nil
	})
	if err != nil {
		return nil, fmt.Errorf("failed to create group: %w", err)
	}

	// Update the member count based on actual query