# frozen_string_literal: true

require "benchmark"

module ActiveRecordDataLoader
  class Loader
    class << self
      def load_data(
        data_generator:,
        total_rows:,
        batch_size:,
        configuration:
      )
        new(
          logger: configuration.logger,
          statement_timeout: configuration.statement_timeout,
          strategy: strategy_class.new(data_generator)
        ).load_data(batch_size, total_rows)
      end

      private

      def strategy_class
        if ::ActiveRecord::Base.connection.raw_connection.respond_to?(:copy_data)
          ActiveRecordDataLoader::CopyStrategy
        else
          ActiveRecordDataLoader::BulkInsertStrategy
        end
      end
    end

    def initialize(logger:, statement_timeout:, strategy:)
      @logger = logger
      @strategy = strategy
      @statement_timeout = statement_timeout
    end

    def load_data(batch_size, total_rows)
      batch_count = (total_rows / batch_size.to_f).ceil

      logger.info(
        "Loading #{total_rows} row(s) into '#{strategy.table_name}' via #{strategy.name}. "\
        "#{batch_size} row(s) per batch, #{batch_count} batch(es)."
      )
      total_time = Benchmark.realtime do
        load_in_batches(batch_size, total_rows, batch_count)
      end
      logger.info(
        "Completed loading #{total_rows} row(s) into '#{strategy.table_name}' "\
        "in #{total_time} seconds."
      )
    end

    private

    attr_reader :strategy, :statement_timeout, :logger

    def load_in_batches(batch_size, total_rows, batch_count)
      with_connection do |connection|
        total_rows.times.each_slice(batch_size).with_index do |row_numbers, i|
          time = Benchmark.realtime { strategy.load_batch(row_numbers, connection) }

          logger.debug(
            "Completed batch #{i + 1}/#{batch_count}, #{row_numbers.count} row(s) in #{time} seconds"
          )
        end
      end
    end

    def with_connection
      if ::ActiveRecord::Base.connection.adapter_name.downcase.to_sym == :postgresql
        original_timeout = retrieve_statement_timeout
        update_statement_timeout(statement_timeout)
        yield ::ActiveRecord::Base.connection
        update_statement_timeout(original_timeout)
      else
        yield ::ActiveRecord::Base.connection
      end
    end

    def retrieve_statement_timeout
      ::ActiveRecord::Base.connection.execute("SHOW statement_timeout").first["statement_timeout"]
    end

    def update_statement_timeout(timeout)
      ::ActiveRecord::Base.connection.execute("SET statement_timeout = \"#{timeout}\"")
    end
  end
end