class MavisCLI::LocalAuthorities::ImportGIASCodes

# File app/lib/mavis_cli/local_authorities/import_gias_codes.rb, line 13
def call(input_file: nil, **)
  MavisCLI.load_rails

  files_to_import =
    (
      if input_file
        Array(input_file)
      else
        Dir.glob("db/data/gias-la-codes-*.zip")
      end
    )
  progress_bar = MavisCLI.progress_bar(files_to_import.size)

  files_to_import.each do |file|
    puts "Importing file #{file}"
    import_file(file)
    progress_bar.increment
  end
end

# File app/lib/mavis_cli/local_authorities/import_gias_codes.rb, line 33
def import_file(input_file)
  Zip::File.open(input_file) do |zip|
    csv_entry = zip.glob("*.csv").first
    csv_content = csv_entry.get_input_stream.read

    rows =
      CSV.parse(csv_content, headers: true, encoding: "ISO-8859-1:UTF-8")
    ons_code_field = rows.headers.find { |h| h =~ /\(ONS\)/ }
    gias_code_field =
      rows.headers.find do |h|
        h =~ /Get Information about Schools \(GIAS\)/
      end

    puts "importing #{rows.count - 1} GIAS/ONS LA code mappings"

    rows.each do |row|
      ons_code = row[ons_code_field]
      gias_code = row[gias_code_field]

      LocalAuthority.where(gss_code: ons_code).update!(
        gias_code: gias_code
      )
    end
  end
end