mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
14efc2f14c
Currently not working:
Expected(204) <=> Actual(404 Not Found)
request => {:connect_timeout=>60, :headers=>{"Authorization"=>"Basic YWE4ZWIxYzktYzc4OC00MDlmLWJmZjQtYjAyMjVjMDE0MDQ1OkFkZ1hYSGVUTmY3TTJHR1l2NEI3WkpnWE1ISkJMY1E2dlJBejRZUUg=", "Accept"=>"application/json", "Host"=>"api.z1-man.serverlove.com:443", "Content-Length"=>0}, :instrumentor_name=>"excon", :mock=>false, :read_timeout=>60, :retry_limit=>4, :ssl_ca_file=>"/Users/seanhandley/.rvm/gems/ruby-1.9.3-p125@fog_gem/gems/excon-0.14.1/data/cacert.pem", :ssl_verify_peer=>true, :write_timeout=>60, :host=>"api.z1-man.serverlove.com", :path=>"/drives/aea15650-5001-4cb8-8146-8c9835f5b880/image/679f5f44-0be7-4745-a658-cccd4334c1aa", :port=>"443", :query=>nil, :scheme=>"https", :method=>"post", :expects=>204}
response => #<Excon::Response:0x007ff661811848 @body="Operation failed: drive not found\n", @headers={"Server"=>"BaseHTTP/0.3 Python/2.6.6", "Date"=>"Fri, 22 Jun 2012 15:03:50 GMT", "X-Elastic-Error"=>"missing drive", "Connection"=>"close", "Content-Type"=>"text/plain"}, @status=404> (Excon::Errors::NotFound)
89 lines
2.3 KiB
Ruby
89 lines
2.3 KiB
Ruby
module Fog
|
|
module Compute
|
|
class Serverlove < Fog::Service
|
|
|
|
API_HOST = "api.z1-man.serverlove.com"
|
|
|
|
requires :serverlove_uuid, :serverlove_api_key
|
|
|
|
recognizes :serverlove_api_url
|
|
|
|
request_path 'fog/serverlove/requests/compute'
|
|
|
|
# Image
|
|
request :get_image
|
|
request :get_images
|
|
request :destroy_image
|
|
request :create_image
|
|
request :update_image
|
|
request :load_standard_image
|
|
|
|
# Server
|
|
request :get_servers
|
|
|
|
model_path 'fog/serverlove/models/compute'
|
|
|
|
model :image
|
|
collection :images
|
|
|
|
model :server
|
|
collection :servers
|
|
|
|
class Mock
|
|
|
|
def initialize(options)
|
|
@serverlove_uuid = options[:serverlove_uuid] || Fog.credentials[:serverlove_uuid]
|
|
@serverlove_api_key = options[:serverlove_api_key] || Fog.credentials[:serverlove_api_key]
|
|
end
|
|
|
|
def request(options)
|
|
raise "Not implemented"
|
|
end
|
|
|
|
end
|
|
|
|
class Real
|
|
|
|
def initialize(options)
|
|
@api_uuid = options[:serverlove_uuid] || Fog.credentials[:serverlove_uuid]
|
|
@api_key = options[:serverlove_api_key] || Fog.credentials[:serverlove_api_key]
|
|
@api_host = options[:serverlove_api_url] || Fog.credentials[:serverlove_api_url] || API_HOST
|
|
|
|
@connection = Fog::Connection.new("https://#{@api_uuid}:#{@api_key}@#{@api_host}")
|
|
end
|
|
|
|
def request(params)
|
|
params = params.merge!(
|
|
:headers => {
|
|
"Accept" => "application/json"
|
|
}
|
|
)
|
|
params[:body] = encode_pairs(params[:options]) unless params[:options].nil?
|
|
response = @connection.request(params)
|
|
|
|
raise_if_error!(response)
|
|
|
|
response.body = Fog::JSON.decode(response.body) if response.body && response.body.length > 0
|
|
|
|
response
|
|
end
|
|
|
|
def encode_pairs(params)
|
|
params.keys.collect do |key|
|
|
"#{key} #{params[key]}"
|
|
end.join("\n")
|
|
end
|
|
|
|
# TODO
|
|
def raise_if_error!(response)
|
|
case response.status
|
|
when 400 then
|
|
raise 'omg'
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
end
|
|
end
|