Module: Fog::StormOnDemand::Shared

Included in:
Account::StormOnDemand::Real, Billing::StormOnDemand::Real, Compute::StormOnDemand::Real, DNS::StormOnDemand::Real, Monitoring::StormOnDemand::Real, Network::StormOnDemand::Real, Fog::Storage::StormOnDemand::Real, Fog::Support::StormOnDemand::Real, VPN::StormOnDemand::Real
Defined in:
lib/fog/storm_on_demand/shared.rb

Constant Summary collapse

API_URL = 
"https://api.stormondemand.com"
API_VERSION = 
"v1"

Instance Method Summary collapse

Instance Method Details

#initialize(options = {}) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/fog/storm_on_demand/shared.rb', line 7

def initialize(options = {})
  uri = URI.parse(options[:storm_on_demand_auth_url] ||= API_URL)
  @connection_options = options[:connection_options] || {}
  @host       = uri.host
  @path       = uri.path
  @persistent = options[:persistent] || false
  @port       = uri.port
  @scheme     = uri.scheme
  @storm_on_demand_username = options[:storm_on_demand_username]
  @storm_on_demand_password = options[:storm_on_demand_password]
  @connection = Fog::XML::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options)
end

#reload ⇒ Object 



20
21
22
 
# File 'lib/fog/storm_on_demand/shared.rb', line 20

def reload
  @connection.reset
end

#request(params) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/fog/storm_on_demand/shared.rb', line 24

def request(params)
  begin
    response = @connection.request(params.merge!({
      :headers  => {
        "Content-Type" => "application/json",
        "Authorization" => "Basic " << Base64.encode64("#{@storm_on_demand_username}:#{@storm_on_demand_password}").chomp
      }.merge!(params[:headers] || {}),
      :path     => "#{@path}/#{API_VERSION}#{params[:path]}",
      :expects  => 200,
      :method   => :post
    }))
  rescue Excon::Errors::HTTPStatusError => error
    raise case error
    when Excon::Errors::NotFound
      Fog::StormOnDemand::Compute::NotFound.slurp(error)
    else
      error
    end
  end
  unless response.body.empty?
    response.body = Fog::JSON.decode(response.body)
  end
  if response.body.key?("error_class")
    raise(Fog::Compute::StormOnDemand::Error, response.body.inspect)
  end
  response
end