#
# Author:: John Keiser (<jkeiser@opscode.com>)
# 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_fs/file_system/rest_list_dir'
require 'chef_fs/file_system/cookbook_dir'
require 'chef_fs/raw_request'

require 'tmpdir'

module ChefFS
  module FileSystem
    class CookbooksDir < RestListDir
      def initialize(parent)
        super("cookbooks", parent)
      end

      def child(name)
        if @children
          result = self.children.select { |child| child.name == name }.first
          if result
            result
          else
            NonexistentFSObject.new(name, self)
          end
        else
          CookbookDir.new(name, self)
        end
      end

      def children
        @children ||= begin
          if Chef::Config[:versioned_cookbooks]
            result = []
            ChefFS::RawRequest.raw_json(rest, "#{api_path}/?num_versions=all").each_pair do |cookbook_name, cookbooks|
              cookbooks['versions'].each do |cookbook_version|
                result << CookbookDir.new("#{cookbook_name}-#{cookbook_version['version']}", self, :exists => true)
              end
            end
          else
            result = ChefFS::RawRequest.raw_json(rest, api_path).keys.map { |cookbook_name| CookbookDir.new(cookbook_name, self, :exists => true) }
          end
          result.sort_by(&:name)
        end
      end

      def create_child_from(other)
        upload_cookbook_from(other)
      end

      def upload_cookbook_from(other)
        Chef::Config[:versioned_cookbooks] ? upload_versioned_cookbook(other) : upload_unversioned_cookbook(other)
      rescue Timeout::Error => e
        raise ChefFS::FileSystem::OperationFailedError.new(:write, self, e), "Timeout writing: #{e}"
      rescue Net::HTTPServerException => e
        case e.response.code
        when "409"
          ui.error "Version #{other_cookbook_version.version} of cookbook #{other_cookbook_version.name} is frozen. Use --force to override."
          Chef::Log.debug(e)
          raise Exceptions::CookbookFrozen
        else
          raise ChefFS::FileSystem::OperationFailedError.new(:write, self, e), "HTTP error writing: #{e}"
        end
      end

      # Knife currently does not understand versioned cookbooks
      # Cookbook Version uploader also requires a lot of refactoring
      # to make this work. So instead, we make a temporary cookbook
      # symlinking back to real cookbook, and upload the proxy.
      def upload_versioned_cookbook(other)
        cookbook_name = ChefFS::FileSystem::ChefRepositoryFileSystemEntry.canonical_cookbook_name(other.name)

        Dir.mktmpdir do |temp_cookbooks_path|
          proxy_cookbook_path = "#{temp_cookbooks_path}/#{cookbook_name}"

          # Make a symlink
          File.symlink other.file_path, proxy_cookbook_path

          # Instantiate a proxy loader using the temporary symlink
          proxy_loader = Chef::Cookbook::CookbookVersionLoader.new(proxy_cookbook_path, other.parent.chefignore)
          proxy_loader.load_cookbooks

          # Instantiate a new uploader based on the proxy loader
          uploader = Chef::CookbookUploader.new(proxy_loader.cookbook_version, proxy_cookbook_path, :rest => rest)

          with_actual_cookbooks_dir(temp_cookbooks_path) do
            upload_cookbook!(uploader)
          end
        end
      end

      def upload_unversioned_cookbook(other)
        uploader = Chef::CookbookUploader.new(other.chef_object, other.parent.file_path, :rest => rest)

        with_actual_cookbooks_dir(other.parent.file_path) do
          upload_cookbook!(uploader)
        end
      end

      # Work around the fact that CookbookUploader doesn't understand chef_repo_path (yet)
      def with_actual_cookbooks_dir(actual_cookbook_path)
        old_cookbook_path = Chef::Config.cookbook_path
        Chef::Config.cookbook_path = actual_cookbook_path if !Chef::Config.cookbook_path

        yield
      ensure
        Chef::Config.cookbook_path = old_cookbook_path
      end

      # Chef 11 changes this API
      def upload_cookbook!(uploader)
        if uploader.respond_to?(:upload_cookbook)
          uploader.upload_cookbook
        else
          uploader.upload_cookbooks
        end
      end

      def can_have_child?(name, is_dir)
        return false if !is_dir
        return false if Chef::Config[:versioned_cookbooks] && name !~ ChefFS::FileSystem::CookbookDir::VALID_VERSIONED_COOKBOOK_NAME
        return true
      end
    end
  end
end