2010-03-16 15:46:21 -07:00
|
|
|
require 'fog/collection'
|
2010-09-08 14:40:02 -07:00
|
|
|
require 'fog/aws/models/compute/server'
|
2010-03-16 15:46:21 -07:00
|
|
|
|
2009-09-15 23:11:06 -07:00
|
|
|
module Fog
|
|
|
|
module AWS
|
2010-09-08 14:40:02 -07:00
|
|
|
class Compute
|
2009-09-15 23:11:06 -07:00
|
|
|
|
2010-01-08 11:29:07 -08:00
|
|
|
class Servers < Fog::Collection
|
2009-09-15 23:11:06 -07:00
|
|
|
|
2010-01-08 11:29:07 -08:00
|
|
|
attribute :server_id
|
2009-09-25 09:01:51 -07:00
|
|
|
|
2010-09-08 14:40:02 -07:00
|
|
|
model Fog::AWS::Compute::Server
|
2009-10-29 23:35:28 -07:00
|
|
|
|
2009-10-08 23:01:09 -07:00
|
|
|
def initialize(attributes)
|
2010-01-08 11:29:07 -08:00
|
|
|
@server_id ||= []
|
2009-10-08 23:01:09 -07:00
|
|
|
super
|
|
|
|
end
|
|
|
|
|
2010-01-08 11:29:07 -08:00
|
|
|
def all(server_id = @server_id)
|
|
|
|
@server_id = server_id
|
|
|
|
data = connection.describe_instances(server_id).body
|
2010-03-06 20:02:10 -08:00
|
|
|
load(
|
|
|
|
data['reservationSet'].map do |reservation|
|
|
|
|
reservation['instancesSet'].map do |instance|
|
|
|
|
instance.merge(:groups => reservation['groupSet'])
|
|
|
|
end
|
2010-03-08 17:35:34 -08:00
|
|
|
end.flatten
|
2010-03-06 20:02:10 -08:00
|
|
|
)
|
2009-09-15 23:11:06 -07:00
|
|
|
end
|
|
|
|
|
2010-09-15 17:31:45 -07:00
|
|
|
def bootstrap(new_attributes = {})
|
2010-09-23 17:39:25 -07:00
|
|
|
server = connection.servers.new(new_attributes)
|
|
|
|
|
2010-09-22 12:06:25 -07:00
|
|
|
# first or create fog_#{credential} keypair
|
2010-09-23 17:39:25 -07:00
|
|
|
unless server.key_pair = connection.key_pairs.get("fog_#{Fog.credential}")
|
|
|
|
server.key_pair = connection.key_pairs.create(
|
|
|
|
:name => "fog_#{Fog.credential}",
|
|
|
|
:public_key => server.public_key
|
|
|
|
)
|
2010-09-22 12:06:25 -07:00
|
|
|
end
|
|
|
|
|
|
|
|
# make sure port 22 is open in the first security group
|
|
|
|
security_group = connection.security_groups.get(server.groups.first)
|
|
|
|
ip_permission = security_group.ip_permissions.detect do |ip_permission|
|
|
|
|
ip_permission['ipRanges'].first && ip_permission['ipRanges'].first['cidrIp'] == '0.0.0.0/0' &&
|
|
|
|
ip_permission['fromPort'] == 22 &&
|
|
|
|
ip_permission['ipProtocol'] == 'tcp' &&
|
|
|
|
ip_permission['toPort'] == 22
|
2010-09-15 17:31:45 -07:00
|
|
|
end
|
2010-09-22 12:06:25 -07:00
|
|
|
unless ip_permission
|
|
|
|
security_group.authorize_port_range(22..22)
|
|
|
|
end
|
|
|
|
|
2010-09-23 17:39:25 -07:00
|
|
|
server.save
|
2010-09-22 12:06:25 -07:00
|
|
|
server.wait_for { ready? }
|
2010-09-23 17:39:25 -07:00
|
|
|
server.setup(:key_data => [server.private_key])
|
2010-09-15 17:31:45 -07:00
|
|
|
server
|
|
|
|
end
|
|
|
|
|
2010-01-08 11:29:07 -08:00
|
|
|
def get(server_id)
|
|
|
|
if server_id
|
|
|
|
all(server_id).first
|
2009-10-22 20:46:15 -07:00
|
|
|
end
|
2010-05-26 17:27:17 -07:00
|
|
|
rescue Fog::Errors::NotFound
|
2009-09-25 09:01:51 -07:00
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
2009-09-15 23:11:06 -07:00
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|