Suppress bogus free-nonheap-object warning in iniparse.cc

[cygwin-apps/setup.git] / libsolv.cc

/*
 * Copyright (c) 2017 Jon Turney
 *
 *     This program is free software; you can redistribute it and/or modify
 *     it under the terms of the GNU General Public License as published by
 *     the Free Software Foundation; either version 2 of the License, or
 *     (at your option) any later version.
 *
 *     A copy of the GNU General Public License can be found at
 *     http://www.gnu.org/
 *
 */

#include "libsolv.h"
#include "package_db.h"
#include "package_meta.h"
#include "resource.h"

#include "solv/solver.h"
#include "solv/solverdebug.h"
#include "solv/evr.h"

#include "LogSingleton.h"
#include <iomanip>
#include <algorithm>

// ---------------------------------------------------------------------------
// Utility functions for mapping between Operators and Relation Ids
// ---------------------------------------------------------------------------

static Id
Operator2RelId(PackageSpecification::_operators op)
{
  switch (op)
    {
    case PackageSpecification::Equals:
      return REL_EQ;
    case PackageSpecification::LessThan:
      return REL_LT;
    case PackageSpecification::MoreThan:
      return REL_GT;
    case PackageSpecification::LessThanEquals:
      return REL_LT | REL_EQ;
    case PackageSpecification::MoreThanEquals:
      return REL_GT | REL_EQ;
    }

  return 0;
}

static PackageSpecification::_operators
RelId2Operator(Id id)
{
  switch (id)
    {
    case REL_EQ:
      return PackageSpecification::Equals;
    case REL_LT:
      return PackageSpecification::LessThan;
    case REL_GT:
      return PackageSpecification::MoreThan;
    case REL_LT | REL_EQ:
      return PackageSpecification::LessThanEquals;
    case REL_GT | REL_EQ:
      return PackageSpecification::MoreThanEquals;
    }

  return PackageSpecification::Equals;
}

// ---------------------------------------------------------------------------
// implements class SolvableVersion
//
// a wrapper around a libsolv Solvable
// ---------------------------------------------------------------------------

Id
SolvableVersion::name_id () const
{
  Solvable *solvable = pool_id2solvable(pool, id);
  return solvable->name;
}

const std::string
SolvableVersion::Name () const
{
  if (!id)
    return "";
  return pool_id2str(pool, name_id());
}

const std::string
SolvableVersion::Canonical_version() const
{
  if (!id)
    return "";
  Solvable *solvable = pool_id2solvable(pool, id);
  return std::string(pool_id2str(pool, solvable->evr));
}

package_type_t
SolvableVersion::Type () const
{
  if (!id)
    return package_binary;
  Solvable *solvable = pool_id2solvable(pool, id);
  if (solvable->arch == ARCH_SRC)
    return package_source;
  else
    return package_binary;
}

const PackageDepends
SolvableVersion::depends() const
{
  return deplist(SOLVABLE_REQUIRES);
}

const PackageDepends
SolvableVersion::obsoletes() const
{
  return deplist(SOLVABLE_OBSOLETES);
}

const PackageDepends
SolvableVersion::provides() const
{
  return deplist(SOLVABLE_PROVIDES);
}

const PackageDepends
SolvableVersion::conflicts() const
{
  return deplist(SOLVABLE_CONFLICTS);
}

// helper function which returns the deplist for a given key, as a PackageDepends
const PackageDepends
SolvableVersion::deplist(Id keyname) const
{
  static PackageDepends empty_package;
  if (!id)
    return empty_package;
  Solvable *solvable = pool_id2solvable(pool, id);

  Queue q;
  queue_init(&q);

  if (repo_lookup_idarray(solvable->repo, id, keyname, &q))
    {
      // convert
      PackageDepends dep;

      for (int i = 0; i < q.count; i++)
        {
#ifdef DEBUG
          Log (LOG_PLAIN) << "dep " << std::hex << q.elements[i] << ": " << pool_dep2str(pool, q.elements[i]) << endLog;
#endif

          const char *name = pool_id2str(pool, q.elements[i]);
          PackageSpecification *spec = new PackageSpecification (name);

          if (ISRELDEP(q.elements[i]))
            {
              Reldep *rd = GETRELDEP(pool, q.elements[i]);
              spec->setOperator(RelId2Operator(rd->flags));
              spec->setVersion(pool_id2str(pool, rd->evr));
            }

          dep.push_back (spec);
        }

      queue_empty(&q);

      return dep;
    }

  // otherwise, return an empty depends list
  return empty_package;
}

