File: //lib/python3/dist-packages/cloudinit/handlers/__pycache__/__init__.cpython-310.pyc
o
�Ad�& �
@ s d dl Z d dlZd dlmZ d dlmZ d dlmZmZ d dlm Z m
Z
m Z e� e
�ZdZdZdZd ZeegZd
gZd Zd Zd
dddd
dddddddd� Zeee�� �dd� d�ZG d d � d e j d �Z d d � Z d!d"� Z d#d$� Z d%d&� Z!d'd(� Z"d)d*� Z#d+d,� Z$d-d.� Z%e fd/d0�Z&d3d1d2�Z'dS )4� N)�importer)�log)�
type_utils�util)� FREQUENCIES�
PER_ALWAYS� PER_INSTANCEztext/x-not-multipartzapplication/octet-stream�__end__� __begin__ztext/part-handlerzpart-handler-%03dz part-%03dztext/x-include-urlztext/x-include-once-urlztext/x-shellscriptztext/cloud-configztext/cloud-boothookztext/cloud-config-archiveztext/cloud-config-jsonpz text/jinja2�text/x-shellscript-per-boot� text/x-shellscript-per-instance�text/x-shellscript-per-once) z#includez
#include-oncez#!z
#cloud-configz
#part-handlerz#cloud-boothookz#cloud-config-archivez#cloud-config-jsonpz## template: jinjar r r
c C s dt | � S )Nr )�len)�e� r �=/usr/lib/python3/dist-packages/cloudinit/handlers/__init__.py�<lambda>? s r )�keyc @ s4 e Zd Zd dd�Zdd� Zdd� Zejdd � �Zd
S ) �Handler� c C s || _ || _d S �N)�handler_version� frequency)�selfr �versionr r r �__init__D s
zHandler.__init__c C s dt �| �| �� f S )Nz%s: [%s])r �obj_name�
list_types�r r r r �__repr__H s zHandler.__repr__c C s& t | d�s td��dd� t| d�D �S )N�prefixesz#Missing prefixes subclass attributec S s g | ]}t | �qS r )�INCLUSION_TYPES_MAP)�.0�prefixr r r �
<listcomp>P s ��z&Handler.list_types.<locals>.<listcomp>)�hasattr�NotImplementedError�getattrr r r r r K s
�zHandler.list_typesc O s t � �r )r& )r �args�kwargsr r r � handle_partU s zHandler.handle_partN)r ) �__name__�
__module__� __qualname__r r r �abc�abstractmethodr* r r r r r C s
r )� metaclassc C s | j }|tks|tkr|tksd S z | j}t|�}W n tttfy( d}Y nw |d }z@t� d| ||||� |dkrI| �
||||||� W d S |dkrY| �
|||||� W d S |dkrh| �
||||� W d S td| �� t y� t �
td| ||||� Y d S w )N� � Content-Typez1Calling handler %s (%s, %s, %s) with frequency %s� r zUnknown module version %sz8Failed calling handler %s (%s, %s, %s) with frequency %s)r r r r �int� TypeError�
ValueError�AttributeError�LOG�debugr* � Exceptionr �logexc) �mod�data�filename�payloadr �headers�mod_freq�mod_ver� content_typer r r �run_partZ sX ��� ��
�
��rD c C � dt i}t| |d d ||� d S �Nr2 )�
CONTENT_STARTrD �r< r= r r@ r r r �
call_begin� � �rI c C rE rF )� CONTENT_ENDrD rH r r r �call_end� rJ rL c
C s� | d }t | }| d }tj�| d d| �}|�d�s d| }t�||d� | d }z tt� |��} t
| | d |� |j | d
d � |d | d< W d S t y\ t�
td
||� Y d S w )N� handlercountr �
handlerdirz%sz.pyz%s.pyi� �handlersr= T)� initializedr1 z7Failed at registering python file: %s (part handler %s))�PART_HANDLER_FN_TMPL�os�path�join�endswithr �
write_file�
fixup_handlerr �
import_modulerI �registerr: r; r8 )
�pdata�_ctype� _filenamer? �curcount�modnamer �modfnamerO r< r r r �walker_handle_handler� s*
��r` c C s� z2t | t�r| �dd�d }n| d d| � jdd��dd�d }t|�|kr0|d |� }W |S W |S tyB | d|� }Y |S w )N�
r1 r � �ignore)�errors)�
isinstance�str�split�decoder �UnicodeDecodeError)�blob�size�startr r r �_extract_first_or_bytes� s
$ � ��rm c C sZ z| � d�W S ttfy# z| � d�W Y S ty" Y Y | S w ty, Y | S w )N�
string_escape�unicode_escape)�encode� LookupErrorr5 r7 )�textr r r �_escape_string� s � �rs c C s� |d }|| � d�v rt�d|� d S |tv r t| |||� d S | d }||v r9t|| | d ||| d |� d S |r\t|d�}dt|� }|tkrSt� d ||� d S t� d
||� d S t�d |� d S ) Nr2 �excludedz content_type "%s" is excludedrO r= r � z'%s...'z)Unhandled non-multipart (%s) userdata: %sz0Unhandled unknown content-type (%s) userdata: %szEmpty payload of type %s)
�getr8 r9 �PART_CONTENT_TYPESr` rD rm rs �NOT_MULTIPART_TYPE�warning)r= r> r? r@ rC rO rl �detailsr r r �walker_callback� s@ �
��r{ c C s� d}| � � D ]:}|�� dkrq|�� }|d u rt}|�� }|s#t| }t|�}t�|� ||d< t �
|�}|||||� |d }qd S )Nr � multipartr2 r1 ) �walk�get_content_maintype�get_content_type�
OCTET_TYPE� get_filename� PART_FN_TPL�dictr8 r9 r �fully_decoded_payload) �msg�callbackr= �partnum�part�ctyper> r@ r? r r r r} s"
�r} c C sT t | d�s t| dd� t | d�st| d|� | S | j}|r(|tvr(t�d| |� | S )Nr r1 r z&Handler %s has an unknown frequency %s)r% �setattrr r r8 ry )r< �def_freq�freqr r r rW s
� rW c C sV z t �| ��� }W n ty | Y S w |�� }tD ]
}|�|�r(t| S q|S r )r �
decode_binary�lowerri �lstrip�INCLUSION_SRCH�
startswithr! )r? �default�
payload_lcrr r r r �type_from_starts_with$ s �
�r� r )(r. rR � cloudinitr r �loggingr r �cloudinit.settingsr r r � getLoggerr+ r8 rx r� rK rG �CONTENT_SIGNALSrw rQ r� r! �sorted�list�keysr� �ABCMetar rD rI rL r` rm rs r{ r} rW r� r r r r �<module> sT
��0)