mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
fixing more warnings
This commit is contained in:
parent
9ff06a8768
commit
c53b5e273c
19 changed files with 97 additions and 99 deletions
2
bin/fog
2
bin/fog
|
@ -1,5 +1,5 @@
|
||||||
#!/usr/bin/env ruby
|
#!/usr/bin/env ruby
|
||||||
require File.join(File.dirname(__FILE__), '..', 'lib', 'fog')
|
require File.expand_path(File.join(File.dirname(__FILE__), '..', 'lib', 'fog'))
|
||||||
require 'irb'
|
require 'irb'
|
||||||
require 'yaml'
|
require 'yaml'
|
||||||
require File.join('fog', 'core', 'credentials')
|
require File.join('fog', 'core', 'credentials')
|
||||||
|
|
|
@ -74,8 +74,8 @@ module Fog
|
||||||
def self.data
|
def self.data
|
||||||
@data ||= Hash.new do |hash, region|
|
@data ||= Hash.new do |hash, region|
|
||||||
owner_id = Fog::AWS::Mock.owner_id
|
owner_id = Fog::AWS::Mock.owner_id
|
||||||
hash[region] = Hash.new do |hash, key|
|
hash[region] = Hash.new do |region_hash, key|
|
||||||
hash[key] = {
|
region_hash[key] = {
|
||||||
:deleted_at => {},
|
:deleted_at => {},
|
||||||
:addresses => {},
|
:addresses => {},
|
||||||
:instances => {},
|
:instances => {},
|
||||||
|
|
|
@ -48,13 +48,13 @@ module Fog
|
||||||
|
|
||||||
# make sure port 22 is open in the first security group
|
# make sure port 22 is open in the first security group
|
||||||
security_group = connection.security_groups.get(server.groups.first)
|
security_group = connection.security_groups.get(server.groups.first)
|
||||||
ip_permission = security_group.ip_permissions.detect do |ip_permission|
|
authorized = security_group.ip_permissions.detect do |ip_permission|
|
||||||
ip_permission['ipRanges'].first && ip_permission['ipRanges'].first['cidrIp'] == '0.0.0.0/0' &&
|
ip_permission['ipRanges'].first && ip_permission['ipRanges'].first['cidrIp'] == '0.0.0.0/0' &&
|
||||||
ip_permission['fromPort'] == 22 &&
|
ip_permission['fromPort'] == 22 &&
|
||||||
ip_permission['ipProtocol'] == 'tcp' &&
|
ip_permission['ipProtocol'] == 'tcp' &&
|
||||||
ip_permission['toPort'] == 22
|
ip_permission['toPort'] == 22
|
||||||
end
|
end
|
||||||
unless ip_permission
|
unless authorized
|
||||||
security_group.authorize_port_range(22..22)
|
security_group.authorize_port_range(22..22)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -30,7 +30,7 @@ module Fog
|
||||||
@image[name] = @value
|
@image[name] = @value
|
||||||
when 'blockDeviceMapping'
|
when 'blockDeviceMapping'
|
||||||
@in_block_device_mapping = false
|
@in_block_device_mapping = false
|
||||||
when 'deviceName', 'virtualName', 'snapshotId', 'volumeSize', 'deleteOnTermination'
|
when 'deviceName', 'virtualName', 'snapshotId', 'deleteOnTermination'
|
||||||
@block_device_mapping[name] = @value
|
@block_device_mapping[name] = @value
|
||||||
when 'isPublic'
|
when 'isPublic'
|
||||||
if @value == 'true'
|
if @value == 'true'
|
||||||
|
|
|
@ -33,7 +33,7 @@ module Fog
|
||||||
@response['MaxKeys'] = @value.to_i
|
@response['MaxKeys'] = @value.to_i
|
||||||
when 'Size'
|
when 'Size'
|
||||||
@object['Size'] = @value.to_i
|
@object['Size'] = @value.to_i
|
||||||
when 'Delimeter', 'Key', 'Name', 'StorageClass'
|
when 'Delimeter', 'Key', 'StorageClass'
|
||||||
@object[name] = @value
|
@object[name] = @value
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -65,17 +65,17 @@ module Fog
|
||||||
elsif @in_version
|
elsif @in_version
|
||||||
@version
|
@version
|
||||||
end['LastModified'] = Time.parse(@value)
|
end['LastModified'] = Time.parse(@value)
|
||||||
when 'KeyMarker', 'Name', 'Prefix', 'VersionIdMarker'
|
|
||||||
@response[name] = @value
|
|
||||||
when 'MaxKeys'
|
when 'MaxKeys'
|
||||||
@response['MaxKeys'] = @value.to_i
|
@response['MaxKeys'] = @value.to_i
|
||||||
when 'Size'
|
when 'Size'
|
||||||
@version['Size'] = @value.to_i
|
@version['Size'] = @value.to_i
|
||||||
when 'Key', 'Name', 'StorageClass', 'VersionId'
|
when 'Key', 'KeyMarker', 'Name', 'Prefix', 'StorageClass', 'VersionId', 'VersionIdMarker'
|
||||||
if @in_delete_marker
|
if @in_delete_marker
|
||||||
@delete_marker
|
@delete_marker
|
||||||
elsif @in_version
|
elsif @in_version
|
||||||
@version
|
@version
|
||||||
|
else
|
||||||
|
@response
|
||||||
end[name] = @value
|
end[name] = @value
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -53,8 +53,8 @@ module Fog
|
||||||
response.status = 200
|
response.status = 200
|
||||||
response.body = {
|
response.body = {
|
||||||
'requestId' => Fog::AWS::Mock.request_id,
|
'requestId' => Fog::AWS::Mock.request_id,
|
||||||
'keySet' => key_set.map do |key|
|
'keySet' => key_set.map do |key_pair|
|
||||||
key.reject {|key,value| !['keyFingerprint', 'keyName'].include?(key)}
|
key_pair.reject {|key,value| !['keyFingerprint', 'keyName'].include?(key)}
|
||||||
end
|
end
|
||||||
}
|
}
|
||||||
response
|
response
|
||||||
|
|
|
@ -75,8 +75,8 @@ module Fog
|
||||||
|
|
||||||
def self.data
|
def self.data
|
||||||
@data ||= Hash.new do |hash, region|
|
@data ||= Hash.new do |hash, region|
|
||||||
hash[region] = Hash.new do |hash, key|
|
hash[region] = Hash.new do |region_hash, key|
|
||||||
hash[key] = {
|
region_hash[key] = {
|
||||||
:buckets => {}
|
:buckets => {}
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
|
@ -6,51 +6,51 @@ module Fog
|
||||||
|
|
||||||
class BlockInstantiationError < StandardError; end
|
class BlockInstantiationError < StandardError; end
|
||||||
|
|
||||||
class Server < Fog::Model
|
class Server < Fog::Model
|
||||||
|
|
||||||
identity :id
|
identity :id
|
||||||
|
|
||||||
attribute :name
|
attribute :name
|
||||||
attribute :image_id # id or name
|
attribute :image_id # id or name
|
||||||
attribute :ip
|
attribute :ip
|
||||||
attribute :memory # server.ram
|
attribute :memory # server.ram
|
||||||
attribute :state
|
attribute :state
|
||||||
attribute :description # Optional
|
attribute :description # Optional
|
||||||
attribute :sandbox # Optional. Default: False
|
attribute :sandbox # Optional. Default: False
|
||||||
|
|
||||||
def initialize(attributes={})
|
def initialize(attributes={})
|
||||||
super
|
super
|
||||||
end
|
end
|
||||||
|
|
||||||
def destroy
|
def destroy
|
||||||
requires :id
|
requires :id
|
||||||
connection.grid_server_destroy(@id)
|
connection.grid_server_destroy(@id)
|
||||||
true
|
true
|
||||||
end
|
end
|
||||||
|
|
||||||
def image
|
def image
|
||||||
requires :image_id
|
requires :image_id
|
||||||
connection.grid_image_get(@image_id)
|
connection.grid_image_get(@image_id)
|
||||||
end
|
end
|
||||||
|
|
||||||
def ready?
|
def ready?
|
||||||
@state == 'On'
|
@state == 'On'
|
||||||
end
|
end
|
||||||
|
|
||||||
def save
|
|
||||||
raise Fog::Errors::Error.new('Resaving an existing object may create a duplicate') if identity
|
|
||||||
requires :name, :image_id, :ip, :memory
|
|
||||||
options['isSandbox'] = sandbox if sandbox
|
|
||||||
options['server.ram'] = memory
|
|
||||||
options['image'] = image_id
|
|
||||||
data = connection.grid_server_add(name, image, ip, options)
|
|
||||||
merge_attributes(data.body)
|
|
||||||
true
|
|
||||||
end
|
|
||||||
|
|
||||||
|
def save
|
||||||
|
raise Fog::Errors::Error.new('Resaving an existing object may create a duplicate') if identity
|
||||||
|
requires :name, :image_id, :ip, :memory
|
||||||
|
options['isSandbox'] = sandbox if sandbox
|
||||||
|
options['server.ram'] = memory
|
||||||
|
options['image'] = image_id
|
||||||
|
data = connection.grid_server_add(name, image, ip, options)
|
||||||
|
merge_attributes(data.body)
|
||||||
|
true
|
||||||
end
|
end
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|
||||||
|
end
|
||||||
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -33,7 +33,7 @@ module Fog
|
||||||
@response['MaxKeys'] = @value.to_i
|
@response['MaxKeys'] = @value.to_i
|
||||||
when 'Size'
|
when 'Size'
|
||||||
@object['Size'] = @value.to_i
|
@object['Size'] = @value.to_i
|
||||||
when 'Delimeter', 'Key', 'Name', 'StorageClass'
|
when 'Delimeter', 'Key', 'StorageClass'
|
||||||
@object[name] = @value
|
@object[name] = @value
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -45,10 +45,7 @@ module Fog
|
||||||
file.close
|
file.close
|
||||||
new(data)
|
new(data)
|
||||||
else
|
else
|
||||||
body = nil
|
body = ::File.read(path)
|
||||||
::File.open(path) do |file|
|
|
||||||
body = file.read
|
|
||||||
end
|
|
||||||
new(data.merge!(:body => body))
|
new(data.merge!(:body => body))
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
|
|
|
@ -22,7 +22,7 @@ module Fog
|
||||||
|
|
||||||
def delete_image(image_id)
|
def delete_image(image_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if image = list_images_detail.body['images'].detect {|image| image['id'] == image_id}
|
if image = list_images_detail.body['images'].detect {|_| _['id'] == image_id}
|
||||||
if image['status'] == 'SAVING'
|
if image['status'] == 'SAVING'
|
||||||
response.status = 409
|
response.status = 409
|
||||||
raise(Excon::Errors.status_error({:expects => 202}, response))
|
raise(Excon::Errors.status_error({:expects => 202}, response))
|
||||||
|
|
|
@ -22,7 +22,7 @@ module Fog
|
||||||
|
|
||||||
def delete_server(server_id)
|
def delete_server(server_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
if server['status'] == 'BUILD'
|
if server['status'] == 'BUILD'
|
||||||
response.status = 409
|
response.status = 409
|
||||||
raise(Excon::Errors.status_error({:expects => 202}, response))
|
raise(Excon::Errors.status_error({:expects => 202}, response))
|
||||||
|
|
|
@ -37,7 +37,7 @@ module Fog
|
||||||
|
|
||||||
def get_server_details(server_id)
|
def get_server_details(server_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
response.status = [200, 203][rand(1)]
|
response.status = [200, 203][rand(1)]
|
||||||
response.body = { 'server' => server }
|
response.body = { 'server' => server }
|
||||||
response
|
response
|
||||||
|
|
|
@ -28,7 +28,7 @@ module Fog
|
||||||
|
|
||||||
def list_addresses(server_id)
|
def list_addresses(server_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
response.status = [200, 203][rand(1)]
|
response.status = [200, 203][rand(1)]
|
||||||
response.body = { 'addresses' => server['addresses'] }
|
response.body = { 'addresses' => server['addresses'] }
|
||||||
response
|
response
|
||||||
|
|
|
@ -26,7 +26,7 @@ module Fog
|
||||||
|
|
||||||
def list_private_addresses(server_id)
|
def list_private_addresses(server_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
response.status = [200, 203][rand(1)]
|
response.status = [200, 203][rand(1)]
|
||||||
response.body = { 'private' => server['addresses']['private'] }
|
response.body = { 'private' => server['addresses']['private'] }
|
||||||
response
|
response
|
||||||
|
|
|
@ -26,7 +26,7 @@ module Fog
|
||||||
|
|
||||||
def list_public_addresses(server_id)
|
def list_public_addresses(server_id)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
response.status = [200, 203][rand(1)]
|
response.status = [200, 203][rand(1)]
|
||||||
response.body = { 'public' => server['addresses']['public'] }
|
response.body = { 'public' => server['addresses']['public'] }
|
||||||
response
|
response
|
||||||
|
|
|
@ -25,7 +25,7 @@ module Fog
|
||||||
|
|
||||||
def update_server(server_id, options)
|
def update_server(server_id, options)
|
||||||
response = Excon::Response.new
|
response = Excon::Response.new
|
||||||
if server = list_servers_detail.body['servers'].detect { |server| server['id'] == server_id }
|
if server = list_servers_detail.body['servers'].detect {|_| _['id'] == server_id}
|
||||||
if options['adminPass']
|
if options['adminPass']
|
||||||
server['adminPass'] = options['adminPass']
|
server['adminPass'] = options['adminPass']
|
||||||
end
|
end
|
||||||
|
|
|
@ -1,39 +1,40 @@
|
||||||
module Fog
|
module Fog
|
||||||
module Terremark
|
module Terremark
|
||||||
module Ecloud
|
module Ecloud
|
||||||
|
|
||||||
module Bin
|
module Bin
|
||||||
end
|
end
|
||||||
|
|
||||||
module Defaults
|
module Defaults
|
||||||
HOST = 'services.enterprisecloud.terremark.com'
|
HOST = 'services.enterprisecloud.terremark.com'
|
||||||
PATH = '/api/v0.8a-ext2.0'
|
PATH = '/api/v0.8a-ext2.0'
|
||||||
PORT = 443
|
PORT = 443
|
||||||
SCHEME = 'https'
|
SCHEME = 'https'
|
||||||
end
|
end
|
||||||
|
|
||||||
extend Fog::Terremark::Shared
|
extend Fog::Terremark::Shared
|
||||||
|
|
||||||
def self.new(options={})
|
def self.new(options={})
|
||||||
|
|
||||||
unless @required
|
unless @required
|
||||||
shared_requires
|
shared_requires
|
||||||
@required = true
|
@required = true
|
||||||
end
|
end
|
||||||
|
|
||||||
check_shared_options(options)
|
check_shared_options(options)
|
||||||
|
|
||||||
if Fog.mocking?
|
if Fog.mocking?
|
||||||
Fog::Terremark::Ecloud::Mock.new(options)
|
Fog::Terremark::Ecloud::Mock.new(options)
|
||||||
else
|
else
|
||||||
Fog::Terremark::Ecloud::Real.new(options)
|
Fog::Terremark::Ecloud::Real.new(options)
|
||||||
end
|
end
|
||||||
end
|
|
||||||
|
|
||||||
class Real
|
end
|
||||||
|
|
||||||
include Fog::Terremark::Shared::Real
|
class Real
|
||||||
include Fog::Terremark::Shared::Parser
|
|
||||||
|
include Fog::Terremark::Shared::Real
|
||||||
|
include Fog::Terremark::Shared::Parser
|
||||||
|
|
||||||
def initialize(options={})
|
def initialize(options={})
|
||||||
@terremark_password = options[:terremark_ecloud_password]
|
@terremark_password = options[:terremark_ecloud_password]
|
||||||
|
@ -45,22 +46,22 @@ module Fog
|
||||||
@connection = Fog::Connection.new("#{@scheme}://#{@host}:#{@port}", options[:persistent])
|
@connection = Fog::Connection.new("#{@scheme}://#{@host}:#{@port}", options[:persistent])
|
||||||
end
|
end
|
||||||
|
|
||||||
|
end
|
||||||
|
|
||||||
|
class Mock
|
||||||
|
include Fog::Terremark::Shared::Mock
|
||||||
|
include Fog::Terremark::Shared::Parser
|
||||||
|
|
||||||
|
def initialize(option = {})
|
||||||
|
super
|
||||||
|
@base_url = Fog::Terremark::Ecloud::Defaults::SCHEME + "://" +
|
||||||
|
Fog::Terremark::Ecloud::Defaults::HOST +
|
||||||
|
Fog::Terremark::Ecloud::Defaults::PATH
|
||||||
|
@data = self.class.data[:terremark_ecloud_username]
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|
||||||
class Mock
|
|
||||||
include Fog::Terremark::Shared::Mock
|
|
||||||
include Fog::Terremark::Shared::Parser
|
|
||||||
|
|
||||||
def initialize(option = {})
|
|
||||||
super
|
|
||||||
@base_url = Fog::Terremark::Ecloud::Defaults::SCHEME + "://" +
|
|
||||||
Fog::Terremark::Ecloud::Defaults::HOST +
|
|
||||||
Fog::Terremark::Ecloud::Defaults::PATH
|
|
||||||
@data = self.class.data[:terremark_ecloud_username]
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue