HabitatMap/AirCasting

class AirNow::ImportMeasurements
  def initialize
    @import_data = AirNow::ImportData.new
    @parse_files = AirNow::ParseFiles
    @cache_manager = AirNow::CacheManager.new
    @save_measurements = SaveMeasurements.new(user: airnow_user)
    @process_measurements = AirNow::ProcessMeasurements
  end

  def call
    locations_data, measurements_data = import_data.call
    measurements_data = cache_manager.call(measurements_data)
    locations = parse_files.parse_locations(locations_data)
    measurements = parse_files.parse_hourly_data(measurements_data, locations)
    saveable_measurements = process_measurements.new.call(measurements)
    streams = GroupByStream.new.call(measurements: saveable_measurements)
    save_measurements.call(streams: streams)
  end

  private

  attr_reader :import_data, :save_measurements, :parse_files, :process_measurements, :cache_manager

  def airnow_user
    User.find_or_create_by(username: 'US EPA AirNow') do |user|
      user.email = 'airnow@example.com'
      user.password = SecureRandom.hex(10)
    end
  end
end