926N/A

565N/A

2026N/Aimport errno

1050N/Aimport operator

926N/Aimport os

926N/Aimport six

2339N/Aimport xml.parsers.expat as expat

2339N/Afrom functools import total_ordering

2339N/Afrom six.moves.urllib.parse import urlsplit

926N/A

926N/Aimport pkg.client.pkgdefs as pkgdefs

838N/A

2034N/AEmptyI = tuple()

2034N/A

1540N/Aclass ApiException(Exception):

1540N/A def __init__(self, *args):

1540N/A Exception.__init__(self)

1540N/A self.__verbose_info = []

1540N/A

1968N/A def add_verbose_info(self, info):

1540N/A self.__verbose_info.extend(info)

2034N/A

2034N/A @property

2200N/A def verbose_info(self):

2034N/A return self.__verbose_info

2034N/A

2034N/Aclass SuidUnsupportedError(ApiException):

565N/A def __str__(self):

2339N/A return _("""

2339N/AThe pkg client api module can not be invoked from an setuid executable.""")

2339N/A

2339N/A

2339N/Aclass HistoryException(ApiException):

2339N/A """Private base exception class for all History exceptions."""

2339N/A

2339N/A def __init__(self, *args):

2339N/A Exception.__init__(self, *args)

2339N/A self.error = args[0]

2339N/A

2339N/A def __str__(self):

2339N/A return str(self.error)

2339N/A

2339N/A

2339N/Aclass HistoryLoadException(HistoryException):

2339N/A """Used to indicate that an unexpected error occurred while loading

1710N/A def __init__(self, *args):

1710N/A HistoryException.__init__(self, *args)

1710N/A self.parse_failure = isinstance(self.error, expat.ExpatError)

1710N/A

1710N/A

1710N/Aclass HistoryRequestException(HistoryException):

1710N/A """Used to indicate that invalid time / range values were provided to

1710N/A pass

1710N/A

1710N/A

1710N/Aclass HistoryStoreException(HistoryException):

1710N/A """Used to indicate that an unexpected error occurred while storing

1710N/A pass

1710N/A

1710N/A

1710N/Aclass HistoryPurgeException(HistoryException):

1710N/A """Used to indicate that an unexpected error occurred while purging

565N/A pass

565N/A

565N/A

565N/Aclass ImageLockedError(ApiException):

565N/A """Used to indicate that the image is currently locked by another thread

565N/A

2144N/A def __init__(self, hostname=None, pid=None, pid_name=None):

2158N/A ApiException.__init__(self)

2158N/A self.hostname = hostname

2158N/A self.pid = pid

2158N/A self.pid_name = pid_name

2158N/A

2158N/A def __str__(self):

2158N/A if self.pid is not None and self.pid_name is not None and \

2158N/A self.hostname is not None:

2158N/A return _("The image cannot be modified as it is "

2158N/A "currently in use by another package client: "

2158N/A "{pid_name} on {host}, pid {pid}.").format(

2158N/A pid_name=self.pid_name, pid=self.pid,

2158N/A host=self.hostname)

2158N/A if self.pid is not None and self.pid_name is not None:

2158N/A return _("The image cannot be modified as it is "

2158N/A "currently in use by another package client: "

2158N/A "{pid_name} on an unknown host, pid {pid}.").format(

2158N/A pid_name=self.pid_name, pid=self.pid)

2144N/A elif self.pid is not None:

2144N/A return _("The image cannot be modified as it is "

2144N/A "currently in use by another package client: "

2144N/A "pid {pid} on {host}.").format(

2144N/A pid=self.pid, host=self.hostname)

2144N/A return _("The image cannot be modified as it is currently "

2144N/A "in use by another package client.")

2144N/A

2144N/Aclass ImageNotFoundException(ApiException):

2144N/A """Used when an image was not found"""

2144N/A def __init__(self, user_specified, user_dir, root_dir):

2144N/A ApiException.__init__(self)

2144N/A self.user_specified = user_specified

2407N/A self.user_dir = user_dir

2407N/A self.root_dir = root_dir

2407N/A

2407N/A def __str__(self):

2407N/A return _("No image rooted at '{0}'").format(self.user_dir)

2407N/A

2407N/A

2407N/Aclass ImageFormatUpdateNeeded(ApiException):

2407N/A """Used to indicate that an image cannot be used until its format is

2407N/A

2407N/A def __init__(self, path):

2407N/A ApiException.__init__(self)

2407N/A self.path = path

2407N/A

2407N/A def __str__(self):

2144N/A return _("The image rooted at {0} is written in an older format "

565N/A "and must be updated before the requested operation can be "

565N/A "performed.").format(self.path)

565N/A

565N/Aclass ImageInsufficentSpace(ApiException):

565N/A """Used when insuffcient space exists for proposed operation"""

565N/A def __init__(self, needed, avail, use):

2144N/A self.needed = needed

565N/A self.avail = avail

565N/A self.use = use

565N/A

565N/A def __str__(self):

565N/A from pkg.misc import bytes_to_str

1618N/A return _("Insufficient disk space available ({avail}) "

1618N/A "for estimated need ({needed}) for {use}").format(

1618N/A avail=bytes_to_str(self.avail),

1618N/A needed=bytes_to_str(self.needed),

1618N/A use=self.use

1618N/A )

1755N/A

1755N/A

1755N/Aclass VersionException(ApiException):

1755N/A def __init__(self, expected_version, received_version):

1755N/A ApiException.__init__(self)

1755N/A self.expected_version = expected_version

1755N/A self.received_version = received_version

1755N/A

1755N/A

1755N/Aclass PlanExistsException(ApiException):

1755N/A def __init__(self, plan_type):

1755N/A ApiException.__init__(self)

1755N/A self.plan_type = plan_type

1755N/A

1755N/A

