Method Delete

app/controlplane/pkg/biz/integration.go:303–336

(ctx context.Context, orgID, integrationID string)

}

func (uc *IntegrationUseCase) Delete(ctx context.Context, orgID, integrationID string) error {
	ctx, span := otelx.Start(ctx, integrationTracer, "IntegrationUseCase.Delete")
	defer span.End()

	orgUUID, err := uuid.Parse(orgID)
	if err != nil {
		return NewErrInvalidUUID(err)
	}

	integrationUUID, err := uuid.Parse(integrationID)
	if err != nil {
		return NewErrInvalidUUID(err)
	}

	uc.logger.Infow("msg", "deleting integration", "ID", integrationID)
	// Make sure that the integration is from this org and it has not associated workflows
	integration, err := uc.integrationRepo.FindByIDInOrg(ctx, orgUUID, integrationUUID)
	if err != nil {
		return err
	} else if integration == nil {
		return NewErrNotFound("integration")
	}

	if integration.SecretName != "" {
		uc.logger.Infow("msg", "deleting integration external secrets", "ID", integrationID, "secretName", integration.SecretName)
		if err := uc.credsRW.DeleteCredentials(ctx, integration.SecretName); err != nil {
			uc.logger.Warnw("msg", "can't delete credentials", "name", integration.SecretName, "err", err)
		}
	}

	uc.logger.Infow("msg", "integration deleted", "ID", integrationID)
	// Check that the workflow to delete belongs to the provided organization
	return uc.integrationRepo.SoftDelete(ctx, integrationUUID)
}

type ListAttachmentsOpts struct {
	// limit search for a particular workflow