package controller import ( "strings" zitadelv1alpha1 "bitbucket.org/topmanage-software-engineering/zitadel-k8s-operator/src/api/v1alpha1" "bitbucket.org/topmanage-software-engineering/zitadel-k8s-operator/src/pkg/controller/zitadel" "context" "fmt" "github.com/zitadel/zitadel-go/v3/pkg/client/management" "github.com/zitadel/zitadel-go/v3/pkg/client/middleware" pb "github.com/zitadel/zitadel-go/v3/pkg/client/zitadel/management" "sigs.k8s.io/controller-runtime/pkg/client" ctrlClient "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" ) const ( OIDCAppFinalizerName = "oidcapp.zitadel.topmanage.com/oidcapp" ) type wrappedOIDCAppFinalizer struct { client.Client OIDCApp *zitadelv1alpha1.OIDCApp refresolver *zitadelv1alpha1.RefResolver } func newWrappedOIDCAppFinalizer(client client.Client, OIDCApp *zitadelv1alpha1.OIDCApp, refresolver *zitadelv1alpha1.RefResolver) zitadel.WrappedFinalizer { return &wrappedOIDCAppFinalizer{ Client: client, OIDCApp: OIDCApp, refresolver: refresolver, } } func (wf *wrappedOIDCAppFinalizer) AddFinalizer(ctx context.Context) error { if wf.ContainsFinalizer() { return nil } return wf.patch(ctx, wf.OIDCApp, func(OIDCApp *zitadelv1alpha1.OIDCApp) { controllerutil.AddFinalizer(OIDCApp, OIDCAppFinalizerName) }) } func (wf *wrappedOIDCAppFinalizer) RemoveFinalizer(ctx context.Context) error { if !wf.ContainsFinalizer() { return nil } return wf.patch(ctx, wf.OIDCApp, func(OIDCApp *zitadelv1alpha1.OIDCApp) { controllerutil.RemoveFinalizer(wf.OIDCApp, OIDCAppFinalizerName) }) } func (wr *wrappedOIDCAppFinalizer) ContainsFinalizer() bool { return controllerutil.ContainsFinalizer(wr.OIDCApp, OIDCAppFinalizerName) } func (wf *wrappedOIDCAppFinalizer) Reconcile(ctx context.Context, ztdClient *management.Client) error { if wf.OIDCApp.Status.AppId == "" { return nil } org, err := wf.OIDCApp.Organization(ctx, wf.refresolver) if err != nil { return err } project, err := wf.OIDCApp.Project(ctx, wf.refresolver) if err != nil { return err } _, err = ztdClient.RemoveApp(middleware.SetOrgID(ctx, org.Status.OrgId), &pb.RemoveAppRequest{ProjectId: project.Status.ProjectId, AppId: wf.OIDCApp.Status.AppId}) if err != nil { if strings.Contains(err.Error(), "doesn't exist") { return nil } return err } return nil } func (wr *wrappedOIDCAppFinalizer) patch(ctx context.Context, OIDCApp *zitadelv1alpha1.OIDCApp, patchFn func(*zitadelv1alpha1.OIDCApp)) error { patch := ctrlClient.MergeFrom(OIDCApp.DeepCopy()) patchFn(OIDCApp) if err := wr.Client.Patch(ctx, OIDCApp, patch); err != nil { return fmt.Errorf("error patching OIDCApp finalizer: %v", err) } return nil }