1755N/Aclass PlanPrepareException(ApiException):

1755N/A """Base exception class for plan preparation errors."""

1618N/A pass

1618N/A

1618N/A

1618N/Aclass InvalidPackageErrors(ApiException):

1618N/A """Used to indicate that the requested operation could not be completed

1618N/A

1618N/A def __init__(self, errors):

1618N/A """'errors' should be a list of exceptions or strings

1618N/A

1618N/A ApiException.__init__(self)

1618N/A self.errors = errors

1618N/A

1618N/A def __str__(self):

1618N/A return _("The requested operation cannot be completed due "

1618N/A "to invalid package metadata. Details follow:\n\n"

1618N/A "{0}").format("\n".join(str(e) for e in self.errors))

1618N/A

1618N/A

1618N/Aclass LicenseAcceptanceError(ApiException):

1618N/A """Used to indicate that license-related errors occurred during

1618N/A

1618N/A def __init__(self, pfmri, src=None, dest=None, accepted=None,

1618N/A displayed=None):

1618N/A ApiException.__init__(self)

1618N/A self.fmri = pfmri

1618N/A self.src = src

1618N/A self.dest = dest

1618N/A self.accepted = accepted

1618N/A self.displayed = displayed

1618N/A

1618N/A

1618N/Aclass PkgLicenseErrors(PlanPrepareException):

1618N/A """Used to indicate that plan evaluation or execution failed due

1618N/A

1618N/A def __init__(self, errors):

1618N/A """'errors' should be a list of LicenseAcceptanceError

1618N/A

1618N/A PlanPrepareException.__init__(self)

1618N/A self.__errors = errors

1618N/A

1618N/A @property

1618N/A def errors(self):

1618N/A """A list of LicenseAcceptanceError exceptions."""

1618N/A return self.__errors

1618N/A

1618N/A

1618N/Aclass PlanLicenseErrors(PlanPrepareException):

1618N/A """Used to indicate that image plan evaluation or execution failed due

1618N/A

1618N/A def __init__(self, pp_errors):

1618N/A """'errors' should be a list of PkgLicenseErrors exceptions."""

1618N/A

1618N/A PlanPrepareException.__init__(self)

1618N/A self.__errors = pkgs = {}

1618N/A for pp_err in pp_errors:

1618N/A for e in pp_err.errors:

1618N/A pkgs.setdefault(str(e.fmri), []).append(e)

1618N/A

1618N/A @property

1618N/A def errors(self):

1618N/A """Returns a dictionary indexed by package FMRI string of

1618N/A

1618N/A return self.__errors

1019N/A

1019N/A def __str__(self):

1019N/A """Returns a string representation of the license errors."""

1019N/A

1019N/A output = ""

1019N/A for sfmri in self.__errors:

1019N/A output += ("-" * 40) + "\n"

1019N/A output += _("Package: {0}\n\n").format(sfmri)

1618N/A for e in self.__errors[sfmri]:

565N/A lic_name = e.dest.attrs["license"]

565N/A output += _("License: {0}\n").format(lic_name)

565N/A if e.dest.must_accept and not e.accepted:

1618N/A output += _(" License requires "

1618N/A "acceptance.")

565N/A if e.dest.must_display and not e.displayed:

565N/A output += _(" License must be viewed.")

1618N/A output += "\n"

565N/A return output

565N/A

565N/A

1618N/Aclass ActuatorException(ApiException):

565N/A def __init__(self, e):

565N/A ApiException.__init__(self)

565N/A self.exception = e

565N/A

565N/A def __str__(self):

1369N/A return str(self.exception)

1710N/A

1710N/A

1710N/Aclass PrematureExecutionException(ApiException):

1710N/A pass

1710N/A

1710N/A

1710N/Aclass AlreadyPreparedException(PlanPrepareException):

1710N/A pass

1710N/A

1710N/A

1372N/Aclass AlreadyExecutedException(ApiException):

1369N/A pass

1369N/A

1369N/A

1369N/Aclass ImageplanStateException(ApiException):

1369N/A def __init__(self, state):

1369N/A ApiException.__init__(self)

1369N/A self.state = state

1369N/A

1372N/A

1372N/Aclass InvalidPlanError(ApiException):

1369N/A """Used to indicate that the image plan is no longer valid, likely as a

565N/A

565N/A def __str__(self):

565N/A return _("The plan for the current operation is no longer "

565N/A "valid. The image has likely been modified by another "

565N/A "process or client. Please try the operation again.")

565N/A

1328N/A

1328N/Aclass ImagePkgStateError(ApiException):

1328N/A

565N/A def __init__(self, fmri, states):

565N/A ApiException.__init__(self)

565N/A self.fmri = fmri

565N/A self.states = states

565N/A

565N/A def __str__(self):

565N/A return _("Invalid package state change attempted '{states}' "

565N/A "for package '{fmri}'.").format(states=self.states,

565N/A fmri=self.fmri)

685N/A

685N/A

685N/Aclass IpkgOutOfDateException(ApiException):

685N/A def __str__(self):

685N/A return _("pkg(7) out of date")

685N/A

685N/A

926N/Aclass ImageUpdateOnLiveImageException(ApiException):

2126N/A def __str__(self):

2126N/A return _("Requested operation cannot be performed "

2126N/A "in live image.")

685N/A

685N/A

2126N/Aclass RebootNeededOnLiveImageException(ApiException):

2126N/A def __str__(self):

685N/A return _("Requested operation cannot be performed "

685N/A "in live image.")

879N/A

879N/A

879N/Aclass CanceledException(ApiException):

879N/A pass

879N/A

879N/Aclass PlanMissingException(ApiException):

879N/A pass

879N/A

879N/Aclass NoPackagesInstalledException(ApiException):

879N/A pass

1335N/A

1335N/Aclass PermissionsException(ApiException):

