module MiGA::Daemon::Base

def bypass_maintenance?
  !!runopts(:bypass_maintenance)
end

def latency
  runopts(:latency)
end

def logfh
  @logfh ||= nil
  return $stderr if show_log?
  return @logfh if @logfh && !@logfh.closed?
  @logfh = File.open(output_file, 'w')
end

def maxjobs
  runopts(:maxjobs)
end

def nodelist
  runopts(:nodelist)
end

def ppn(what = :dataset)
  runopts_for(:ppn, what)
end

def runopts(k, v = nil, force = false)
  k = k.to_sym
  unless v.nil?
    case k
    when :latency, :maxjobs, :ppn, :ppn_project, :format_version, :verbosity,
         :skip_maintenance
      v = v.to_i
      if !force && v == 0 && !%i[verbosity skip_maintenance].include?(k)
        raise "Daemon's #{k} cannot be set to zero"
      end
    when :shutdown_when_done, :show_log, :bypass_maintenance
      v = !!v
    when :nodelist
      if v =~ /^\$/
        vv = ENV[v.sub('$', '')] or raise "Unset environment variable: #{v}"
        v = vv
      end
      say "Reading node list: #{v}"
      v = File.readlines(v).map(&:chomp)
    end
    @runopts[k] = v
  end
  @runopts[k]
end

def runopts_for(opt, what)
  runopts(:"#{opt}_#{what}") || runopts(opt)
end

def show_log!
  @runopts[:show_log] = true
end

def show_log?
  @runopts[:show_log] ||= false
end

def show_summary!
  @runopts[:show_log] = false
end

def shutdown_when_done?
  !!runopts(:shutdown_when_done)
end

def skip_maintenance
  runopts(:skip_maintenance) || 0
end

def verbosity
  runopts(:verbosity) || 1
end