# frozen_string_literal: true

class RSpec::OpenAPI::ResultRecorder
  def initialize(path_records)
    @path_records = path_records
    @error_records = {}
  end

  def record_results!
    @path_records.each do |path, records|
      # Look for a path-specific config file and run it.
      config_file = File.join(File.dirname(path), RSpec::OpenAPI.config_filename)
      begin
        require config_file if File.exist?(config_file)
      rescue StandardError => e
        puts "WARNING: Unable to load #{config_file}: #{e}"
      end

      title = RSpec::OpenAPI.title
      RSpec::OpenAPI::SchemaFile.new(path).edit do |spec|
        schema = RSpec::OpenAPI::DefaultSchema.build(title)
        schema[:info].merge!(RSpec::OpenAPI.info)
        RSpec::OpenAPI::SchemaMerger.merge!(spec, schema)
        new_from_zero = {}
        records.each do |record|
          record_schema = RSpec::OpenAPI::SchemaBuilder.build(record)
          RSpec::OpenAPI::SchemaMerger.merge!(spec, record_schema)
          RSpec::OpenAPI::SchemaMerger.merge!(new_from_zero, record_schema)
        rescue StandardError, NotImplementedError => e # e.g. SchemaBuilder raises a NotImplementedError
          @error_records[e] = record # Avoid failing the build
        end
        cleanup_schema!(new_from_zero, spec)
        execute_post_process_hook(path, records, spec)
      end
    end
  end

  def errors?
    @error_records.any?
  end

  def error_message
    <<~ERR_MSG
      RSpec::OpenAPI got errors building #{@error_records.size} requests

      #{@error_records.map { |e, record| "#{e.inspect}: #{record.inspect}" }.join("\n")}
    ERR_MSG
  end

  private

  def execute_post_process_hook(path, records, spec)
    RSpec::OpenAPI.post_process_hook.call(path, records, spec) if RSpec::OpenAPI.post_process_hook.is_a?(Proc)
  end

  def cleanup_schema!(new_from_zero, spec)
    RSpec::OpenAPI::SchemaCleaner.cleanup_conflicting_security_parameters!(spec)
    RSpec::OpenAPI::SchemaCleaner.cleanup!(spec, new_from_zero)
    RSpec::OpenAPI::ComponentsUpdater.update!(spec, new_from_zero)
    RSpec::OpenAPI::SchemaCleaner.cleanup_empty_required_array!(spec)
    RSpec::OpenAPI::SchemaSorter.deep_sort!(spec)
  end
end