class URBANopt::Scenario::ScenarioRunnerOSW

# File lib/urbanopt/scenario/scenario_runner_osw.rb, line 18
def initialize; end

# File lib/urbanopt/scenario/scenario_runner_osw.rb, line 28
def create_simulation_files(scenario, force_clear = false)
  if force_clear
    scenario.clear
  end

  FileUtils.mkdir_p(scenario.run_dir) if !File.exist?(scenario.run_dir)
  FileUtils.rm_rf(File.join(scenario.run_dir, 'run_status.json')) if File.exist?(File.join(scenario.run_dir, 'run_status.json'))

  simulation_dirs = scenario.simulation_dirs

  simulation_dirs.each do |simulation_dir|
    if simulation_dir.out_of_date?
      puts "simulation_dir #{simulation_dir.run_dir} is out of date, regenerating input files"
      simulation_dir.create_input_files
    end
  end
  return simulation_dirs
end

# File lib/urbanopt/scenario/scenario_runner_osw.rb, line 145
def get_results(scenario, simulation_dirs)
  # look for other failed datapoints (command line display)
  # also compile datapoint status for latest_run.json file
  status_arr = []
  failed_sims = []
  simulation_dirs.each do |sim_dir|
    if File.exist?(sim_dir.failed_job_path)
      failed_sims << sim_dir.run_dir.split('/')[-1]
    end
    status_arr << { "id": sim_dir.feature_id, "status": sim_dir.simulation_status, "mapper_class": sim_dir.mapper_class }
  end

  # write to file
  File.open(File.join(scenario.run_dir, 'run_status.json'), 'w') { |f| f.write JSON.pretty_generate("timestamp": Time.now.strftime('%Y-%m-%dT%k:%M:%S.%L'), "results": status_arr) }

  if !failed_sims.empty?
    puts "FAILED SIMULATION IDs: #{failed_sims.join(',')}"
  end
end

# File lib/urbanopt/scenario/scenario_runner_osw.rb, line 62
def run(scenario, force_clear = false, options = {})
  # instantiate openstudio runner - use the defaults for now. If need to change then create
  # the runner.conf file (i.e. run `rake openstudio:runner:init`)
  # allow passing gemfile_path and bundle_install_path in options
  runner = OpenStudio::Extension::Runner.new(scenario.root_dir, [], options)

  # create simulation files
  simulation_dirs = create_simulation_files(scenario, force_clear)

  # osws = []
  # simulation_dirs.each do |simulation_dir|
  #   if !simulation_dir.is_a?(SimulationDirOSW)
  #     raise "ScenarioRunnerOSW does not know how to run #{simulation_dir.class}"
  #   end
  #   if simulation_dir.out_of_date?
  #     osws << simulation_dir.in_osw_path
  #   end
  # end

  # cretae 3 groups to store .osw files (+building_osws+ , +transformer_osws+ , +district_system_osws+)
  building_osws = []
  transformer_osws = []
  district_system_osws = []

  simulation_dirs.each do |simulation_dir|
    in_osw = File.read(simulation_dir.in_osw_path)
    in_osw_hash = JSON.parse(in_osw, symbolize_names: true)

    if !simulation_dir.is_a?(SimulationDirOSW)
      raise "ScenarioRunnerOSW does not know how to run #{simulation_dir.class}"
    end

    # get feature_type value from in.osw files
    feature_type = nil
    in_osw_hash[:steps].each { |x| feature_type = x[:arguments][:feature_type] if x[:arguments][:feature_type] }

    # add each osw file to its corresponding group id +simulation_dir+ is out_of_date
    if simulation_dir.out_of_date?

      case feature_type
      when 'Building'
        building_osws << simulation_dir.in_osw_path
      when 'District System'
        district_system_osws << simulation_dir.in_osw_path
      when 'Transformer'
        transformer_osws << simulation_dir.in_osw_path
      else
        raise "ScenarioRunnerOSW does not know how to run a #{feature_type} feature"
      end

    end
  end

  # Run osw groups in order and store simulation failure in an array.
  # Return simulation_dirs after running all simulations.

  # failures
  failures = []
  # run building_osws
  # building_failures = runner.run_osws(building_osws, num_parallel = Extension::NUM_PARALLEL, max_to_run = Extension::MAX_DATAPOINTS)
  building_failures = runner.run_osws(building_osws)
  failures + building_failures
  # run district_system_osws
  # district_system_failures = runner.run_osws(district_system_osws, num_parallel = Extension::NUM_PARALLEL, max_to_run = Extension::MAX_DATAPOINTS)
  district_system_failures = runner.run_osws(district_system_osws)
  failures + district_system_failures
  # run transformer_osws
  # transformer_failures = runner.run_osws(transformer_osws, num_parallel = Extension::NUM_PARALLEL, max_to_run = Extension::MAX_DATAPOINTS)
  transformer_failures = runner.run_osws(transformer_osws)
  failures + transformer_failures

  puts 'Done Running Scenario'

  # if failures.size > 0
  #   puts "DATAPOINT FAILURES: #{failures}"
  # end

  # write results to file and to command line
  get_results(scenario, simulation_dirs)

  return simulation_dirs
end