const std::string
SolvableVersion::SDesc () const
{
  if (!id)
    return "";
  Solvable *solvable = pool_id2solvable(pool, id);
  const char *sdesc = repo_lookup_str(solvable->repo, id, SOLVABLE_SUMMARY);

  if (!sdesc)
    return "";

  return sdesc;
}

const std::string
SolvableVersion::LDesc () const
{
  if (!id)
    return "";
  Solvable *solvable = pool_id2solvable(pool, id);
  const char *ldesc = repo_lookup_str(solvable->repo, id, SOLVABLE_DESCRIPTION);

  if (!ldesc)
    return "";

  return ldesc;
}

const std::string
SolvableVersion::sourcePackageName () const
{
  if (!id)
    return "";

  // extract source package name
  Solvable *solvable = pool_id2solvable(pool, id);
  Id spkg = repo_lookup_id(solvable->repo, id, SOLVABLE_SOURCENAME);

  // has no such attribute
  if (!spkg)
    return "";

  return std::string(pool_id2str(pool, spkg));
}

const std::string
SolvableVersion::Vendor () const
{
  if (!id)
    return "";

  // extract vendor
  Solvable *solvable = pool_id2solvable(pool, id);
  Id vendor = repo_lookup_id(solvable->repo, id, SOLVABLE_VENDOR);

  // has no such attribute
  if (!vendor)
    return "";

  return std::string(pool_id2str(pool, vendor));
}

SolvableVersion
SolvableVersion::sourcePackage () const
{
  if (!id)
    return SolvableVersion();

  // extract source package id
  Solvable *solvable = pool_id2solvable(pool, id);
  Id spkg_attr = pool_str2id(pool, "solvable:sourceid", 1);
  Id spkg_id = repo_lookup_id(solvable->repo, id, spkg_attr);

  // has no such attribute
  if (!spkg_id)
    return SolvableVersion();

  return SolvableVersion(spkg_id, pool);
}

void
SolvableVersion::fixup_spkg_id (SolvableVersion spkg_id) const
{
  if (!id)
    return;
  Solvable *solvable = pool_id2solvable(pool, id);
  Repodata *data = repo_last_repodata(solvable->repo);
  Id handle = id;
  Id spkg_attr = pool_str2id(pool, "solvable:sourceid", 1);
  repodata_set_id(data, handle, spkg_attr, spkg_id.id);
}

packagesource *
SolvableVersion::source() const
{
  static packagesource empty_source = packagesource();
  if (!id) {
    return &empty_source;
  }

  Solvable *solvable = pool_id2solvable(pool, id);
  Id psrc_attr = pool_str2id(pool, "solvable:packagesource", 1);
  return (packagesource *)repo_lookup_num(solvable->repo, id, psrc_attr, (unsigned long long)&empty_source);
}

bool
SolvableVersion::accessible () const
{
  // empty packages are never accessible
  if (id == 0)
    return false;

  // If we're doing a local re-install, is there an archive available?
  //
  // (This assumes that packagemeta::ScanDownloadedFiles() has already been
  // called to check for presence in the package cache, which would have removed
  // the version if not available, unless it is already installed)
  if (::source == IDC_SOURCE_LOCALDIR)
    return source ()->Cached ();

  // Otherwise, package is (presumably) retrievable
  return true;
}

package_stability_t
SolvableVersion::Stability () const
{
  if (!id)
    return TRUST_UNKNOWN;
  Solvable *solvable = pool_id2solvable(pool, id);
  Id stability_attr = pool_str2id(pool, "solvable:stability", 1);
  return (package_stability_t)repo_lookup_num(solvable->repo, id, stability_attr, TRUST_UNKNOWN);
}

bool
SolvableVersion::operator <(SolvableVersion const &rhs) const
{
  return (compareVersions(*this, rhs) < 0);
}

bool
SolvableVersion::operator ==(SolvableVersion const &rhs) const
{
  return (compareVersions(*this, rhs) == 0);
}

bool
SolvableVersion::operator !=(SolvableVersion const &rhs) const
{
  return (compareVersions(*this, rhs) != 0);
}

int
SolvableVersion::compareVersions(const SolvableVersion &a,
                                 const SolvableVersion &b)
{
  if (a.id == b.id)
    return 0;

  // if a and b are different, at least one of them has a pool
  Pool *pool = a.pool ? a.pool : b.pool;

  Solvable *sa = a.id ? pool_id2solvable(a.pool, a.id) : NULL;
  Solvable *sb = b.id ? pool_id2solvable(b.pool, b.id) : NULL;

  // empty versions compare as if their version is the empty string
  Id evra = sa ? sa->evr : pool_str2id(pool, "", 1);
  Id evrb = sb ? sb->evr : pool_str2id(pool, "", 1);

  return pool_evrcmp(pool, evra, evrb, EVRCMP_COMPARE);
}

void
SolvableVersion::remove() const
{
  if (!id)
    return;

  Solvable *solvable = pool_id2solvable(pool, id);
  repo_free_solvable(solvable->repo, id, 0);
}

// ---------------------------------------------------------------------------
// implements class SolverPool
//
// a simplified wrapper for libsolv
// ---------------------------------------------------------------------------

static
void debug_callback(Pool *pool, void *data, int type, const char *str)
{
  if (type & (SOLV_FATAL|SOLV_ERROR))
    LogPlainPrintf("libsolv: %s", str);
  else
    LogBabblePrintf("libsolv: %s", str);
}

SolverPool::SolverPool()
{
  init();
}

void
SolverPool::init()
{
  /* create a pool */
  pool = pool_create();

  pool_setdebugcallback(pool, debug_callback, NULL);

  int level = 1;
#if DEBUG
  level = 3;
#endif
  pool_setdebuglevel(pool, level);

  /* create the repo to hold installed packages */
  SolvRepo *installed = getRepo("_installed");
  pool_set_installed(pool, installed->repo);
}

void
SolverPool::clear()
{
  repos.clear();
  pool_free(pool);
  pool = NULL;

  init();
}

SolvRepo *
SolverPool::getRepo(const std::string &name, bool test)
{
  RepoList::iterator i = repos.find(name);
  if (i != repos.end())
    return i->second;

  /* create repo if not found */
  SolvRepo *r = new(SolvRepo);
  r->repo = repo_create(pool, name.c_str());

  /* create attribute store, with no local pool */
  r->data = repo_add_repodata(r->repo, 0);

  /* remember if this is a test stability repo */
  r->test = test;

  /* set default priority */
  r->repo->priority = SolvRepo::priorityNormal;

  repos[name] = r;

  return r;
}

/*
  Helper function to convert a PackageDepends list to libsolv dependencies.
*/
Id
SolverPool::makedeps(Repo *repo, PackageDepends *requires)
{
  Id deps = 0;

  for (PackageDepends::iterator i = requires->begin();
       i != requires->end();
       i++)
    {
      Id name = pool_str2id(pool, (*i)->packageName().c_str(), 1);

      if ((*i)->version().size() == 0)
        {
          // no relation, so dependency is just on package name
          deps = repo_addid_dep(repo, deps, name, 0);
        }
      else
        {
          // otherwise, dependency is on package name with a version condition
          Id evr = pool_str2id(pool, (*i)->version().c_str(), 1);
          int rel = pool_rel2id(pool, name, evr, Operator2RelId((*i)->op()), 1);

          deps = repo_addid_dep(repo, deps, rel, 0);
        }
    }

  return deps;
}

