mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
105 lines
2.2 KiB
Ruby
105 lines
2.2 KiB
Ruby
require 'spec'
|
|
require 'open-uri'
|
|
|
|
current_directory = File.dirname(__FILE__)
|
|
require "#{current_directory}/../lib/fog"
|
|
require "#{current_directory}/../lib/fog/bin"
|
|
|
|
if ENV["FOG_MOCK"] == "true"
|
|
Fog.mock!
|
|
end
|
|
|
|
require "#{current_directory}/../lib/fog/vcloud/bin"
|
|
|
|
module AWS
|
|
class << self
|
|
def [](service)
|
|
@@connections ||= Hash.new do |hash, key|
|
|
credentials = Fog.credentials.reject do |k, v|
|
|
![:aws_access_key_id, :aws_secret_access_key].include?(k)
|
|
end
|
|
hash[key] = case key
|
|
when :ec2
|
|
Fog::AWS::EC2.new(credentials)
|
|
when :eu_s3
|
|
Fog::AWS::S3.new(credentials.merge!(:host => 's3-external-3.amazonaws.com'))
|
|
when :sdb
|
|
Fog::AWS::SimpleDB.new(credentials)
|
|
when :s3
|
|
Fog::AWS::S3.new(credentials)
|
|
end
|
|
end
|
|
@@connections[service]
|
|
end
|
|
end
|
|
end
|
|
|
|
module Rackspace
|
|
class << self
|
|
def [](service)
|
|
@@connections ||= Hash.new do |hash, key|
|
|
credentials = Fog.credentials.reject do |k, v|
|
|
![:rackspace_api_key, :rackspace_username].include?(k)
|
|
end
|
|
hash[key] = case key
|
|
when :files
|
|
Fog::Rackspace::Files.new(credentials)
|
|
when :servers
|
|
Fog::Rackspace::Servers.new(credentials)
|
|
end
|
|
end
|
|
@@connections[service]
|
|
end
|
|
end
|
|
end
|
|
|
|
module Slicehost
|
|
class << self
|
|
def [](service)
|
|
@@connections ||= Hash.new do |hash, key|
|
|
credentials = Fog.credentials.reject do |k, v|
|
|
![:slicehost_password].include?(k)
|
|
end
|
|
hash[key] = case key
|
|
when :slices
|
|
Fog::Slicehost.new(credentials)
|
|
end
|
|
end
|
|
@@connections[service]
|
|
end
|
|
end
|
|
end
|
|
|
|
|
|
|
|
def eventually(max_delay = 16, &block)
|
|
delays = [0]
|
|
delay_step = 1
|
|
total = 0
|
|
while true
|
|
delay = 1
|
|
delay_step.times do
|
|
delay *= 2
|
|
end
|
|
delays << delay
|
|
delay_step += 1
|
|
break if delay >= max_delay
|
|
end
|
|
delays.each do |delay|
|
|
begin
|
|
sleep(delay)
|
|
yield
|
|
break
|
|
rescue => error
|
|
raise error if delay >= max_delay
|
|
end
|
|
end
|
|
end
|
|
|
|
unless defined?(GENTOO_AMI)
|
|
GENTOO_AMI = 'ami-5ee70037'
|
|
end
|
|
|
|
def lorem_file
|
|
File.open(File.dirname(__FILE__) + '/lorem.txt', 'r')
|
|
end
|