1945N/A def __init__(self, path):

1335N/A ApiException.__init__(self)

1335N/A self.path = path

1335N/A

1335N/A def __str__(self):

1335N/A if self.path:

1335N/A return _("Could not operate on {0}\nbecause of "

1335N/A "insufficient permissions. Please try the "

1335N/A "command again as a privileged user.").format(

1335N/A self.path)

1968N/A else:

1335N/A return _("""

1335N/A""")

2301N/A

2301N/Aclass FileInUseException(PermissionsException):

2301N/A def __init__(self, path):

2301N/A PermissionsException.__init__(self, path)

2301N/A assert path

2301N/A

2301N/A def __str__(self):

2301N/A return _("Could not operate on {0}\nbecause the file is "

2301N/A "in use. Please stop using the file and try the\n"

2301N/A "operation again.").format(self.path)

2301N/A

2301N/A

2301N/Aclass UnprivilegedUserError(PermissionsException):

2301N/A def __init__(self, path):

2301N/A PermissionsException.__init__(self, path)

2301N/A

2301N/A def __str__(self):

2301N/A return _("Insufficient access to complete the requested "

2301N/A "operation.\nPlease try the operation again as a "

2301N/A "privileged user.")

2301N/A

2301N/A

2301N/Aclass ReadOnlyFileSystemException(PermissionsException):

2301N/A """Used to indicate that the operation was attempted on a

2301N/A

2301N/A def __init__(self, path):

2301N/A ApiException.__init__(self)

2301N/A self.path = path

2301N/A

2301N/A def __str__(self):

2301N/A if self.path:

2301N/A return _("Could not complete the operation on {0}: "

2301N/A "read-only filesystem.").format(self.path)

2301N/A return _("Could not complete the operation: read-only "

2301N/A "filesystem.")

2301N/A

2301N/A

2301N/Aclass InvalidLockException(ApiException):

2301N/A def __init__(self, path):

2301N/A ApiException.__init__(self)

2301N/A self.path = path

565N/A

2339N/A def __str__(self):

2339N/A return _("Unable to obtain or operate on lock at {0}.\n"

2339N/A "Please try the operation again as a privileged "

2339N/A "user.").format(self.path)

2339N/A

2339N/A

2339N/Aclass PackageMatchErrors(ApiException):

2339N/A """Used to indicate which patterns were not matched or illegal during

2339N/A

2339N/A def __init__(self, unmatched_fmris=EmptyI, multiple_matches=EmptyI,

2339N/A illegal=EmptyI, multispec=EmptyI):

2339N/A ApiException.__init__(self)

2339N/A self.unmatched_fmris = unmatched_fmris

2339N/A self.multiple_matches = multiple_matches

2339N/A self.illegal = illegal

2339N/A self.multispec = multispec

2339N/A

2339N/A def __str__(self):

2339N/A res = []

2339N/A if self.unmatched_fmris:

2339N/A s = _("The following pattern(s) did not match any "

565N/A "packages:")

2339N/A

2339N/A res += [s]

2339N/A res += ["\t{0}".format(p) for p in self.unmatched_fmris]

2339N/A

2339N/A if self.multiple_matches:

2339N/A s = _("'{0}' matches multiple packages")

2339N/A for p, lst in self.multiple_matches:

1505N/A res.append(s.format(p))

1505N/A for pfmri in lst:

2339N/A res.append("\t{0}".format(pfmri))

2339N/A

2339N/A if self.illegal:

2339N/A s = _("'{0}' is an illegal FMRI")

2207N/A res += [ s.format(p) for p in self.illegal ]

2339N/A

2339N/A if self.multispec:

2339N/A s = _("The following different patterns specify the "

2339N/A "same package(s):")

1505N/A res += [s]

2212N/A for t in self.multispec:

2339N/A res += [

565N/A ", ".join([t[i] for i in range(1, len(t))])

616N/A + ": {0}".format(t[0])

1141N/A ]

616N/A

2339N/A return "\n".join(res)

2339N/A

2339N/A

926N/Aclass PlanExecutionError(InvalidPlanError):

1141N/A """Used to indicate that the requested operation could not be executed

2212N/A

2212N/A def __init__(self, paths):

2212N/A self.paths = paths

2212N/A

2212N/A def __str__(self):

2212N/A return _("The files listed below were modified after operation "

1505N/A "planning was complete or were missing during plan "

1505N/A "execution; this may indicate an administrative issue or "

1505N/A "system configuration issue:\n{0}".format(

1505N/A "\n".join(list(self.paths))))

1505N/A

1505N/A

1505N/Aclass PlanCreationException(ApiException):

565N/A def __init__(self,

988N/A already_installed=EmptyI,

565N/A badarch=EmptyI,

922N/A illegal=EmptyI,

922N/A installed=EmptyI,

633N/A invalid_mediations=EmptyI,

616N/A linked_pub_error=EmptyI,

1505N/A missing_dependency=EmptyI,

1505N/A missing_matches=EmptyI,

1505N/A multiple_matches=EmptyI,

616N/A multispec=EmptyI,

1505N/A no_solution=False,

1505N/A no_tmp_origins=False,

1505N/A no_version=EmptyI,

655N/A not_avoided=EmptyI,

838N/A nofiles=EmptyI,

838N/A obsolete=EmptyI,

838N/A pkg_updates_required=EmptyI,

1027N/A rejected_pats=EmptyI,

838N/A solver_errors=EmptyI,

838N/A no_repo_pubs=EmptyI,

838N/A unmatched_fmris=EmptyI,

1461N/A would_install=EmptyI,

1461N/A wrong_publishers=EmptyI,

1461N/A wrong_variants=EmptyI):

1352N/A

1352N/A ApiException.__init__(self)

1352N/A self.already_installed = already_installed

1352N/A self.badarch = badarch

1352N/A self.illegal = illegal

1352N/A self.installed = installed

1352N/A self.invalid_mediations = invalid_mediations

1505N/A self.linked_pub_error = linked_pub_error

2224N/A self.missing_dependency = missing_dependency

1505N/A self.missing_matches = missing_matches

1505N/A self.multiple_matches = multiple_matches

1505N/A self.multispec = multispec

1505N/A self.no_solution = no_solution

1505N/A self.no_tmp_origins = no_tmp_origins

1505N/A self.no_version = no_version

1505N/A self.not_avoided = not_avoided

1945N/A self.nofiles = nofiles

1505N/A self.obsolete = obsolete

1505N/A self.pkg_updates_required = pkg_updates_required

2197N/A self.rejected_pats = rejected_pats

2197N/A self.solver_errors = solver_errors

2207N/A self.unmatched_fmris = unmatched_fmris

2339N/A self.no_repo_pubs = no_repo_pubs

2339N/A self.would_install = would_install

2339N/A self.wrong_publishers = wrong_publishers

2339N/A self.wrong_variants = wrong_variants

2339N/A

2339N/A def __str__(self):

2339N/A res = []

2339N/A if self.unmatched_fmris:

2339N/A s = _("""\

1505N/A""")

2339N/A res += [s]

2339N/A res += ["\t{0}".format(p) for p in self.unmatched_fmris]

2339N/A

2339N/A if self.rejected_pats:

2339N/A s = _("""\

2339N/A""")

2339N/A res += [s]

1505N/A res += ["\t{0}".format(p) for p in self.rejected_pats]

1945N/A

1945N/A if self.wrong_variants:

1945N/A s = _("""\

2200N/Afor the current image's architecture, zone type, and/or other variant:""")

2200N/A res += [s]

2200N/A res += ["\t{0}".format(p) for p in self.wrong_variants]

1945N/A

2207N/A if self.wrong_publishers:

2207N/A s = _("The following patterns only matched packages "

2207N/A "that are from publishers other than that which "

2207N/A "supplied the already installed version of this package")

2207N/A res += [s]

2228N/A res += ["\t{0}: {1}".format(p[0], ", ".join(p[1])) for p in self.wrong_publishers]

2339N/A

2339N/A if self.multiple_matches:

2339N/A s = _("'{0}' matches multiple packages")

2228N/A for p, lst in self.multiple_matches:

2228N/A res.append(s.format(p))

2228N/A for pfmri in lst:

2339N/A res.append("\t{0}".format(pfmri))

2339N/A

2339N/A if self.missing_matches:

2228N/A s = _("'{0}' matches no installed packages")

2228N/A res += [ s.format(p) for p in self.missing_matches ]

2339N/A

2339N/A if self.illegal:

2339N/A s = _("'{0}' is an illegal fmri")

2339N/A res += [ s.format(p) for p in self.illegal ]

2339N/A

2339N/A if self.badarch:

2339N/A s = _("'{p}' supports the following architectures: "

2339N/A "{archs}")

2339N/A a = _("Image architecture is defined as: {0}")

2339N/A res += [ s.format(p=self.badarch[0],

2339N/A archs=", ".join(self.badarch[1]))]

2339N/A res += [ a.format(self.badarch[2])]

2339N/A

2339N/A s = _("'{p}' depends on obsolete package '{op}'")

2339N/A res += [ s.format(p=p, op=op) for p, op in self.obsolete ]

2339N/A

2339N/A if self.installed:

2339N/A s = _("The proposed operation can not be performed for "

2364N/A "the following package(s) as they are already "

2339N/A "installed: ")

2339N/A res += [s]

2339N/A res += ["\t{0}".format(p) for p in self.installed]

2339N/A

2339N/A if self.invalid_mediations:

2339N/A s = _("The following mediations are not syntactically "

2339N/A "valid:")

2339N/A for m, entries in six.iteritems(self.invalid_mediations):

2339N/A for value, error in entries.values():

2339N/A res.append(error)

1352N/A

565N/A if self.multispec:

2228N/A s = _("The following patterns specify different "

2205N/A "versions of the same package(s):")

2205N/A res += [s]

2205N/A for t in self.multispec:

2205N/A res += [

2205N/A ", ".join(

2205N/A [t[i] for i in range(1, len(t))])

2205N/A + ": {0}".format(t[0])

2205N/A ]

2205N/A if self.no_solution:

2205N/A res += [_("No solution was found to satisfy constraints")]

2205N/A if isinstance(self.no_solution, list):

2205N/A res.extend(self.no_solution)

2205N/A

2205N/A if self.pkg_updates_required:

2205N/A s = _("""\

2205N/A""")

2205N/A res += [s]

2205N/A for (oldfmri, newfmri) in self.pkg_updates_required:

2205N/A res += ["{oldfmri} -> {newfmri}\n".format(

2205N/A oldfmri=oldfmri, newfmri=newfmri)]

2205N/A

2205N/A if self.no_version:

2205N/A res += self.no_version

2205N/A

2205N/A if self.no_tmp_origins:

2205N/A s = _("""

2205N/Apersistently.""")

2205N/A res = [s]

2205N/A

2205N/A if self.missing_dependency:

2205N/A res += [_("Package {pkg} is missing a dependency: "

2205N/A "{dep}").format(

2205N/A pkg=self.missing_dependency[0],

2205N/A dep=self.missing_dependency[1])]

2205N/A if self.nofiles:

2205N/A res += [_("The following files are not packaged in this image:")]

2205N/A res += ["\t{0}".format(f) for f in self.nofiles]

2205N/A

2205N/A if self.solver_errors:

2205N/A res += ["\n"]

2205N/A res += [_("Solver dependency errors:")]

2205N/A res.extend(self.solver_errors)

2205N/A

2205N/A if self.already_installed:

2205N/A res += [_("The following packages are already "

2205N/A "installed in this image; use uninstall to "

2205N/A "avoid these:")]

2205N/A res += [ "\t{0}".format(s) for s in self.already_installed]

2205N/A

2205N/A if self.would_install:

2205N/A res += [_("The following packages are a target "

2205N/A "of group dependencies; use install to unavoid "

2205N/A "these:")]

2205N/A res += [ "\t{0}".format(s) for s in self.would_install]

2205N/A

2205N/A if self.not_avoided:

2205N/A res += [_("The following packages are not on the "

2205N/A "avoid list, so they\ncannot be removed from it.")]

2205N/A res += [ "\t{0}".format(s) for s in sorted(self.not_avoided)]

2205N/A

2205N/A def __format_li_pubs(pubs, res):

2205N/A i = 0

2205N/A for pub, sticky in pubs:

2205N/A s = " {0} {1:d}: {2}".format(_("PUBLISHER"),

2205N/A i, pub)

2205N/A mod = []

2205N/A if not sticky:

2205N/A mod.append(_("non-sticky"))

2205N/A if mod:

2205N/A s += " ({0})".format(",".join(mod))

2205N/A res.append(s)

2205N/A i += 1

2205N/A

2205N/A if self.linked_pub_error:

2205N/A res = []

2205N/A (pubs, parent_pubs) = self.linked_pub_error

2205N/A

2205N/A res.append(_("""

2205N/AThe parent image has the following enabled publishers:"""))

2205N/A __format_li_pubs(parent_pubs, res)

2205N/A res.append(_("""

2205N/AThe child image has the following enabled publishers:"""))

2205N/A __format_li_pubs(pubs, res)

2205N/A

2205N/A if self.no_repo_pubs:

2205N/A res += [_("The following publishers do not have any "

2205N/A "configured package repositories and cannot be "

2205N/A "used in package dehydration or rehydration "

2205N/A "operations:\n")]

2205N/A res += ["\t{0}".format(s) for s in sorted(

2205N/A self.no_repo_pubs)]

2400N/A

2400N/A return "\n".join(res)

2205N/A

2205N/A

2205N/Aclass ConflictingActionError(ApiException):

2205N/A """Used to indicate that the imageplan would result in one or more sets

2205N/A

2205N/A def __init__(self, data):

2205N/A self._data = data

2205N/A

2205N/Aclass ConflictingActionErrors(ApiException):

2205N/A """A container for multiple ConflictingActionError exception objects

2205N/A

2205N/A def __init__(self, errors):

2205N/A self.__errors = errors

2205N/A

2205N/A def __str__(self):

2205N/A return "\n\n".join((str(err) for err in self.__errors))

2205N/A

2205N/Aclass DuplicateActionError(ConflictingActionError):

2205N/A """Multiple actions of the same type have been delivered with the same

2239N/A

2205N/A def __str__(self):

2205N/A pfmris = set((a[1] for a in self._data))

2239N/A kv = self._data[0][0].attrs[self._data[0][0].key_attr]

2205N/A action = self._data[0][0].name

2205N/A if len(pfmris) > 1:

2205N/A s = _("The following packages all deliver {action} "

2205N/A "actions to {kv}:\n").format(**locals())

2205N/A for a, p in self._data:

2205N/A s += "\n {0}".format(p)

2205N/A s += _("\n\nThese packages cannot be installed "

2205N/A "together. Any non-conflicting subset\nof "

2205N/A "the above packages can be installed.")

2205N/A else:

2205N/A pfmri = pfmris.pop()

2205N/A s = _("The package {pfmri} delivers multiple copies "

2205N/A "of {action} {kv}").format(**locals())

2205N/A s += _("\nThis package must be corrected before it "

2205N/A "can be installed.")

2205N/A

2205N/A return s

2205N/A

2205N/Aclass InconsistentActionTypeError(ConflictingActionError):

2205N/A """Multiple actions of different types have been delivered with the same

2205N/A

2205N/A def __str__(self):

2205N/A ad = {}

2205N/A pfmris = set()

2205N/A kv = self._data[0][0].attrs[self._data[0][0].key_attr]

2205N/A for a, p in self._data:

2205N/A ad.setdefault(a.name, []).append(p)

2205N/A pfmris.add(p)

2205N/A

2205N/A if len(pfmris) > 1:

1068N/A s = _("The following packages deliver conflicting "

1050N/A "action types to {0}:\n").format(kv)

1859N/A for name, pl in six.iteritems(ad):

1859N/A s += "\n {0}:".format(name)

1050N/A s += "".join("\n {0}".format(p) for p in pl)

1050N/A s += _("\n\nThese packages cannot be installed "

1859N/A "together. Any non-conflicting subset\nof "

1859N/A "the above packages can be installed.")

1859N/A else:

1859N/A pfmri = pfmris.pop()

1859N/A types = list_to_lang(list(ad.keys()))

1859N/A s = _("The package {pfmri} delivers conflicting "

1859N/A "action types ({types}) to {kv}").format(**locals())

1859N/A s += _("\nThis package must be corrected before it "

1859N/A "can be installed.")

1859N/A return s

1859N/A

1859N/Aclass InconsistentActionAttributeError(ConflictingActionError):

