mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
Copied auth token reauthentication from rackspace|compute
This commit is contained in:
parent
3f8d1b4c90
commit
7487cf356f
1 changed files with 35 additions and 8 deletions
|
@ -83,16 +83,13 @@ module Fog
|
||||||
@rackspace_username = options[:rackspace_username]
|
@rackspace_username = options[:rackspace_username]
|
||||||
@rackspace_cdn_ssl = options[:rackspace_cdn_ssl]
|
@rackspace_cdn_ssl = options[:rackspace_cdn_ssl]
|
||||||
@rackspace_auth_url = options[:rackspace_auth_url]
|
@rackspace_auth_url = options[:rackspace_auth_url]
|
||||||
|
@rackspace_servicenet = options[:rackspace_servicenet]
|
||||||
|
@rackspace_auth_token = options[:rackspace_auth_token]
|
||||||
|
@rackspace_storage_url = options[:rackspace_storage_url]
|
||||||
|
@rackspace_must_reauthenticate = false
|
||||||
@connection_options = options[:connection_options] || {}
|
@connection_options = options[:connection_options] || {}
|
||||||
credentials = Fog::Rackspace.authenticate(options, @connection_options)
|
authenticate
|
||||||
@auth_token = credentials['X-Auth-Token']
|
|
||||||
|
|
||||||
uri = URI.parse(credentials['X-Storage-Url'])
|
|
||||||
@host = options[:rackspace_servicenet] == true ? "snet-#{uri.host}" : uri.host
|
|
||||||
@path = uri.path
|
|
||||||
@persistent = options[:persistent] || false
|
@persistent = options[:persistent] || false
|
||||||
@port = uri.port
|
|
||||||
@scheme = uri.scheme
|
|
||||||
Excon.ssl_verify_peer = false if options[:rackspace_servicenet] == true
|
Excon.ssl_verify_peer = false if options[:rackspace_servicenet] == true
|
||||||
@connection = Fog::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options)
|
@connection = Fog::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options)
|
||||||
end
|
end
|
||||||
|
@ -111,6 +108,14 @@ module Fog
|
||||||
:host => @host,
|
:host => @host,
|
||||||
:path => "#{@path}/#{params[:path]}",
|
:path => "#{@path}/#{params[:path]}",
|
||||||
}), &block)
|
}), &block)
|
||||||
|
rescue Excon::Errors::Unauthorized => error
|
||||||
|
if error.response.body != 'Bad username or password' # token expiration
|
||||||
|
@rackspace_must_reauthenticate = true
|
||||||
|
authenticate
|
||||||
|
retry
|
||||||
|
else # bad credentials
|
||||||
|
raise error
|
||||||
|
end
|
||||||
rescue Excon::Errors::HTTPStatusError => error
|
rescue Excon::Errors::HTTPStatusError => error
|
||||||
raise case error
|
raise case error
|
||||||
when Excon::Errors::NotFound
|
when Excon::Errors::NotFound
|
||||||
|
@ -125,6 +130,28 @@ module Fog
|
||||||
response
|
response
|
||||||
end
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def authenticate
|
||||||
|
if @rackspace_must_reauthenticate || @rackspace_auth_token.nil?
|
||||||
|
options = {
|
||||||
|
:rackspace_api_key => @rackspace_api_key,
|
||||||
|
:rackspace_username => @rackspace_username,
|
||||||
|
:rackspace_auth_url => @rackspace_auth_url
|
||||||
|
}
|
||||||
|
credentials = Fog::Rackspace.authenticate(options, @connection_options)
|
||||||
|
@auth_token = credentials['X-Auth-Token']
|
||||||
|
uri = URI.parse(credentials['X-Storage-Url'])
|
||||||
|
else
|
||||||
|
@auth_token = @rackspace_auth_token
|
||||||
|
uri = URI.parse(@rackspace_storage_url)
|
||||||
|
end
|
||||||
|
@host = @rackspace_servicenet == true ? "snet-#{uri.host}" : uri.host
|
||||||
|
@path = uri.path
|
||||||
|
@port = uri.port
|
||||||
|
@scheme = uri.scheme
|
||||||
|
end
|
||||||
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Add table
Reference in a new issue