HEX

File: //snap/core22/2111/lib/python3/dist-packages/cloudinit/reporting/__pycache__/events.cpython-310.pyc
o

x[h$�@s�dZddlZddlZddlZddlZddlmZddlm	Z	ddl
mZmZddl
mZdZdZd	Ze�e�ZGd
d�de�Zed�ZGd
d�d�ZGdd�de�Zddd�Zejdfdd�Zdd�ZGdd�d�Zdd�ZdS)z�
events for reporting.

The events here are designed to be used with reporting.
They can be published to registered handlers with report_event.
�N)�List)�performance)�available_handlers�instantiated_handler_registry)�ReportingHandler�finish�start�	cloudinitc@seZdZdd�ZdS)�_namesetcCs||vr|Std|��)Nz%s not a valid value)�AttributeError)�self�name�r�</usr/lib/python3/dist-packages/cloudinit/reporting/events.py�__getattr__ sz_nameset.__getattr__N)�__name__�
__module__�__qualname__rrrrrr
sr
)�SUCCESS�WARN�FAILc@s.eZdZdZedfdd�Zdd�Zdd�ZdS)	�ReportingEventz"Encapsulation of event formatting.NcCs2||_||_||_||_|durt��}||_dS�N)�
event_typer
�description�origin�time�	timestamp)rrr
rrrrrr�__init__,s
zReportingEvent.__init__cCsd�|j|j|j�S)z"The event represented as a string.z
{0}: {1}: {2})�formatrr
r�rrrr�	as_string<s�zReportingEvent.as_stringcCs|j|j|j|j|jd�S)z&The event represented as a dictionary.�r
rrrrr"r rrr�as_dictBs�zReportingEvent.as_dict)rrr�__doc__�DEFAULT_EVENT_ORIGINrr!r#rrrrr)s
�rcs8eZdZejdf�fdd�	Zdd�Z�fdd�Z�ZS)�FinishReportingEventNcsDtt|��t||�||_|durg}||_|tvr td|��dS)NzInvalid result: %s)�superr&r�FINISH_EVENT_TYPE�result�
post_files�status�
ValueError)rr
rr)r*��	__class__rrrNs
��zFinishReportingEvent.__init__cCsd�|j|j|j|j�S)Nz{0}: {1}: {2}: {3})rrr
r)rr rrrr![s�zFinishReportingEvent.as_stringcs0tt|���}|j|d<|jrt|j�|d<|S)z'The event represented as json friendly.r)�files)r'r&r#r)r*�_collect_file_info)r�datar-rrr#`s

zFinishReportingEvent.as_dict)	rrrr+rrr!r#�
__classcell__rrr-rr&Ms
�
r&csT�si��fdd�tj��D�}ttj���}|D]}t|�|vr"q|�|�qdS)a�Report an event to all registered event handlers
    except those whose type is in excluded_handler_types.

    This should generally be called via one of the other functions in
    the reporting module.

    :param excluded_handler_types:
         List of handlers types to exclude from reporting the event to.
    :param event_type:
        The type of the event; this should be a constant from the
        reporting module.
    csh|]
\}}|�vr|�qSrr)�.0�	hndl_type�hndl_cls��excluded_handler_typesrr�	<setcomp>ys
�zreport_event.<locals>.<setcomp>N)r�registered_items�items�listr�values�type�
publish_event)�eventr7�excluded_handler_classes�handlers�handlerrr6r�report_eventis
���rCcCst||||d�}t|�S)zVReport a "finish" event.

    See :py:func:`.report_event` for parameter details.
    �r*)r&rC)�
event_name�event_descriptionr)r*r?rrr�report_finish_event�s�rGcCstt||�}t|�S)a'Report a "start" event.

    :param event_name:
        The name of the event; this should be a topic which events would
        share (e.g. it will be the same for start and finish events).

    :param event_description:
        A human-readable description of the event that has occurred.
    )r�START_EVENT_TYPErC)rErFr?rrr�report_start_event�s
rIc@s�eZdZdZdddejdfdd�Zdd�Zdd�Zd	d
�Z	e
dd��Zejd
d��Ze
dd��Z
e
jdd��Z
dd�Zdd�ZdS)�ReportEventStackaKContext Manager for using :py:func:`report_event`

    This enables calling :py:func:`report_start_event` and
    :py:func:`report_finish_event` through a context manager.

    :param name:
        the name of the event

    :param description:
        the event's description, passed on to :py:func:`report_start_event`

    :param message:
        the description to use for the finish event. defaults to
        :param:description.

    :param parent:
    :type parent: :py:class:ReportEventStack or None
        The parent of this event.  The parent is populated with
        results of all its children.  The name used in reporting
        is <parent.name>/<name>

    :param reporting_enabled:
        Indicates if reporting events should be generated.
        If not provided, defaults to the parent's value, or True if no parent
        is provided.

    :param result_on_exception:
        The result value to set if an exception is caught. default
        value is FAIL.

    :param post_files:
        Can hold filepaths of files that are to get posted/created
        regarding a given event. Something like success or failure information
        in a given log file. For each filepath, if it's a valid regular file
        it will get: read & encoded as base64 at the close of the event.
        Default value, if None, is an empty list.
    NcCs�||_||_||_||_||_tj|_|durg}||_|dur(|r&|j	}nd}||_	|r7d�
|j|f�|_n|j|_i|_dS)NT�/)
�parentr
r�message�result_on_exceptionr+rr)r*�reporting_enabled�join�fullname�children)rr
rrMrLrOrNr*rrrr�s,
��
zReportEventStack.__init__cCsd|j|j|jfS)Nz.ReportEventStack(%s, %s, reporting_enabled=%s))r
rrOr rrr�__repr__�s
�zReportEventStack.__repr__cCs4tj|_|jrt|j|j�|jrd|jj|j	<|S)N)NN)
r+rr)rOrIrQrrLrRr
r rrr�	__enter__�szReportEventStack.__enter__cCsPtjtjfD]}|j��D]\}\}}||kr ||jfSq
q|j|jfSr)r+rrrRr:rMr))r�cand_result�_name�value�_msgrrr�_childrens_finish_infos��z'ReportEventStack._childrens_finish_infocCs|jSr)�_resultr rrrr)szReportEventStack.resultcCs|tvr
td|��||_dS)Nz'%s' not a valid result)r+r,rZ�rrWrrrr)s
cCs|jdur|jS|jSr)�_messagerr rrrrMs
zReportEventStack.messagecCs
||_dSr)r\r[rrrrMs
cCs|r|j|jfS|��Sr)rNrMrY)r�excrrr�_finish_infoszReportEventStack._finish_infocCsH|�|�\}}|jr||f|jj|j<|jr"t|j|||jd�dSdS)NrD)r^rLrRr
rOrGrQr*)r�exc_type�	exc_value�	tracebackr)�msgrrr�__exit__!s
��zReportEventStack.__exit__)rrrr$r+rrrSrTrY�propertyr)�setterrMr^rcrrrrrJ�s**
�'



rJc
Cs�|sdSg}|D]J}tj�|�sd}n6t�d|����&t|d��}t�|����	�}Wd�n1s5wYWd�n1sDwY|�
||dd��q|S)NzReading �rb�base64)�path�content�encoding)�osrh�isfiler�Timed�openrg�	b64encode�read�decode�append)r/�ret�fnameri�fprrrr0+s ���r0r) r$rg�logging�os.pathrkr�typingrr	r�cloudinit.reportingrr�cloudinit.reporting.handlersrr(rHr%�	getLoggerr�LOG�setr
r+rr&rCrrGrIrJr0rrrr�<module>s0
$
 