1859N/A """Multiple actions of the same type representing the same object have

1859N/A

1859N/A def __str__(self):

1859N/A actions = self._data

1859N/A keyattr = actions[0][0].attrs[actions[0][0].key_attr]

1859N/A actname = actions[0][0].name

1859N/A

1859N/A # Trim the action's attributes to only those required to be

1050N/A # unique.

1859N/A def ou(action):

1050N/A ua = dict(

1859N/A (k, v)

1859N/A for k, v in six.iteritems(action.attrs)

1859N/A if ((k in action.unique_attrs and

1859N/A not (k == "preserve" and "overlay" in action.attrs)) or

1859N/A ((action.name == "link" or action.name == "hardlink") and

1859N/A k.startswith("mediator")))

1859N/A )

1859N/A action.attrs = ua

1050N/A return action

1050N/A

1050N/A d = {}

1859N/A for a in actions:

1859N/A if a[0].attrs.get("implicit", "false") == "false":

1859N/A d.setdefault(str(ou(a[0])), set()).add(a[1])

1859N/A l = sorted([

1050N/A (len(pkglist), action, pkglist)

1859N/A for action, pkglist in six.iteritems(d)

1050N/A ])

1050N/A

1050N/A s = _("The requested change to the system attempts to install "

1859N/A "multiple actions\nfor {a} '{k}' with conflicting "

1859N/A "attributes:\n\n").format(a=actname, k=keyattr)

1859N/A allpkgs = set()

1859N/A for num, action, pkglist in l:

1859N/A allpkgs.update(pkglist)

1050N/A if num <= 5:

1859N/A if num == 1:

1859N/A t = _(" {n:d} package delivers '{a}':\n")

1859N/A else:

1859N/A t = _(" {n:d} packages deliver '{a}':\n")

2073N/A s += t.format(n=num, a=action)

1859N/A for pkg in sorted(pkglist):

1859N/A s += _(" {0}\n").format(pkg)

1859N/A else:

1859N/A t = _(" {n:d} packages deliver '{a}', including:\n")

1050N/A s += t.format(n=num, a=action)

1050N/A for pkg in sorted(pkglist)[:5]:

1859N/A s += _(" {0}\n").format(pkg)

1050N/A

1068N/A if len(allpkgs) == 1:

565N/A s += _("\nThis package must be corrected before it "

1603N/A "can be installed.")

565N/A else:

565N/A s += _("\n\nThese packages cannot be installed "

565N/A "together. Any non-conflicting subset\nof "

565N/A "the above packages can be installed.")

1603N/A

565N/A return s

1068N/A

1352N/A

1352N/Aclass ImageBoundaryError(ApiException):

1352N/A """Used to indicate that a file is delivered to image dir"""

1352N/A

565N/A GENERIC = "generic" # generic image boundary violation

1352N/A OUTSIDE_BE = "outside_be" # deliver items outside boot environment

1352N/A RESERVED = "reserved" # deliver items to reserved dirs

1352N/A

1352N/A def __init__(self, fmri, actions=None):

1516N/A """fmri is the package fmri

1352N/A

1352N/A ApiException.__init__(self)

1352N/A self.fmri = fmri

1352N/A generic = _("The following items are outside the boundaries "

1352N/A "of the target image:\n\n")

1352N/A outside_be = _("The following items are delivered outside "

1352N/A "the target boot environment:\n\n")

1352N/A reserved = _("The following items are delivered to "

1352N/A "reserved directories:\n\n")

1352N/A

1352N/A self.message = {

1352N/A self.GENERIC: generic,

1352N/A self.OUTSIDE_BE: outside_be,

1352N/A self.RESERVED: reserved

1352N/A }

1352N/A

1352N/A if actions:

1352N/A self.actions = actions

1352N/A else:

1516N/A self.actions = {}

1352N/A

1352N/A def append_error(self, action, err_type=GENERIC):

1352N/A """This function is used to append errors in the error

1352N/A

1352N/A if action:

1352N/A self.actions.setdefault(err_type, []).append(action)

1352N/A

1352N/A def isEmpty(self):

1352N/A """Return whether error dictionary is empty"""

1352N/A

1352N/A return len(self.actions) == 0

1352N/A

1352N/A def __str__(self):

1352N/A error_list = [self.GENERIC, self.OUTSIDE_BE, self.RESERVED]

1352N/A s = _("The package {0} delivers items outside the boundaries of"

1516N/A " the target image and can not be "

1352N/A "installed.\n\n").format(self.fmri)

1352N/A for err_type in error_list:

1352N/A if not err_type in self.actions:

1352N/A continue

1352N/A if self.actions[err_type]:

1352N/A s += self.message[err_type]

1352N/A for action in self.actions[err_type]:

1352N/A s += (" {0} {1}\n").format(

1352N/A action.name, action.attrs["path"])

1352N/A return s

1352N/A

1352N/A

1352N/Aclass ImageBoundaryErrors(ApiException):

1352N/A """A container for multiple ImageBoundaryError exception objects

1352N/A

1352N/A def __init__(self, errors):

1352N/A ApiException.__init__(self)

1352N/A self.__errors = errors

1352N/A

1352N/A generic = _("The following packages deliver items outside "

1352N/A "the boundaries of the target image and can not be "

1352N/A "installed:\n\n")

1352N/A outside_be = _("The following packages deliver items outside "

1352N/A "the target boot environment and can not be "

1352N/A "installed:\n\n")

1352N/A reserved = _("The following packages deliver items to reserved "

1352N/A "directories and can not be installed:\n\n")

1352N/A

1352N/A self.message = {

1352N/A ImageBoundaryError.GENERIC: generic,

1352N/A ImageBoundaryError.OUTSIDE_BE: outside_be,

1352N/A ImageBoundaryError.RESERVED: reserved

1516N/A }

1516N/A

1352N/A def __str__(self):

1352N/A if len(self.__errors) <= 1:

1352N/A return "\n".join([str(err) for err in self.__errors])

1352N/A

1352N/A s = ""

1352N/A for err_type in self.message:

1352N/A cur_errs = []

1352N/A for err in self.__errors:

1352N/A # If err does not contain this error type

1352N/A # we just ignore this.

1352N/A if not err_type in err.actions or \

1352N/A not err.actions[err_type]:

1352N/A continue

1352N/A cur_errs.append(err)

1352N/A

1352N/A if not cur_errs:

1352N/A continue

1352N/A

1352N/A if len(cur_errs) == 1:

2022N/A fmri = cur_errs[0].fmri

2022N/A s += _("The package {0} delivers items outside "

2022N/A "the boundaries of the target image and can "

2022N/A "not be installed.\n\n").format(fmri)

2022N/A s += cur_errs[0].message[err_type]

2022N/A for action in cur_errs[0].actions[err_type]:

2022N/A s += (" {0} {1}\n").format(

2022N/A action.name, action.attrs["path"])

2022N/A s += "\n"

2022N/A continue

2022N/A

2022N/A s += self.message[err_type]

2022N/A for err in cur_errs:

2022N/A s += (" {0}\n").format(err.fmri)

1352N/A for action in err.actions[err_type]:

1352N/A s += (" {0} {1}\n").format(

1352N/A action.name, action.attrs["path"])

1352N/A s += "\n"

1352N/A return s

1352N/A

1352N/A

1352N/Adef list_to_lang(l):

1352N/A """Takes a list of items and puts them into a string, with commas in

1352N/A

1352N/A if not l:

1352N/A return ""

1352N/A if len(l) == 1:

1352N/A return l[0]

1352N/A if len(l) == 2:

1352N/A # Used for a two-element list

1352N/A return _("{penultimate} and {ultimate}").format(

1352N/A penultimate=l[0],

1352N/A ultimate=l[1]

1352N/A )

1352N/A # In order to properly i18n this construct, we create two templates:

1352N/A # one for each element save the last, and one that tacks on the last

1352N/A # element.

1352N/A # 'elementtemplate' is for each element through the penultimate

1352N/A elementtemplate = _("{0}, ")

1431N/A # 'listtemplate' concatenates the concatenation of non-ultimate elements

1431N/A # and the ultimate element.

1431N/A listtemplate = _("{list}and {tail}")

1431N/A return listtemplate.format(

1431N/A list="".join(elementtemplate.format(i) for i in l[:-1]),

1431N/A tail=l[-1]

1431N/A )

1431N/A

1431N/Aclass ActionExecutionError(ApiException):

1352N/A """Used to indicate that action execution (such as install, remove,

1352N/A

1352N/A def __init__(self, action, details=None, error=None, fmri=None,

838N/A use_errno=None):

1352N/A """'action' is the object for the action that failed during the

1352N/A

614N/A assert (details or error)

614N/A self.action = action

926N/A self.details = details

614N/A self.error = error

1352N/A self.fmri = fmri

1352N/A if use_errno == None:

1352N/A # If details were provided, don't use errno unless

1352N/A # explicitly requested.

1352N/A use_errno = not details

1352N/A self.use_errno = use_errno

1352N/A

596N/A def __str__(self):

565N/A errno = ""

1027N/A if self.use_errno and self.error and \

1191N/A hasattr(self.error, "errno"):

1191N/A errno = "[errno {0:d}: {1}]".format(self.error.errno,

1027N/A os.strerror(self.error.errno))

1027N/A

1027N/A details = self.details or ""

1027N/A

1027N/A # Fall back on the wrapped exception if we don't have anything

1191N/A # useful.

1191N/A if not errno and not details:

1191N/A return str(self.error)

1191N/A

1191N/A if errno and details:

1191N/A details = "{0}: {1}".format(errno, details)

1191N/A

1191N/A if details and not self.fmri:

1191N/A details = _("Requested operation failed for action "

1191N/A "{action}:\n{details}").format(

1191N/A action=self.action,

1191N/A details=details)

1191N/A elif details:

1191N/A details = _("Requested operation failed for package "

1191N/A "{fmri}:\n{details}").format(fmri=self.fmri,

1191N/A details=details)

1191N/A

1191N/A # If we only have one of the two, no need for the colon.

1191N/A return "{0}{1}".format(errno, details)

1191N/A

1191N/A

1191N/Aclass CatalogOriginRefreshException(ApiException):

1191N/A def __init__(self, failed, total, errmessage=None):

1191N/A ApiException.__init__(self)

1191N/A self.failed = failed

1191N/A self.total = total

1191N/A self.errmessage = errmessage

1191N/A

1191N/A

1191N/Aclass CatalogRefreshException(ApiException):

1191N/A def __init__(self, failed, total, succeeded, errmessage=None):

1191N/A ApiException.__init__(self)

1191N/A self.failed = failed

1191N/A self.total = total

1895N/A self.succeeded = succeeded

1191N/A self.errmessage = errmessage

1191N/A

1191N/A

1191N/Aclass CatalogError(ApiException):

1191N/A """Base exception class for all catalog exceptions."""

1191N/A

1191N/A def __init__(self, *args, **kwargs):

1895N/A ApiException.__init__(self)

1895N/A if args:

1191N/A self.data = args[0]

1191N/A else:

1191N/A self.data = None

1191N/A self._args = kwargs

1191N/A

1191N/A def __str__(self):

1191N/A return str(self.data)

1191N/A

1191N/A

1191N/Aclass AnarchicalCatalogFMRI(CatalogError):

1191N/A """Used to indicate that the specified FMRI is not valid for catalog

1191N/A

1191N/A def __str__(self):

1191N/A return _("The FMRI '{0}' does not contain publisher information "

1191N/A "and cannot be used for catalog operations.").format(

1191N/A self.data)

1191N/A

1191N/A

1191N/Aclass BadCatalogMetaRoot(CatalogError):

1191N/A """Used to indicate an operation on the catalog's meta_root failed

1191N/A

1191N/A def __str__(self):

1191N/A return _("Catalog meta_root '{root}' is invalid; unable "

1191N/A "to complete operation: '{op}'.").format(root=self.data,

1895N/A op=self._args.get("operation", None))

1895N/A

1191N/A

1895N/Aclass BadCatalogPermissions(CatalogError):

1191N/A """Used to indicate the server catalog files do not have the expected

1191N/A

1191N/A def __init__(self, files):

1191N/A """files should contain a list object with each entry consisting

1945N/A if not files:

1191N/A files = []

1191N/A CatalogError.__init__(self, files)

1191N/A

1191N/A def __str__(self):

1191N/A msg = _("The following catalog files have incorrect "

1191N/A "permissions:\n")

1191N/A for f in self.data:

1191N/A fname, emode, fmode = f

1027N/A msg += _("\t{fname}: expected mode: {emode}, found "

565N/A "mode: {fmode}\n").format(fname=fname,

1027N/A emode=emode, fmode=fmode)

565N/A return msg

1027N/A

565N/A

565N/Aclass BadCatalogSignatures(CatalogError):

1027N/A """Used to indicate that the Catalog signatures are not valid."""

565N/A

565N/A def __str__(self):

565N/A return _("The signature data for the '{0}' catalog file is not "

565N/A "valid.").format(self.data)

1027N/A

1191N/A

1191N/Aclass BadCatalogUpdateIdentity(CatalogError):

1191N/A """Used to indicate that the requested catalog updates could not be

1191N/A

1191N/A def __str__(self):

1191N/A return _("Unable to determine the updates needed for "

1191N/A "the current catalog using the provided catalog "

1191N/A "update data in '{0}'.").format(self.data)

1191N/A

2028N/A

2028N/Aclass DuplicateCatalogEntry(CatalogError):

2028N/A """Used to indicate that the specified catalog operation could not be

2028N/A

2028N/A def __str__(self):

2028N/A return _("Unable to perform '{op}' operation for catalog "

2028N/A "{name}; completion would result in a duplicate entry "

2028N/A "for package '{fmri}'.").format(op=self._args.get(

2028N/A "operation", None), name=self._args.get("catalog_name",

2028N/A None), fmri=self.data)

2028N/A

565N/A

565N/Aclass CatalogUpdateRequirements(CatalogError):

565N/A """Used to indicate that an update request for the catalog could not

565N/A

565N/A def __str__(self):

565N/A return _("Catalog updates can only be applied to an on-disk "

565N/A "catalog.")

941N/A

1286N/A

1286N/Aclass InvalidCatalogFile(CatalogError):

2089N/A """Used to indicate a Catalog file could not be loaded."""

2089N/A

1286N/A def __str__(self):

1286N/A return _("Catalog file '{0}' is invalid.\nUse 'pkgrepo rebuild' "

1286N/A "to create a new package catalog.").format(self.data)

1286N/A

1286N/A

1286N/Aclass MismatchedCatalog(CatalogError):

1286N/A """Used to indicate that a Catalog's attributes and parts do not

1286N/A

1286N/A def __str__(self):

1286N/A return _("The content of the catalog for publisher '{0}' "

1286N/A "doesn't match the catalog's attributes. This is "

1286N/A "likely the result of a mix of older and newer "

2089N/A "catalog files being provided for the publisher.").format(

2089N/A self.data)

1286N/A

1286N/A

1286N/Aclass ObsoleteCatalogUpdate(CatalogError):

1191N/A """Used to indicate that the specified catalog updates are for an older

1191N/A

1191N/A def __str__(self):

1191N/A return _("Unable to determine the updates needed for the "

941N/A "catalog using the provided catalog update data in '{0}'. "

941N/A "The specified catalog updates are for an older version "

1191N/A "of the catalog and cannot be used.").format(self.data)

1191N/A

1191N/A

1191N/Aclass UnknownCatalogEntry(CatalogError):

1191N/A """Used to indicate that an entry for the specified package FMRI or

1191N/A

1191N/A def __str__(self):

1191N/A return _("'{0}' could not be found in the catalog.").format(

1191N/A self.data)

941N/A

941N/A

941N/Aclass UnknownUpdateType(CatalogError):

1027N/A """Used to indicate that the specified CatalogUpdate operation is

565N/A

565N/A def __str__(self):

565N/A return _("Unknown catalog update type '{0}'").format(self.data)

1027N/A

565N/A

565N/Aclass UnrecognizedCatalogPart(CatalogError):

565N/A """Raised when the catalog finds a CatalogPart that is unrecognized

565N/A

565N/A def __str__(self):

565N/A return _("Unrecognized, unknown, or invalid CatalogPart '{0}'").format(

565N/A self.data)

565N/A

565N/A

565N/Aclass InventoryException(ApiException):

835N/A """Used to indicate that some of the specified patterns to a catalog

2205N/A

2205N/A def __init__(self, illegal=EmptyI, matcher=EmptyI, notfound=EmptyI,

2205N/A publisher=EmptyI, version=EmptyI):

2205N/A ApiException.__init__(self)

2205N/A self.illegal = illegal

2205N/A self.matcher = matcher

2205N/A self.notfound = set(notfound)

2205N/A self.publisher = publisher

2205N/A self.version = version

2205N/A

835N/A self.notfound.update(matcher)

835N/A self.notfound.update(publisher)

835N/A self.notfound.update(version)

835N/A self.notfound = sorted(list(self.notfound))

926N/A

835N/A assert self.illegal or self.notfound

835N/A

835N/A def __str__(self):

835N/A outstr = ""

2205N/A for x in self.illegal:

835N/A # Illegal FMRIs have their own __str__ method

2205N/A outstr += "{0}\n".format(x)

835N/A

2205N/A if self.matcher or self.publisher or self.version:

835N/A outstr += _("No matching package could be found for "

2205N/A "the following FMRIs in any of the catalogs for "

2205N/A "the current publishers:\n")

2205N/A

835N/A for x in self.matcher:

884N/A outstr += \

926N/A _("{0} (pattern did not match)\n").format(x)

926N/A for x in self.publisher: