module MiGA::Cli::Action::Doctor::Base

check_dist_eval(cli, p, res) click to toggle source

Scans the all-vs-all matrix registered in res (MiGA::Result) in search of pairs where one or both datasets are missing or inactive in the project p (MiGA::Project), and report progress through cli (MiGA::Cli). Returns an Array with two arrays: the first a list of dataset names that are no longer registered in the project or are currently inactive, and the second a list of dataset names that have registered pairs with the first list, and therefore the databases need to be cleaned. This is a subtask of check_dist

# File lib/miga/cli/action/doctor/base.rb, line 49
def check_dist_eval(cli, p, res)
  notok = {}
  fix = {}
  Zlib::GzipReader.open(res.file_path(:matrix)) do |fh|
    lineno = 0
    fh.each_line do |ln|
      next if (lineno += 1) == 1

      r = ln.split("\t")
      next unless [1, 2].map { |i| p.dataset(r[i]).nil? }.any?

      [1, 2].each do |i|
        if p.dataset(r[i]).nil? || !p.dataset(r[i]).active?
          notok[r[i]] = true
        else
          fix[r[i]] = true
        end
      end
    end
  end
  [notok.keys, fix.keys]
end

check_dist_fix(cli, p, fix) click to toggle source

Cleanup distance databases for datasets names in fix (Array: String) from project p (MiGA::Project), and report through cli (MiGA::Cli). This is a subtask of check_dist

# File lib/miga/cli/action/doctor/base.rb, line 76
def check_dist_fix(cli, p, fix)
  return if fix.empty?

  cli.say("- Fixing #{fix.size} datasets")
  fix.each do |d_n|
    cli.say "  > Fixing #{d_n}."
    p.dataset(d_n).cleanup_distances!
  end
end

check_dist_recompute(cli, res, notok) click to toggle source

Recompute res (MiGA::Result) if notok (Array: String) has any dataset names registered, and report through cli (MiGA::Cli). This is a subtask of check_dist

# File lib/miga/cli/action/doctor/base.rb, line 90
def check_dist_recompute(cli, res, notok)
  return if notok.empty?

  cli.say '- Unregistered datasets detected: '
  if notok.size <= 5
    notok.each { |i| cli.say "  > #{i}" }
  else
    cli.say "  > #{notok.size}, including #{notok.first}"
  end
  cli.say '- Removing tables, recompute'
  res.remove!
end

check_sqlite3_database(db_file, metric, &blk) click to toggle source

Check the database in db_file maintains integrity for the tables saving metric (:ani or :aai) and call blk if the file is corrupt or doesn't contain the expected structure

# File lib/miga/cli/action/doctor/base.rb, line 12
def check_sqlite3_database(db_file, metric, &blk)
  SQLite3::Database.new(db_file) do |conn|
    conn.execute("select count(*) from #{metric}").first
  end
rescue SQLite3::SQLException, SQLite3::CorruptException
  blk.call
end

each_database_file(dataset, &blk) click to toggle source

# File lib/miga/cli/action/doctor/base.rb, line 20
def each_database_file(dataset, &blk)
  ref_db = { '01.haai' => :aai, '02.aai' => :aai, '03.ani' => :ani }
  qry_db = { '.haai.db' => :aai, '.aai.db' => :aai, '.ani.db' => :ani }
  base = File.join(dataset.project.path, 'data', '09.distances')
  result = :distances
  if dataset.ref?
    file_db = "#{dataset.name}.db"
    ref_db.each do |dir, metric|
      file = File.join(base, dir, file_db)
      blk[file, metric, result] if File.exist? file
    end
    base = File.join(base, '05.taxonomy')
    result = :taxonomy
  end
  qry_db.each do |ext, metric|
    file = File.join(base, "#{dataset.name}#{ext}")
    blk[file, metric, result] if File.exist? file
  end
end

module MiGA::Cli::Action::Doctor::Base

Public Instance Methods