Method CleanupRelease

internal/helm/release/manager.go:409–452

CleanupRelease deletes resources if they are not deleted already. Return true if all the resources are deleted, false otherwise.

(manifest string)

// CleanupRelease deletes resources if they are not deleted already.
// Return true if all the resources are deleted, false otherwise.
func (m manager) CleanupRelease(manifest string) (bool, error) {
	dc, err := m.actionConfig.RESTClientGetter.ToDiscoveryClient()
	if err != nil {
		return false, fmt.Errorf("failed to get Kubernetes discovery client: %w", err)
	}
	apiVersions, err := action.GetVersionSet(dc)
	if err != nil && !discovery.IsGroupDiscoveryFailedError(err) {
		return false, fmt.Errorf("failed to get apiVersions from Kubernetes: %w", err)
	}
	manifests := releaseutil.SplitManifests(manifest)
	_, files, err := releaseutil.SortManifests(manifests, apiVersions, releaseutil.UninstallOrder)
	if err != nil {
		return false, fmt.Errorf("failed to sort manifests: %w", err)
	}
	// do not delete resources that are annotated with the Helm resource policy 'keep'
	_, filesToDelete := manifestutil.FilterManifestsToKeep(files)
	var builder strings.Builder
	for _, file := range filesToDelete {
		builder.WriteString("\n---\n" + file.Content)
	}
	resources, err := m.kubeClient.Build(strings.NewReader(builder.String()), false)
	if err != nil {
		return false, fmt.Errorf("failed to build resources from manifests: %w", err)
	}
	if len(resources) <= 0 {
		return true, nil
	}
	for _, resource := range resources {
		err = resource.Get()
		if err != nil {
			if apierrors.IsNotFound(err) {
				continue // resource is already delete, check the next one.
			}
			return false, fmt.Errorf("failed to get resource: %w", err)
		}
		// found at least one resource that is not deleted so just delete everything again.
		_, errs := m.kubeClient.Delete(resources)
		if len(errs) > 0 {
			return false, fmt.Errorf("failed to delete resources: %v", apiutilerrors.NewAggregate(errs))
		}
		return false, nil
	}
	return true, nil
}