Do not put machine in failed state if VM is is topping or stopped state, and use ID from instance during deletion

Author: shyamradhakrishnan

cloud/scope/machine.go

@@ -301,8 +301,8 @@ func (m *MachineScope) getFreeFormTags() map[string]string {
 }
 
 // DeleteMachine terminates the instance using InstanceId from the OCIMachine spec and deletes the boot volume
-func (m *MachineScope) DeleteMachine(ctx context.Context) error {
-	req := core.TerminateInstanceRequest{InstanceId: m.OCIMachine.Spec.InstanceId,
+func (m *MachineScope) DeleteMachine(ctx context.Context, instance *core.Instance) error {
+	req := core.TerminateInstanceRequest{InstanceId: instance.Id,
 		PreserveBootVolume: common.Bool(false)}
 	_, err := m.ComputeClient.TerminateInstance(ctx, req)
 	return err
@@ -405,6 +405,11 @@ func (m *MachineScope) SetReady() {
 	m.OCIMachine.Status.Ready = true
 }
 
+// SetNotReady sets the OCIMachine Ready Status to false.
+func (m *MachineScope) SetNotReady() {
+	m.OCIMachine.Status.Ready = false
+}
+
 // IsReady returns the ready status of the machine.
 func (m *MachineScope) IsReady() bool {
 	return m.OCIMachine.Status.Ready

controllers/ocimachine_controller.go

@@ -326,6 +326,10 @@ func (r *OCIMachineReconciler) reconcileNormal(ctx context.Context, logger logr.
 		machineScope.Info("Instance is pending")
 		conditions.MarkFalse(machineScope.OCIMachine, infrastructurev1beta2.InstanceReadyCondition, infrastructurev1beta2.InstanceNotReadyReason, clusterv1.ConditionSeverityInfo, "")
 		return reconcile.Result{RequeueAfter: 10 * time.Second}, nil
+	case core.InstanceLifecycleStateStopping, core.InstanceLifecycleStateStopped:
+		machineScope.SetNotReady()
+		conditions.MarkFalse(machineScope.OCIMachine, infrastructurev1beta2.InstanceReadyCondition, infrastructurev1beta2.InstanceNotReadyReason, clusterv1.ConditionSeverityInfo, "")
+		return reconcile.Result{}, nil
 	case core.InstanceLifecycleStateRunning:
 		machineScope.Info("Instance is active")
 		if machine.Status.Addresses == nil || len(machine.Status.Addresses) == 0 {
@@ -446,7 +450,7 @@ func (r *OCIMachineReconciler) reconcileDelete(ctx context.Context, machineScope
 		if err != nil {
 			return reconcile.Result{}, err
 		}
-		if err := machineScope.DeleteMachine(ctx); err != nil {
+		if err := machineScope.DeleteMachine(ctx, instance); err != nil {
 			machineScope.Error(err, "Error deleting Instance")
 			return ctrl.Result{}, errors.Wrapf(err, "error deleting instance %s", machineScope.Name())
 		}

controllers/ocimachine_controller_test.go

@@ -302,6 +302,38 @@ func TestNormalReconciliationFunction(t *testing.T) {
 				g.Expect(result.RequeueAfter).To(Equal(300 * time.Second))
 			},
 		},
+		{
+			name:               "instance in stopped state",
+			errorExpected:      false,
+			conditionAssertion: []conditionAssertion{{infrastructurev1beta2.InstanceReadyCondition, corev1.ConditionFalse, clusterv1.ConditionSeverityInfo, infrastructurev1beta2.InstanceNotReadyReason}},
+			testSpecificSetup: func(t *test, machineScope *scope.MachineScope, computeClient *mock_compute.MockComputeClient, vcnClient *mock_vcn.MockClient, nlbclient *mock_nlb.MockNetworkLoadBalancerClient) {
+				computeClient.EXPECT().GetInstance(gomock.Any(), gomock.Eq(core.GetInstanceRequest{
+					InstanceId: common.String("test"),
+				})).
+					Return(core.GetInstanceResponse{
+						Instance: core.Instance{
+							Id:             common.String("test"),
+							LifecycleState: core.InstanceLifecycleStateStopped,
+						},
+					}, nil)
+			},
+		},
+		{
+			name:               "instance in stopping state",
+			errorExpected:      false,
+			conditionAssertion: []conditionAssertion{{infrastructurev1beta2.InstanceReadyCondition, corev1.ConditionFalse, clusterv1.ConditionSeverityInfo, infrastructurev1beta2.InstanceNotReadyReason}},
+			testSpecificSetup: func(t *test, machineScope *scope.MachineScope, computeClient *mock_compute.MockComputeClient, vcnClient *mock_vcn.MockClient, nlbclient *mock_nlb.MockNetworkLoadBalancerClient) {
+				computeClient.EXPECT().GetInstance(gomock.Any(), gomock.Eq(core.GetInstanceRequest{
+					InstanceId: common.String("test"),
+				})).
+					Return(core.GetInstanceResponse{
+						Instance: core.Instance{
+							Id:             common.String("test"),
+							LifecycleState: core.InstanceLifecycleStateStopping,
+						},
+					}, nil)
+			},
+		},
 		{
 			name:               "instance in terminated state",
 			errorExpected:      true,