Merge "Use openstack CLI instad of trove CLI"
This commit is contained in:
commit
773cd0ee47
|
@ -1,49 +1,43 @@
|
||||||
require 'json'
|
# Add openstacklib code to $LOAD_PATH so that we can load this during
|
||||||
require 'puppet/util/inifile'
|
# standalone compiles without error.
|
||||||
|
File.expand_path('../../../../openstacklib/lib', File.dirname(__FILE__)).tap { |dir| $LOAD_PATH.unshift(dir) unless $LOAD_PATH.include?(dir) }
|
||||||
|
|
||||||
class Puppet::Provider::Trove < Puppet::Provider
|
require 'puppet/util/inifile'
|
||||||
|
require 'puppet/provider/openstack'
|
||||||
|
require 'puppet/provider/openstack/auth'
|
||||||
|
require 'puppet/provider/openstack/credentials'
|
||||||
|
|
||||||
|
class Puppet::Provider::Trove < Puppet::Provider::Openstack
|
||||||
|
|
||||||
|
extend Puppet::Provider::Openstack::Auth
|
||||||
|
|
||||||
|
def self.request(service, action, properties=nil)
|
||||||
|
begin
|
||||||
|
super
|
||||||
|
rescue Puppet::Error::OpenstackAuthInputError => error
|
||||||
|
trove_request(service, action, error, properties)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.trove_request(service, action, error, properties=nil)
|
||||||
|
properties ||= []
|
||||||
|
@credentials.username = trove_credentials['username']
|
||||||
|
@credentials.password = trove_credentials['password']
|
||||||
|
@credentials.project_name = trove_credentials['project_name']
|
||||||
|
@credentials.auth_url = auth_endpoint
|
||||||
|
@credentials.user_domain_name = trove_credentials['user_domain_name']
|
||||||
|
@credentials.project_domain_name = trove_credentials['project_domain_name']
|
||||||
|
if trove_credentials['region_name']
|
||||||
|
@credentials.region_name = trove_credentials['region_name']
|
||||||
|
end
|
||||||
|
raise error unless @credentials.set?
|
||||||
|
Puppet::Provider::Openstack.request(service, action, properties, @credentials)
|
||||||
|
end
|
||||||
|
|
||||||
def self.conf_filename
|
def self.conf_filename
|
||||||
'/etc/trove/trove.conf'
|
'/etc/trove/trove.conf'
|
||||||
end
|
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.trove_credentials
|
|
||||||
@trove_credentials ||= get_trove_credentials
|
|
||||||
end
|
|
||||||
|
|
||||||
def self.get_trove_credentials
|
|
||||||
auth_keys = ['auth_url', 'project_name', 'username', 'password',
|
|
||||||
'project_domain_name', 'user_domain_name']
|
|
||||||
conf = trove_conf
|
|
||||||
if conf and conf['keystone_authtoken'] and
|
|
||||||
auth_keys.all?{|k| !conf['keystone_authtoken'][k].nil?}
|
|
||||||
return Hash[ auth_keys.map \
|
|
||||||
{ |k| [k, conf['keystone_authtoken'][k].strip] } ]
|
|
||||||
else
|
|
||||||
raise(Puppet::Error, "File: #{conf_filename} does not contain all \
|
|
||||||
required sections. Trove types will not work if trove is not \
|
|
||||||
correctly configured.")
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def trove_credentials
|
|
||||||
self.class.trove_credentials
|
|
||||||
end
|
|
||||||
|
|
||||||
def self.trove_conf
|
def self.trove_conf
|
||||||
return @trove_conf if @trove_conf
|
return @trove_conf if @trove_conf
|
||||||
@trove_conf = Puppet::Util::IniConfig::File.new
|
@trove_conf = Puppet::Util::IniConfig::File.new
|
||||||
|
@ -51,35 +45,63 @@ correctly configured.")
|
||||||
@trove_conf
|
@trove_conf
|
||||||
end
|
end
|
||||||
|
|
||||||
def self.auth_trove(*args)
|
def self.trove_credentials
|
||||||
q = trove_credentials
|
@trove_credentials ||= get_trove_credentials
|
||||||
authenv = {
|
end
|
||||||
:OS_AUTH_URL => q['auth_url'],
|
|
||||||
:OS_USERNAME => q['username'],
|
def trove_credentials
|
||||||
:OS_PROJECT_NAME => q['project_name'],
|
self.class.trove_credentials
|
||||||
:OS_PASSWORD => q['password'],
|
end
|
||||||
:OS_PROJECT_DOMAIN_NAME => q['project_domain_name'],
|
|
||||||
:OS_USER_DOMAIN_NAME => q['user_domain_name']
|
def self.get_trove_credentials
|
||||||
}
|
#needed keys for authentication
|
||||||
begin
|
auth_keys = ['auth_url', 'project_name', 'username', 'password']
|
||||||
withenv authenv do
|
conf = trove_conf
|
||||||
trove(args)
|
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['keystone_authtoken']['region_name'].nil?
|
||||||
|
creds['region_name'] = conf['keystone_authtoken']['region_name'].strip
|
||||||
end
|
end
|
||||||
rescue Exception => e
|
|
||||||
if (e.message =~ /\[Errno 111\] Connection refused/) or
|
if !conf['keystone_authtoken']['project_domain_name'].nil?
|
||||||
(e.message =~ /\(HTTP 400\)/)
|
creds['project_domain_name'] = conf['keystone_authtoken']['project_domain_name'].strip
|
||||||
sleep 10
|
|
||||||
withenv authenv do
|
|
||||||
trove(args)
|
|
||||||
end
|
|
||||||
else
|
else
|
||||||
raise(e)
|
creds['project_domain_name'] = 'Default'
|
||||||
end
|
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. Trove types will not work if trove is not " +
|
||||||
|
"correctly configured.")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def auth_trove(*args)
|
def self.conf_filename
|
||||||
self.class.auth_trove(args)
|
'/etc/trove/trove.conf'
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.get_auth_endpoint
|
||||||
|
q = trove_credentials
|
||||||
|
"#{q['auth_url']}"
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.auth_endpoint
|
||||||
|
@auth_endpoint ||= get_auth_endpoint
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.reset
|
||||||
|
@auth_endpoint = nil
|
||||||
|
@trove_conf = nil
|
||||||
|
@trove_credentials = nil
|
||||||
end
|
end
|
||||||
|
|
||||||
def trove_manage(*args)
|
def trove_manage(*args)
|
||||||
|
@ -87,20 +109,4 @@ correctly configured.")
|
||||||
output = `#{cmd}`
|
output = `#{cmd}`
|
||||||
$?.exitstatus
|
$?.exitstatus
|
||||||
end
|
end
|
||||||
|
|
||||||
def self.reset
|
|
||||||
@trove_conf = nil
|
|
||||||
@trove_credentials = nil
|
|
||||||
end
|
|
||||||
|
|
||||||
def self.list_trove_resources(type, *args)
|
|
||||||
json = auth_trove("--json", "#{type}-list", *args)
|
|
||||||
return JSON.parse(json)
|
|
||||||
end
|
|
||||||
|
|
||||||
def self.get_trove_resource_attrs(type, id)
|
|
||||||
json = auth_trove("--json", "#{type}-show", id)
|
|
||||||
return JSON.parse(json)
|
|
||||||
end
|
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|
|
@ -9,16 +9,16 @@ Puppet::Type.type(:trove_datastore).provide(
|
||||||
Trove provider to manage datastore type.
|
Trove provider to manage datastore type.
|
||||||
EOT
|
EOT
|
||||||
|
|
||||||
commands :trove => "trove"
|
|
||||||
|
|
||||||
mk_resource_methods
|
mk_resource_methods
|
||||||
|
|
||||||
|
@credentials = Puppet::Provider::Openstack::CredentialsV3.new
|
||||||
|
|
||||||
def self.instances
|
def self.instances
|
||||||
list_trove_resources("datastore").collect do |attrs|
|
request('datastore', 'list').collect do |attrs|
|
||||||
new(
|
new(
|
||||||
:ensure => :present,
|
:ensure => :present,
|
||||||
:name => attrs["name"],
|
:name => attrs[:name],
|
||||||
:id => attrs["id"]
|
:id => attrs[:id]
|
||||||
)
|
)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -9,10 +9,10 @@ Puppet::Type.type(:trove_datastore_version).provide(
|
||||||
Trove provider to manage datastore version type.
|
Trove provider to manage datastore version type.
|
||||||
EOT
|
EOT
|
||||||
|
|
||||||
commands :trove => "trove"
|
|
||||||
|
|
||||||
mk_resource_methods
|
mk_resource_methods
|
||||||
|
|
||||||
|
@credentials = Puppet::Provider::Openstack::CredentialsV3.new
|
||||||
|
|
||||||
def self.prefetch(resource)
|
def self.prefetch(resource)
|
||||||
@datastore_version_hash = nil
|
@datastore_version_hash = nil
|
||||||
end
|
end
|
||||||
|
@ -30,7 +30,7 @@ Puppet::Type.type(:trove_datastore_version).provide(
|
||||||
end
|
end
|
||||||
|
|
||||||
def exists?
|
def exists?
|
||||||
datastore_version_hash(resource[:datastore])[resource[:name]]
|
datastore_version_hash(@resource[:datastore])[@resource[:name]]
|
||||||
end
|
end
|
||||||
|
|
||||||
def create
|
def create
|
||||||
|
@ -49,12 +49,12 @@ Puppet::Type.type(:trove_datastore_version).provide(
|
||||||
|
|
||||||
private
|
private
|
||||||
|
|
||||||
def self.build_datastore_version_hash(datastore)
|
def self.build_datastore_version_hash(datastore)
|
||||||
dvs = {}
|
dvs = {}
|
||||||
list_trove_resources("datastore-version", datastore).collect do |attrs|
|
request('datastore version', 'list', datastore).each do |attrs|
|
||||||
dvs[attrs["name"]] = attrs
|
dvs[attrs[:name]] = attrs
|
||||||
end
|
|
||||||
dvs
|
|
||||||
end
|
end
|
||||||
|
dvs
|
||||||
|
end
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|
|
@ -6,6 +6,13 @@ provider_class = Puppet::Type.type(:trove_datastore).provider(:trove)
|
||||||
|
|
||||||
describe provider_class do
|
describe provider_class do
|
||||||
|
|
||||||
|
let(:set_env) do
|
||||||
|
ENV['OS_USERNAME'] = 'test'
|
||||||
|
ENV['OS_PASSWORD'] = 'abc123'
|
||||||
|
ENV['OS_PROJECT_NAME'] = 'test'
|
||||||
|
ENV['OS_AUTH_URL'] = 'http://127.0.0.1:5000'
|
||||||
|
end
|
||||||
|
|
||||||
let :datastore_name do
|
let :datastore_name do
|
||||||
'foo'
|
'foo'
|
||||||
end
|
end
|
||||||
|
@ -23,32 +30,35 @@ describe provider_class do
|
||||||
end
|
end
|
||||||
|
|
||||||
before :each do
|
before :each do
|
||||||
described_class.stubs(:list_trove_resources).with('datastore').returns([
|
set_env
|
||||||
resource
|
|
||||||
])
|
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "self.instances" do
|
describe "self.instances" do
|
||||||
it "should have an instances method" do
|
it 'lists datastores' do
|
||||||
expect(provider.class).to respond_to(:instances)
|
provider_class.expects(:openstack)
|
||||||
end
|
.with('datastore', 'list', '--quiet', '--format', 'csv', [])
|
||||||
|
.returns('"ID","Name"
|
||||||
it "should list instances" do
|
"1275b24c-73af-4c51-98ec-c9938a94a153","store1"
|
||||||
datastores = described_class.instances
|
"18088802-efe2-42f8-ac85-ecfddd37d24e","store2"
|
||||||
expect(datastores.size).to eq(1)
|
')
|
||||||
datastores.map {|provider| provider.name} == datastore_name
|
instances = provider_class.instances
|
||||||
|
expect(instances.length).to eq(2)
|
||||||
|
expect(instances[0].id).to eq('1275b24c-73af-4c51-98ec-c9938a94a153')
|
||||||
|
expect(instances[0].name).to eq('store1')
|
||||||
|
expect(instances[1].id).to eq('18088802-efe2-42f8-ac85-ecfddd37d24e')
|
||||||
|
expect(instances[1].name).to eq('store2')
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe '#create' do
|
describe '#create' do
|
||||||
it 'should call trove-manage' do
|
it 'creates datastore' do
|
||||||
provider.expects(:trove_manage).with(
|
provider.expects(:trove_manage)
|
||||||
['trove-manage', 'datastore_update', datastore_name, "''"]
|
.with(['trove-manage', 'datastore_update', datastore_name, "''"])
|
||||||
).returns(0)
|
.returns(0)
|
||||||
|
|
||||||
provider.expects(:trove_manage).with(
|
provider.expects(:trove_manage)
|
||||||
['trove-manage', 'datastore_update', datastore_name, "0.1"]
|
.with(['trove-manage', 'datastore_update', datastore_name, "0.1"])
|
||||||
).returns(0)
|
.returns(0)
|
||||||
|
|
||||||
provider.create
|
provider.create
|
||||||
end
|
end
|
||||||
|
|
|
@ -6,12 +6,19 @@ provider_class = Puppet::Type.type(:trove_datastore_version).provider(:trove)
|
||||||
|
|
||||||
describe provider_class do
|
describe provider_class do
|
||||||
|
|
||||||
|
let(:set_env) do
|
||||||
|
ENV['OS_USERNAME'] = 'test'
|
||||||
|
ENV['OS_PASSWORD'] = 'abc123'
|
||||||
|
ENV['OS_PROJECT_NAME'] = 'test'
|
||||||
|
ENV['OS_AUTH_URL'] = 'http://127.0.0.1:5000'
|
||||||
|
end
|
||||||
|
|
||||||
let :datastore_name do
|
let :datastore_name do
|
||||||
'foo'
|
'mysql'
|
||||||
end
|
end
|
||||||
|
|
||||||
let :datastore_version do
|
let :datastore_version do
|
||||||
'1.0'
|
'5.7.29'
|
||||||
end
|
end
|
||||||
|
|
||||||
let :resource do
|
let :resource do
|
||||||
|
@ -30,7 +37,11 @@ describe provider_class do
|
||||||
described_class.new(resource)
|
described_class.new(resource)
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "self.instances" do
|
before :each do
|
||||||
|
set_env
|
||||||
|
end
|
||||||
|
|
||||||
|
describe "#instances" do
|
||||||
it "should have an instances method" do
|
it "should have an instances method" do
|
||||||
expect(provider.class).to respond_to(:instances)
|
expect(provider.class).to respond_to(:instances)
|
||||||
end
|
end
|
||||||
|
@ -39,12 +50,24 @@ describe provider_class do
|
||||||
describe '#create' do
|
describe '#create' do
|
||||||
it 'should call trove-manage' do
|
it 'should call trove-manage' do
|
||||||
provider.expects(:trove_manage).with(
|
provider.expects(:trove_manage).with(
|
||||||
['trove-manage', 'datastore_version_update', datastore_name, "1.0",
|
['trove-manage', 'datastore_version_update', datastore_name,
|
||||||
'mysql', '1234', 'mysql', '1']
|
datastore_version, 'mysql', '1234', 'mysql', '1']
|
||||||
).returns(0)
|
).returns(0)
|
||||||
|
|
||||||
provider.create
|
provider.create
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe '#exists' do
|
||||||
|
it 'should list datastore versions' do
|
||||||
|
provider_class.expects(:openstack)
|
||||||
|
.with('datastore version', 'list', '--quiet', '--format', 'csv',
|
||||||
|
datastore_name)
|
||||||
|
.returns('"ID","Name","Version"
|
||||||
|
"9c4d3fb1-644c-4543-9c37-49b3a801b66c","5.7.29","5.7.29"
|
||||||
|
"406b75fb-0727-4923-a702-d677e3fd84ab","5.7.30","5.7.30"
|
||||||
|
')
|
||||||
|
expect(provider.exists?).to be_truthy
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue