diff options
author | luke <luke@980ebf18-57e1-0310-9a29-db15c13687c0> | 2007-05-09 23:08:42 +0000 |
---|---|---|
committer | luke <luke@980ebf18-57e1-0310-9a29-db15c13687c0> | 2007-05-09 23:08:42 +0000 |
commit | 1d23013abf9e8db5aa405c87ac6657df3f050926 (patch) | |
tree | 9e0cb3f82fea8ffdcfacc4637e1412454f538e34 /lib/puppet/provider | |
parent | de212261e75883036f74e241a548d31340440df9 (diff) | |
download | puppet-1d23013abf9e8db5aa405c87ac6657df3f050926.tar.gz puppet-1d23013abf9e8db5aa405c87ac6657df3f050926.tar.xz puppet-1d23013abf9e8db5aa405c87ac6657df3f050926.zip |
Fixing #605 -- providers now refer to @resource or @resource_type.
git-svn-id: https://reductivelabs.com/svn/puppet/trunk@2501 980ebf18-57e1-0310-9a29-db15c13687c0
Diffstat (limited to 'lib/puppet/provider')
38 files changed, 244 insertions, 244 deletions
diff --git a/lib/puppet/provider/cron/crontab.rb b/lib/puppet/provider/cron/crontab.rb index 017744435..23fa9201c 100755 --- a/lib/puppet/provider/cron/crontab.rb +++ b/lib/puppet/provider/cron/crontab.rb @@ -85,7 +85,7 @@ Puppet::Type.type(:cron).provide(:crontab, # See if we can match the hash against an existing cron job. def self.match(hash) - model.find_all { |obj| + resource_type.find_all { |obj| obj.value(:user) == hash[:user] and obj.value(:command) == hash[:command] }.each do |obj| # we now have a cron job whose command exactly matches diff --git a/lib/puppet/provider/group/groupadd.rb b/lib/puppet/provider/group/groupadd.rb index c37bdb933..b41ff6f93 100644 --- a/lib/puppet/provider/group/groupadd.rb +++ b/lib/puppet/provider/group/groupadd.rb @@ -12,15 +12,15 @@ Puppet::Type.type(:group).provide :groupadd, :parent => Puppet::Provider::NameSe def addcmd cmd = [command(:add)] - if gid = @model.should(:gid) + if gid = @resource.should(:gid) unless gid == :absent cmd << flag(:gid) << gid end end - if @model[:allowdupe] == :true + if @resource[:allowdupe] == :true cmd << "-o" end - cmd << @model[:name] + cmd << @resource[:name] return cmd end diff --git a/lib/puppet/provider/group/pw.rb b/lib/puppet/provider/group/pw.rb index 8011357b5..d2b9611b1 100644 --- a/lib/puppet/provider/group/pw.rb +++ b/lib/puppet/provider/group/pw.rb @@ -11,8 +11,8 @@ Puppet::Type.type(:group).provide :pw, :parent => Puppet::Provider::NameService: end def addcmd - cmd = [command(:pw), "groupadd", @model[:name]] - if gid = @model.should(:gid) + cmd = [command(:pw), "groupadd", @resource[:name]] + if gid = @resource.should(:gid) unless gid == :absent cmd << flag(:gid) << gid end diff --git a/lib/puppet/provider/mount.rb b/lib/puppet/provider/mount.rb index cdae61f83..d270261ec 100644 --- a/lib/puppet/provider/mount.rb +++ b/lib/puppet/provider/mount.rb @@ -14,15 +14,15 @@ module Puppet::Provider::Mount if self.options and self.options != :absent args << "-o" << self.options end - args << @model[:name] + args << @resource[:name] mountcmd(*args) end def remount info "Remounting" - if @model[:remounts] == :true - mountcmd "-o", "remount", @model[:name] + if @resource[:remounts] == :true + mountcmd "-o", "remount", @resource[:name] else unmount() mount() @@ -31,7 +31,7 @@ module Puppet::Provider::Mount # This only works when the mount point is synced to the fstab. def unmount - umount @model[:name] + umount @resource[:name] end # Is the mount currently mounted? @@ -45,10 +45,10 @@ module Puppet::Provider::Mount execute(df).split("\n").find do |line| fs = line.split(/\s+/)[-1] if platform == "Darwin" - fs == "/private/var/automount" + @model[:name] or - fs == @model[:name] + fs == "/private/var/automount" + @resource[:name] or + fs == @resource[:name] else - fs == @model[:name] + fs == @resource[:name] end end end diff --git a/lib/puppet/provider/mount/netinfo.rb b/lib/puppet/provider/mount/netinfo.rb index bd1d451c0..ca3aee107 100644 --- a/lib/puppet/provider/mount/netinfo.rb +++ b/lib/puppet/provider/mount/netinfo.rb @@ -19,18 +19,18 @@ require 'puppet/provider/mount' # # defaultfor :operatingsystem => :darwin # -# def initialize(model) +# def initialize(resource) # warning "The NetInfo mount provider is highly experimental. Use at your own risk." # super # end # # def mount # cmd = [] -# if opts = @model.should(:options) +# if opts = @resource.should(:options) # cmd << opts # end -# cmd << @model.should(:device) -# cmd << @model[:name] +# cmd << @resource.should(:device) +# cmd << @resource[:name] # mountcmd cmd # end # end diff --git a/lib/puppet/provider/nameservice.rb b/lib/puppet/provider/nameservice.rb index 9b4d34ddb..8e01bfe21 100644 --- a/lib/puppet/provider/nameservice.rb +++ b/lib/puppet/provider/nameservice.rb @@ -29,12 +29,12 @@ class Puppet::Provider::NameService < Puppet::Provider objects = [] listbyname do |name| obj = nil - check = model.validproperties - if obj = model[name] + check = resource_type.validproperties + if obj = resource_type[name] obj[:check] = check else # unless it exists, create it as an unmanaged object - obj = model.create(:name => name, :check => check) + obj = resource_type.create(:name => name, :check => check) end next unless obj # In case there was an error somewhere @@ -56,9 +56,9 @@ class Puppet::Provider::NameService < Puppet::Provider end def options(name, hash) - unless model.validattr?(name) + unless resource_type.validattr?(name) raise Puppet::DevError, "%s is not a valid attribute for %s" % - [name, model.name] + [name, resource_type.name] end @options ||= {} @options[name] ||= {} @@ -89,9 +89,9 @@ class Puppet::Provider::NameService < Puppet::Provider return names end - def model=(model) + def resource_type=(resource_type) super - @model.validproperties.each do |prop| + @resource_type.validproperties.each do |prop| next if prop == :ensure unless public_method_defined?(prop) define_method(prop) { get(prop) || :absent} @@ -105,13 +105,13 @@ class Puppet::Provider::NameService < Puppet::Provider # This is annoying, but there really aren't that many options, # and this *is* built into Ruby. def section - unless defined? @model + unless defined? @resource_type raise Puppet::DevError, - "Cannot determine Etc section without a model" + "Cannot determine Etc section without a resource type" end - if @model.name == :group + if @resource_type.name == :group "gr" else "pw" @@ -146,7 +146,7 @@ class Puppet::Provider::NameService < Puppet::Provider def autogen(field) field = symbolize(field) id_generators = {:user => :uid, :group => :gid} - if id_generators[@model.class.name] == field + if id_generators[@resource.class.name] == field return autogen_id(field) else if value = self.class.autogen_default(field) @@ -165,11 +165,11 @@ class Puppet::Provider::NameService < Puppet::Provider highest = 0 group = method = nil - case @model.class.name + case @resource.class.name when :user: group = :passwd; method = :uid when :group: group = :group; method = :gid else - raise Puppet::DevError, "Invalid model name %s" % model + raise Puppet::DevError, "Invalid resource name %s" % resource end # Make sure we don't use the same value multiple times @@ -239,7 +239,7 @@ class Puppet::Provider::NameService < Puppet::Provider execute(cmd) rescue Puppet::ExecutionFailure => detail raise Puppet::Error, "Could not %s %s %s: %s" % - [type, @model.class.name, @model.name, detail] + [type, @resource.class.name, @resource.name, detail] end end @@ -266,7 +266,7 @@ class Puppet::Provider::NameService < Puppet::Provider if @objectinfo.nil? or refresh == true @etcmethod ||= ("get" + self.class.section().to_s + "nam").intern begin - @objectinfo = Etc.send(@etcmethod, @model[:name]) + @objectinfo = Etc.send(@etcmethod, @resource[:name]) rescue ArgumentError => detail @objectinfo = nil end @@ -288,7 +288,7 @@ class Puppet::Provider::NameService < Puppet::Provider # Reset our group list Etc.setgrent - user = @model[:name] + user = @resource[:name] # Now iterate across all of the groups, adding each one our # user is a member of @@ -310,7 +310,7 @@ class Puppet::Provider::NameService < Puppet::Provider # Convert the Etc struct into a hash. def info2hash(info) hash = {} - self.class.model.validproperties.each do |param| + self.class.resource_type.validproperties.each do |param| method = posixmethod(param) if info.respond_to? method hash[param] = info.send(posixmethod(param)) @@ -320,7 +320,7 @@ class Puppet::Provider::NameService < Puppet::Provider return hash end - def initialize(model) + def initialize(resource) super @objectinfo = nil @@ -336,7 +336,7 @@ class Puppet::Provider::NameService < Puppet::Provider execute(cmd) rescue Puppet::ExecutionFailure => detail raise Puppet::Error, "Could not set %s on %s[%s]: %s" % - [param, @model.class.name, @model.name, detail] + [param, @resource.class.name, @resource.name, detail] end end end diff --git a/lib/puppet/provider/nameservice/netinfo.rb b/lib/puppet/provider/nameservice/netinfo.rb index 134ef37e9..c44f105e8 100644 --- a/lib/puppet/provider/nameservice/netinfo.rb +++ b/lib/puppet/provider/nameservice/netinfo.rb @@ -32,7 +32,7 @@ class NetInfo < Puppet::Provider::NameService if defined? @netinfodir return @netinfodir else - return @model.name.to_s + "s" + return @resource_type.name.to_s + "s" end end @@ -62,8 +62,8 @@ class NetInfo < Puppet::Provider::NameService end def self.list - report(@model.validproperties).collect do |hash| - @model.hash2obj(hash) + report(@resource_type.validproperties).collect do |hash| + @resource_type.hash2obj(hash) end end @@ -118,7 +118,7 @@ class NetInfo < Puppet::Provider::NameService cmd = [command(:niutil)] cmd << arg - cmd << "/" << "/%s/%s" % [self.class.netinfodir(), @model[:name]] + cmd << "/" << "/%s/%s" % [self.class.netinfodir(), @resource[:name]] return cmd end @@ -136,9 +136,9 @@ class NetInfo < Puppet::Provider::NameService # Because our stupid type can't create the whole thing at once, # we have to do this hackishness. Yay. if arg == :present - @model.class.validproperties.each do |name| + @resource.class.validproperties.each do |name| next if name == :ensure - next unless val = @model.should(name) || autogen(name) + next unless val = @resource.should(name) || autogen(name) self.send(name.to_s + "=", val) end end @@ -157,7 +157,7 @@ class NetInfo < Puppet::Provider::NameService # Retrieve everything about this object at once, instead of separately. def getinfo(refresh = false) if refresh or (! defined? @infohash or ! @infohash) - properties = [:name] + self.class.model.validproperties + properties = [:name] + self.class.resource_type.validproperties properties.delete(:ensure) if properties.include? :ensure @infohash = single_report(*properties) end @@ -171,7 +171,7 @@ class NetInfo < Puppet::Provider::NameService # warning "Netinfo providers cannot currently handle multiple values" # end - cmd << "-createprop" << "/" << "/%s/%s" % [self.class.netinfodir, @model[:name]] + cmd << "-createprop" << "/" << "/%s/%s" % [self.class.netinfodir, @resource[:name]] value = [value] unless value.is_a?(Array) if key = netinfokey(param) @@ -192,7 +192,7 @@ class NetInfo < Puppet::Provider::NameService # Get a report for a single resource, not the whole table def single_report(*properties) - self.class.report(*properties).find do |hash| hash[:name] == @model[:name] end + self.class.report(*properties).find do |hash| hash[:name] == @resource[:name] end end def setuserlist(group, list) diff --git a/lib/puppet/provider/nameservice/objectadd.rb b/lib/puppet/provider/nameservice/objectadd.rb index af099289f..f7865185d 100644 --- a/lib/puppet/provider/nameservice/objectadd.rb +++ b/lib/puppet/provider/nameservice/objectadd.rb @@ -12,7 +12,7 @@ class ObjectAdd < Puppet::Provider::NameService end def deletecmd - [command(:delete), @model[:name]] + [command(:delete), @resource[:name]] end # Determine the flag to pass to our command. @@ -25,10 +25,10 @@ class ObjectAdd < Puppet::Provider::NameService cmd = [command(:modify), flag(param), value] - if @model[:allowdupe] == :true + if @resource[:allowdupe] == :true cmd << "-o" end - cmd << @model[:name] + cmd << @resource[:name] return cmd end diff --git a/lib/puppet/provider/nameservice/pw.rb b/lib/puppet/provider/nameservice/pw.rb index 72d7628e6..0ee9d1d2c 100644 --- a/lib/puppet/provider/nameservice/pw.rb +++ b/lib/puppet/provider/nameservice/pw.rb @@ -3,14 +3,14 @@ require 'puppet/provider/nameservice/objectadd' class Puppet::Provider::NameService class PW < ObjectAdd def deletecmd - [command(:pw), "#{@model.class.name.to_s}del", @model[:name]] + [command(:pw), "#{@resource.class.name.to_s}del", @resource[:name]] end def modifycmd(param, value) cmd = [ command(:pw), - "#{@model.class.name.to_s}mod", - @model[:name], + "#{@resource.class.name.to_s}mod", + @resource[:name], flag(param), value ] diff --git a/lib/puppet/provider/package/apple.rb b/lib/puppet/provider/package/apple.rb index e34820b55..ce845670f 100755 --- a/lib/puppet/provider/package/apple.rb +++ b/lib/puppet/provider/package/apple.rb @@ -33,8 +33,8 @@ Puppet::Type.type(:package).provide :apple do end def query - if FileTest.exists?("/Library/Receipts/#{@model[:name]}.pkg") - return {:name => @model[:name], :ensure => :present} + if FileTest.exists?("/Library/Receipts/#{@resource[:name]}.pkg") + return {:name => @resource[:name], :ensure => :present} else return nil end @@ -42,7 +42,7 @@ Puppet::Type.type(:package).provide :apple do def install source = nil - unless source = @model[:source] + unless source = @resource[:source] self.fail "Mac OS X packages must specify a package source" end diff --git a/lib/puppet/provider/package/apt.rb b/lib/puppet/provider/package/apt.rb index 034a406f1..81b7c9a12 100755 --- a/lib/puppet/provider/package/apt.rb +++ b/lib/puppet/provider/package/apt.rb @@ -31,7 +31,7 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do end end - if @@checkedforcdrom and @model[:allowcdrom] != :true + if @@checkedforcdrom and @resource[:allowcdrom] != :true raise Puppet::Error, "/etc/apt/sources.list contains a cdrom source; not installing. Use 'allowcdrom' to override this failure." end @@ -40,14 +40,14 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do # Install a package using 'apt-get'. This function needs to support # installing a specific version. def install - if @model[:responsefile] + if @resource[:responsefile] self.run_preseed end - should = @model.should(:ensure) + should = @resource.should(:ensure) checkforcdrom() - str = @model[:name] + str = @resource[:name] case should when true, false, Symbol # pass @@ -58,7 +58,7 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do cmd = %w{-q -y} keep = "" - if config = @model[:configfiles] + if config = @resource[:configfiles] case config when :keep cmd << "-o" << 'DPkg::Options::=--force-confold' @@ -76,7 +76,7 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do # What's the latest package version available? def latest - output = aptcache :policy, @model[:name] + output = aptcache :policy, @resource[:name] if output =~ /Candidate:\s+(\S+)\s/ return $1 @@ -90,7 +90,7 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do # preseeds answers to dpkg-set-selection from the "responsefile" # def run_preseed - if response = @model[:responsefile] and FileTest.exists?(response) + if response = @resource[:responsefile] and FileTest.exists?(response) self.info("Preseeding %s to debconf-set-selections" % response) preseed response @@ -104,11 +104,11 @@ Puppet::Type.type(:package).provide :apt, :parent => :dpkg do end def uninstall - aptget "-y", "-q", :remove, @model[:name] + aptget "-y", "-q", :remove, @resource[:name] end def purge - aptget '-y', '-q', 'remove', '--purge', @model[:name] + aptget '-y', '-q', 'remove', '--purge', @resource[:name] end def versionable? diff --git a/lib/puppet/provider/package/aptitude.rb b/lib/puppet/provider/package/aptitude.rb index c4f8023d2..32dd37627 100755 --- a/lib/puppet/provider/package/aptitude.rb +++ b/lib/puppet/provider/package/aptitude.rb @@ -23,7 +23,7 @@ Puppet::Type.type(:package).provide :aptitude, :parent => :apt do end def purge - aptitude '-y', 'purge', @model[:name] + aptitude '-y', 'purge', @resource[:name] end end diff --git a/lib/puppet/provider/package/aptrpm.rb b/lib/puppet/provider/package/aptrpm.rb index 919236365..89a309857 100644 --- a/lib/puppet/provider/package/aptrpm.rb +++ b/lib/puppet/provider/package/aptrpm.rb @@ -11,9 +11,9 @@ Puppet::Type.type(:package).provide :aptrpm, :parent => :rpm do # Install a package using 'apt-get'. This function needs to support # installing a specific version. def install - should = @model.should(:ensure) + should = @resource.should(:ensure) - str = @model[:name] + str = @resource[:name] case should when true, false, Symbol # pass @@ -30,7 +30,7 @@ Puppet::Type.type(:package).provide :aptrpm, :parent => :rpm do # What's the latest package version available? def latest - output = aptcache :showpkg, @model[:name] + output = aptcache :showpkg, @resource[:name] if output =~ /Versions:\s*\n((\n|.)+)^$/ versions = $1 @@ -64,11 +64,11 @@ Puppet::Type.type(:package).provide :aptrpm, :parent => :rpm do end def uninstall - aptget "-y", "-q", 'remove', @model[:name] + aptget "-y", "-q", 'remove', @resource[:name] end def purge - aptget '-y', '-q', 'remove', '--purge', @model[:name] + aptget '-y', '-q', 'remove', '--purge', @resource[:name] end def versionable? diff --git a/lib/puppet/provider/package/blastwave.rb b/lib/puppet/provider/package/blastwave.rb index e8a925b2c..9f544dbd5 100755 --- a/lib/puppet/provider/package/blastwave.rb +++ b/lib/puppet/provider/package/blastwave.rb @@ -86,28 +86,28 @@ Puppet::Type.type(:package).provide :blastwave, :parent => :sun do end def install - pkgget "-f", :install, @model[:name] + pkgget "-f", :install, @resource[:name] end # Retrieve the version from the current package file. def latest - hash = self.class.blastlist(:justme => @model[:name]) + hash = self.class.blastlist(:justme => @resource[:name]) hash[:avail] end def query - hash = self.class.blastlist(:justme => @model[:name]) + hash = self.class.blastlist(:justme => @resource[:name]) {:ensure => hash[:ensure]} end # Remove the old package, and install the new one def update - pkgget "-f", :upgrade, @model[:name] + pkgget "-f", :upgrade, @resource[:name] end def uninstall - pkgget "-f", :remove, @model[:name] + pkgget "-f", :remove, @resource[:name] end end diff --git a/lib/puppet/provider/package/darwinport.rb b/lib/puppet/provider/package/darwinport.rb index adc722a66..70e6ed388 100755 --- a/lib/puppet/provider/package/darwinport.rb +++ b/lib/puppet/provider/package/darwinport.rb @@ -43,19 +43,19 @@ Puppet::Type.type(:package).provide :darwinport do end def install - should = @model.should(:ensure) + should = @resource.should(:ensure) # Seems like you can always say 'upgrade' - output = port "upgrade", @model[:name] + output = port "upgrade", @resource[:name] if output =~ /^Error: No port/ - raise Puppet::ExecutionFailure, "Could not find package %s" % @model[:name] + raise Puppet::ExecutionFailure, "Could not find package %s" % @resource[:name] end end def query version = nil self.class.eachpkgashash do |hash| - if hash[:name] == @model[:name] + if hash[:name] == @resource[:name] return hash end end @@ -64,7 +64,7 @@ Puppet::Type.type(:package).provide :darwinport do end def latest - info = port :search, "^#{@model[:name]}$" + info = port :search, "^#{@resource[:name]}$" if $? != 0 or info =~ /^Error/ return nil @@ -77,7 +77,7 @@ Puppet::Type.type(:package).provide :darwinport do end def uninstall - port :uninstall, @model[:name] + port :uninstall, @resource[:name] end def update diff --git a/lib/puppet/provider/package/dpkg.rb b/lib/puppet/provider/package/dpkg.rb index 53b23ad64..45b351351 100755 --- a/lib/puppet/provider/package/dpkg.rb +++ b/lib/puppet/provider/package/dpkg.rb @@ -41,7 +41,7 @@ Puppet::Type.type(:package).provide :dpkg do end def install - unless file = @model[:source] + unless file = @resource[:source] raise ArgumentError, "You cannot install dpkg packages without a source" end dpkg "-i", file @@ -57,12 +57,12 @@ Puppet::Type.type(:package).provide :dpkg do # list out our specific package begin output = dpkgquery("-W", "--showformat", - '${Status} ${Package} ${Version}\\n', @model[:name] + '${Status} ${Package} ${Version}\\n', @resource[:name] ) rescue Puppet::ExecutionFailure # dpkg-query exits 1 if the package is not found. return {:ensure => :absent, :status => 'missing', - :name => @model[:name], :error => 'ok'} + :name => @resource[:name], :error => 'ok'} end # Our regex for matching dpkg-query output. We could probably just @@ -79,7 +79,7 @@ Puppet::Type.type(:package).provide :dpkg do else notice "Failed to handle dpkg-query line %s" % line.inspect return {:ensure => :absent, :status => 'missing', - :name => @model[:name], :error => 'ok'} + :name => @resource[:name], :error => 'ok'} end if hash[:error] != "ok" @@ -98,11 +98,11 @@ Puppet::Type.type(:package).provide :dpkg do end def uninstall - dpkg "-r", @model[:name] + dpkg "-r", @resource[:name] end def purge - dpkg "--purge", @model[:name] + dpkg "--purge", @resource[:name] end end diff --git a/lib/puppet/provider/package/freebsd.rb b/lib/puppet/provider/package/freebsd.rb index f1649efa4..e9fbf6a4c 100755 --- a/lib/puppet/provider/package/freebsd.rb +++ b/lib/puppet/provider/package/freebsd.rb @@ -16,19 +16,19 @@ Puppet::Type.type(:package).provide :freebsd, :parent => :openbsd do end def install - should = @model.should(:ensure) + should = @resource.should(:ensure) - if @model[:source] + if @resource[:source] return super end - pkgadd "-r", @model[:name] + pkgadd "-r", @resource[:name] end def query self.class.list - if @model.is(:ensure) + if @resource.is(:ensure) return :listed else return nil @@ -36,7 +36,7 @@ Puppet::Type.type(:package).provide :freebsd, :parent => :openbsd do end def uninstall - pkgdelete "%s-%s" % [@model[:name], @model.should(:ensure)] + pkgdelete "%s-%s" % [@resource[:name], @resource.should(:ensure)] end end diff --git a/lib/puppet/provider/package/gem.rb b/lib/puppet/provider/package/gem.rb index d68031826..572069e9b 100755 --- a/lib/puppet/provider/package/gem.rb +++ b/lib/puppet/provider/package/gem.rb @@ -62,16 +62,16 @@ Puppet::Type.type(:package).provide :gem do def install(useversion = true) command = ["install"] - if (! @model.should(:ensure).is_a? Symbol) and useversion - command << "-v" << @model.should(:ensure) + if (! @resource.should(:ensure).is_a? Symbol) and useversion + command << "-v" << @resource.should(:ensure) end # Always include dependencies command << "--include-dependencies" - if source = @model[:source] + if source = @resource[:source] command << source else - command << @model[:name] + command << @resource[:name] end gemcmd(*command) @@ -79,17 +79,17 @@ Puppet::Type.type(:package).provide :gem do def latest # This always gets the latest version available. - hash = self.class.gemlist(:justme => @model[:name]) + hash = self.class.gemlist(:justme => @resource[:name]) return hash[:ensure] end def query - self.class.gemlist(:justme => @model[:name], :local => true) + self.class.gemlist(:justme => @resource[:name], :local => true) end def uninstall - gemcmd "uninstall", "-x", "-a", @model[:name] + gemcmd "uninstall", "-x", "-a", @resource[:name] end def update diff --git a/lib/puppet/provider/package/openbsd.rb b/lib/puppet/provider/package/openbsd.rb index 2d1b6d07d..e910a41ba 100755 --- a/lib/puppet/provider/package/openbsd.rb +++ b/lib/puppet/provider/package/openbsd.rb @@ -56,22 +56,22 @@ Puppet::Type.type(:package).provide :openbsd do end def install - should = @model.should(:ensure) + should = @resource.should(:ensure) - unless @model[:source] + unless @resource[:source] raise Puppet::Error, "You must specify a package source for BSD packages" end - pkgadd @model[:source] + pkgadd @resource[:source] end def query hash = {} - info = pkginfo @model[:name] + info = pkginfo @resource[:name] # Search for the version info - if info =~ /Information for #{@model[:name]}-(\S+)/ + if info =~ /Information for #{@resource[:name]}-(\S+)/ hash[:ensure] = $1 else return nil @@ -86,7 +86,7 @@ Puppet::Type.type(:package).provide :openbsd do end def uninstall - pkgdelete @model[:name] + pkgdelete @resource[:name] end end diff --git a/lib/puppet/provider/package/pkgdmg.rb b/lib/puppet/provider/package/pkgdmg.rb index c57f8a890..e3d211fef 100644 --- a/lib/puppet/provider/package/pkgdmg.rb +++ b/lib/puppet/provider/package/pkgdmg.rb @@ -97,8 +97,8 @@ Puppet::Type.type(:package).provide :pkgdmg do end # def self.installpkgdmg def query - if FileTest.exists?("/var/db/.puppet_pkgdmg_installed_#{@model[:name]}") - return {:name => @model[:name], :ensure => :present} + if FileTest.exists?("/var/db/.puppet_pkgdmg_installed_#{@resource[:name]}") + return {:name => @resource[:name], :ensure => :present} else return nil end @@ -106,10 +106,10 @@ Puppet::Type.type(:package).provide :pkgdmg do def install source = nil - unless source = @model[:source] + unless source = @resource[:source] self.fail "Mac OS X PKG DMG's must specify a package source." end - unless name = @model[:name] + unless name = @resource[:name] self.fail "Mac OS X PKG DMG's must specify a package name." end self.class.installpkgdmg(source,name) diff --git a/lib/puppet/provider/package/portage.rb b/lib/puppet/provider/package/portage.rb index 4c1655495..32a664e1b 100644 --- a/lib/puppet/provider/package/portage.rb +++ b/lib/puppet/provider/package/portage.rb @@ -37,7 +37,7 @@ Puppet::Type.type(:package).provide :portage do end def install - should = @model.should(:ensure) + should = @resource.should(:ensure) name = package_name unless should == :present or should == :latest # We must install a specific version @@ -48,7 +48,7 @@ Puppet::Type.type(:package).provide :portage do # The common package name format. def package_name - "%s/%s" % [@model[:category], @model[:name]] + "%s/%s" % [@resource[:category], @resource[:name]] end def uninstall @@ -63,8 +63,8 @@ Puppet::Type.type(:package).provide :portage do result_format = /(\S+) (\S+) \[(.*)\] \[[^0-9]*([^\s:]*)(:\S*)?\] ([\S]*) (.*)/ result_fields = [:category, :name, :ensure, :version_available, :slot, :vendor, :description] - search_field = @model[:category] ? "--category-name" : "--name" - search_value = @model[:category] ? package_name : @model[:name] + search_field = @resource[:category] ? "--category-name" : "--name" + search_value = @resource[:category] ? package_name : @resource[:name] search_format = "<category> <name> [<installedversionsshort>] [<best>] <homepage> <description>" begin @@ -88,7 +88,7 @@ Puppet::Type.type(:package).provide :portage do case packages.size when 0 - not_found_value = "%s/%s" % [@model[:category] ? @model[:category] : "<unspecified category>", @model[:name]] + not_found_value = "%s/%s" % [@resource[:category] ? @resource[:category] : "<unspecified category>", @resource[:name]] raise Puppet::PackageError.new("No package found with the specified name [#{not_found_value}]") when 1 return packages[0] diff --git a/lib/puppet/provider/package/ports.rb b/lib/puppet/provider/package/ports.rb index 685479285..76eed9c2a 100755 --- a/lib/puppet/provider/package/ports.rb +++ b/lib/puppet/provider/package/ports.rb @@ -19,17 +19,17 @@ Puppet::Type.type(:package).provide :ports, :parent => :freebsd do # -p: create a package # -N: install if the package is missing, otherwise upgrade # -P: prefer binary packages - cmd = %w{-p -N -P} << @model[:name] + cmd = %w{-p -N -P} << @resource[:name] output = portupgrade(*cmd) if output =~ /\*\* No such / - raise Puppet::ExecutionFailure, "Could not find package %s" % @model[:name] + raise Puppet::ExecutionFailure, "Could not find package %s" % @resource[:name] end end # If there are multiple packages, we only use the last one def latest - cmd = ["-v", @model[:name]] + cmd = ["-v", @resource[:name]] begin output = portversion(*cmd) @@ -75,7 +75,7 @@ Puppet::Type.type(:package).provide :ports, :parent => :freebsd do def query self.class.list - if @model.is(:ensure) and @model.is(:ensure) != :absent + if @resource.is(:ensure) and @resource.is(:ensure) != :absent return :listed else return nil @@ -83,7 +83,7 @@ Puppet::Type.type(:package).provide :ports, :parent => :freebsd do end def uninstall - portuninstall @model[:name] + portuninstall @resource[:name] end def update diff --git a/lib/puppet/provider/package/rpm.rb b/lib/puppet/provider/package/rpm.rb index 894f2b450..abd9fa022 100755 --- a/lib/puppet/provider/package/rpm.rb +++ b/lib/puppet/provider/package/rpm.rb @@ -47,7 +47,7 @@ Puppet::Type.type(:package).provide :rpm do # a hash with entries :instance => fully versioned package name, and # :ensure => version-release def query - cmd = ["-q", @model[:name], "--nosignature", "--nodigest", "--qf", "#{NVRFORMAT} #{VERSIONSTRING}\n"] + cmd = ["-q", @resource[:name], "--nosignature", "--nodigest", "--qf", "#{NVRFORMAT} #{VERSIONSTRING}\n"] begin output = rpm(*cmd) @@ -75,29 +75,29 @@ Puppet::Type.type(:package).provide :rpm do # Here we just retrieve the version from the file specified in the source. def latest - unless source = @model[:source] - @model.fail "RPMs must specify a package source" + unless source = @resource[:source] + @resource.fail "RPMs must specify a package source" end - cmd = [command(:rpm), "-q", "--qf", "#{VERSIONSTRING}", "-p", "#{@model[:source]}"] + cmd = [command(:rpm), "-q", "--qf", "#{VERSIONSTRING}", "-p", "#{@resource[:source]}"] version = execfail(cmd, Puppet::Error) return version end def install source = nil - unless source = @model[:source] - @model.fail "RPMs must specify a package source" + unless source = @resource[:source] + @resource.fail "RPMs must specify a package source" end - if @model.should(:ensure) == @model.is(:ensure) || - @model.should(:ensure) == :latest && @model.is(:ensure) == latest + if @resource.should(:ensure) == @resource.is(:ensure) || + @resource.should(:ensure) == :latest && @resource.is(:ensure) == latest # RPM gets pissy if you try to install an already # installed package return end flag = "-i" - if @model.is(:ensure) != :absent + if @resource.is(:ensure) != :absent flag = "-U" end diff --git a/lib/puppet/provider/package/rug.rb b/lib/puppet/provider/package/rug.rb index e6a70ae2a..4916aaec8 100644 --- a/lib/puppet/provider/package/rug.rb +++ b/lib/puppet/provider/package/rug.rb @@ -7,9 +7,9 @@ Puppet.type(:package).provide :rug, :parent => :rpm do # Install a package using 'rug'. def install - should = @model.should(:ensure) + should = @resource.should(:ensure) self.debug "Ensuring => #{should}" - wanted = @model[:name] + wanted = @resource[:name] # XXX: We don't actually deal with epochs here. case should @@ -33,12 +33,12 @@ Puppet.type(:package).provide :rug, :parent => :rpm do #rug can only get a list of *all* available packages? output = rug "list-updates" - if output =~ /#{@model[:name]}\s*\|\s*([0-9\.\-]+)/ + if output =~ /#{@resource[:name]}\s*\|\s*([0-9\.\-]+)/ return $1 else # rug didn't find updates, pretend the current # version is the latest - return @model.is(:ensure) + return @resource.is(:ensure) end end diff --git a/lib/puppet/provider/package/sun.rb b/lib/puppet/provider/package/sun.rb index c9a71e200..ea169548d 100755 --- a/lib/puppet/provider/package/sun.rb +++ b/lib/puppet/provider/package/sun.rb @@ -85,7 +85,7 @@ Puppet::Type.type(:package).provide :sun do if device cmd += " -d #{device}" end - cmd += " #{@model[:name]}" + cmd += " #{@resource[:name]}" begin # list out all of the packages @@ -115,28 +115,28 @@ Puppet::Type.type(:package).provide :sun do end def install - unless @model[:source] + unless @resource[:source] raise Puppet::Error, "Sun packages must specify a package source" end cmd = [] - if @model[:adminfile] - cmd << "-a" << @model[:adminfile] + if @resource[:adminfile] + cmd << "-a" << @resource[:adminfile] end - if @model[:responsefile] - cmd << "-r" << @model[:responsefile] + if @resource[:responsefile] + cmd << "-r" << @resource[:responsefile] end - cmd << "-d" << @model[:source] - cmd << "-n" << @model[:name] + cmd << "-d" << @resource[:source] + cmd << "-n" << @resource[:name] pkgadd cmd end # Retrieve the version from the current package file. def latest - hash = info2hash(@model[:source]) + hash = info2hash(@resource[:source]) hash[:ensure] end @@ -147,18 +147,18 @@ Puppet::Type.type(:package).provide :sun do def uninstall command = ["-n"] - if @model[:adminfile] - command << "-a" << @model[:adminfile] + if @resource[:adminfile] + command << "-a" << @resource[:adminfile] end - command << @model[:name] + command << @resource[:name] pkgrm command end # Remove the old package, and install the new one. This will probably # often fail. def update - if @model.is(:ensure) != :absent + if @resource.is(:ensure) != :absent self.uninstall end self.install diff --git a/lib/puppet/provider/package/up2date.rb b/lib/puppet/provider/package/up2date.rb index c195e18fb..42234e8ab 100644 --- a/lib/puppet/provider/package/up2date.rb +++ b/lib/puppet/provider/package/up2date.rb @@ -9,7 +9,7 @@ Puppet.type(:package).provide :up2date, :parent => :rpm do # Install a package using 'up2date'. def install - up2date "-u", @model[:name] + up2date "-u", @resource[:name] unless self.query raise Puppet::ExecutionFailure.new( @@ -23,12 +23,12 @@ Puppet.type(:package).provide :up2date, :parent => :rpm do #up2date can only get a list of *all* available packages? output = up2date "--show-available" - if output =~ /#{@model[:name]}-(\d+.*)\.\w+/ + if output =~ /#{@resource[:name]}-(\d+.*)\.\w+/ return $1 else # up2date didn't find updates, pretend the current # version is the latest - return @model.is(:ensure) + return @resource.is(:ensure) end end diff --git a/lib/puppet/provider/package/yum.rb b/lib/puppet/provider/package/yum.rb index 262048900..75acb4cae 100755 --- a/lib/puppet/provider/package/yum.rb +++ b/lib/puppet/provider/package/yum.rb @@ -6,11 +6,11 @@ Puppet::Type.type(:package).provide :yum, :parent => :rpm do def install - should = @model.should(:ensure) - self.debug "Ensuring => #{should}" - wanted = @model[:name] + should = @resource.should(:ensure) + self.debug "Ensuring => #{should}" + wanted = @resource[:name] - # XXX: We don't actually deal with epochs here. + # XXX: We don't actually deal with epochs here. case should when true, false, Symbol # pass @@ -30,14 +30,14 @@ Puppet::Type.type(:package).provide :yum, :parent => :rpm do # What's the latest package version available? def latest - output = yum "-d", "0", "-e", "0", :list, :available, @model[:name] + output = yum "-d", "0", "-e", "0", :list, :available, @resource[:name] - if output =~ /^#{@model[:name]}\S+\s+(\S+)\s/ + if output =~ /^#{@resource[:name]}\S+\s+(\S+)\s/ return $1 else # Yum didn't find updates, pretend the current # version is the latest - return @model[:ensure] + return @resource[:ensure] end end diff --git a/lib/puppet/provider/parsedfile.rb b/lib/puppet/provider/parsedfile.rb index 295c69168..3a2acf85f 100755 --- a/lib/puppet/provider/parsedfile.rb +++ b/lib/puppet/provider/parsedfile.rb @@ -8,7 +8,7 @@ require 'puppet/util/fileparsing' # on the provider instance. At this point, the file is written once # for every provider instance. # -# Once the provider prefetches the data, it's the model's job to copy +# Once the provider prefetches the data, it's the resource's job to copy # that data over to the @is variables. class Puppet::Provider::ParsedFile < Puppet::Provider extend Puppet::Util::FileParsing @@ -70,7 +70,7 @@ class Puppet::Provider::ParsedFile < Puppet::Provider flushed = [] @modified.sort { |a,b| a.to_s <=> b.to_s }.uniq.each do |target| - Puppet.debug "Flushing %s provider target %s" % [@model.name, target] + Puppet.debug "Flushing %s provider target %s" % [@resource_type.name, target] flush_target(target) flushed << target end @@ -119,46 +119,46 @@ class Puppet::Provider::ParsedFile < Puppet::Provider end # Override the default method with a lot more functionality. - def self.mkmodelmethods - [model.validproperties, model.parameters].flatten.each do |attr| + def self.mk_resource_methods + [resource_type.validproperties, resource_type.parameters].flatten.each do |attr| attr = symbolize(attr) define_method(attr) do # If it's not a valid field for this record type (which can happen # when different platforms support different fields), then just - # return the should value, so the model shuts up. + # return the should value, so the resource shuts up. if @property_hash[attr] or self.class.valid_attr?(self.class.name, attr) @property_hash[attr] || :absent else - @model.should(attr) + @resource.should(attr) end end define_method(attr.to_s + "=") do |val| # Mark that this target was modified. - modeltarget = @model.should(:target) || self.class.default_target + resourcetarget = @resource.should(:target) || self.class.default_target # If they're the same, then just mark that one as modified - if @property_hash[:target] and @property_hash[:target] == modeltarget - self.class.modified(modeltarget) + if @property_hash[:target] and @property_hash[:target] == resourcetarget + self.class.modified(resourcetarget) else - # Always mark the modeltarget as modified, and if there's + # Always mark the resourcetarget as modified, and if there's # and old property_hash target, mark it as modified and replace # it. - self.class.modified(modeltarget) + self.class.modified(resourcetarget) if @property_hash[:target] self.class.modified(@property_hash[:target]) end - @property_hash[:target] = modeltarget + @property_hash[:target] = resourcetarget end @property_hash[attr] = val end end end - # Always make the model methods. - def self.model=(model) + # Always make the resource methods. + def self.resource_type=(resource) super - mkmodelmethods() + mk_resource_methods() end # Mark a target as modified so we know to flush it. This only gets @@ -170,11 +170,11 @@ class Puppet::Provider::ParsedFile < Puppet::Provider # Retrieve all of the data from disk. There are three ways to know # while files to retrieve: We might have a list of file objects already - # set up, there might be instances of our associated model and they + # set up, there might be instances of our associated resource and they # will have a path parameter set, and we will have a default path # set. We need to turn those three locations into a list of files, # prefetch each one, and make sure they're associated with each appropriate - # model instance. + # resource instance. def self.prefetch # Reset the record list. @records = [] @@ -204,8 +204,8 @@ class Puppet::Provider::ParsedFile < Puppet::Provider # Set current property on any existing resource instances. target_records(target).find_all { |i| i.is_a?(Hash) }.each do |record| - # Find any model instances whose names match our instances. - if instance = self.model[record[:name]] + # Find any resource instances whose names match our instances. + if instance = self.resource_type[record[:name]] next unless instance.provider.is_a?(self) instance.provider.property_hash = record elsif respond_to?(:match) @@ -267,14 +267,14 @@ class Puppet::Provider::ParsedFile < Puppet::Provider # Then get each of the file objects targets += @target_objects.keys - # Lastly, check the file from any model instances - self.model.each do |model| - targets << model.value(:target) + # Lastly, check the file from any resource instances + self.resource_type.each do |resource| + targets << resource.value(:target) # This is only the case for properties, and targets should always # be properties. - #if model.respond_to?(:is) - # targets << model.is(:target) + #if resource.respond_to?(:is) + # targets << resource.is(:target) #end end @@ -288,19 +288,19 @@ class Puppet::Provider::ParsedFile < Puppet::Provider def create - @model.class.validproperties.each do |property| - if value = @model.should(property) + @resource.class.validproperties.each do |property| + if value = @resource.should(property) @property_hash[property] = value end end self.class.modified(@property_hash[:target] || self.class.default_target) - return (@model.class.name.to_s + "_created").intern + return (@resource.class.name.to_s + "_created").intern end def destroy # We use the method here so it marks the target as modified. self.ensure = :absent - return (@model.class.name.to_s + "_deleted").intern + return (@resource.class.name.to_s + "_deleted").intern end def exists? @@ -318,15 +318,15 @@ class Puppet::Provider::ParsedFile < Puppet::Provider # If the target isn't set, then this is our first modification, so # mark it for flushing. unless @property_hash[:target] - @property_hash[:target] = @model.should(:target) || self.class.default_target + @property_hash[:target] = @resource.should(:target) || self.class.default_target self.class.modified(@property_hash[:target]) end - @property_hash[:name] ||= @model.name + @property_hash[:name] ||= @resource.name self.class.flush(@property_hash) end - def initialize(model) + def initialize(resource) super # See if there's already a matching property_hash in the records list; @@ -334,7 +334,7 @@ class Puppet::Provider::ParsedFile < Puppet::Provider # We provide a default for 'ensure' here, because the provider will # override it if the thing exists, but it won't touch it if it doesn't # exist. - @property_hash = self.class.record?(model[:name]) || + @property_hash = self.class.record?(resource[:name]) || {:record_type => self.class.name, :ensure => :absent} end end diff --git a/lib/puppet/provider/service/base.rb b/lib/puppet/provider/service/base.rb index c736c20c2..ad29a24bd 100755 --- a/lib/puppet/provider/service/base.rb +++ b/lib/puppet/provider/service/base.rb @@ -11,16 +11,16 @@ Puppet::Type.type(:service).provide :base do # Get the process ID for a running process. Requires the 'pattern' # parameter. def getpid - unless @model[:pattern] - @model.fail "Either a stop command or a pattern must be specified" + unless @resource[:pattern] + @resource.fail "Either a stop command or a pattern must be specified" end ps = Facter["ps"].value unless ps and ps != "" - @model.fail( + @resource.fail( "You must upgrade Facter to a version that includes 'ps'" ) end - regex = Regexp.new(@model[:pattern]) + regex = Regexp.new(@resource[:pattern]) self.debug "Executing '#{ps}'" IO.popen(ps) { |table| table.each { |line| @@ -36,7 +36,7 @@ Puppet::Type.type(:service).provide :base do # How to restart the process. def restart - if @model[:restart] or self.respond_to?(:restartcmd) + if @resource[:restart] or self.respond_to?(:restartcmd) ucommand(:restart) else self.stop @@ -50,7 +50,7 @@ Puppet::Type.type(:service).provide :base do # happen if, for instance, it has an init script (and thus responds to # 'statuscmd') but does not have 'hasstatus' enabled. def status - if @model[:status] or ( + if @resource[:status] or ( self.respond_to?(:statuscmd) and self.statuscmd ) # Don't fail when the exit status is not 0. @@ -79,8 +79,8 @@ Puppet::Type.type(:service).provide :base do # The command used to start. Generated if the 'binary' argument # is passed. def startcmd - if @model[:binary] - return @model[:binary] + if @resource[:binary] + return @resource[:binary] else raise Puppet::Error, "Services must specify a start command or a binary" @@ -93,7 +93,7 @@ Puppet::Type.type(:service).provide :base do # for the process in the process table. # This method will generally not be overridden by submodules. def stop - if @model[:stop] or self.respond_to?(:stopcmd) + if @resource[:stop] or self.respond_to?(:stopcmd) ucommand(:stop) else pid = getpid @@ -104,7 +104,7 @@ Puppet::Type.type(:service).provide :base do begin output = kill pid rescue Puppet::ExecutionFailure => detail - @model.fail "Could not kill %s, PID %s: %s" % + @resource.fail "Could not kill %s, PID %s: %s" % [self.name, pid, output] end return true @@ -117,14 +117,14 @@ Puppet::Type.type(:service).provide :base do # #565: Services generally produce no output, so squelch them. execute(command, :failonfail => fof, :squelch => true) rescue Puppet::ExecutionFailure => detail - @model.fail "Could not %s %s: %s" % [type, @model.ref, detail] + @resource.fail "Could not %s %s: %s" % [type, @resource.ref, detail] end return nil end # Use either a specified command or the default for our provider. def ucommand(type, fof = true) - if c = @model[type] + if c = @resource[type] cmd = [c] else cmd = self.send("%scmd" % type) diff --git a/lib/puppet/provider/service/debian.rb b/lib/puppet/provider/service/debian.rb index 445108fa9..f7c5f3ced 100755 --- a/lib/puppet/provider/service/debian.rb +++ b/lib/puppet/provider/service/debian.rb @@ -9,11 +9,11 @@ Puppet::Type.type(:service).provide :debian, :parent => :init do # Remove the symlinks def disable - update "-f", @model[:name], "remove" + update "-f", @resource[:name], "remove" end def enabled? - output = update "-n", "-f", @model[:name], "remove" + output = update "-n", "-f", @resource[:name], "remove" # If it's enabled, then it will print output showing removal of # links. @@ -25,7 +25,7 @@ Puppet::Type.type(:service).provide :debian, :parent => :init do end def enable - update @model[:name], "defaults" + update @resource[:name], "defaults" end end diff --git a/lib/puppet/provider/service/gentoo.rb b/lib/puppet/provider/service/gentoo.rb index a4d4a9b85..2dcc3e9c1 100644 --- a/lib/puppet/provider/service/gentoo.rb +++ b/lib/puppet/provider/service/gentoo.rb @@ -10,7 +10,7 @@ Puppet::Type.type(:service).provide :gentoo, :parent => :init do def disable begin - output = update :del, @model[:name], :default + output = update :del, @resource[:name], :default rescue Puppet::ExecutionFailure raise Puppet::Error, "Could not disable %s: %s" % [self.name, output] @@ -24,12 +24,12 @@ Puppet::Type.type(:service).provide :gentoo, :parent => :init do return :false end - line = output.split(/\n/).find { |l| l.include?(@model[:name]) } + line = output.split(/\n/).find { |l| l.include?(@resource[:name]) } return :false unless line # If it's enabled then it will print output showing service | runlevel - if output =~ /#{@model[:name]}\s*|\s*default/ + if output =~ /#{@resource[:name]}\s*|\s*default/ return :true else return :false @@ -38,7 +38,7 @@ Puppet::Type.type(:service).provide :gentoo, :parent => :init do def enable begin - output = update :add, @model[:name], :default + output = update :add, @resource[:name], :default rescue Puppet::ExecutionFailure raise Puppet::Error, "Could not enable %s: %s" % [self.name, output] diff --git a/lib/puppet/provider/service/init.rb b/lib/puppet/provider/service/init.rb index 018aeaae0..c5bcc26eb 100755 --- a/lib/puppet/provider/service/init.rb +++ b/lib/puppet/provider/service/init.rb @@ -87,12 +87,12 @@ Puppet::Type.type(:service).provide :init, :parent => :base do if defined? @initscript return @initscript else - @initscript = self.search(@model[:name]) + @initscript = self.search(@resource[:name]) end end def restart - if @model[:hasrestart] == :true + if @resource[:hasrestart] == :true command = [self.initscript, :restart] texecute("restart", command) else @@ -101,7 +101,7 @@ Puppet::Type.type(:service).provide :init, :parent => :base do end def search(name) - @model[:path].each { |path| + @resource[:path].each { |path| fqname = File.join(path,name) begin stat = File.stat(fqname) @@ -126,7 +126,7 @@ Puppet::Type.type(:service).provide :init, :parent => :base do # we just return that; otherwise, we return false, which causes it to # fallback to other mechanisms. def statuscmd - if @model[:hasstatus] + if @resource[:hasstatus] return [self.initscript, :status] else return false diff --git a/lib/puppet/provider/service/redhat.rb b/lib/puppet/provider/service/redhat.rb index 93cf2fc73..c932bd95f 100755 --- a/lib/puppet/provider/service/redhat.rb +++ b/lib/puppet/provider/service/redhat.rb @@ -19,8 +19,8 @@ Puppet::Type.type(:service).provide :redhat, :parent => :init do # Remove the symlinks def disable begin - output = chkconfig(@model[:name], :off) - output += chkconfig("--del", @model[:name]) + output = chkconfig(@resource[:name], :off) + output += chkconfig("--del", @resource[:name]) rescue Puppet::ExecutionFailure raise Puppet::Error, "Could not disable %s: %s" % [self.name, output] @@ -29,7 +29,7 @@ Puppet::Type.type(:service).provide :redhat, :parent => :init do def enabled? begin - output = chkconfig(@model[:name]) + output = chkconfig(@resource[:name]) rescue Puppet::ExecutionFailure return :false end @@ -47,8 +47,8 @@ Puppet::Type.type(:service).provide :redhat, :parent => :init do # in the init scripts. def enable begin - output = chkconfig("--add", @model[:name]) - output += chkconfig(@model[:name], :on) + output = chkconfig("--add", @resource[:name]) + output += chkconfig(@resource[:name], :on) rescue Puppet::ExecutionFailure => detail raise Puppet::Error, "Could not enable %s: %s" % [self.name, detail] diff --git a/lib/puppet/provider/service/smf.rb b/lib/puppet/provider/service/smf.rb index e2e5c989a..f25f65cd1 100755 --- a/lib/puppet/provider/service/smf.rb +++ b/lib/puppet/provider/service/smf.rb @@ -27,20 +27,20 @@ Puppet::Type.type(:service).provide :smf, :parent => :base do end def restartcmd - [command(:adm), :restart, @model[:name]] + [command(:adm), :restart, @resource[:name]] end def startcmd - [command(:adm), :enable, @model[:name]] + [command(:adm), :enable, @resource[:name]] end def status - if @model[:status] + if @resource[:status] super return end begin - output = svcs "-l", @model[:name] + output = svcs "-l", @resource[:name] rescue Puppet::ExecutionFailure warning "Could not get status on service %s" % self.name return :stopped @@ -78,7 +78,7 @@ Puppet::Type.type(:service).provide :smf, :parent => :base do end def stopcmd - [command(:adm), :disable, @model[:name]] + [command(:adm), :disable, @resource[:name]] end end diff --git a/lib/puppet/provider/user/netinfo.rb b/lib/puppet/provider/user/netinfo.rb index b86ed8c54..01d1dc275 100644 --- a/lib/puppet/provider/user/netinfo.rb +++ b/lib/puppet/provider/user/netinfo.rb @@ -30,7 +30,7 @@ Puppet::Type.type(:user).provide :netinfo, :parent => Puppet::Provider::NameServ end def autogen_comment - return @model[:name].capitalize + return @resource[:name].capitalize end # The list of all groups the user is a member of. Different @@ -38,7 +38,7 @@ Puppet::Type.type(:user).provide :netinfo, :parent => Puppet::Provider::NameServ def groups groups = [] - user = @model[:name] + user = @resource[:name] # Retrieve them all from netinfo open("| #{command(:nireport)} / /groups name users") do |file| file.each do |line| @@ -84,7 +84,7 @@ Puppet::Type.type(:user).provide :netinfo, :parent => Puppet::Provider::NameServ end end - user = @model[:name] + user = @resource[:name] data.each do |name, members| if members.include? user and groups.include? name # I'm in the group and should be diff --git a/lib/puppet/provider/user/pw.rb b/lib/puppet/provider/user/pw.rb index 9b85a22f9..a75850679 100644 --- a/lib/puppet/provider/user/pw.rb +++ b/lib/puppet/provider/user/pw.rb @@ -20,17 +20,17 @@ Puppet::Type.type(:user).provide :pw, :parent => Puppet::Provider::NameService:: end def addcmd - cmd = [command(:pw), "useradd", @model[:name]] - @model.class.validproperties.each do |property| + cmd = [command(:pw), "useradd", @resource[:name]] + @resource.class.validproperties.each do |property| next if property == :ensure # the value needs to be quoted, mostly because -c might # have spaces in it - if value = @model.should(property) and value != "" + if value = @resource.should(property) and value != "" cmd << flag(property) << value end end - if @model[:allowdupe] == :true + if @resource[:allowdupe] == :true cmd << "-o" end diff --git a/lib/puppet/provider/user/useradd.rb b/lib/puppet/provider/user/useradd.rb index 572f5af79..702932e07 100644 --- a/lib/puppet/provider/user/useradd.rb +++ b/lib/puppet/provider/user/useradd.rb @@ -30,33 +30,33 @@ Puppet::Type.type(:user).provide :useradd, :parent => Puppet::Provider::NameServ def addcmd cmd = [command(:add)] - @model.class.validproperties.each do |property| + @resource.class.validproperties.each do |property| next if property == :ensure # the value needs to be quoted, mostly because -c might # have spaces in it - if value = @model.should(property) and value != "" + if value = @resource.should(property) and value != "" cmd << flag(property) << value end end - if @model.allowdupe? + if @resource.allowdupe? cmd << "-o" end - if @model.managehome? + if @resource.managehome? cmd << "-m" elsif %w{Fedora RedHat}.include?(Facter.value("operatingsystem")) cmd << "-M" end - cmd << @model[:name] + cmd << @resource[:name] cmd end # Retrieve the password using the Shadow Password library def password - if ent = Shadow::Passwd.getspnam(@model.name) + if ent = Shadow::Passwd.getspnam(@resource.name) return ent.sp_pwdp else return :absent diff --git a/lib/puppet/provider/zone/solaris.rb b/lib/puppet/provider/zone/solaris.rb index d92a774c1..7ace69047 100644 --- a/lib/puppet/provider/zone/solaris.rb +++ b/lib/puppet/provider/zone/solaris.rb @@ -26,8 +26,8 @@ Puppet::Type.type(:zone).provide(:solaris) do hash = line2hash(line) obj = nil - unless obj = @model[hash[:name]] - obj = @model.create(:name => hash[:name]) + unless obj = @resource[hash[:name]] + obj = @resource.create(:name => hash[:name]) end obj.setstatus(hash) @@ -41,11 +41,11 @@ Puppet::Type.type(:zone).provide(:solaris) do # If the thing is entirely absent, then we need to create the config. str = %{create -b set zonepath=%s -} % @model[:path] +} % @resource[:path] # Then perform all of our configuration steps. It's annoying - # that we need this much internal info on the model. - @model.send(:properties).each do |property| + # that we need this much internal info on the resource. + @resource.send(:properties).each do |property| if property.is_a? ZoneConfigProperty and ! property.insync? str += property.configtext + "\n" end @@ -125,8 +125,8 @@ set zonepath=%s # Execute a configuration string. Can't be private because it's called # by the properties. def setconfig(str) - command = "#{command(:cfg)} -z %s -f -" % @model[:name] - debug "Executing '%s' in zone %s with '%s'" % [command, @model[:name], str] + command = "#{command(:cfg)} -z %s -f -" % @resource[:name] + debug "Executing '%s' in zone %s with '%s'" % [command, @resource[:name], str] IO.popen(command, "w") do |pipe| pipe.puts str end @@ -138,8 +138,8 @@ set zonepath=%s def start # Check the sysidcfg stuff - if cfg = @model[:sysidcfg] - path = File.join(@model[:path], "root", "etc", "sysidcfg") + if cfg = @resource[:sysidcfg] + path = File.join(@resource[:path], "root", "etc", "sysidcfg") unless File.exists?(path) begin @@ -161,7 +161,7 @@ set zonepath=%s # Return a hash of the current status of this zone. def statushash begin - output = adm "-z", @model[:name], :list, "-p" + output = adm "-z", @resource[:name], :list, "-p" rescue Puppet::ExecutionFailure return nil end @@ -185,7 +185,7 @@ set zonepath=%s def zoneadm(*cmd) begin - adm("-z", @model[:name], *cmd) + adm("-z", @resource[:name], *cmd) rescue Puppet::ExecutionFailure => detail self.fail "Could not %s zone: %s" % [cmd[0], detail] end @@ -193,7 +193,7 @@ set zonepath=%s def zonecfg(*cmd) begin - cfg("-z", @model[:name], *cmd) + cfg("-z", @resource[:name], *cmd) rescue Puppet::ExecutionFailure => detail self.fail "Could not %s zone: %s" % [cmd[0], detail] end |