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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
require 'puppet/util/inifile'
class Puppet::Provider::Murano < Puppet::Provider
def self.conf_filename
'/etc/murano/murano.conf'
end
def self.withenv(hash, &block)
saved = ENV.to_hash
hash.each do |name, val|
ENV[name.to_s] = val
end
yield
ensure
ENV.clear
saved.each do |name, val|
ENV[name] = val
end
end
def self.murano_conf
return @murano_conf if @murano_conf
@murano_conf = Puppet::Util::IniConfig::File.new
@murano_conf.read(conf_filename)
@murano_conf
end
def self.murano_credentials
@murano_credentials ||= get_murano_credentials
end
def murano_credentials
self.class.murano_credentials
end
def self.get_murano_credentials
#needed keys for authentication
auth_keys = ['auth_url', 'project_name', 'username', 'password']
conf = murano_conf
if conf and conf['keystone_authtoken'] and
auth_keys.all?{|k| !conf['keystone_authtoken'][k].nil?}
creds = Hash[ auth_keys.map { |k| [k, conf['keystone_authtoken'][k].strip] } ]
if conf['engine'] and !conf['engine']['packages_service'].nil?
creds['packages_service'] = conf['engine']['packages_service'].strip
end
if !conf['keystone_authtoken']['project_domain_name'].nil?
creds['project_domain_name'] = conf['keystone_authtoken']['project_domain_name'].strip
else
creds['project_domain_name'] = 'Default'
end
if !conf['keystone_authtoken']['user_domain_name'].nil?
creds['user_domain_name'] = conf['keystone_authtoken']['user_domain_name'].strip
else
creds['user_domain_name'] = 'Default'
end
return creds
else
raise(Puppet::Error, "File: #{conf_filename} does not contain all " +
'required sections. Murano types will not work if murano is not ' +
'correctly configured.')
end
end
def self.auth_murano(*args)
m = murano_credentials
authenv = {
:OS_AUTH_URL => m['auth_url'],
:OS_USERNAME => m['username'],
:OS_TENANT_NAME => m['project_name'],
:OS_PASSWORD => m['password'],
:OS_ENDPOINT_TYPE => 'internalURL',
:OS_PROJECT_DOMAIN_NAME => m['project_domain_name'],
:OS_USER_DOMAIN_NAME => m['user_domain_name']
}
if m.key?('packages_service')
authenv[:MURANO_PACKAGES_SERVICE] = m['packages_service']
end
begin
withenv authenv do
murano(args)
end
rescue Exception => e
if (e.message =~ /\[Errno 111\] Connection refused/) or
(e.message =~ /\(HTTP 400\)/)
sleep 10
withenv authenv do
murano(args)
end
else
raise(e)
end
end
end
def auth_murano(*args)
self.class.auth_murano(args)
end
def self.reset
@murano_conf = nil
@murano_credentials = nil
end
end
|
