# encoding: utf-8
require "thread"
require "forwardable"
require "fileutils"
require "logstash-integration-aws_jars"

module LogStash
  module Outputs
    class S3

      java_import 'org.logstash.plugins.integration.outputs.s3.GzipUtil'

      # Wrap the actual file descriptor into an utility class
      # Make it more OOP and easier to reason with the paths.
      class TemporaryFile
        extend Forwardable

        GZIP_EXTENSION = "txt.gz"
        TXT_EXTENSION = "txt"
        RECOVERED_FILE_NAME_TAG = "-recovered"

        def_delegators :@fd, :path, :write, :close, :fsync

        attr_reader :fd

        def initialize(key, fd, temp_path)
          @fd = fd
          @key = key
          @temp_path = temp_path
          @created_at = Time.now
        end

        def ctime
          @created_at
        end

        def temp_path
          @temp_path
        end

        def size
          # Use the fd size to get the accurate result,
          # so we dont have to deal with fsync
          # if the file is close, fd.size raises an IO exception so we use the File::size
          begin
            # fd is nil when LS tries to recover gzip file but fails
            return 0 unless @fd != nil
            @fd.size
          rescue IOError
            ::File.size(path)
          end
        end

        def key
          @key.gsub(/^\//, "")
        end

        # Each temporary file is created inside a directory named with an UUID,
        # instead of deleting the file directly and having the risk of deleting other files
        # we delete the root of the UUID, using a UUID also remove the risk of deleting unwanted file, it acts as
        # a sandbox.
        def delete!
          @fd.close rescue IOError # force close anyway
          FileUtils.rm_r(@temp_path, :secure => true)
        end

        def empty?
          size == 0
        end

        # only to cover the case where LS cannot restore corrupted file, file is not exist
        def recoverable?
          !@fd.nil?
        end

        def self.create_from_existing_file(file_path, temporary_folder)
          key_parts = Pathname.new(file_path).relative_path_from(temporary_folder).to_s.split(::File::SEPARATOR)

          # recover gzip file and compress back before uploading to S3
          if file_path.end_with?("." + GZIP_EXTENSION)
            file_path = self.recover(file_path)
          end
          TemporaryFile.new(key_parts.slice(1, key_parts.size).join("/"),
                            ::File.exist?(file_path) ? ::File.open(file_path, "r") : nil, # for the nil case, file size will be 0 and upload will be ignored.
                            ::File.join(temporary_folder, key_parts.slice(0, 1)))
        end

        def self.gzip_extension
          GZIP_EXTENSION
        end

        def self.text_extension
          TXT_EXTENSION
        end

        def self.recovery_file_name_tag
          RECOVERED_FILE_NAME_TAG
        end

        private
        def self.recover(file_path)
          full_gzip_extension = "." + GZIP_EXTENSION
          recovered_txt_file_path = file_path.gsub(full_gzip_extension, RECOVERED_FILE_NAME_TAG + "." + TXT_EXTENSION)
          recovered_gzip_file_path = file_path.gsub(full_gzip_extension, RECOVERED_FILE_NAME_TAG + full_gzip_extension)
          GzipUtil.recover(file_path, recovered_txt_file_path)
          if ::File.exist?(recovered_txt_file_path) && !::File.zero?(recovered_txt_file_path)
            GzipUtil.compress(recovered_txt_file_path, recovered_gzip_file_path)
          end
          recovered_gzip_file_path
        end
      end
    end
  end
end