CartoDB/cartodb20

require 'open3'
require_relative './source_file'
require_relative './unp'
require_relative './exceptions'

module CartoDB
  module Importer2
    class GpkgSplitter

      MAX_LAYERS = 50
      ITEM_COUNT_REGEX = 'Feature Count:\s'.freeze
      OGRINFO_BINARY = 'ogrinfo'.freeze
      DEFAULT_OGR2OGR_BINARY = 'ogr2ogr'.freeze

      def self.support?(source_file)
        source_file.extension == '.gpkg'
      end

      def initialize(source_file, temporary_directory, ogr2ogr_config = nil)
        @source_file = source_file
        @temporary_directory = temporary_directory
        @ogr2ogr_binary = if ogr2ogr_config && ogr2ogr_config['binary'].present?
                            `#{ogr2ogr_config['binary']}`.strip
                          else
                            DEFAULT_OGR2OGR_BINARY
                          end
      end

      def run
        n_layers = layers_in(source_file).length
        return self if n_layers <= 1

        if n_layers > MAX_LAYERS
          raise CartoDB::Importer2::TooManyLayersError.new(
            "File has too many layers (#{n_layers}). Maximum number of layers: #{MAX_LAYERS}"
          )
        end
        @source_files = source_files_for(source_file, layers_in(source_file))
        self
      end

      def source_files
        return [source_file] unless multiple_layers?(source_file)

        @source_files
      end

      def source_files_for(source_file, layer_names = [])
        layer_names.map do |layer_name|
          layer_file_name = path_for(source_file, layer_name)
          extract(layer_file_name, source_file, layer_name)
          SourceFile.new(layer_file_name, nil, layer_name)
        end
      end

      def extract(extracted_file_path, source_file, layer_name)
        system(@ogr2ogr_binary, '-f', 'GPKG', extracted_file_path, source_file.fullpath, layer_name)
      end

      def multiple_layers?(source_file)
        layers_in(source_file).length > 1
      end

      def number_or_nil(string)
        Integer(string || '')
      rescue ArgumentError
        nil
      end

      def layers_in(source_file)
        layers = []

        stdout, stderr, status = Open3.capture3(OGRINFO_BINARY, source_file.fullpath)
        gpkg_layers = stdout.split("\n")
                            .select { |line| line =~ /^\d+/ }
                            .map { |line| line.gsub(/^\d+: | \(.+\)$/, '') }

        gpkg_layers.each do |layer|
          stdout, stderr, status =
            Open3.capture3(OGRINFO_BINARY, '-so', source_file.fullpath, layer)
          number_rows = stdout.split("\n")
                              .select { |line| line =~ /^#{ITEM_COUNT_REGEX}/ }
                              .map { |line| line.gsub(/#{ITEM_COUNT_REGEX}/, '') }.first
          number_rows = number_or_nil(number_rows)
          layers << layer if !number_rows.nil? && number_rows.positive?
        end
        layers
      end

      def path_for(source_file, layer_name)
        file_layer_name = "#{source_file.name}_#{layer_name}"
        File.join(
          temporary_directory,
          Unp.new.underscore(file_layer_name) + '.gpkg'
        )
      end

      attr_reader :source_file

      private

      attr_reader :temporary_directory
      attr_writer :source_file

    end
  end
end