package ovirtsdk

import (
	"fmt"
	"time"
)

const DefaultInterval = 10 * time.Second

const DefaultVMTimeout = 120 * time.Second

// WaitForVM waits for VM to given status
func (c *Connection) WaitForVM(vmID string, status VmStatus, timeout time.Duration) error {
	if timeout <= 0 {
		timeout = DefaultVMTimeout
	}
	if vmID == "" {
		return fmt.Errorf("the VM ID must not be empty")
	}
	vmService := c.SystemService().VmsService().VmService(vmID)
	for {
		resp, err := vmService.Get().Send()
		if err != nil {
			return err
		}
		if timeout <= 0 {
			return fmt.Errorf("timeout for waiting for VM to %v", status)
		}

		vm, ok := resp.Vm()
		if !ok {
			continue
		}
		if vm.MustStatus() == status {
			break
		}

		timeout = timeout - DefaultInterval
		time.Sleep(DefaultInterval)
	}

	return nil
}

const DefaultDiskTimeout = 120 * time.Second

func (c *Connection) WaitForDisk(diskID string, status DiskStatus, timeout time.Duration) error {
	if timeout <= 0 {
		timeout = DefaultDiskTimeout
	}
	if diskID == "" {
		return fmt.Errorf("the Disk ID must not be empty")
	}
	diskService := c.SystemService().DisksService().DiskService(diskID)
	for {
		resp, err := diskService.Get().Send()
		if err != nil {
			return err
		}
		if timeout <= 0 {
			return fmt.Errorf("timeout for waiting for Disk to %v", status)
		}

		disk, ok := resp.Disk()
		if !ok {
			continue
		}
		if disk.MustStatus() == status {
			break
		}

		timeout = timeout - DefaultInterval
		time.Sleep(DefaultInterval)
	}

	return nil
}