#!/usr/bin/python

#

# CDDL HEADER START

#

# The contents of this file are subject to the terms of the

# Common Development and Distribution License (the "License").

# You may not use this file except in compliance with the License.

#

# You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE

# or http://www.opensolaris.org/os/licensing.

# See the License for the specific language governing permissions

# and limitations under the License.

#

# When distributing Covered Code, include this CDDL HEADER in each

# file and include the License file at usr/src/OPENSOLARIS.LICENSE.

# If applicable, add the following below this CDDL HEADER, with the

# fields enclosed by brackets "[]" replaced with your own identifying

# information: Portions Copyright [yyyy] [name of copyright owner]

#

# CDDL HEADER END

#

#

#

import copy

import errno

import gettext

import locale

import os

import shutil

import sys

import traceback

import xml.dom.minidom as xmini

import pkg

import pkg.client.api_errors as apx

import pkg.client.bootenv as bootenv

import pkg.fmri as fmri

import pkg.misc as misc

import pkg.portable as portable

# Constants for the (outcome, reason) combination for operation result

# and reason.  The first field, 'outcome' should be a single word to allow easy

# extraction from 'pkg history' but 'reason' may be a phrase.

# Indicates that the user canceled the operation.

RESULT_CANCELED = ["Canceled", "None"]

# Indicates that the operation had no work to perform or didn't need to make

# any changes to the image.

RESULT_NOTHING_TO_DO = ["Ignored", "Nothing to do"]

# Indicates that the operation succeeded.

RESULT_SUCCEEDED = ["Succeeded", "None"]

# Indicates that the user or client provided bad information which resulted in

# operation failure.

RESULT_FAILED_BAD_REQUEST = ["Failed", "Bad Request"]

# Indicates that the operation failed due to a configuration error (such as an

# invalid SSL Certificate, etc.).

RESULT_FAILED_CONFIGURATION = ["Failed", "Configuration"]

# Indicates that the operation failed due to package constraints or because of

# a restriction enforced by the client (e.g. pkg(5) out of date).

RESULT_FAILED_CONSTRAINED = ["Failed", "Constrained"]

# Indicates an operation failed because the image was already in use.

RESULT_FAILED_LOCKED = ["Failed", "Locked"]

# Indicates that a search operation failed.

RESULT_FAILED_SEARCH = ["Failed", "Search"]

# Indicates that there was a problem reading, writing, or accessing a file.

RESULT_FAILED_STORAGE = ["Failed", "Storage"]

# Indicates that a transport error caused the operation to fail.

RESULT_FAILED_TRANSPORT = ["Failed", "Transport"]

# Indicates that the operation failed due to an actuator problem

RESULT_FAILED_ACTUATOR = ["Failed", "Actuator"]

# Indicates that the operation failed due to not enough memory

RESULT_FAILED_OUTOFMEMORY = ["Failed", "Out of Memory"]

# Indicates that the operation failed because of conflicting actions

RESULT_CONFLICTING_ACTIONS = ["Failed", "Conflicting Actions"]

# Indicates that the operation failed for an unknown reason.

RESULT_FAILED_UNKNOWN = ["Failed", "Unknown"]

# Operations that are discarded, not saved, when recorded by history.

DISCARDED_OPERATIONS = ["contents", "info", "list"]

# Cross-reference table for errors and results.  Entries should be ordered

# most-specific to least-specific.

error_results = {

    apx.ImageLockedError: RESULT_FAILED_LOCKED,

    apx.InvalidCatalogFile: RESULT_FAILED_STORAGE,

    apx.BENamingNotSupported: RESULT_FAILED_BAD_REQUEST,

    apx.InvalidBENameException: RESULT_FAILED_BAD_REQUEST,

    apx.CertificateError: RESULT_FAILED_CONFIGURATION,

    apx.PublisherError: RESULT_FAILED_BAD_REQUEST,

    apx.CanceledException: RESULT_CANCELED,

    apx.ImageUpdateOnLiveImageException: RESULT_FAILED_BAD_REQUEST,

    apx.ProblematicPermissionsIndexException: RESULT_FAILED_STORAGE,

    apx.PermissionsException: RESULT_FAILED_STORAGE,

    apx.SearchException: RESULT_FAILED_SEARCH,

    apx.PlanCreationException: RESULT_FAILED_CONSTRAINED,

    apx.NonLeafPackageException: RESULT_FAILED_CONSTRAINED,

    apx.IpkgOutOfDateException: RESULT_FAILED_CONSTRAINED,

    apx.InvalidDepotResponseException: RESULT_FAILED_TRANSPORT,

    apx.ConflictingActionErrors: RESULT_CONFLICTING_ACTIONS,

    fmri.IllegalFmri: RESULT_FAILED_BAD_REQUEST,

    KeyboardInterrupt: RESULT_CANCELED,

    MemoryError: RESULT_FAILED_OUTOFMEMORY,

}

misc.setlocale(locale.LC_ALL, "")

gettext.install("pkg", "/usr/share/locale")

# since we store english text in our XML files, we need a way for clients

# obtain a translated version of these messages.

result_l10n = {

    "Canceled": _("Canceled"),

    "Failed": _("Failed"),

    "Ignored": _("Ignored"),

    "Nothing to do": _("Nothing to do"),

    "Succeeded": _("Succeeded"),

    "Bad Request": _("Bad Request"),

    "Configuration": _("Configuration"),

    "Constrained": _("Constrained"),

    "Locked": _("Locked"),

    "Search": _("Search"),

    "Storage": _("Storage"),

    "Transport": _("Transport"),

    "Actuator": _("Actuator"),

    "Out of Memory": _("Out of Memory"),

    "Conflicting Actions": _("Conflicting Actions"),

    "Unknown": _("Unknown"),

    "None": _("None")

}

class _HistoryOperation(object):

        """A _HistoryOperation object is a representation of data about an

        operation that a pkg(5) client has performed.  This class is private

        and not intended for use by classes other than History.

        This class provides an abstraction layer between the stack of

        operations that History manages should these values need to be

        manipulated as they are set or retrieved.

        """

        def __copy__(self):

                h = _HistoryOperation()

                for attr in ("name", "start_time", "end_time", "start_state",

                    "end_state", "username", "userid", "be", "be_exists",

                    "be_uuid", "current_be", "current_new_be", "new_be",

                    "new_be_exists", "new_be_uuid", "result", "snapshot"):

                        setattr(h, attr, getattr(self, attr))

                h.errors = [copy.copy(e) for e in self.errors]

                return h

        def __setattr__(self, name, value):

                if name not in ("result", "errors", "be", "be_uuid",

                    "current_be", "current_new_be", "new_be", "new_be_exists",

                    "new_be_uuid", "snapshot"):

                        # Force all other attribute values to be a string

                        # to avoid issues with minidom.

                        value = str(value)

                return object.__setattr__(self, name, value)

        def __str__(self):

                return """\

Operation Name: %s

Operation Result: %s

Operation Start Time: %s

Operation End Time: %s

Operation Start State:

%s

Operation End State:

%s

Operation User: %s (%s)

Operation Boot Env.: %s

Operation Boot Env. Currrent: %s

Operation Boot Env. UUID: %s

Operation New Boot Env.: %s

Operation New Boot Env. Current: %s

Operation New Boot Env. UUID: %s

Operation Snapshot: %s

Operation Errors:

%s

""" % (self.name, self.result, self.start_time, self.end_time,

    self.start_state, self.end_state, self.username, self.userid,

    self.be, self.current_be, self.be_uuid, self.new_be, self.current_new_be,

    self.new_be_uuid, self.snapshot, self.errors)

        # All "time" values should be in UTC, using ISO 8601 as the format.

        # Name of the operation performed (e.g. install, update, etc.).

        name = None

        # When the operation started.

        start_time = None

        # When the operation ended.

        end_time = None

        # The starting state of the operation (e.g. image plan pre-evaluation).

        start_state = None

        # The ending state of the operation (e.g. image plan post-evaluation).

        end_state = None

        # Errors encountered during an operation.

        errors = None

        # username of the user that performed the operation.

        username = None

        # id of the user that performed the operation.

        userid = None

        # The boot environment on which the user performed the operation

        be = None

        # The current name of the boot environment.

        current_be = None

        # The uuid of the BE on which the user performed the operation

        be_uuid = None

        # The new boot environment that was created as a result of the operation

        new_be = None

        # The current name of the new boot environment.

        current_new_be = None

        # The uuid of the boot environment that was created as a result of the

        # operation

        new_be_uuid = None

        # The snapshot that was created while running this operation

        # set to None if no snapshot was taken, or destroyed after successful

        # completion

        snapshot = None

        # The result of the operation (must be a list indicating (outcome,

        # reason)).

        result = None

        def __init__(self):

                self.errors = []

        @property

        def result_text(self):

                """Returns a tuple containing the translated text for the

                operation result of the form (outcome, reason)."""

                if not self.start_time or not self.result:

                        return ("", "")

                return (result_l10n[self.result[0]],

                    result_l10n[self.result[1]])

class History(object):

        """A History object is a representation of data about a pkg(5) client

        and about operations that the client is executing or has executed.  It

        uses the _HistoryOperation class to represent the data about an

        operation.

        """

        # The directory where the history directory can be found (or

        # created if it doesn't exist).

        root_dir = None

        # The name of the client (e.g. pkg, packagemanager, etc.)

        client_name = None

        # The version of the client (e.g. 093ca22da67c).

        client_version = None

        # How the client was invoked (e.g. 'pkg install -n foo').

        client_args = None

        # A stack where operation data will actually be stored.

        __operations = []

        # A private property used by preserve() and restore() to store snapshots

        # of history and operation state information.

        __snapshot = None

        # These attributes exist to fake access to the operations stack.

        operation_name = None

        operation_username = None

        operation_userid = None

        operation_current_be = None

        operation_be = None

        operation_be_uuid = None

        operation_current_new_be = None

        operation_new_be = None

        operation_new_be_uuid = None

        operation_start_time = None

        operation_end_time = None

        operation_start_state = None

        operation_end_state = None

        operation_snapshot = None

        operation_errors = None

        operation_result = None

        def __copy__(self):

                h = History()

                for attr in ("root_dir", "client_name", "client_version"):

                        setattr(h, attr, getattr(self, attr))

                object.__setattr__(self, "client_args",

                    [copy.copy(a) for a in self.client_args])

                # A deepcopy has to be performed here since this a list of dicts

                # and not just History operation objects.

                h.__operations = [copy.deepcopy(o) for o in self.__operations]

                return h

        def __getattribute__(self, name):

                if name == "client_args":

                        return object.__getattribute__(self, name)[:]

                if not name.startswith("operation_"):

                        return object.__getattribute__(self, name)

                ops = object.__getattribute__(self, "_History__operations")

                if not ops:

                        return None

                return getattr(ops[-1]["operation"], name[len("operation_"):])

        def __setattr__(self, name, value):

                if name == "client_args":

                        raise AttributeError("'history' object attribute '%s' "

                            "is read-only." % name)

                if not name.startswith("operation_"):

                        return object.__setattr__(self, name, value)

                ops = object.__getattribute__(self, "_History__operations")

                if name == "operation_name":

                        if not ops:

                                ops = []

                                object.__setattr__(self,

                                    "_History__operations", ops)

                        ops.append({

                            "pathname": None,

                            "operation": _HistoryOperation()

                        })

                elif not ops:

                        raise AttributeError("'history' object attribute '%s' "

                            "cannot be set before 'operation_name'." % name)

                op = ops[-1]["operation"]

                setattr(op, name[len("operation_"):], value)

                # Access to the class attributes is done through object instead

                # of just referencing self to avoid any of the special logic in

                # place interfering with logic here.

                if name == "operation_name":

                        # Before a new operation starts, clear exception state

                        # for the current one so that when this one ends, the

                        # last operation's exception won't be recorded to this

                        # one.  If the error hasn't been recorded by now, it

                        # doesn't matter anyway, so should be safe to clear.

                        sys.exc_clear()

                        # Mark the operation as having started and record

                        # other, relevant information.

                        op.start_time = misc.time_to_timestamp(None)

                        try:

                                op.username = portable.get_username()

                        except KeyError:

                                op.username = "unknown"

                        op.userid = portable.get_userid()

                        ca = None

                        if sys.argv[0]:

                                ca = [sys.argv[0]]

                        else:

                                # Fallback for clients that provide no value.

                                ca = [self.client_name]

                        ca.extend(sys.argv[1:])

                        object.__setattr__(self, "client_args", ca)

                        object.__setattr__(self, "client_version", pkg.VERSION)

                elif name == "operation_result":

                        # Record when the operation ended.

                        op.end_time = misc.time_to_timestamp(None)

                        # Some operations shouldn't be saved -- they're merely

                        # included in the stack for completeness or to support

                        # client functionality.

                        if op.name not in DISCARDED_OPERATIONS and \

                            value != RESULT_NOTHING_TO_DO:

                                # Write current history and last operation to a

                                # file.

                                self.__save()

                        # Discard it now that it is no longer needed.

                        del ops[-1]

                """'root_dir' should be the path of the directory where the

                history directory can be found (or created if it doesn't

                exist).  'filename' should be the name of an XML file

                containing serialized history information to load.

                """

                # Since this is a read-only attribute normally, we have to

                # bypass our setattr override by calling object.

                object.__setattr__(self, "client_args", [])

                # Initialize client_name to what the client thinks it is.  This

                # will be overridden if we load history entries off disk.

                self.client_name = pkg.client.global_settings.client_name

                self.root_dir = root_dir

                if filename:

        def __str__(self):

                ops = self.__operations

                return "\n".join([str(op["operation"]) for op in ops])

        @property

        def path(self):

                """The directory where history files will be written to or

                read from.

                """

                return os.path.join(self.root_dir, "history")

        @property

        def pathname(self):

                """Returns the pathname that the history information was read

                from or will attempted to be written to.  Returns None if no

                operation has started yet or if no operation has been loaded.

                """

                if not self.operation_start_time:

                        return None

                ops = self.__operations

                pathname = ops[-1]["pathname"]

                if not pathname:

                        return os.path.join(self.path,

                            "%s-01.xml" % ops[-1]["operation"].start_time)

                return pathname

        def clear(self):

                """Discards all information related to the current history

                object.

                """

                self.client_name = None

                self.client_version = None

                object.__setattr__(self, "client_args", [])

                self.__operations = []

        def __load_client_data(self, node):

                """Internal function to load the client data from the given XML

                'node' object.

                """

                self.client_name = node.getAttribute("name")

                self.client_version = node.getAttribute("version")

                try:

                        args = node.getElementsByTagName("args")[0]

                except IndexError:

                        # There might not be any.

                        pass

                else:

                        ca = object.__getattribute__(self, "client_args")

                        for cnode in args.getElementsByTagName("arg"):

                                try:

                                        ca.append(cnode.childNodes[0].wholeText)

                                except (AttributeError, IndexError):

                                        # There may be no childNodes, or

                                        # wholeText may not be defined.

                                        pass

        @staticmethod

        def __load_operation_data(node, uuid_be_dic):

                """Internal function to load the operation data from the given

                XML 'node' object and return a _HistoryOperation object.

                """

                op = _HistoryOperation()

                op.name = node.getAttribute("name")

                op.start_time = node.getAttribute("start_time")

                op.end_time = node.getAttribute("end_time")

                op.username = node.getAttribute("username")

                op.userid = node.getAttribute("userid")

                op.result = node.getAttribute("result").split(", ")

                if len(op.result) == 1:

                        op.result.append("None")

                # older clients simply wrote "Nothing to do" instead of

                # "Ignored, Nothing to do", so work around that

                if op.result[0] == "Nothing to do":

                        op.result = RESULT_NOTHING_TO_DO

                if node.hasAttribute("be_uuid"):

                        op.be_uuid = node.getAttribute("be_uuid")

                if node.hasAttribute("new_be_uuid"):

                        op.new_be_uuid = node.getAttribute("new_be_uuid")

                if node.hasAttribute("be"):

                        op.be = node.getAttribute("be")

                        if op.be_uuid:

                                op.current_be = uuid_be_dic.get(op.be_uuid,

                                    op.be)

                if node.hasAttribute("new_be"):

                        op.new_be = node.getAttribute("new_be")

                        if op.new_be_uuid:

                                op.current_new_be = uuid_be_dic.get(

                                    op.new_be_uuid, op.new_be)

                def get_node_values(parent_name, child_name=None):

                        try:

                                parent = node.getElementsByTagName(parent_name)[0]

                                if child_name:

                                        cnodes = parent.getElementsByTagName(

                                            child_name)

                                        return [

                                            cnode.childNodes[0].wholeText

                                            for cnode in cnodes

                                        ]