# # Author:: John Keiser () # Copyright:: Copyright (c) 2012 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/chef_fs/file_system/base_fs_dir" require "chef/chef_fs/file_system/chef_server/rest_list_dir" require "chef/chef_fs/file_system/already_exists_error" require "chef/chef_fs/file_system/must_delete_recursively_error" require "chef/chef_fs/file_system/not_found_error" require "chef/chef_fs/path_utils" require "fileutils" class Chef module ChefFS module FileSystem module Repository class FileSystemEntry < BaseFSDir def initialize(name, parent, file_path = nil) super(name, parent) @file_path = file_path || "#{parent.file_path}/#{name}" end attr_reader :file_path def path_for_printing file_path end def children # Except cookbooks and data bag dirs, all things must be json files begin Dir.entries(file_path).sort. map { |child_name| make_child_entry(child_name) }. select { |child| child && can_have_child?(child.name, child.dir?) } rescue Errno::ENOENT raise Chef::ChefFS::FileSystem::NotFoundError.new(self, $!) end end def create_child(child_name, file_contents=nil) child = make_child_entry(child_name) if child.exists? raise Chef::ChefFS::FileSystem::AlreadyExistsError.new(:create_child, child) end if file_contents child.write(file_contents) else begin Dir.mkdir(child.file_path) rescue Errno::EEXIST raise Chef::ChefFS::FileSystem::AlreadyExistsError.new(:create_child, child) end end child end def dir? File.directory?(file_path) end def delete(recurse) begin if dir? if !recurse raise MustDeleteRecursivelyError.new(self, $!) end FileUtils.rm_r(file_path) else File.delete(file_path) end rescue Errno::ENOENT raise Chef::ChefFS::FileSystem::NotFoundError.new(self, $!) end end def exists? File.exists?(file_path) && (parent.nil? || parent.can_have_child?(name, dir?)) end def read begin File.open(file_path, "rb") {|f| f.read} rescue Errno::ENOENT raise Chef::ChefFS::FileSystem::NotFoundError.new(self, $!) end end def write(content) File.open(file_path, "wb") do |file| file.write(content) end end protected def make_child_entry(child_name) FileSystemEntry.new(child_name, self) end end end end end end