SolvableVersion
SolverPool::addPackage(const std::string& pkgname, const addPackageData &pkgdata)
{
  std::string repoName = pkgdata.reponame;
  bool test = false;

  /* It's simplest to place test packages into a separate repo, and
     then arrange for that repo to have low priority, if we don't want
     to install those packages by default */

  if (pkgdata.stability == TRUST_TEST && repoName != "_installed")
    {
      repoName = pkgdata.reponame + "_test_";
      test = true;
    }

  SolvRepo *r = getRepo(repoName, test);
  Repo *repo = r->repo;

  /* create a solvable */
  Id s = repo_add_solvable(repo);
  Solvable *solvable = pool_id2solvable(pool, s);

  /* initialize solvable for this packageo/version/etc.  */
  solvable->name = pool_str2id(pool, pkgname.c_str(), 1);
  solvable->arch = (pkgdata.type == package_binary) ? ARCH_ANY : ARCH_SRC;
  solvable->evr = pool_str2id(repo->pool, pkgdata.version.c_str(), 1);
  solvable->vendor = pool_str2id(repo->pool, pkgdata.vendor.c_str(), 1);
  if (pkgdata.provides)
    solvable->provides = makedeps(repo, pkgdata.provides);
  /* in the absence of specific provides, we provide what we obsolete */
  else if (pkgdata.obsoletes)
    solvable->provides = makedeps(repo, pkgdata.obsoletes);
  /* we always provide ourselves */
  solvable->provides = repo_addid_dep(repo, solvable->provides, pool_rel2id(pool, solvable->name, solvable->evr, REL_EQ, 1), 0);
  if (pkgdata.requires)
    solvable->requires = makedeps(repo, pkgdata.requires);
  if (pkgdata.obsoletes)
    solvable->obsoletes = makedeps(repo, pkgdata.obsoletes);
  if (pkgdata.conflicts)
    solvable->conflicts = makedeps(repo, pkgdata.conflicts);

  /* a solvable can also store arbitrary attributes not needed for dependency
     resolution, if we need them */

  Repodata *data = r->data;
  Id handle = s;
#if DEBUG
  Log (LOG_PLAIN) << "solvable " << s << " name " << pkgname << endLog;
#endif

  /* store short description attribute */
  repodata_set_str(data, handle, SOLVABLE_SUMMARY, pkgdata.sdesc.c_str());
  /* store long description attribute */
  repodata_set_str(data, handle, SOLVABLE_DESCRIPTION, pkgdata.ldesc.c_str());

  /* store source-package attribute */
  const std::string sname = pkgdata.spkg.packageName();
  if (!sname.empty())
    repodata_set_id(data, handle, SOLVABLE_SOURCENAME, pool_str2id(pool, sname.c_str(), 1));
  else
    repodata_set_void(data, handle, SOLVABLE_SOURCENAME);
  /* solvable:sourceevr may also be available from spkg but assumed to be same
     as evr for the moment */

  /* store source-package id */
  /* (If the source-package hasn't been seen yet, we don't know what it's Id
     will be.  That gets fixed up later.) */
  if (pkgdata.spkg_id)
    {
      Id spkg_attr = pool_str2id(pool, "solvable:sourceid", 1);
      repodata_set_id(data, handle, spkg_attr, pkgdata.spkg_id.id);
    }

  /* we could store packagesource information as attributes ...

     e.g.
       size     SOLVABLE_DOWNLOADSIZE
       pathname SOLVABLE_MEDIAFILE
       site     SOLVABLE_MEDIABASE
       checksum SOLVABLE_CHECKSUM

     ... but for the moment, we just store a pointer to a packagesource object
  */
  Id psrc_attr = pool_str2id(pool, "solvable:packagesource", 1);
  packagesource *psrc = new packagesource(pkgdata.archive);
  repodata_set_num(data, handle, psrc_attr, (intptr_t)psrc);

  /* store stability level attribute */
  Id stability_attr = pool_str2id(pool, "solvable:stability", 1);
  repodata_set_num(data, handle, stability_attr, pkgdata.stability);

#if 0
  repodata_internalize(data);

  /* debug: verify the attributes we've just set get retrieved correctly */
  SolvableVersion sv = SolvableVersion(s, pool);
  const std::string check_sdesc = sv.SDesc();
  if (pkgdata.sdesc.compare(check_sdesc) != 0) {
    Log (LOG_PLAIN) << pkgname << " has sdesc mismatch: '" << pkgdata.sdesc << "' and '"
                    << check_sdesc << "'" << endLog;
  }
  if (!sname.empty()) {
    SolvableVersion check_spkg = sv.sourcePackage();
    Solvable *check_spkg_solvable = pool_id2solvable(pool, check_spkg.id);
    std::string check_sname = pool_id2str(pool, check_spkg_solvable->name);
    if (sname.compare(check_sname) != 0) {
      Log (LOG_PLAIN) << pkgname << " has spkg mismatch: '" << pkgdata.spkg.packageName()
                      << "' and '" << check_sname << "'" << endLog;
    }
  }
  packagesource *check_archive = sv.source();
  if (check_archive != psrc)
    Log (LOG_PLAIN) << pkgname << " has archive mismatch: " << psrc
                    << " and " << check_archive << endLog;
  package_stability_t check_stability = sv.Stability();
  if (check_stability != pkgdata.stability) {
    Log (LOG_PLAIN) << pkgname << " has stability mismatch: " << pkgdata.stability
                    << " and " << check_stability << endLog;
  }
#endif

  return SolvableVersion(s, pool);
}

