class NonstandardPooler

Public Class Methods

delete(verbose, url, hosts, token, _user) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 81
def self.delete(verbose, url, hosts, token, _user)
  raise TokenError, 'Token provided was nil; Request cannot be made to delete VM' if token.nil?

  conn = Http.get_conn(verbose, url)

  conn.headers['X-AUTH-TOKEN'] = token if token

  response_body = {}

  hosts = hosts.split(',') unless hosts.is_a? Array
  hosts.each do |host|
    response = conn.delete "host/#{host}"
    res_body = JSON.parse(response.body)
    response_body[host] = res_body
  end

  response_body
end
disk(_verbose, _url, _hostname, _token, _disk) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 69
def self.disk(_verbose, _url, _hostname, _token, _disk)
  raise ModifyError, 'Configured service type does not support modification of disk space'
end
list(verbose, url, os_filter = nil) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 9
def self.list(verbose, url, os_filter = nil)
  conn = Http.get_conn(verbose, url)

  response = conn.get 'status'
  response_body = JSON.parse(response.body)
  os_list = response_body.keys.sort
  os_list.delete 'ok'

  os_filter ? os_list.select { |i| i[/#{os_filter}/] } : os_list
end
list_active(verbose, url, token, _user) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 20
def self.list_active(verbose, url, token, _user)
  status = Auth.token_status(verbose, url, token)
  status['reserved_hosts'] || []
end
modify(verbose, url, hostname, token, modify_hash) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 45
def self.modify(verbose, url, hostname, token, modify_hash)
  raise TokenError, 'Token provided was nil; Request cannot be made to modify VM' if token.nil?

  modify_hash.each do |key, _value|
    raise ModifyError, "Configured service type does not support modification of #{key}" unless %i[reason
                                                                                                   reserved_for_reason].include? key
  end

  if modify_hash[:reason]
    # "reason" is easier to type than "reserved_for_reason", but nspooler needs the latter
    modify_hash[:reserved_for_reason] = modify_hash.delete :reason
  end

  conn = Http.get_conn(verbose, url)
  conn.headers['X-AUTH-TOKEN'] = token

  response = conn.put do |req|
    req.url "host/#{hostname}"
    req.body = modify_hash.to_json
  end

  response.body.empty? ? {} : JSON.parse(response.body)
end
query(verbose, url, hostname) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 114
def self.query(verbose, url, hostname)
  conn = Http.get_conn(verbose, url)

  response = conn.get "host/#{hostname}"
  JSON.parse(response.body)
end
retrieve(verbose, os_type, token, url, _user, _options, _ondemand = nil, _continue = nil) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 25
def self.retrieve(verbose, os_type, token, url, _user, _options, _ondemand = nil, _continue = nil)
  conn = Http.get_conn(verbose, url)
  conn.headers['X-AUTH-TOKEN'] = token if token

  os_string = os_type.map { |os, num| Array(os) * num }.flatten.join('+')
  raise MissingParamError, 'No operating systems provided to obtain.' if os_string.empty?

  response = conn.post "host/#{os_string}"

  res_body = JSON.parse(response.body)

  if res_body['ok']
    res_body
  elsif response.status == 401
    raise AuthError, "HTTP #{response.status}: The token provided could not authenticate to the pooler.\n#{res_body}"
  else
    raise "HTTP #{response.status}: Failed to obtain VMs from the pooler at #{url}/host/#{os_string}. #{res_body}"
  end
end
revert(_verbose, _url, _hostname, _token, _snapshot_sha) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 77
def self.revert(_verbose, _url, _hostname, _token, _snapshot_sha)
  raise ModifyError, 'Configured service type does not support snapshots'
end
snapshot(_verbose, _url, _hostname, _token) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 73
def self.snapshot(_verbose, _url, _hostname, _token)
  raise ModifyError, 'Configured service type does not support snapshots'
end
status(verbose, url) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 100
def self.status(verbose, url)
  conn = Http.get_conn(verbose, url)

  response = conn.get '/status'
  JSON.parse(response.body)
end
summary(verbose, url) click to toggle source
# File lib/vmfloaty/nonstandard_pooler.rb, line 107
def self.summary(verbose, url)
  conn = Http.get_conn(verbose, url)

  response = conn.get '/summary'
  JSON.parse(response.body)
end