Method UpdateVMStatus

pkg/mockpve/state.go:482–517

(vmid string, action string)

}

func (s *MockState) UpdateVMStatus(vmid string, action string) (string, error) {
	s.mu.Lock()
	// Check if VM exists
	vm, ok := s.VMs[vmid]
	s.mu.Unlock()

	if !ok {
		return "", fmt.Errorf("vm not found")
	}

	// Queue task
	// NOTE: We queue the task first, but the state update (running -> stopped) happens when the task completes.
	// OR for simplicity in testing, we might update it immediately or inside the goroutine.
	// To test "Waiting", we should update it in the goroutine.

	upid := s.createTaskWithCompletion(vm.Node, "qm"+action, vmid, "root@pam", func() {
		s.mu.Lock()
		defer s.mu.Unlock()

		if vm, ok := s.VMs[vmid]; ok {
			switch action {
			case "start":
				vm.Status = guestStatusRunning
				vm.Uptime = 1
			case "stop", "shutdown":
				vm.Status = guestStatusStopped
				vm.Uptime = 0
			case "reboot":
				vm.Status = guestStatusRunning
				vm.Uptime = 1
			}
		}
	})

	return upid, nil
}

func (s *MockState) DeleteVM(vmid string) error {
	s.mu.Lock()