mirror of
https://github.com/fog/fog-aws.git
synced 2022-11-09 13:50:52 -05:00
297 lines
11 KiB
Ruby
297 lines
11 KiB
Ruby
Shindo.tests('Fog::Compute[:aws] | instance requests', ['aws']) do
|
|
|
|
@instance_format = {
|
|
'architecture' => String,
|
|
'amiLaunchIndex' => Integer,
|
|
'associatePublicIP' => Fog::Nullable::Boolean,
|
|
'attachmentId' => Fog::Nullable::String,
|
|
'blockDeviceMapping' => [Fog::Nullable::Hash],
|
|
'networkInterfaces' => [Fog::Nullable::Hash],
|
|
'clientToken' => Fog::Nullable::String,
|
|
'dnsName' => NilClass,
|
|
'ebsOptimized' => Fog::Boolean,
|
|
'imageId' => String,
|
|
'instanceId' => String,
|
|
'instanceState' => {'code' => Integer, 'name' => String},
|
|
'instanceType' => String,
|
|
'kernelId' => Fog::Nullable::String,
|
|
'keyName' => Fog::Nullable::String,
|
|
'launchTime' => Time,
|
|
'monitoring' => {'state' => Fog::Boolean},
|
|
'networkInterfaceId' => Fog::Nullable::String,
|
|
'placement' => {
|
|
'availabilityZone' => String,
|
|
'groupName' => Fog::Nullable::String,
|
|
'tenancy' => String
|
|
},
|
|
'platform' => Fog::Nullable::String,
|
|
'privateDnsName' => NilClass,
|
|
'productCodes' => Array,
|
|
'reason' => Fog::Nullable::String,
|
|
'rootDeviceName' => Fog::Nullable::String,
|
|
'rootDeviceType' => String,
|
|
'sourceDestCheck' => Fog::Nullable::Boolean,
|
|
'subnetId' => Fog::Nullable::String,
|
|
'vpcId' => Fog::Nullable::String
|
|
}
|
|
|
|
@run_instances_format = {
|
|
'groupSet' => [String],
|
|
'instancesSet' => [@instance_format],
|
|
'ownerId' => Fog::Nullable::String,
|
|
'requestId' => String,
|
|
'reservationId' => String
|
|
}
|
|
|
|
@describe_instances_format = {
|
|
'reservationSet' => [{
|
|
'groupSet' => [String],
|
|
'groupIds' => [String],
|
|
'instancesSet' => [@instance_format.merge(
|
|
'architecture' => String,
|
|
'dnsName' => Fog::Nullable::String,
|
|
'hypervisor' => String,
|
|
'iamInstanceProfile' => Hash,
|
|
'ipAddress' => Fog::Nullable::String,
|
|
'networkInterfaces' => Array,
|
|
'ownerId' => String,
|
|
'privateDnsName' => Fog::Nullable::String,
|
|
'privateIpAddress' => Fog::Nullable::String,
|
|
'stateReason' => Hash,
|
|
'tagSet' => Hash,
|
|
'virtualizationType' => String
|
|
)],
|
|
'ownerId' => Fog::Nullable::String,
|
|
'reservationId' => String
|
|
}],
|
|
'requestId' => String
|
|
}
|
|
|
|
@get_console_output_format = {
|
|
'instanceId' => String,
|
|
'output' => Fog::Nullable::String,
|
|
'requestId' => String,
|
|
'timestamp' => Time
|
|
}
|
|
|
|
@get_password_data_format = {
|
|
'instanceId' => String,
|
|
'passwordData' => Fog::Nullable::String,
|
|
'requestId' => String,
|
|
'timestamp' => Time
|
|
}
|
|
|
|
@terminate_instances_format = {
|
|
'instancesSet' => [{
|
|
'currentState' => {'code' => Integer, 'name' => String},
|
|
'instanceId' => String,
|
|
'previousState' => {'code' => Integer, 'name' => String},
|
|
}],
|
|
'requestId' => String
|
|
}
|
|
|
|
@describe_reserved_instances_offerings_format = {
|
|
'reservedInstancesOfferingsSet' => [{
|
|
'reservedInstancesOfferingId' => String,
|
|
'instanceType' => String,
|
|
'availabilityZone' => String,
|
|
'duration' => Integer,
|
|
'fixedPrice' => Float,
|
|
'offeringType' => String,
|
|
'usagePrice' => Float,
|
|
'productDescription' => String,
|
|
'instanceTenancy' => String,
|
|
'currencyCode' => String
|
|
}],
|
|
'requestId' => String
|
|
}
|
|
|
|
@purchase_reserved_instances_offering_format = {
|
|
'reservedInstancesId' => String,
|
|
'requestId' => String
|
|
}
|
|
|
|
@describe_reserved_instances_format = {
|
|
'reservedInstancesSet' => [{
|
|
'reservedInstancesId' => String,
|
|
'instanceType' => String,
|
|
'availabilityZone' => String,
|
|
'start' => Time,
|
|
'end' => Time,
|
|
'duration' => Integer,
|
|
'fixedPrice' => Float,
|
|
'usagePrice' => Float,
|
|
'instanceCount' => Integer,
|
|
'offeringType' => String,
|
|
'productDescription' => String,
|
|
'state' => String,
|
|
'tagSet' => [{
|
|
'key' => String,
|
|
'value' => String
|
|
}],
|
|
'instanceTenancy' => String,
|
|
'currencyCode' => String
|
|
}],
|
|
'requestId' => String
|
|
}
|
|
|
|
@describe_instance_status_format = {
|
|
'requestId' => String,
|
|
'instanceStatusSet' => [{
|
|
'instanceId' => String,
|
|
'availabilityZone' => String,
|
|
'instanceState' => {
|
|
'code' => Integer,
|
|
'name' => String
|
|
},
|
|
'systemStatus' => {
|
|
'status' => String,
|
|
'details' => [{
|
|
'name' => String,
|
|
'status' => String
|
|
}]
|
|
},
|
|
'instanceStatus' => {
|
|
'status' => String,
|
|
'details' => [{
|
|
'name' => String,
|
|
'status' => String
|
|
}]
|
|
},
|
|
'eventsSet' => [Fog::Nullable::Hash],
|
|
}]
|
|
}
|
|
tests('success') do
|
|
|
|
@instance_id = nil
|
|
@ami = if ENV['FASTER_TEST_PLEASE']
|
|
'ami-79c0ae10' # ubuntu 12.04 daily build 20120728
|
|
else
|
|
# Use a MS Windows AMI to test #get_password_data
|
|
'ami-71b50018' # Amazon Public Images - Windows_Server-2008-SP2-English-64Bit-Base-2012.07.11
|
|
end
|
|
|
|
# Create a keypair for decrypting the password
|
|
key_name = uniq_id('fog-test-key')
|
|
key = Fog::Compute[:aws].key_pairs.create(:name => key_name)
|
|
|
|
tests("#run_instances").formats(@run_instances_format) do
|
|
data = Fog::Compute[:aws].run_instances(@ami, 1, 1, 'InstanceType' => 't1.micro', 'KeyName' => key_name, 'BlockDeviceMapping' => [{"DeviceName" => "/dev/sdp1", "VirtualName" => nil, "Ebs.VolumeSize" => 15}]).body
|
|
@instance_id = data['instancesSet'].first['instanceId']
|
|
data
|
|
end
|
|
|
|
server = Fog::Compute[:aws].servers.get(@instance_id)
|
|
while server.nil? do
|
|
# It may take a moment to get the server after launching it
|
|
sleep 0.1
|
|
server = Fog::Compute[:aws].servers.get(@instance_id)
|
|
end
|
|
server.wait_for { ready? }
|
|
|
|
tests("#describe_instances").formats(@describe_instances_format) do
|
|
Fog::Compute[:aws].describe_instances('instance-state-name' => 'running').body
|
|
end
|
|
|
|
# Launch another instance to test filters
|
|
another_server = Fog::Compute[:aws].servers.create
|
|
|
|
tests("#describe_instances('instance-id' => '#{@instance_id}'").formats(@describe_instances_format) do
|
|
body = Fog::Compute[:aws].describe_instances('instance-id' => "#{@instance_id}").body
|
|
tests("returns 1 instance").returns(1) { body['reservationSet'].size }
|
|
body
|
|
end
|
|
|
|
# Test network interface attachment
|
|
tests('#describe_instances networkInterfaces') do
|
|
vpc = Fog::Compute[:aws].vpcs.create('cidr_block' => '10.0.10.0/16')
|
|
subnet = Fog::Compute[:aws].subnets.create('vpc_id' => vpc.id, 'cidr_block' => '10.0.10.0/16')
|
|
data = Fog::Compute[:aws].create_network_interface(subnet.subnet_id).body
|
|
@network_interface_id = data['networkInterface']['networkInterfaceId']
|
|
Fog::Compute[:aws].attach_network_interface(@network_interface_id, @instance_id, '1')
|
|
body = Fog::Compute[:aws].describe_instances('instance-id' => "#{@instance_id}").body
|
|
tests("returns 1 attachment").returns(1) { body['reservationSet'].first['instancesSet'].first['networkInterfaces'].size }
|
|
subnet.destroy
|
|
vpc.destroy
|
|
end
|
|
|
|
another_server.destroy
|
|
|
|
tests("#get_console_output('#{@instance_id}')").formats(@get_console_output_format) do
|
|
Fog::Compute[:aws].get_console_output(@instance_id).body
|
|
end
|
|
|
|
tests("#get_password_data('#{@instance_id}')").formats(@get_password_data_format) do
|
|
result = Fog::Compute[:aws].get_password_data(@instance_id).body
|
|
|
|
tests("key can decrypt passwordData").returns(true) do
|
|
|
|
pending if Fog.mocking?
|
|
|
|
password_data = result['passwordData']
|
|
Fog.wait_for do
|
|
password_data ||= Fog::Compute[:aws].get_password_data(@instance_id).body['passwordData']
|
|
end
|
|
|
|
decoded_password = Base64.decode64(password_data)
|
|
pkey = OpenSSL::PKey::RSA.new(key.private_key)
|
|
String === pkey.private_decrypt(decoded_password)
|
|
end
|
|
result
|
|
end unless ENV['FASTER_TEST_PLEASE']
|
|
|
|
key.destroy
|
|
|
|
tests("#reboot_instances('#{@instance_id}')").formats(AWS::Compute::Formats::BASIC) do
|
|
Fog::Compute[:aws].reboot_instances(@instance_id).body
|
|
end
|
|
|
|
tests("#terminate_instances('#{@instance_id}')").formats(@terminate_instances_format) do
|
|
Fog::Compute[:aws].terminate_instances(@instance_id).body
|
|
end
|
|
|
|
tests("#describe_reserved_instances_offerings").formats(@describe_reserved_instances_offerings_format) do
|
|
@reserved_instances = Fog::Compute[:aws].describe_reserved_instances_offerings.body
|
|
@reserved_instances
|
|
end
|
|
|
|
tests('#describe_instance_status').formats(@describe_instance_status_format) do
|
|
Fog::Compute[:aws].describe_instance_status.body
|
|
end
|
|
|
|
if Fog.mocking?
|
|
@reserved_instance_offering_id = @reserved_instances["reservedInstancesOfferingsSet"].first["reservedInstancesOfferingId"]
|
|
tests("#purchase_reserved_instances_offering('#{@reserved_instance_offering_id}')").formats(@purchase_reserved_instances_offering_format) do
|
|
Fog::Compute[:aws].purchase_reserved_instances_offering(@reserved_instance_offering_id, 1).body
|
|
end
|
|
|
|
tests("#describe_reserved_instances").formats(@describe_reserved_instances_format) do
|
|
Fog::Compute[:aws].describe_reserved_instances.body
|
|
end
|
|
end
|
|
end
|
|
|
|
tests('failure') do
|
|
|
|
tests("#run_instances(nil, 1, 1, {'SubnetId'=>'subnet-00000000'}").raises(::Fog::Compute::AWS::Error) do
|
|
Fog::Compute[:aws].run_instances(nil, 1, 1, {'SubnetId' => 'subnet-000000'})
|
|
end
|
|
tests("#get_console_output('i-00000000')").raises(Fog::Compute::AWS::NotFound) do
|
|
Fog::Compute[:aws].get_console_output('i-00000000')
|
|
end
|
|
|
|
tests("#get_password_data('i-00000000')").raises(Fog::Compute::AWS::NotFound) do
|
|
Fog::Compute[:aws].get_password_data('i-00000000')
|
|
end
|
|
|
|
tests("#reboot_instances('i-00000000')").raises(Fog::Compute::AWS::NotFound) do
|
|
Fog::Compute[:aws].reboot_instances('i-00000000')
|
|
end
|
|
|
|
tests("#terminate_instances('i-00000000')").raises(Fog::Compute::AWS::NotFound) do
|
|
Fog::Compute[:aws].terminate_instances('i-00000000')
|
|
end
|
|
|
|
end
|
|
|
|
end
|