Module: ForemanFogProxmox::ProxmoxVmCommands

Includes:
ProxmoxPools, ProxmoxVolumes, ProxmoxVmHelper
Included in:
Proxmox
Defined in:
app/models/foreman_fog_proxmox/proxmox_vm_commands.rb

Instance Method Summary collapse

Methods included from ProxmoxVmHelper

#parse_typed_vm, #vm_collection

Methods included from ProxmoxVmOsTemplateHelper

#ostemplate_keys, #parse_container_ostemplate, #parse_ostemplate, #parse_ostemplate_without_keys

Methods included from ProxmoxVmConfigHelper

#args_a, #config_a, #config_general_or_ostemplate_key?, #config_options, #config_typed_keys, #general_a, #object_to_config_hash, #parse_typed_cpu, #parse_typed_memory, #parsed_typed_config

Methods included from ProxmoxVmVolumesHelper

#add_disk_options, #add_typed_volume, #parse_hard_disk_volume, #parse_typed_volume, #parse_typed_volumes, #parsed_typed_volumes, #remove_volume_keys, #volume_type?

Methods included from ProxmoxVmCloudinitHelper

#parse_server_cloudinit

Methods included from ProxmoxVmCdromHelper

#parse_server_cdrom

Methods included from ProxmoxVmInterfacesHelper

#add_or_delete_typed_interface, #compute_dhcps, #interface_common_typed_keys, #interface_compute_attributes_typed_keys, #parse_typed_interfaces, #parsed_typed_interfaces

Methods included from ProxmoxPools

#add_vm_to_pool, #pool_owner, #pools, #remove_vm_from_pool, #update_pool

Methods included from ProxmoxVolumes

#add_volume, #delete_volume, #extend_volume, #extract_id, #move_volume, #save_volume, #update_cdrom, #update_options, #update_volume, #update_volume_required?, #volume_exists?, #volume_options, #volume_to_delete?

Instance Method Details

#compute_clone_attributes(args, container, type) ⇒ Object 



58
59
60
61
62
63
64
65
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 58

def compute_clone_attributes(args, container, type)
  parsed_args = parse_typed_vm(args, type)
  if container
    options = { :hostname => args[:name] }
    parsed_args.merge(options)
  end
  parsed_args.reject { |k| k == 'pool' }
end

#compute_config_attributes(parsed_attr) ⇒ Object 



85
86
87
88
89
90
91
92
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 85

def compute_config_attributes(parsed_attr)
  excluded_keys = [:vmid, :templated, :ostemplate, :ostemplate_file, :ostemplate_storage, :volumes_attributes,
                   :pool]
  config_attributes = parsed_attr.reject { |key, _value| excluded_keys.include? key.to_sym }
  ForemanFogProxmox::HashCollection.remove_empty_values(config_attributes)
  config_attributes = config_attributes.reject { |key, _value| Fog::Proxmox::DiskHelper.disk?(key) }
  { config_attributes: config_attributes }
end

#create_vm(args = {}) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 34

def create_vm(args = {})
  vmid = args[:vmid].to_i
  type = args[:type]
  node = client.nodes.get(args[:node_id])
  vmid = node.servers.next_id.to_i if vmid < 1
  raise ::Foreman::Exception, format(N_('invalid vmid=%<vmid>s'), vmid: vmid) unless node.servers.id_valid?(vmid)

  image_id = args[:image_id]
  remove_volume_keys(args)
  if image_id
    vm = clone_from_image(image_id, vmid)
    vm.update(compute_clone_attributes(args, vm.container?, type))
    update_pool(vm, args[:pool]) if args[:pool]
  else
    logger.warn("create vm: args=#{args}")
    vm = node.send(vm_collection(type)).create(parse_typed_vm(args, type))
  end
  start_on_boot(vm, args)
rescue StandardError => e
  logger.warn("failed to create vm: #{e}")
  destroy_vm id.to_s + '_' + vm.vmid.to_s if vm
  raise e
end

#destroy_vm(uuid) ⇒ Object 



67
68
69
70
71
72
73
74
75
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 67

def destroy_vm(uuid)
  vm = find_vm_by_uuid(uuid)
  return true if vm.nil?
  vm.stop if vm.ready?
  vm.destroy
rescue ActiveRecord::RecordNotFound
  # if the VM does not exists, we don't really care.
  true
end

#save_vm(uuid, new_attributes) ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 94

def save_vm(uuid, new_attributes)
  vm = find_vm_by_uuid(uuid)
  templated = new_attributes['templated']
  node_id = new_attributes['node_id']
  if templated == '1' && !vm.templated?
    vm.create_template
  elsif vm.node_id != node_id
    vm.migrate(node_id)
  else
    parsed_attr = parse_typed_vm(
      ForemanFogProxmox::HashCollection.new_hash_reject_keys(new_attributes,
        ['volumes_attributes']).merge(type: vm.type), vm.type
    )
    config_attributes = compute_config_attributes(parsed_attr)
    volumes_attributes = new_attributes['volumes_attributes']
    logger.debug("save_vm(#{uuid}) volumes_attributes=#{volumes_attributes}")
    volumes_attributes&.each_value { |volume_attributes| save_volume(vm, volume_attributes) }
    vm.update(config_attributes[:config_attributes])
    poolid = new_attributes['pool'] if new_attributes.key?('pool')
    update_pool(vm, poolid) if poolid
  end
  find_vm_by_uuid(uuid)
end

#start_on_boot(vm, args) ⇒ Object 



28
29
30
31
32
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 28

def start_on_boot(vm, args)
  startonboot = args[:start_after_create].blank? ? false : Foreman::Cast.to_bool(args[:start_after_create])
  vm.start if startonboot
  vm
end

#supports_update? ⇒ Boolean

Returns:

  • (Boolean) 


77
78
79
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 77

def supports_update?
  true
end

#user_data_supported? ⇒ Boolean

Returns:

  • (Boolean) 


81
82
83
 
# File 'app/models/foreman_fog_proxmox/proxmox_vm_commands.rb', line 81

def user_data_supported?
  true
end