Method Create

app/controlplane/pkg/data/casbackend.go:130–193

Create creates a new CAS backend in the given organization If it's set as default, it will unset the previous default backend

(ctx context.Context, opts *biz.CASBackendCreateOpts)

// Create creates a new CAS backend in the given organization
// If it's set as default, it will unset the previous default backend
func (r *CASBackendRepo) Create(ctx context.Context, opts *biz.CASBackendCreateOpts) (*biz.CASBackend, error) {
	ctx, span := otelx.Start(ctx, casBackendRepoTracer, "CASBackendRepo.Create")
	defer span.End()

	var (
		backend *ent.CASBackend
		err     error
	)
	if err := WithTx(ctx, r.data.DB, func(tx *ent.Tx) error {
		// 0 - Prevent setting a backend as both default and fallback
		if opts.Default != nil && *opts.Default && opts.Fallback != nil && *opts.Fallback {
			return fmt.Errorf("a backend cannot be both default and fallback")
		}

		// 1 - unset default backend for all the other backends in the org
		if opts.Default != nil && *opts.Default {
			if err := tx.CASBackend.Update().
				Where(casbackend.HasOrganizationWith(organization.ID(opts.OrgID))).
				Where(casbackend.Default(true)).
				SetDefault(false).
				Exec(ctx); err != nil {
				return fmt.Errorf("failed to clear previous default backend: %w", err)
			}
		}

		// 2 - unset fallback backend for all the other backends in the org
		if opts.Fallback != nil && *opts.Fallback {
			if err := tx.CASBackend.Update().
				Where(casbackend.HasOrganizationWith(organization.ID(opts.OrgID))).
				Where(casbackend.Fallback(true)).
				SetFallback(false).
				Exec(ctx); err != nil {
				return fmt.Errorf("failed to clear previous fallback backend: %w", err)
			}
		}

		// 3 - create the new backend and set it as default/fallback if needed
		backend, err = tx.CASBackend.Create().
			SetName(opts.Name).
			SetOrganizationID(opts.OrgID).
			SetLocation(opts.Location).
			SetNillableDescription(opts.Description).
			SetNillableFallback(opts.Fallback).
			SetProvider(opts.Provider).
			SetNillableDefault(opts.Default).
			SetNillableManaged(opts.Managed).
			SetSecretName(opts.SecretName).
			SetMaxBlobSizeBytes(opts.MaxBytes).
			Save(ctx)
		if err != nil {
			if ent.IsConstraintError(err) {
				return biz.NewErrAlreadyExists(err)
			}

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