Revision 18bca424
Added by Eric Helms about 1 month ago
| lib/puppet/provider/cpdb_update/cpdb_update.rb | ||
|---|---|---|
|
Puppet::Type.type(:cpdb_update).provide(:cpdb_update) do
|
||
|
|
||
|
commands :cpdb => '/usr/share/candlepin/cpdb'
|
||
|
commands :rpm => 'rpm'
|
||
|
|
||
|
def create
|
||
|
migrate_database
|
||
|
update_version_file
|
||
|
end
|
||
|
|
||
|
def exists?
|
||
|
return false if previous_candlepin_version.nil?
|
||
|
return false if candlepin_rpm_version.nil?
|
||
|
|
||
|
Gem::Version.new(previous_candlepin_version) == Gem::Version.new(candlepin_rpm_version)
|
||
|
!pending_migrations?
|
||
|
end
|
||
|
|
||
|
private
|
||
|
|
||
|
def migrate_database
|
||
|
output = cpdb(
|
||
|
cpdb(
|
||
|
"--update",
|
||
|
"--dbhost=#{resource[:db_host]}",
|
||
|
"--dbport=#{resource[:db_port]}",
|
||
| ... | ... | |
|
)
|
||
|
end
|
||
|
|
||
|
def version_file
|
||
|
"/var/lib/candlepin/.puppet-candlepin-rpm-version"
|
||
|
end
|
||
|
|
||
|
def update_version_file
|
||
|
File.open(version_file, "w") do |file|
|
||
|
file.write(candlepin_rpm_version)
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def candlepin_rpm_version
|
||
|
rpm('-q', 'candlepin', '--queryformat=%{version}')
|
||
|
end
|
||
|
def pending_migrations?
|
||
|
output = cpdb(
|
||
|
"--status",
|
||
|
"--dbhost=#{resource[:db_host]}",
|
||
|
"--dbport=#{resource[:db_port]}",
|
||
|
"--database=#{resource[:db_name]}#{resource[:ssl_options]}",
|
||
|
"--user=#{resource[:db_user]}",
|
||
|
"--password=#{resource[:db_password]}"
|
||
|
)
|
||
|
|
||
|
def previous_candlepin_version
|
||
|
File.read(version_file) if File.exist?(version_file)
|
||
|
output.include?("changesets have not been applied")
|
||
|
end
|
||
|
|
||
|
end
|
||
Also available in: Unified diff
Support Candlepin 4.4