Module: Fog::StormOnDemand::RealShared

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 



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

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::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options)
end

#reload ⇒ Object 



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

def reload
  @connection.reset
end

#request(params) ⇒ Object 



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
51
52
 
# File 'lib/fog/storm_on_demand/shared.rb', line 25

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] || {}),
      :host     => @host,
      :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.has_key?('error_class')
    raise(Fog::Compute::StormOnDemand::Error, response.body.inspect)
  end
  response
end