Method Create

app/controlplane/pkg/data/integration.go:46–68

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

}

func (r *IntegrationRepo) Create(ctx context.Context, opts *biz.IntegrationCreateOpts) (*biz.Integration, error) {
	ctx, span := otelx.Start(ctx, integrationRepoTracer, "IntegrationRepo.Create")
	defer span.End()

	integration, err := r.data.DB.Integration.Create().
		SetName(opts.Name).
		SetOrganizationID(opts.OrgID).
		SetKind(opts.Kind).
		SetDescription(opts.Description).
		SetSecretName(opts.SecretName).
		SetConfiguration(opts.Config).
		Save(ctx)

	if err != nil {
		if ent.IsConstraintError(err) {
			return nil, biz.NewErrAlreadyExists(err)
		}

		return nil, fmt.Errorf("failed to create registration: %w", err)
	}

	return entIntegrationToBiz(integration), nil
}

func (r *IntegrationRepo) List(ctx context.Context, orgID uuid.UUID) ([]*biz.Integration, error) {
	ctx, span := otelx.Start(ctx, integrationRepoTracer, "IntegrationRepo.List")