class URBANopt::Scenario::SimulationDirOSW

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 19
def initialize(scenario, features, feature_names, mapper_class)
  super(scenario, features, feature_names)

  if features.size != 1
    raise 'SimulationDirOSW currently cannot simulate more than one feature'
  end

  @feature = features[0]
  @feature_id = @feature.id

  if feature_names.size == 1
    @feature_name = feature_names[0]
  else
    @feature_name = @feature.name
  end

  @mapper_class = mapper_class
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 192
def clear
  dir = run_dir
  FileUtils.mkdir_p(dir) if !File.exist?(dir)
  Dir.glob(File.join(dir, '/*')).each do |f|
    FileUtils.rm_rf(f)
  end
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 207
def create_input_files
  clear

  dir = run_dir
  osw = eval("#{@mapper_class}.new.create_osw(scenario, features, feature_names)")
  osw_path = File.join(dir, 'in.osw')
  File.open(osw_path, 'w') do |f|
    f << JSON.pretty_generate(osw)
    # make sure data is written to the disk one way or the other
    begin
      f.fsync
    rescue StandardError
      f.flush
    end
  end
  return osw_path
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 80
def failed_job_path
  return File.join(run_dir, 'failed.job')
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 87
def finished_job_path
  return File.join(run_dir, 'finished.job')
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 60
def in_osw
  result = nil
  if File.exist?(in_osw_path)
    File.open(in_osw_path, 'r') do |f|
      result = JSON.parse(f.read, symbolize_names: true)
    end
  end
  return result
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 53
def in_osw_path
  return File.join(run_dir, 'in.osw')
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 115
def out_of_date?
  if !File.exist?(run_dir)
    puts "run_dir '#{run_dir}' does not exist, simulation dir '#{run_dir}' out of date"
    return true
  end

  if !File.exist?(finished_job_path)
    puts "finished_job_path '#{finished_job_path}' does not exist, simulation dir '#{run_dir}' out of date"
    return true
  end

  if !File.exist?(out_osw_path)
    puts "out_osw_path '#{out_osw_path}' does not exist, simulation dir '#{run_dir}' out of date"
    return true
  end
  out_osw_time = File.mtime(out_osw_path)

  # array of files that this simulation dir depends on
  dependencies = []
  out_of_date_files = []

  # depends on the in.osw
  dependencies << in_osw_path

  # depends on the feature file
  dependencies << scenario.feature_file.path

  # depends on the mapper classes
  Dir.glob(File.join(scenario.mapper_files_dir, '*')).each do |f|
    dependencies << f
  end

  # depends on the root gemfile
  dependencies << File.join(scenario.root_dir, 'Gemfile')
  dependencies << File.join(scenario.root_dir, 'Gemfile.lock')

  # todo, read in the in.osw and depend on all the measures

  # check if out of date
  dependencies.each do |f|
    if File.exist?(f)
      if File.mtime(f) > out_osw_time
        out_of_date_files << f
      end
    else
      puts "Dependency file '#{f}' does not exist"
    end
  end

  if !out_of_date_files.empty?
    puts "Files [#{out_of_date_files.join(',')}] are newer than '#{out_osw_path}', simulation dir '#{run_dir}' out of date"
    return true
  end

  return false
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 101
def out_osw
  result = nil
  if File.exist?(out_osw_path)
    File.open(out_osw_path, 'r') do |f|
      result = JSON.parse(f.read, symbolize_names: true)
    end
  end
  return result
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 94
def out_osw_path
  return File.join(run_dir, 'out.osw')
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 43
def run_dir
  raise 'Feature ID not set' if @feature_id.nil?
  raise 'Scenario run dir not set' if scenario.run_dir.nil?

  return File.join(scenario.run_dir, "#{@feature_id}/")
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 175
def simulation_status
  if File.exist?(failed_job_path)
    return 'Failed'
  elsif File.exist?(started_job_path)
    if File.exist?(finished_job_path)
      return 'Complete'
    else
      return 'Failed'
    end
  end

  return 'Not Started'
end

# File lib/urbanopt/scenario/simulation_dir_osw.rb, line 73
def started_job_path
  return File.join(run_dir, 'started.job')
end