# frozen_string_literal: true
# Copyright 2018 Tristan Robert
# This file is part of ForemanFogProxmox.
# ForemanFogProxmox is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
# ForemanFogProxmox is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
# You should have received a copy of the GNU General Public License
# along with ForemanFogProxmox. If not, see .
require 'fog/proxmox/helpers/nic_helper'
require 'fog/proxmox/helpers/disk_helper'
require 'foreman_fog_proxmox/value'
module ForemanFogProxmox
class Proxmox < ComputeResource
include ProxmoxVmHelper
include ProxmoxConnection
include ProxmoxVmNew
include ProxmoxVmCommands
include ProxmoxVmQueries
include ProxmoxComputeAttributes
include ProxmoxVolumes
include ProxmoxInterfaces
include ProxmoxImages
include ProxmoxOperatingSystems
include ProxmoxVersion
include ProxmoxConsole
validates :url, :format => { :with => URI::DEFAULT_PARSER.make_regexp }, :presence => true
validates :auth_method, :presence => true, inclusion: { in: ['access_ticket', 'user_token'], message: ->(value) do format('%s is not a valid authentication method', { value: value }) end }
validates :user, :format => { :with => /(\w+)[@]{1}(\w+)/ }, :presence => true
validates :password, :presence => true, if: :access_ticket?
validates :token_id, :presence => true, if: :user_token?
validates :token, :presence => true, if: :user_token?
def provided_attributes
super.merge(
:mac => :mac
)
end
def self.provider_friendly_name
'Proxmox'
end
def capabilities
[:build, :new_volume, :new_interface, :image]
end
def self.model_name
ComputeResource.model_name
end
def associated_host(vm)
associate_by('mac', vm.mac)
end
def ssl_certs
attrs[:ssl_certs]
end
def ssl_certs=(value)
attrs[:ssl_certs] = value
end
def certs_to_store
return if ssl_certs.blank?
store = OpenSSL::X509::Store.new
ssl_certs.split(/(?=-----BEGIN)/).each do |cert|
x509_cert = OpenSSL::X509::Certificate.new cert
store.add_cert x509_cert
end
store
rescue StandardError => e
logger.error(e)
raise ::Foreman::Exception, N_('Unable to store X509 certificates')
end
def ssl_verify_peer
attrs[:ssl_verify_peer].blank? ? false : Foreman::Cast.to_bool(attrs[:ssl_verify_peer])
end
def ssl_verify_peer=(value)
attrs[:ssl_verify_peer] = value
end
def auth_method
attrs[:auth_method] || 'access_ticket'
end
def auth_method=(value)
attrs[:auth_method] = value
end
def token_id
attrs[:token_id]
end
def token_id=(value)
attrs[:token_id] = value
end
def token
attrs[:token]
end
def token=(value)
attrs[:token] = value
end
private
def fog_credentials
hash = {
proxmox_url: url,
proxmox_auth_method: auth_method || 'access_ticket',
connection_options: connection_options
}
if access_ticket?
hash[:proxmox_username] = user
hash[:proxmox_password] = password
end
if user_token?
hash[:proxmox_userid] = user
hash[:proxmox_token] = token
hash[:proxmox_tokenid] = token_id
end
hash
end
def token_expired?(e)
e.response.reason_phrase == 'token expired'
end
def client
@client ||= ::Fog::Proxmox::Compute.new(fog_credentials)
rescue Excon::Errors::Unauthorized => e
raise ::Foreman::Exception, 'User token expired' if token_expired?(e)
rescue StandardError => e
logger.warn(format(_('failed to create compute client: %s'), e: e))
raise e
end
def identity_client
@identity_client ||= ::Fog::Proxmox::Identity.new(fog_credentials)
rescue Excon::Errors::Unauthorized => e
raise ::Foreman::Exception, 'User token expired' if token_expired?(e)
rescue StandardError => e
logger.warn(format(_('failed to create identity client: %s'), e: e))
raise e
end
def network_client
@network_client ||= ::Fog::Proxmox::Network.new(fog_credentials)
rescue Excon::Errors::Unauthorized => e
raise ::Foreman::Exception, 'User token expired' if token_expired?(e)
rescue StandardError => e
logger.warn(format(_('failed to create network client: %s'), e: e))
raise e
end
def host
URI.parse(url).host
end
end
end