diff options
Diffstat (limited to 'lib/chef/provider/group.rb')
| -rw-r--r-- | lib/chef/provider/group.rb | 159 |
1 files changed, 159 insertions, 0 deletions
diff --git a/lib/chef/provider/group.rb b/lib/chef/provider/group.rb new file mode 100644 index 0000000000..81d7d7a400 --- /dev/null +++ b/lib/chef/provider/group.rb @@ -0,0 +1,159 @@ +# +# Author:: AJ Christensen (<aj@opscode.com>) +# Copyright:: Copyright (c) 2008 OpsCode, Inc. +# License:: Apache License, Version 2.0 +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +require 'chef/provider' +require 'chef/mixin/command' +require 'chef/resource/group' +require 'etc' + +class Chef + class Provider + class Group < Chef::Provider + include Chef::Mixin::Command + attr_accessor :group_exists + attr_accessor :change_desc + + def whyrun_supported? + true + end + + def initialize(new_resource, run_context) + super + @group_exists = true + end + + def load_current_resource + @current_resource = Chef::Resource::Group.new(@new_resource.name) + @current_resource.group_name(@new_resource.group_name) + + group_info = nil + begin + group_info = Etc.getgrnam(@new_resource.group_name) + rescue ArgumentError => e + @group_exists = false + Chef::Log.debug("#{@new_resource} group does not exist") + end + + if group_info + @new_resource.gid(group_info.gid) unless @new_resource.gid + @current_resource.gid(group_info.gid) + @current_resource.members(group_info.mem) + end + + @current_resource + end + + def define_resource_requirements + requirements.assert(:modify) do |a| + a.assertion { @group_exists } + a.failure_message(Chef::Exceptions::Group, "Cannot modify #{@new_resource} - group does not exist!") + a.whyrun("Group #{@new_resource} does not exist. Unless it would have been created earlier in this run, this attempt to modify it would fail.") + end + end + + # Check to see if a group needs any changes. Populate + # @change_desc with a description of why a change must occur + # + # ==== Returns + # <true>:: If a change is required + # <false>:: If a change is not required + def compare_group + @change_desc = nil + if @new_resource.gid != @current_resource.gid + @change_desc = "change gid #{@current_resource.gid} to #{@new_resource.gid}" + return true + end + + if(@new_resource.append) + missing_members = [] + @new_resource.members.each do |member| + next if @current_resource.members.include?(member) + missing_members << member + end + if missing_members.length > 0 + @change_desc = "add missing member(s): #{missing_members.join(", ")}" + return true + end + else + if @new_resource.members != @current_resource.members + @change_desc = "replace group members with new list of members" + return true + end + end + return false + end + + def action_create + case @group_exists + when false + converge_by("create #{@new_resource}") do + create_group + Chef::Log.info("#{@new_resource} created") + end + else + if compare_group + converge_by(["alter group #{@new_resource}", @change_desc ]) do + manage_group + Chef::Log.info("#{@new_resource} altered") + end + end + end + end + + def action_remove + if @group_exists + converge_by("remove group #{@new_resource}") do + remove_group + Chef::Log.info("#{@new_resource} removed") + end + end + end + + def action_manage + if @group_exists && compare_group + converge_by(["manage group #{@new_resource}", @change_desc]) do + manage_group + Chef::Log.info("#{@new_resource} managed") + end + end + end + + def action_modify + if compare_group + converge_by(["modify group #{@new_resource}", @change_desc]) do + manage_group + Chef::Log.info("#{@new_resource} modified") + end + end + end + + def create_group + raise NotImplementedError, "subclasses of Chef::Provider::Group should define #create_group" + end + + def manage_group + raise NotImplementedError, "subclasses of Chef::Provider::Group should define #manage_group" + end + + def remove_group + raise NotImplementedError, "subclasses of Chef::Provider::Group should define #remove_group" + end + + end + end +end |