Skip to content

Commit

Permalink
Fix: missing odh-admins group (#535)
Browse files Browse the repository at this point in the history
Signed-off-by: Wen Zhou <wenzhou@redhat.com>
  • Loading branch information
zdtsw authored Sep 14, 2023
1 parent b6e0587 commit 461faa8
Show file tree
Hide file tree
Showing 2 changed files with 31 additions and 19 deletions.
27 changes: 8 additions & 19 deletions controllers/dscinitialization/dscinitialization_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,13 +21,11 @@ import (
"context"
"fmt"
operatorv1 "github.com/openshift/api/operator/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

logr "github.com/go-logr/logr"

"k8s.io/client-go/util/retry"

ocuserv1 "github.com/openshift/api/user/v1"
appsv1 "k8s.io/api/apps/v1"
corev1 "k8s.io/api/core/v1"
netv1 "k8s.io/api/networking/v1"
Expand Down Expand Up @@ -153,27 +151,18 @@ func (r *DSCInitializationReconciler) Reconcile(ctx context.Context, req ctrl.Re
} else {
// Apply self-managed rhods config
// Create rhods-admins Group if it doesn't exist
rhodsuserGroup := &ocuserv1.Group{
ObjectMeta: metav1.ObjectMeta{
Name: "rhods-admins",
},
}
err := r.Client.Get(ctx, client.ObjectKey{
Name: rhodsuserGroup.Name,
}, rhodsuserGroup)
err := r.createUserGroup(instance, "rhods-admins", ctx)
if err != nil {
if apierrs.IsNotFound(err) {
err = r.Client.Create(ctx, rhodsuserGroup)
if err != nil && !apierrs.IsAlreadyExists(err) {
return reconcile.Result{}, err
}
} else {
return reconcile.Result{}, err
}
return reconcile.Result{}, err
}
}

// Apply common rhods-specific config
} else { // ODH case
// Create odh-admins Group if it doesn't exist
err := r.createUserGroup(instance, "odh-admins", ctx)
if err != nil {
return reconcile.Result{}, err
}
}

// If monitoring enabled
Expand Down
23 changes: 23 additions & 0 deletions controllers/dscinitialization/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (
"reflect"
"time"

ocuserv1 "github.com/openshift/api/user/v1"
corev1 "k8s.io/api/core/v1"
netv1 "k8s.io/api/networking/v1"
authv1 "k8s.io/api/rbac/v1"
Expand Down Expand Up @@ -330,3 +331,25 @@ func (r *DSCInitializationReconciler) createOdhCommonConfigMap(dscInit *dsci.DSC
}
return nil
}

func (r *DSCInitializationReconciler) createUserGroup(dscInit *dsci.DSCInitialization, userGroupName string, ctx context.Context) error {
userGroup := &ocuserv1.Group{
ObjectMeta: metav1.ObjectMeta{
Name: userGroupName,
},
}
err := r.Client.Get(ctx, client.ObjectKey{
Name: userGroup.Name,
}, userGroup)
if err != nil {
if apierrs.IsNotFound(err) {
err = r.Client.Create(ctx, userGroup)
if err != nil && !apierrs.IsAlreadyExists(err) {
return err
}
} else {
return err
}
}
return nil
}

0 comments on commit 461faa8

Please sign in to comment.