-
Notifications
You must be signed in to change notification settings - Fork 52
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
✨ refactor ClusterExtensionReconciler.reconcile() (#1068)
* update reconciler with logical interface abstractions to simply unit testing by moving bundle validation logic to the resolver, moving installation of content behind a new Applier interface, and using the new contentmanager.Watcher interface for watching managed objects Signed-off-by: everettraven <everettraven@gmail.com> * update testing Signed-off-by: everettraven <everettraven@gmail.com> * update testing Signed-off-by: everettraven <everettraven@gmail.com> * remove bundle validation unit tests from controller package Signed-off-by: everettraven <everettraven@gmail.com> * make linter happy Signed-off-by: everettraven <everettraven@gmail.com> * remove postrenderer, replace with map[string]string for labels Signed-off-by: everettraven <everettraven@gmail.com> * update debugging error string Signed-off-by: everettraven <everettraven@gmail.com> * rebase fixes Signed-off-by: everettraven <everettraven@gmail.com> --------- Signed-off-by: everettraven <everettraven@gmail.com>
- Loading branch information
1 parent
989a3df
commit cab9eab
Showing
11 changed files
with
791 additions
and
361 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,166 @@ | ||
| package applier | ||
|
|
||
| import ( | ||
| "context" | ||
| "errors" | ||
| "fmt" | ||
| "io/fs" | ||
| "strings" | ||
|
|
||
| "helm.sh/helm/v3/pkg/action" | ||
| "helm.sh/helm/v3/pkg/chart" | ||
| "helm.sh/helm/v3/pkg/chartutil" | ||
| "helm.sh/helm/v3/pkg/release" | ||
| "helm.sh/helm/v3/pkg/storage/driver" | ||
| corev1 "k8s.io/api/core/v1" | ||
| "sigs.k8s.io/controller-runtime/pkg/client" | ||
|
|
||
| helmclient "github.com/operator-framework/helm-operator-plugins/pkg/client" | ||
|
|
||
| ocv1alpha1 "github.com/operator-framework/operator-controller/api/v1alpha1" | ||
| "github.com/operator-framework/operator-controller/internal/rukpak/convert" | ||
| "github.com/operator-framework/operator-controller/internal/rukpak/preflights/crdupgradesafety" | ||
| "github.com/operator-framework/operator-controller/internal/rukpak/util" | ||
| ) | ||
|
|
||
| const ( | ||
| StateNeedsInstall string = "NeedsInstall" | ||
| StateNeedsUpgrade string = "NeedsUpgrade" | ||
| StateUnchanged string = "Unchanged" | ||
| StateError string = "Error" | ||
| maxHelmReleaseHistory = 10 | ||
| ) | ||
|
|
||
| // Preflight is a check that should be run before making any changes to the cluster | ||
| type Preflight interface { | ||
| // Install runs checks that should be successful prior | ||
| // to installing the Helm release. It is provided | ||
| // a Helm release and returns an error if the | ||
| // check is unsuccessful | ||
| Install(context.Context, *release.Release) error | ||
|
|
||
| // Upgrade runs checks that should be successful prior | ||
| // to upgrading the Helm release. It is provided | ||
| // a Helm release and returns an error if the | ||
| // check is unsuccessful | ||
| Upgrade(context.Context, *release.Release) error | ||
| } | ||
|
|
||
| type Helm struct { | ||
| ActionClientGetter helmclient.ActionClientGetter | ||
| Preflights []Preflight | ||
| } | ||
|
|
||
| func (h *Helm) Apply(ctx context.Context, contentFS fs.FS, ext *ocv1alpha1.ClusterExtension, labels map[string]string) ([]client.Object, string, error) { | ||
| chrt, err := convert.RegistryV1ToHelmChart(ctx, contentFS, ext.Spec.InstallNamespace, []string{corev1.NamespaceAll}) | ||
| if err != nil { | ||
| return nil, "", err | ||
| } | ||
| values := chartutil.Values{} | ||
|
|
||
| ac, err := h.ActionClientGetter.ActionClientFor(ctx, ext) | ||
| if err != nil { | ||
| return nil, "", err | ||
| } | ||
|
|
||
| rel, desiredRel, state, err := h.getReleaseState(ac, ext, chrt, values, labels) | ||
| if err != nil { | ||
| return nil, "", err | ||
| } | ||
|
|
||
| for _, preflight := range h.Preflights { | ||
| if ext.Spec.Preflight != nil && ext.Spec.Preflight.CRDUpgradeSafety != nil { | ||
| if _, ok := preflight.(*crdupgradesafety.Preflight); ok && ext.Spec.Preflight.CRDUpgradeSafety.Disabled { | ||
| // Skip this preflight check because it is of type *crdupgradesafety.Preflight and the CRD Upgrade Safety | ||
| // preflight check has been disabled | ||
| continue | ||
| } | ||
| } | ||
| switch state { | ||
| case StateNeedsInstall: | ||
| err := preflight.Install(ctx, desiredRel) | ||
| if err != nil { | ||
| return nil, state, err | ||
| } | ||
| case StateNeedsUpgrade: | ||
| err := preflight.Upgrade(ctx, desiredRel) | ||
| if err != nil { | ||
| return nil, state, err | ||
| } | ||
| } | ||
| } | ||
|
|
||
| switch state { | ||
| case StateNeedsInstall: | ||
| rel, err = ac.Install(ext.GetName(), ext.Spec.InstallNamespace, chrt, values, func(install *action.Install) error { | ||
| install.CreateNamespace = false | ||
| install.Labels = labels | ||
| return nil | ||
| }) | ||
| if err != nil { | ||
| return nil, state, err | ||
| } | ||
| case StateNeedsUpgrade: | ||
| rel, err = ac.Upgrade(ext.GetName(), ext.Spec.InstallNamespace, chrt, values, func(upgrade *action.Upgrade) error { | ||
| upgrade.MaxHistory = maxHelmReleaseHistory | ||
| upgrade.Labels = labels | ||
| return nil | ||
| }) | ||
| if err != nil { | ||
| return nil, state, err | ||
| } | ||
| case StateUnchanged: | ||
| if err := ac.Reconcile(rel); err != nil { | ||
| return nil, state, err | ||
| } | ||
| default: | ||
| return nil, state, fmt.Errorf("unexpected release state %q", state) | ||
| } | ||
|
|
||
| relObjects, err := util.ManifestObjects(strings.NewReader(rel.Manifest), fmt.Sprintf("%s-release-manifest", rel.Name)) | ||
| if err != nil { | ||
| return nil, state, err | ||
| } | ||
|
|
||
| return relObjects, state, nil | ||
| } | ||
|
|
||
| func (h *Helm) getReleaseState(cl helmclient.ActionInterface, ext *ocv1alpha1.ClusterExtension, chrt *chart.Chart, values chartutil.Values, labels map[string]string) (*release.Release, *release.Release, string, error) { | ||
| currentRelease, err := cl.Get(ext.GetName()) | ||
| if err != nil && !errors.Is(err, driver.ErrReleaseNotFound) { | ||
| return nil, nil, StateError, err | ||
| } | ||
| if errors.Is(err, driver.ErrReleaseNotFound) { | ||
| return nil, nil, StateNeedsInstall, nil | ||
| } | ||
|
|
||
| if errors.Is(err, driver.ErrReleaseNotFound) { | ||
| desiredRelease, err := cl.Install(ext.GetName(), ext.Spec.InstallNamespace, chrt, values, func(i *action.Install) error { | ||
| i.DryRun = true | ||
| i.DryRunOption = "server" | ||
| i.Labels = labels | ||
| return nil | ||
| }) | ||
| if err != nil { | ||
| return nil, nil, StateError, err | ||
| } | ||
| return nil, desiredRelease, StateNeedsInstall, nil | ||
| } | ||
| desiredRelease, err := cl.Upgrade(ext.GetName(), ext.Spec.InstallNamespace, chrt, values, func(upgrade *action.Upgrade) error { | ||
| upgrade.MaxHistory = maxHelmReleaseHistory | ||
| upgrade.DryRun = true | ||
| upgrade.DryRunOption = "server" | ||
| upgrade.Labels = labels | ||
| return nil | ||
| }) | ||
| if err != nil { | ||
| return currentRelease, nil, StateError, err | ||
| } | ||
| relState := StateUnchanged | ||
| if desiredRelease.Manifest != currentRelease.Manifest || | ||
| currentRelease.Info.Status == release.StatusFailed || | ||
| currentRelease.Info.Status == release.StatusSuperseded { | ||
| relState = StateNeedsUpgrade | ||
| } | ||
| return currentRelease, desiredRelease, relState, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.