1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
require 'fog/openstack/auth/token/v2'
require 'fog/openstack/auth/token/v3'
require 'fog/openstack/auth/catalog/v2'
require 'fog/openstack/auth/catalog/v3'
module Fog
module OpenStack
module Auth
module Token
attr_reader :catalog, :expires, :tenant, :token, :user, :data
class ExpiryError < RuntimeError; end
class StandardError < RuntimeError; end
class URLError < RuntimeError; end
def self.build(auth, options)
if auth[:openstack_identity_api_version] =~ /(v)*2(\.0)*/i ||
auth[:openstack_tenant_id] || auth[:openstack_tenant]
Fog::OpenStack::Auth::Token::V2.new(auth, options)
else
Fog::OpenStack::Auth::Token::V3.new(auth, options)
end
end
def initialize(auth, options)
raise URLError, 'No URL provided' if auth[:openstack_auth_url].nil? || auth[:openstack_auth_url].empty?
@creds = {
:data => build_credentials(auth),
:uri => URI.parse(auth[:openstack_auth_url])
}
response = authenticate(@creds, options)
set(response)
end
def get
set(authenticate(@creds, {})) if expired?
@token
end
private
def authenticate(creds, options)
connection = Fog::Core::Connection.new(creds[:uri].to_s, false, options)
headers = {
'Accept' => 'application/json',
'Content-Type' => 'application/json'
}
request_options = {
:expects => [200, 201],
:headers => headers,
:body => Fog::JSON.encode(creds[:data]),
:method => 'POST',
:path => creds[:uri].path + prefix_path(creds[:uri]) + path
}
connection.request(request_options)
end
def expired?
if @expires.nil? || @expires.empty?
raise ExpiryError, 'Missing token expiration data'
end
Time.parse(@expires) < Time.now.utc
end
def refresh
raise StandardError, "__method__ not implemented yet!"
end
end
end
end
end
|
