mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
140 lines
4.7 KiB
Ruby
140 lines
4.7 KiB
Ruby
module Fog
|
|
module Compute
|
|
class OpenStack
|
|
class Real
|
|
|
|
def create_server(name, image_ref, flavor_ref, options = {})
|
|
data = {
|
|
'server' => {
|
|
'flavorRef' => flavor_ref,
|
|
'imageRef' => image_ref,
|
|
'name' => name
|
|
}
|
|
}
|
|
|
|
vanilla_options = ['metadata', 'accessIPv4', 'accessIPv6',
|
|
'availability_zone', 'user_data', 'key_name', 'adminPass']
|
|
vanilla_options.select{|o| options[o]}.each do |key|
|
|
data['server'][key] = options[key]
|
|
end
|
|
|
|
if options['security_groups']
|
|
# security names requires a hash with a name prefix
|
|
data['server']['security_groups'] =
|
|
Array(options['security_groups']).map do |sg|
|
|
name = if sg.is_a?(Fog::Compute::OpenStack::SecurityGroup) then
|
|
sg.name
|
|
else
|
|
sg
|
|
end
|
|
{ :name => name }
|
|
end
|
|
end
|
|
|
|
if options['personality']
|
|
data['server']['personality'] = []
|
|
for file in options['personality']
|
|
data['server']['personality'] << {
|
|
'contents' => Base64.encode64(file['contents']),
|
|
'path' => file['path']
|
|
}
|
|
end
|
|
end
|
|
|
|
if options['nics']
|
|
data['server']['networks'] =
|
|
Array(options['nics']).map do |nic|
|
|
{
|
|
'uuid' => nic['net_id'],
|
|
'fixed_ip' => nic['v4_fixed_ip'],
|
|
'port' => nic['port_id']
|
|
}
|
|
end
|
|
end
|
|
|
|
if options['os:scheduler_hints']
|
|
data['os:scheduler_hints'] = options['os:scheduler_hints']
|
|
end
|
|
|
|
request(
|
|
:body => Fog::JSON.encode(data),
|
|
:expects => [200, 202],
|
|
:method => 'POST',
|
|
:path => 'servers.json'
|
|
)
|
|
end
|
|
|
|
end
|
|
|
|
class Mock
|
|
|
|
def create_server(name, image_ref, flavor_ref, options = {})
|
|
response = Excon::Response.new
|
|
response.status = 202
|
|
|
|
server_id = Fog::Mock.random_numbers(6).to_s
|
|
identity = Fog::Identity[:openstack]
|
|
user = identity.users.find { |u|
|
|
u.name == @openstack_username
|
|
}
|
|
|
|
user_id = if user then
|
|
user.id
|
|
else
|
|
response = identity.create_user(@openstack_username,
|
|
'password',
|
|
"#{@openstack_username}@example.com")
|
|
response.body["user"]["id"]
|
|
end
|
|
|
|
|
|
mock_data = {
|
|
'addresses' => {},
|
|
'flavor' => {"id" => flavor_ref, "links"=>[{"href"=>"http://nova1:8774/admin/flavors/1", "rel"=>"bookmark"}]},
|
|
'id' => server_id,
|
|
'image' => {"id" => image_ref, "links"=>[{"href"=>"http://nova1:8774/admin/images/#{image_ref}", "rel"=>"bookmark"}]},
|
|
'links' => [{"href"=>"http://nova1:8774/v1.1/admin/servers/5", "rel"=>"self"}, {"href"=>"http://nova1:8774/admin/servers/5", "rel"=>"bookmark"}],
|
|
'hostId' => "123456789ABCDEF01234567890ABCDEF",
|
|
'metadata' => options['metadata'] || {},
|
|
'name' => name || "server_#{rand(999)}",
|
|
'accessIPv4' => options['accessIPv4'] || "",
|
|
'accessIPv6' => options['accessIPv6'] || "",
|
|
'progress' => 0,
|
|
'status' => 'BUILD',
|
|
'created' => '2012-09-27T00:04:18Z',
|
|
'updated' => '2012-09-27T00:04:27Z',
|
|
'user_id' => @openstack_username,
|
|
}
|
|
|
|
response_data = {
|
|
'adminPass' => 'password',
|
|
'id' => server_id,
|
|
'links' => mock_data['links'],
|
|
}
|
|
|
|
self.data[:last_modified][:servers][server_id] = Time.now
|
|
self.data[:servers][server_id] = mock_data
|
|
|
|
if security_groups = options['security_groups'] then
|
|
groups = Array(options['security_groups']).map do |sg|
|
|
if sg.is_a?(Fog::Compute::OpenStack::SecurityGroup) then
|
|
sg.name
|
|
else
|
|
sg
|
|
end
|
|
end
|
|
|
|
self.data[:server_security_group_map][server_id] = groups
|
|
response_data['security_groups'] = groups
|
|
end
|
|
|
|
self.data[:last_modified][:servers][server_id] = Time.now
|
|
self.data[:servers][server_id] = mock_data
|
|
response.body = { 'server' => response_data }
|
|
response
|
|
end
|
|
|
|
end
|
|
end
|
|
end
|
|
end
|