Skip to content

Commit

Permalink
[Helm] Remove from SupportsOwnerReference
Browse files Browse the repository at this point in the history
Signed-off-by: varshaprasad96 <varshaprasad96@gmail.com>
  • Loading branch information
varshaprasad96 committed Oct 15, 2021
1 parent 38d1ff7 commit fa48880
Show file tree
Hide file tree
Showing 7 changed files with 15 additions and 19 deletions.
2 changes: 1 addition & 1 deletion internal/controller/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ func watchDependentResources(mgr manager.Manager, r *HelmOperatorReconciler, c c
}

restMapper := mgr.GetRESTMapper()
useOwnerRef, err := controllerutil.SupportsOwnerReference(restMapper, owner, dependent, "")
useOwnerRef, err := controllerutil.SupportsOwnerReference(restMapper, owner, dependent)
if err != nil {
return err
}
Expand Down
5 changes: 1 addition & 4 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@ import (
"sigs.k8s.io/kubebuilder/v3/pkg/model/stage"
"sigs.k8s.io/kubebuilder/v3/pkg/plugin"

helmcmd "github.com/operator-framework/helm-operator-plugins/internal/cmd/helm-operator/run"
hybridcmd "github.com/operator-framework/helm-operator-plugins/internal/cmd/hybrid-operator/run"
"github.com/operator-framework/helm-operator-plugins/internal/version"
pluginv1 "github.com/operator-framework/helm-operator-plugins/pkg/plugins/helm/v1"
Expand All @@ -39,18 +38,16 @@ import (
func main() {
commands := []*cobra.Command{
hybridcmd.NewCmd(),
helmcmd.NewCmd(),
}
c, err := cli.New(
cli.WithCommandName("helm-operator"),
cli.WithVersion(getVersion()),
cli.WithPlugins(
getHybridPlugin(),
golangv3.Plugin{},
getHelmPlugin(),
),
cli.WithDefaultProjectVersion(config.Version),
cli.WithDefaultPlugins(config.Version, getHybridPlugin(), getHelmPlugin()),
cli.WithDefaultPlugins(config.Version, getHybridPlugin()),
cli.WithExtraCommands(commands...),
)
if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion pkg/client/actionclient.go
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ func (pr *ownerPostRenderer) Run(in *bytes.Buffer) (*bytes.Buffer, error) {
return err
}
u := &unstructured.Unstructured{Object: objMap}
useOwnerRef, err := controllerutil.SupportsOwnerReference(pr.rm, pr.owner, u, "")
useOwnerRef, err := controllerutil.SupportsOwnerReference(pr.rm, pr.owner, u)
if err != nil {
return err
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/client/helm/client/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ func (c *ownerRefInjectingClient) Build(reader io.Reader, validate bool) (kube.R
return err
}
u := &unstructured.Unstructured{Object: objMap}
useOwnerRef, err := controllerutil.SupportsOwnerReference(c.restMapper, c.owner, u, "")
useOwnerRef, err := controllerutil.SupportsOwnerReference(c.restMapper, c.owner, u)
if err != nil {
return err
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/reconciler/internal/hook/hook.go
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ func (d *dependentResourceWatcher) Exec(owner *unstructured.Unstructured, rel re
continue
}

useOwnerRef, err := controllerutil.SupportsOwnerReference(d.restMapper, owner, &obj, "")
useOwnerRef, err := controllerutil.SupportsOwnerReference(d.restMapper, owner, &obj)
if err != nil {
return err
}
Expand Down
7 changes: 3 additions & 4 deletions pkg/sdk/controllerutil/controllerutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ func WaitForDeletion(ctx context.Context, cl client.Reader, o client.Object) err
}, ctx.Done())
}

func SupportsOwnerReference(restMapper meta.RESTMapper, owner, dependent runtime.Object, depNamespace string) (bool, error) {
func SupportsOwnerReference(restMapper meta.RESTMapper, owner, dependent runtime.Object) (bool, error) {
ownerGVK := owner.GetObjectKind().GroupVersionKind()
ownerMapping, err := restMapper.RESTMapping(ownerGVK.GroupKind(), ownerGVK.Version)
if err != nil {
Expand All @@ -83,9 +83,8 @@ func SupportsOwnerReference(restMapper meta.RESTMapper, owner, dependent runtime
ownerClusterScoped := ownerMapping.Scope.Name() == meta.RESTScopeNameRoot
ownerNamespace := mOwner.GetNamespace()
depClusterScoped := depMapping.Scope.Name() == meta.RESTScopeNameRoot
if depNamespace == "" {
depNamespace = mDep.GetNamespace()
}

depNamespace := mDep.GetNamespace()

if ownerClusterScoped {
return true, nil
Expand Down
14 changes: 7 additions & 7 deletions pkg/sdk/controllerutil/controllerutil_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,13 +91,13 @@ var _ = Describe("Controllerutil", func() {
})
It("should be true for cluster-scoped dependents", func() {
dependent = createObject(clusterScoped, types.NamespacedName{Namespace: "", Name: "dependent"})
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeTrue())
Expect(err).To(BeNil())
})
It("should be true for namespace-scoped dependents", func() {
dependent = createObject(namespaceScoped, types.NamespacedName{Namespace: "ns1", Name: "dependent"})
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeTrue())
Expect(err).To(BeNil())
})
Expand All @@ -108,22 +108,22 @@ var _ = Describe("Controllerutil", func() {
})
It("should be false for cluster-scoped dependents", func() {
dependent = createObject(clusterScoped, types.NamespacedName{Namespace: "", Name: "dependent"})
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, dependent.GetNamespace())
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeFalse())
Expect(err).To(BeNil())
})
When("dependent is in owner namespace", func() {
It("should be true", func() {
dependent = createObject(namespaceScoped, types.NamespacedName{Namespace: "ns1", Name: "dependent"})
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeTrue())
Expect(err).To(BeNil())
})
})
When("dependent is not in owner namespace", func() {
It("should be false", func() {
dependent = createObject(namespaceScoped, types.NamespacedName{Namespace: "ns2", Name: "dependent"})
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeFalse())
Expect(err).To(BeNil())
})
Expand All @@ -140,13 +140,13 @@ var _ = Describe("Controllerutil", func() {
rm = meta.NewDefaultRESTMapper([]schema.GroupVersion{})
})
It("fails when owner REST mapping is missing", func() {
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeFalse())
Expect(err).NotTo(BeNil())
})
It("fails when dependent REST mapping is missing", func() {
rm.Add(clusterScoped, meta.RESTScopeRoot)
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent, "")
supportsOwnerRef, err := SupportsOwnerReference(rm, owner, dependent)
Expect(supportsOwnerRef).To(BeFalse())
Expect(err).NotTo(BeNil())
})
Expand Down

0 comments on commit fa48880

Please sign in to comment.