void
SolverPool::internalize()
{
  /* Make attribute data available to queries */
  for (RepoList::iterator i = repos.begin();
       i != repos.end();
       i++)
    {
      repodata_internalize(i->second->data);
    }
}

bool
SolverPool::is_test_package(SolvableVersion sv)
{
  Solvable *solvable = pool_id2solvable(pool, sv.id);

  for (RepoList::iterator i = repos.begin();
       i != repos.end();
       i++)
    {
      if (solvable->repo == i->second->repo)
        return i->second->test;
    }

  return false;
}

void
SolverTasks::setTasks()
{
  // go through all packages, adding changed ones to the solver task list
  packagedb db;
  tasks.clear();

  for (packagedb::packagecollection::iterator p = db.packages.begin ();
       p != db.packages.end (); ++p)
    {
      packagemeta *pkg = p->second;

      switch (pkg->get_action())
        {
        case packagemeta::NoChange_action: // skip/keep
          // keep and skip need attention only when they differ from the
          // solver's solution
          if (pkg->installed)
            {
              if (!pkg->picked() && pkg->installed != pkg->default_version)
                add(pkg->installed, taskKeep); // keep
              else if (pkg->isBlacklisted(pkg->installed))
                {
                  // if installed (with no action selected), but blacklisted,
                  // force a distupgrade of this package
                  add(pkg->installed, taskForceDistUpgrade);
                }
            }
          else if (pkg->default_version)
             add(pkg->default_version, taskSkip); // skip

          break;

        case packagemeta::Install_action:
          if (pkg->desired)
            add(pkg->desired, taskInstall); // install/upgrade
          else
            {
              // install
              //
              // empty desired means "any version", it doesn't matter which one
              // we use as taskInstallAny only match on the provides name
              if (pkg->curr)
                add(pkg->curr, taskInstallAny);
              else if (pkg->exp)
                add(pkg->exp, taskInstallAny);
            }
          break;

        case packagemeta::Uninstall_action:
          add(pkg->installed, taskUninstall); // uninstall
          break;

        case packagemeta::Reinstall_action:
          add(pkg->installed, taskReinstall); // reinstall
          break;
        }

      // only install action makes sense for source packages
      if (pkg->srcpicked())
        {
          if (pkg->desired)
            add(pkg->desired.sourcePackage(), taskInstall);
          else
            add(pkg->installed.sourcePackage(), taskInstall);
        }
    }
}

void
SolverPool::use_test_packages(bool use_test_packages)
{
  // Give repos containing test packages higher priority than normal
  // if wanted, otherwise lower priority.
  SolvRepo::priority_t p = use_test_packages ? SolvRepo::priorityNormal : SolvRepo::priorityLow;
  for (RepoList::iterator i = repos.begin();
       i != repos.end();
       i++)
    {
      if (i->second->test)
        i->second->setPriority(p);
    }
}

// ---------------------------------------------------------------------------
// implements class SolverSolution
//
// A wrapper around the libsolv solver
// ---------------------------------------------------------------------------

SolverSolution::SolverSolution(SolverPool &_pool) : pool(_pool), solv(NULL)
{
  queue_init(&job);
}

SolverSolution::~SolverSolution()
{
  clear();
}

void
SolverSolution::clear()
{
  if (solv)
    {
      solver_free(solv);
      solv = NULL;
    }
  queue_free(&job);
}

void
SolverSolution::trans2db() const
{
  packagedb db;
  // First reset all packages to the "no changes" state
  db.noChanges ();

  // Now make changes according to trans.  transErase requires some
  // care; it could either be a "plain" uninstall, or it could be
  // paired with a transInstall for an upgrade/downgrade or reinstall.
  for (SolverTransactionList::const_iterator i = trans.begin();
       i != trans.end(); i++)
    {
      const packageversion & pv = i->version;
      packagemeta *pkg = db.findBinary(PackageSpecification(pv.Name()));
      if (!pkg)
        // Can't happen - throw an exception?
        {
          Log (LOG_PLAIN) << "Can't happen.  No packagemeta for "
                          << pv.Name() << endLog;
          return;
        }
      switch (i->type)
        {
        case SolverTransaction::transInstall:
          if (pv.Type() == package_binary)
            {
              pkg->set_action(packagemeta::Install_action, pv);
              pkg->default_version = pv;
            }
          else // source package
            pkg->srcpick(true);
          break;
        case SolverTransaction::transErase:
          // Only relevant if pkg is still in its "no change" state
          if (pkg->get_action() == packagemeta::NoChange_action)
            {
              pkg->set_action(packagemeta::Uninstall_action, packageversion());
              pkg->default_version = packageversion();
            }
          break;
        default:
          break;
        }
    }
}

void
SolverSolution::db2trans()
{
  trans.clear();
  packagedb db;

  for (packagedb::packagecollection::iterator p = db.packages.begin ();
       p != db.packages.end (); ++p)
    {
      packagemeta *pkg = p->second;
      if ((pkg->get_action() == packagemeta::Install_action) ||
          (pkg->get_action() == packagemeta::Reinstall_action))
        {
          trans.push_back(SolverTransaction(pkg->desired, SolverTransaction::transInstall));
          if (pkg->installed)
            trans.push_back(SolverTransaction(pkg->installed, SolverTransaction::transErase));
        }
      else if (pkg->get_action() == packagemeta::Uninstall_action)
        trans.push_back(SolverTransaction(pkg->installed, SolverTransaction::transErase));

      if (pkg->srcpicked())
        {
          if (pkg->desired)
            trans.push_back(SolverTransaction(pkg->desired.sourcePackage(), SolverTransaction::transInstall));
          else
            trans.push_back(SolverTransaction(pkg->installed.sourcePackage(), SolverTransaction::transInstall));
        }
    }
}

static
std::ostream &operator<<(std::ostream &stream,
                         SolverTransaction::transType type)
{
  switch (type)
    {
    case SolverTransaction::transInstall:
      stream << "install";
      break;
    case SolverTransaction::transErase:
      stream << "erase";
      break;
    default:
      stream << "unknown";
    }
  return stream;
}

void
SolverSolution::tasksToJobs(SolverTasks &tasks, updateMode update, Queue &job)
{
  // solver accepts a queue containing pairs of (cmd, id) tasks
  // cmd is job and selection flags ORed together
  for (SolverTasks::taskList::const_iterator i = tasks.tasks.begin();
       i != tasks.tasks.end();
       i++)
    {
      const SolvableVersion &sv = (*i).first;

      switch ((*i).second)
        {
        case SolverTasks::taskInstall:
          queue_push2(&job, SOLVER_INSTALL | SOLVER_SOLVABLE, sv.id);
          break;
        case SolverTasks::taskInstallAny:
          queue_push2(&job, SOLVER_INSTALL | SOLVER_SOLVABLE_PROVIDES, sv.name_id());
          break;
        case SolverTasks::taskUninstall:
          queue_push2(&job, SOLVER_ERASE | SOLVER_SOLVABLE, sv.id);
          break;
        case SolverTasks::taskReinstall:
          // we don't know how to ask solver for this, so we just add the erase
          // and install later
          break;
        case SolverTasks::taskKeep:
          queue_push2(&job, SOLVER_LOCK | SOLVER_SOLVABLE, sv.id);
          break;
        case SolverTasks::taskSkip:
          queue_push2(&job, SOLVER_LOCK | SOLVER_SOLVABLE_NAME, sv.name_id());
          break;
        case SolverTasks::taskForceDistUpgrade:
          queue_push2(&job, SOLVER_DISTUPGRADE | SOLVER_SOLVABLE, sv.id);
          break;
        default:
          Log (LOG_PLAIN) << "unknown task " << (*i).second << endLog;
        }
    }

  // Ask solver to update packages
  switch (update)
    {
    case keep:
      break;

    case updateBest:
      // Update to best version
      queue_push2(&job, SOLVER_UPDATE | SOLVER_SOLVABLE_ALL, 0);
      break;

    case updateForce:
      // Bring installed, non-orphaned packages in sync with the ones in the
      // repository
      queue_push2(&job, SOLVER_DISTUPGRADE | SOLVER_SOLVABLE_ALL, 0);
      break;
    }

  // Ask solver to check dependencies of installed packages.
  queue_push2(&job, SOLVER_VERIFY | SOLVER_SOLVABLE_ALL, 0);
}

