discourse/lib/compression/zip.rb

# frozen_string_literal: true

require "zip"

module Compression
  class Zip < Strategy
    def extension
      ".zip"
    end

    def compress(path, target_name)
      absolute_path = sanitize_path("#{path}/#{target_name}")
      zip_filename = "#{absolute_path}.zip"

      ::Zip::File.open(zip_filename, ::Zip::File::CREATE) do |zipfile|
        if File.directory?(absolute_path)
          entries = Dir.entries(absolute_path) - %w[. ..]
          write_entries(entries, absolute_path, "", zipfile)
        else
          put_into_archive(absolute_path, zipfile, target_name)
        end
      end

      zip_filename
    end

    private

    def extract_folder(entry, entry_path)
      entry.extract(entry_path)
    end

    def get_compressed_file_stream(compressed_file_path)
      zip_file = ::Zip::File.open(compressed_file_path)
      yield(zip_file)
    end

    def build_entry_path(dest_path, entry, _)
      File.join(dest_path, entry.name)
    end

    def decompression_results_path(dest_path, _)
      dest_path
    end

    def extract_file(entry, entry_path, available_size)
      remaining_size = available_size

      if ::File.exist?(entry_path)
        raise ::Zip::DestinationFileExistsError, "Destination '#{entry_path}' already exists"
      end

      ::File.open(entry_path, "wb") do |os|
        entry.get_input_stream do |is|
          entry.set_extra_attributes_on_path(entry_path)

          buf = "".dup
          while (buf = is.sysread(chunk_size, buf))
            remaining_size -= chunk_size
            raise ExtractFailed if remaining_size.negative?
            os << buf
          end
        end
      end

      remaining_size
    end

    # A helper method to make the recursion work.
    def write_entries(entries, base_path, path, zipfile)
      entries.each do |e|
        zipfile_path = path == "" ? e : File.join(path, e)
        disk_file_path = File.join(base_path, zipfile_path)

        if File.directory? disk_file_path
          recursively_deflate_directory(disk_file_path, zipfile, base_path, zipfile_path)
        else
          put_into_archive(disk_file_path, zipfile, zipfile_path)
        end
      end
    end

    def recursively_deflate_directory(disk_file_path, zipfile, base_path, zipfile_path)
      zipfile.mkdir zipfile_path
      subdir = Dir.entries(disk_file_path) - %w[. ..]
      write_entries subdir, base_path, zipfile_path, zipfile
    end

    def put_into_archive(disk_file_path, zipfile, zipfile_path)
      zipfile.add(zipfile_path, disk_file_path)
    end
  end
end