require 'childprocess'
require 'singleton'
require 'socket'
require 'net/http'

module Kameleon
  #This ruby class will control the execution of Polipo web proxy
  class Persistent_cache

    include Singleton
    attr_reader :cache_dir
    attr_reader :polipo_port
    attr_writer :activated
    attr_reader :cwd
    attr_writer :polipo_path
    attr_reader :name
    attr_writer :cache_path
    attr_accessor :mode
    attr_accessor :name
    attr_accessor :recipe_files # FIXME have to check those.
    attr_accessor :recipe_path
    attr_accessor :archive_format
    attr_accessor :polipo_cmd_options
    attr_accessor :offline

    def initialize()
      ## we must configure Polipo to be execute for the in and out context
      ## we have to start polipo in the out context for debootstrap step

      @polipo_process = nil
      @polipo_port = find_unused_port

      @polipo_cmd_options = {:diskCacheRoot => "",
                             :maxDiskCacheEntrySize => "-1",
                             :idleTime => "1",
                             :allowedClients => "0.0.0.0/0",
                             :proxyPort => @polipo_port,
                             :daemonise => false,
                             :proxyAddress => "0.0.0.0",
                             :logFile => File.join(Kameleon.env.build_path, "polipo-#{ENV['USER']}.log"),
                             :logLevel => "0xFF",
                            }

      @activated = false

      @mode = nil #It could be build or from
      @cache_dir = Kameleon.env.cache_path
      @polipo_path = nil
      @cwd = ""
      @cmd_cached = []
      @cache_path = ""
      @current_raw_cmd = nil
      @current_step_dir = nil
      @recipe_file = nil
      @steps_files = []
      @cached_recipe_dir = nil
      @offline = false
    end

    def find_unused_port
      ports = (8000..9000)
      port = 0
      tmp = nil
      ports.each do |p|
        begin
          port = p
          tmp = TCPServer.new('127.0.0.1', port)
        rescue
          port =0
        end
        break if(port>0)
      end
      tmp.close
      port
    end

    def check_polipo_binary

      @polipo_path ||= Utils.which("polipo")

      if @polipo_path.nil? then
        Kameleon.ui.error("Polipo binary not found, make sure it is in your current PATH")
        Kameleon.ui.error("or use the option --proxy-path")
        raise BuildError, "Failed to use persistent cache"
      end
    end

    def activated?
      @activated
    end

    def cwd=(dir)
      @cwd = dir
    end

    def create_cache_directory(step_name)
      Kameleon.ui.debug("Creating  cache directory #{step_name} for Polipo")
      directory_name = File.join(@cache_dir,"DATA","#{step_name}")
      FileUtils.mkdir_p directory_name
      directory_name
    end

    def proxy_is_running?()
      begin
        res = Net::HTTP.get_response(URI("http://127.0.0.1:#{@polipo_port}/polipo/status"))
        if not @offline
          if not res.body.include? "is on line"
            Kameleon.ui.debug("The proxy is running but not responding. Server response: #{res.inspect}")
            return false
          else
            Kameleon.ui.debug("The proxy is responding")
            return true
          end
        end
        return true
      rescue Exception => e
        Kameleon.ui.debug("The proxy is not responding. Server response: #{e.message}")
        return false
      end
    end

    def start_web_proxy_in(directory)
      ## This function assumes that the cache directory has already been created by the engine

      # setting current step dir
      @current_step_dir = directory
      Kameleon.ui.debug("Starting web proxy Polipo in directory #{directory} using port: #{@polipo_port}")
      @polipo_process.stop(0) unless @polipo_process.nil?
      command = ["#{@polipo_path}/polipo", "-c", "/dev/null"]
      @polipo_cmd_options[:diskCacheRoot] = directory
      @polipo_cmd_options.each{ |v,k| command.push("#{v}=#{k}") }
      ChildProcess.posix_spawn = true
      Kameleon.ui.debug("Starting process '#{command}'")
      @polipo_process = ChildProcess.build(*command)
      @polipo_process.start
      timeout = 0
      while ( not(proxy_is_running?) and timeout < 5 )
        sleep 1
        timeout = timeout + 1
      end
      return (@polipo_process.alive? and proxy_is_running?)
    end


    def stop_web_proxy
      # http://www.pps.univ-paris-diderot.fr/~jch/software/polipo/manual/Stopping.html
      Kameleon.ui.info("Stopping web proxy polipo")
      unless (@polipo_process.nil? || @polipo_process.exited?)
        Process.kill("USR1", @polipo_process.pid)  # will write out all the in-memory data to disk
        Process.kill("SIGINT", @polipo_process.pid)  # will shut down cleanly
        begin
          @polipo_process.poll_for_exit(10)
        rescue ChildProcess::TimeoutError
          @polipo_process.stop # tries increasingly harsher methods to kill the process.
        end
      end
    end

    def pack()
      if @archive_format.eql? "gzip"
        env = {"GZIP" => "-9"}
        Kameleon.ui.info("Packing up the generated cache in #{@cwd}/#{@name}-cache.tar.gz")
        execute("tar","-czvf #{@name}-cache.tar.gz -C #{@cache_dir} .", @cwd, env)
      elsif @archive_format.eql? "bz2"
        env = {"BZIP" => "-9"}
        Kameleon.ui.info("Packing up the generated cache in #{@cwd}/#{@name}-cache.tar.bz2")
        execute("tar","-cjvf #{@name}-cache.tar.bz2 -C #{@cache_dir} .", @cwd, env)
      elsif @archive_format.eql? "xz"
        env = {"XZ_OPT" => "-9"}
        Kameleon.ui.info("Packing up the generated cache in #{@cwd}/#{@name}-cache.tar.xz")
        execute("tar","-cJvf #{@name}-cache.tar.xz -C #{@cache_dir} .", @cwd, env)
      else
        env = {}
        Kameleon.ui.info("Packing up the generated cache in #{@cwd}/#{@name}-cache.tar")
        execute("tar","-cvf #{@name}-cache.tar -C #{@cache_dir} .", @cwd, env)
      end
    end

    def unpack(cache_path)
      Kameleon.ui.info("Unpacking persistent cache: #{cache_path}")
      FileUtils.mkdir_p @cache_dir
      execute("tar","-xf #{cache_path} -C #{@cache_dir}")
    end


    # This function caches the raw command specified in the recipe
    def cache_cmd_raw(raw_cmd_id)
      @current_raw_cmd = raw_cmd_id
      return true
    end

    def cache_cmd(cmd,file_path)
      Kameleon.ui.info("Caching file")
      Kameleon.ui.debug("command: cp #{file_path} #{@cwd}/cache/files/")
      FileUtils.mkdir_p @current_step_dir + "/data/"
      FileUtils.cp file_path, @current_step_dir + "/data/"
      @cmd_cached.push({:raw_cmd_id => @current_raw_cmd,
                        :stdout_filename => File.basename(file_path)})
    end

    def get_cache_cmd(cmd)
      return false if @mode == :build
      cache_line = @cmd_cached.select{ |reg| reg[:raw_cmd_id] == @current_raw_cmd  }.first
      if cache_line.nil? then
        # This error can be due to the improper format of the file cache_cmd_index
        Kameleon.ui.error("Persistent cache missing file")
        raise BuildError, "Failed to use persistent cache"
      end
      return File.new("#{@current_step_dir}/data/#{cache_line[:stdout_filename]}","r")
    end

    def stop()
      stop_web_proxy
      Kameleon.ui.info("Finishing persistent cache with last files")
      cache_metadata_dir = File.join(@cache_dir,"metadata")
      if @mode == :build then
        File.open("#{cache_metadata_dir}/cache_cmd_index",'w+') do |f|
          f.puts(@cmd_cached.to_yaml)
        end

        unless @recipe_files.empty?
          all_files = @recipe_files.push(@recipe_path)
          recipe_dir = Pathname.new(common_prefix(all_files))
          cached_recipe_dir = Pathname.new(File.join(@cache_dir,"recipe"))
          Kameleon::Utils.copy_files(recipe_dir, cached_recipe_dir, all_files)
        end
        ## Saving metadata information
        Kameleon.ui.info("Caching recipe")

        File.open("#{cache_metadata_dir}/header",'w+') do |f|
          if recipe_dir.nil?
            recipe_path = @recipe_path.basename
          else
            recipe_path = @recipe_path.relative_path_from(recipe_dir)
          end
          f.puts({:recipe_path => recipe_path.to_s}.to_yaml)
          f.puts({:date => Time.now.to_i}.to_yaml)
        end

        #Removing empty directories
        cache_data_dir = File.join(@cache_dir,"DATA")
        Dir.foreach(cache_data_dir) do |item|
          dir_temp = File.join(cache_data_dir,item)
          Dir.delete(dir_temp) if File.stat(dir_temp).nlink == 2
        end

        pack
      end
    end

    def start()
      check_polipo_binary
      if @mode == :from then
        begin
          unpack(@cache_path)
        rescue
          raise BuildError, "Failed to untar the persistent cache file"
        end
        ## We have to load the file
        metadata_dir = File.join(@cache_dir,"metadata")
        @cmd_cached = YAML.load(File.read("#{metadata_dir}/cache_cmd_index"))
      end
      @activated = true
      #@cached_recipe_dir = @cache_dir
      FileUtils.mkdir_p @cache_dir
      # Creating sctructure of the cache
      FileUtils.mkdir_p File.join(@cache_dir,"recipe")
      FileUtils.mkdir_p File.join(@cache_dir,"DATA")
      FileUtils.mkdir_p File.join(@cache_dir,"metadata")
      @polipo_cmd_options[:proxyOffline] = @offline
    end

    def get_recipe()
      extract_path = File.join(Kameleon.env.build_path, File.basename(@cache_path, ".*"))
      FileUtils.mkdir_p extract_path
      execute("tar","-xf #{@cache_path} -C #{extract_path} ./recipe ./metadata")
      Kameleon.ui.info("Getting cached recipe")
      recipe_header = YAML::load(File.read(File.join(extract_path,"metadata","header")))
      recipe_file = File.join(extract_path,"recipe",recipe_header[:recipe_path])
      return recipe_file
    end

    def execute(cmd,args, dir=nil, environment={})
      command = [cmd ] + args.split(" ")
      process = ChildProcess.build(*command)
      process.cwd = dir unless dir.nil?
      environment.each do |key, value|
        process.environment[key] = value
      end
      process.start
      process.wait
    end

    def common_prefix(paths)
      return '' if paths.empty?
      return paths.first.split('/').slice(0...-1).join('/') if paths.length <= 1
      arr = paths.sort
      first = arr.first.to_s.split('/')
      last = arr.last.to_s.split('/')
      i = 0
      i += 1 while first[i] == last[i] && i <= first.length
      first.slice(0, i).join('/')
    end

  end

end