78 lines
1.6 KiB
Ruby
78 lines
1.6 KiB
Ruby
require File.join(File.dirname(__FILE__), '..', 'vcsrepo')
|
|
|
|
Puppet::Type.type(:vcsrepo).provide(:hg, :parent => Puppet::Provider::Vcsrepo) do
|
|
desc "Supports Mercurial repositories"
|
|
|
|
commands :hg => 'hg'
|
|
defaultfor :hg => :exists
|
|
has_features :reference_tracking
|
|
|
|
def create
|
|
if !@resource.value(:source)
|
|
create_repository(@resource.value(:path))
|
|
else
|
|
clone_repository(@resource.value(:revision))
|
|
end
|
|
end
|
|
|
|
def exists?
|
|
File.directory?(File.join(@resource.value(:path), '.hg'))
|
|
end
|
|
|
|
def destroy
|
|
FileUtils.rm_rf(@resource.value(:path))
|
|
end
|
|
|
|
def revision
|
|
at_path do
|
|
current = hg('parents')[/^changeset:\s+(?:-?\d+):(\S+)/m, 1]
|
|
desired = @resource.value(:revision)
|
|
if current == desired
|
|
current
|
|
else
|
|
mapped = hg('tags')[/^#{Regexp.quote(desired)}\s+\d+:(\S+)/m, 1]
|
|
if mapped
|
|
# A tag, return that tag if it maps to the current nodeid
|
|
if current == mapped
|
|
desired
|
|
else
|
|
current
|
|
end
|
|
else
|
|
# Use the current nodeid
|
|
current
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def revision=(desired)
|
|
at_path do
|
|
hg('pull')
|
|
begin
|
|
hg('merge')
|
|
rescue Puppet::ExecutionFailure
|
|
# If there's nothing to merge, just skip
|
|
end
|
|
hg('update', '--clean', '-r', desired)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def create_repository(path)
|
|
hg('init', path)
|
|
end
|
|
|
|
def clone_repository(revision)
|
|
args = ['clone']
|
|
if revision
|
|
args.push('-u', revision)
|
|
end
|
|
args.push(@resource.value(:source),
|
|
@resource.value(:path))
|
|
hg(*args)
|
|
end
|
|
|
|
end
|