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 47
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 74
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 88
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)
  MiGA::SQLite.new(db_file).run("select count(*) from #{metric}")
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 18
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

save_bidirectional(a, b) click to toggle source

Saves all the distance estimates in a -> b into the b databases (as b -> a), where both a and b are MiGA::Dataset objects

# File lib/miga/cli/action/doctor/base.rb, line 114
def save_bidirectional(a, b)
  each_database_file(a) do |db_file, metric, result|
    data = nil
    data = MiGA::SQLite.new(db_file).run(
      "select seq1, seq2, #{metric}, sd, n, omega " +
      "from #{metric} where seq2 = ? limit 1", b.name
    ).first
    next if data.nil? || data.empty?

    db_file_b = File.join(File.dirname(db_file), "#{b.name}.db")
    next unless File.exist?(db_file_b)

    data[0], data[1] = data[1], data[0]
    MiGA::SQLite.new(db_file_b).run(
      "insert into #{metric} (seq1, seq2, #{metric}, sd, n, omega) " +
      "values(?, ?, ?, ?, ?, ?)", data
    )
  end
end

saved_targets(dataset) click to toggle source

Returns all targets identified by AAI

# File lib/miga/cli/action/doctor/base.rb, line 103
def saved_targets(dataset)
  # Return nil if distance or database are not retrievable
  dist = dataset.result(:distances) or return
  path = dist.file_path(:aai_db) or return

  MiGA::SQLite.new(path).run('select seq2 from aai').map(&:first)
end

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

Public Instance Methods