class MiGA::MiGA

# File lib/miga/common/base.rb, line 31
def DEBUG(*args)
  $stderr.puts(*args) if debug?
  $stderr.puts(
    caller.map { |v| v.gsub(/^/, '     ') }.join("\n")
  ) if debug_trace?
end

# File lib/miga/common/base.rb, line 12
def DEBUG_OFF
  @@DEBUG = false
end

# File lib/miga/common/base.rb, line 6
def DEBUG_ON
  @@DEBUG = true
end

# File lib/miga/common/base.rb, line 25
def DEBUG_TRACE_OFF
  @@DEBUG_TRACE = false
end

# File lib/miga/common/base.rb, line 18
def DEBUG_TRACE_ON
  @@DEBUG_TRACE = true
  DEBUG_ON()
end

# File lib/miga/common/base.rb, line 38
def debug?
  @@DEBUG ||= false
end

# File lib/miga/common/base.rb, line 42
def debug_trace?
  @@DEBUG_TRACE ||= false
end

# File lib/miga/common.rb, line 36
def self.initialized?
  File.exist?(rc_path) &&
    File.exist?(File.join(ENV['MIGA_HOME'], '.miga_daemon.json'))
end

# File lib/miga/common.rb, line 30
def self.rc_path
  File.join(ENV['MIGA_HOME'], '.miga_rc')
end

# File lib/miga/common.rb, line 65
def advance(step, n = 0, total = nil, bin = true)
  # Initialize advance timing
  @_advance_time ||= { last: nil, n: 0, avg: nil, total: total }
  if @_advance_time[:n] > n || total != @_advance_time[:total]
    @_advance_time[:last] = nil
    @_advance_time[:n] = 0
    @_advance_time[:avg]  = nil
    @_advance_time[:total] = total
  end

  # Estimate timing
  adv_n = n - @_advance_time[:n]
  if total.nil? || @_advance_time[:last].nil? || adv_n.negative?
    # Initial report
    @_advance_time[:last] = Time.now
    @_advance_time[:n] = n
  elsif adv_n > 0.001 * total
    # Advance report (if change > 0.1% change and time > 1 second)
    this_time = (Time.now - @_advance_time[:last]).to_f
    return if this_time < 1.0 && n < total

    this_avg = this_time / adv_n
    @_advance_time[:avg] ||= this_avg
    @_advance_time[:avg] = 0.9 * @_advance_time[:avg] + 0.1 * this_avg
    @_advance_time[:last] = Time.now
    @_advance_time[:n] = n
  else
    # Final report (if the last update was too small) or ignore update
    return if n < total
  end

  # Report
  adv =
    if total.nil?
      (n == 0 ? '' : num_suffix(n, bin))
    else
      vals = [100.0 * n / total, num_suffix(n, bin), num_suffix(total, bin)]
      ('%.1f%% (%s/%s)' % vals)
    end
  left =
    if @_advance_time[:avg].nil?
      ''
    else
      left_time = @_advance_time[:avg] * (total - n) / 60 # <- in minutes
      left_time < 0.01 ? '         ' :
        left_time < 1 ? ('%.0fs left' % (left_time * 60)) :
        left_time > 1440 ? ('%.1fd left' % (left_time / 1440)) :
        left_time > 60 ? ('%.1fh left' % (left_time / 60)) :
        ('%.1fm left' % left_time)
    end
  $stderr.print("[%s] %s %s %s    \r" % [Time.now, step, adv, left])
end

# File lib/miga/common.rb, line 134
def like_io?(obj)
  obj.is_a?(IO) || obj.is_a?(StringIO)
end

# File lib/miga/common.rb, line 121
def num_suffix(n, bin = false)
  p = ''
  { T: 4, G: 3, M: 2, K: 1 }.each do |k, x|
    v = (bin ? 1024 : 1e3)**x
    if n > v
      n = '%.1f' % (n.to_f / v)
      p = k
      break
    end
  end
  "#{n}#{p}"
end

# File lib/miga/common.rb, line 44
def result_files_exist?(base, ext)
  ext = [ext] unless ext.is_a? Array
  MiGA::MiGA.DEBUG("Assserting files for result: #{ext}")
  ext.all? { |f| File.exist?(base + f) or File.exist?("#{base}#{f}.gz") }
end

# File lib/miga/common.rb, line 55
def say(*par)
  io = like_io?(par.first) ? par.shift : $stderr
  io.puts(*par.map { |i| "[#{Time.now}] #{i}" })
end