class Chef::ChefFS::Knife
def self.deps
def self.deps super do require "chef/config" unless defined?(Chef::Config) require "chef/chef_fs/config" unless defined?(Chef::ChefFS::Config) require "chef/chef_fs/file_pattern" unless defined?(Chef::ChefFS::FilePattern) require "chef/chef_fs/path_utils" unless defined?(Chef::ChefFS::PathUtils) yield end end
def self.inherited(c)
def self.inherited(c) super # Ensure we always get to do our includes, whether subclass calls deps or not c.deps do end end
def chef_fs
def chef_fs @chef_fs_config.chef_fs end
def configure_chef
def configure_chef super Chef::Config[:repo_mode] = config[:repo_mode] if config[:repo_mode] Chef::Config[:concurrency] = config[:concurrency].to_i if config[:concurrency] # --chef-repo-path forcibly overrides all other paths if config[:chef_repo_path] Chef::Config[:chef_repo_path] = config[:chef_repo_path] Chef::ChefFS::Config::INFLECTIONS.each_value do |variable_name| Chef::Config.delete("#{variable_name}_path".to_sym) end end @chef_fs_config = Chef::ChefFS::Config.new(Chef::Config, Dir.pwd, config, ui) ChefUtils::DefaultThreadPool.instance.threads = (Chef::Config[:concurrency] || 10) - 1 end
def create_chef_fs
def create_chef_fs @chef_fs_config.create_chef_fs end
def create_local_fs
def create_local_fs @chef_fs_config.create_local_fs end
def discover_repo_dir(dir)
def discover_repo_dir(dir) %w{.chef cookbooks data_bags environments roles}.each do |subdir| return dir if File.directory?(File.join(dir, subdir)) end # If this isn't it, check the parent parent = File.dirname(dir) if parent && parent != dir discover_repo_dir(parent) else nil end end
def format_path(entry)
def format_path(entry) @chef_fs_config.format_path(entry) end
def local_fs
def local_fs @chef_fs_config.local_fs end
def parallelize(inputs, options = {}, &block)
def parallelize(inputs, options = {}, &block) inputs.parallel_map(&block) end
def pattern_arg_from(arg)
def pattern_arg_from(arg) inferred_path = nil if Chef::ChefFS::PathUtils.is_absolute?(arg) # We should be able to use this as-is - but the user might have incorrectly provided # us with a path that is based off of the OS root path instead of the Chef-FS root. # Do a quick and dirty sanity check. if possible_server_path = @chef_fs_config.server_path(arg) ui.warn("The absolute path provided is suspicious: #{arg}") ui.warn("If you wish to refer to a file location, please provide a path that is rooted at the chef-repo.") ui.warn("Consider writing '#{possible_server_path}' instead of '#{arg}'") end # Use the original path because we can't be sure. inferred_path = arg elsif arg.start_with?("~") # Let's be nice and fix it if possible - but warn the user. ui.warn("A path relative to a user home directory has been provided: #{arg}") ui.warn("Paths provided need to be rooted at the chef-repo being considered or be relative paths.") inferred_path = @chef_fs_config.server_path(arg) ui.warn("Using '#{inferred_path}' as the path instead of '#{arg}'.") elsif Pathname.new(arg).absolute? # It is definitely a system absolute path (such as C:\ or \\foo\bar) but it cannot be # interpreted as a Chef-FS absolute path. Again attempt to be nice but warn the user. ui.warn("An absolute file system path that isn't a server path was provided: #{arg}") ui.warn("Paths provided need to be rooted at the chef-repo being considered or be relative paths.") inferred_path = @chef_fs_config.server_path(arg) ui.warn("Using '#{inferred_path}' as the path instead of '#{arg}'.") elsif @chef_fs_config.base_path.nil? # These are all relative paths. We can't resolve and root paths unless we are in the # chef repo. ui.error("Attempt to use relative path '#{arg}' when current directory is outside the repository path.") ui.error("Current working directory is '#{@chef_fs_config.cwd}'.") exit(1) else inferred_path = Chef::ChefFS::PathUtils.join(@chef_fs_config.base_path, arg) end Chef::ChefFS::FilePattern.new(inferred_path) end
def pattern_args
def pattern_args @pattern_args ||= pattern_args_from(name_args) end
def pattern_args_from(args)
def pattern_args_from(args) args.map { |arg| pattern_arg_from(arg) } end