software-engineering/zitadel-k8s-operator
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix instance deletion

Browse Source 
[ZITADOPER-1]
This commit is contained in:
Haim Kortovich
2024-05-28 18:12:31 -05:00
parent 2fb58abd75
commit e00d976565
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/internal/controller/zitadelcluster_controller.go
View File

@@ -383,7 +383,8 @@ func (r *ZitadelClusterReconciler) reconcileDefaultInstance(ctx context.Context,
return ctrl.Result{}, fmt.Errorf("Error listing instances: %v", err) return ctrl.Result{}, fmt.Errorf("Error listing instances: %v", err)
} }
for _, instance := range resp.Result { for _, instance := range resp.Result {
if instance.Id != zitadel.Status.DefaultInstanceId || instance.Id == "" { if instance != nil {
if instance.Id != zitadel.Status.DefaultInstanceId || zitadel.Status.DefaultInstanceId == "" {
fmt.Println("DELETING INSTANCE") fmt.Println("DELETING INSTANCE")
_, err := ztdClient.RemoveInstance(ctx, &pb.RemoveInstanceRequest{InstanceId: instance.Id}) _, err := ztdClient.RemoveInstance(ctx, &pb.RemoveInstanceRequest{InstanceId: instance.Id})
if err != nil { if err != nil {
@@ -392,6 +393,7 @@ func (r *ZitadelClusterReconciler) reconcileDefaultInstance(ctx context.Context,
} }
} }
} }
}
// Check if instance already exists // Check if instance already exists
_, err = ztdClient.GetInstance(ctx, &pb.GetInstanceRequest{InstanceId: zitadel.Status.DefaultInstanceId}) _, err = ztdClient.GetInstance(ctx, &pb.GetInstanceRequest{InstanceId: zitadel.Status.DefaultInstanceId})