bool
SolverSolution::update(SolverTasks &tasks, updateMode update, bool use_test_packages)
{
  Log (LOG_PLAIN) << "solving: " << tasks.tasks.size() << " tasks," <<
    " update: " << (update ? "yes" : "no") << "," <<
    " use test packages: " << (use_test_packages ? "yes" : "no") << endLog;

  pool.use_test_packages(use_test_packages);

  queue_free(&job);
  tasksToJobs(tasks, update, job);

  if (!solv)
    solv = solver_create(pool.pool);

  return solve();
}

bool
SolverSolution::solve()
{
  solver_set_flag(solv, SOLVER_FLAG_ALLOW_VENDORCHANGE, 1);
  solver_set_flag(solv, SOLVER_FLAG_ALLOW_DOWNGRADE, 0);
  solver_set_flag(solv, SOLVER_FLAG_DUP_ALLOW_VENDORCHANGE, 1);
  solver_set_flag(solv, SOLVER_FLAG_DUP_ALLOW_DOWNGRADE, 1);
  solver_solve(solv, &job);

  int pcnt = solver_problem_count(solv);
  solver_printdecisions(solv);

  solutionToTransactionList();

  return (pcnt == 0);
}

void
SolverSolution::solutionToTransactionList()
{
  // get transactions for solution
  Transaction *t = solver_create_transaction(solv);
  transaction_order(t, 0);
  transaction_print(t);

  // massage into SolverTransactions form
  trans.clear();
  for (int i = 0; i < t->steps.count; i++)
    {
      Id id = t->steps.elements[i];
      SolverTransaction::transType tt = type(t, i);
      if (tt != SolverTransaction::transIgnore)
        trans.push_back(SolverTransaction(SolvableVersion(id, pool.pool), tt));
    }

  transaction_free(t);

#if DEBUG
  dumpTransactionList();
#endif
}

void
SolverSolution::augmentTasks(SolverTasks &tasks)
{
  // add install and remove tasks for anything marked as reinstall
  for (SolverTasks::taskList::const_iterator i = tasks.tasks.begin();
       i != tasks.tasks.end();
       i++)
    {
      const SolvableVersion &sv = (*i).first;

      if (sv && (((*i).second) == SolverTasks::taskReinstall))
        {
          trans.push_back(SolverTransaction(SolvableVersion(sv.id, pool.pool),
                                            SolverTransaction::transErase));
          trans.push_back(SolverTransaction(SolvableVersion(sv.id, pool.pool),
                                            SolverTransaction::transInstall));
        }
    }
}

void
SolverSolution::addSource(bool include_source)
{
  // if include_source mode is on, also install source for everything we are
  // installing
  if (include_source)
    {
      // (this uses indicies into the vector, as iterators might become
      // invalidated by doing push_back)
      size_t n = trans.size();
      for (size_t i = 0; i < n; i++)
        {
          if (trans[i].type == SolverTransaction::transInstall)
            {
              SolvableVersion src_version = trans[i].version.sourcePackage();
              if (src_version)
                trans.push_back(SolverTransaction(src_version,
                                                  SolverTransaction::transInstall));
            }
        }
    }
}

void
SolverSolution::dumpTransactionList() const
{
  if (trans.size())
    {
      size_t width_name = 0;
      size_t width_version = 0;

      for (SolverTransactionList::const_iterator i = trans.begin ();
           i != trans.end ();
           ++i)
        {
          width_name = std::max(width_name, i->version.Name().length()+1);
          width_version = std::max(width_version, i->version.Canonical_version().length()+1);
        }

      Log (LOG_PLAIN) << "Augmented Transaction List:" << endLog;
      for (SolverTransactionList::const_iterator i = trans.begin ();
           i != trans.end ();
           ++i)
        {
          Log (LOG_PLAIN) << std::setw(4) << std::distance(trans.begin(), i)
                          << std::setw(8) << i->type << " "
                          << std::left
                          << std::setw(width_name) << i->version.Name()
                          << std::setw(width_version) << i->version.Canonical_version() << endLog;
        }
    }
  else
    Log (LOG_PLAIN) << "Augmented Transaction List: is empty" << endLog;
}

void SolverSolution::applyDefaultProblemSolutions()
{
  // adjust the task list with the default solutions
  int pcnt = solver_problem_count(solv);
  for (Id problem = 1; problem <= pcnt; problem++)
    {
      int scnt = solver_solution_count(solv, problem);
      solver_take_solution(solv, problem, scnt, &job);
    }

  // re-solve
  if (!solve())
    Log (LOG_PLAIN) << "default solutions did not solve all problems!" << endLog;
}

const SolverTransactionList &
SolverSolution::transactions() const
{
  return trans;
}

// Construct a string reporting the problems and solutions
std::string
SolverSolution::report() const
{
  packagedb db;
  std::string r = "";
  int pcnt = solver_problem_count(solv);
  for (Id problem = 1; problem <= pcnt; problem++)
    {
      r += "Problem " + std::to_string(problem) + "/" + std::to_string(pcnt);
      r += "\n";

      Id probr = solver_findproblemrule(solv, problem);
      Id dep, source, target;
      SolverRuleinfo type = solver_ruleinfo(solv, probr, &source, &target, &dep);
      if (source == db.basepkg.id)
        r += "package " + std::string(pool_dep2str(pool.pool, dep)) + " is a Base package and is therefore required";
      else
        r += solver_problemruleinfo2str(solv, type, source, target, dep);
      r += "\n";

      int scnt = solver_solution_count(solv, problem);
      for (Id solution = 1; solution <= scnt; solution++)
        {
          r += "Solution " + std::to_string(solution) + "/" + std::to_string(scnt);
          if (solution == scnt) r += " (default)";
          r += "\n";

          Id p, rp, element;
          element = 0;
          while ((element = solver_next_solutionelement(solv, problem, solution, element, &p, &rp)) != 0)
            {
              r += "  - ";
              if (p == db.basepkg.id)
                r += "allow deinstallation of Base packages";
              else
                r += solver_solutionelement2str(solv, p, rp);
              r += "\n";
            }
        }
    }

  // since package arch isn't set usefully at the moment, remove all ".any" from
  // package names in the problem report string.
  std::string any = ".any";
  size_t pos;
  while ((pos = r.find(any)) != std::string::npos)
    {
      r.replace(pos, any.length(), "");
    }

  return r;
}

// helper function to map transaction type
SolverTransaction::transType
SolverSolution::type(Transaction *trans, int pos)
{
  Id tt = transaction_type(trans, trans->steps.elements[pos],
                           SOLVER_TRANSACTION_SHOW_ACTIVE);

  // if active side of transaction is nothing, ask again for passive side of
  // transaction
  if (tt == SOLVER_TRANSACTION_IGNORE)
    tt = transaction_type(trans, trans->steps.elements[pos], 0);

  switch(tt)
    {
    case SOLVER_TRANSACTION_INSTALL:
    case SOLVER_TRANSACTION_REINSTALL:
    case SOLVER_TRANSACTION_UPGRADE:
    case SOLVER_TRANSACTION_DOWNGRADE:
      return SolverTransaction::transInstall;
    case SOLVER_TRANSACTION_ERASE:
    case SOLVER_TRANSACTION_REINSTALLED:
    case SOLVER_TRANSACTION_UPGRADED:
    case SOLVER_TRANSACTION_DOWNGRADED:
      return SolverTransaction::transErase;
    default:
      Log (LOG_PLAIN) << "unknown transaction type " << std::hex << tt << endLog;
    case SOLVER_TRANSACTION_CHANGE:
    case SOLVER_TRANSACTION_CHANGED:
    case SOLVER_TRANSACTION_IGNORE:
      return SolverTransaction::transIgnore;
    }
};