| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/cloudinit/handlers/__pycache__/ |
Upload File : |
o
x[h}& �
@ s d dl Z d dlZd dlZd dlmZmZmZ d dlmZm Z m
Z
e� e �Z
dZdZdZdZeegZdgZd Zd
Zd d d
dddddddddd� Zeee�� �dd� d�ZG dd� de jd �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-d.�Z%d1d/d0�Z&dS )2� N)�importer�
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__C s
zHandler.__init__c C s dt �| �| �� f S )Nz%s: [%s])r �obj_name�
list_types�r r r r �__repr__G 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>O s ��z&Handler.list_types.<locals>.<listcomp>)�hasattr�NotImplementedError�getattrr r r r r J s
�zHandler.list_typesc O s t � �r )r% )r �args�kwargsr r r � handle_partT s zHandler.handle_partN)r ) �__name__�
__module__� __qualname__r r r �abc�abstractmethodr) r r r r r B 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_partY sP ��
�
��rC c C � dt i}t| |d d ||� d S �Nr1 )�
CONTENT_STARTrC �r; r< r r? r r r �
call_begin� � �rH c C rD rE )� CONTENT_ENDrC rG r r r �call_end� rI rK 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)� initializedr0 z7Failed at registering python file: %s (part handler %s))�PART_HANDLER_FN_TMPL�os�path�join�endswithr �
write_file�
fixup_handlerr �
import_modulerH �registerr9 r: r7 )
�pdata�_ctype� _filenamer> �curcount�modnamer �modfnamerN 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�
r0 r � �ignore)�errors)�
isinstance�str�split�decoder
�UnicodeDecodeError)�blob�size�startr r r �_extract_first_or_bytes� s
$ � ��rl 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� LookupErrorr4 r6 )�textr r r �_escape_string� s � �rr 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 ) Nr1 �excludedz content_type "%s" is excludedrN r< r � z'%s...'z)Unhandled non-multipart (%s) userdata: %sz0Unhandled unknown content-type (%s) userdata: %szEmpty payload of type %s)
�getr7 r8 �PART_CONTENT_TYPESr_ rC rl rr �NOT_MULTIPART_TYPE�warning)r< r= r> r? rB rN rk �detailsr r r �walker_callback� s@ �
��rz c C s� d}| � � D ]:}|�� dkrq|�� }|d u rt}|�� }|s#t| }t|�}t�|� ||d< t �
|�}|||||� |d }qd S )Nr � multipartr1 r0 ) �walk�get_content_maintype�get_content_type�
OCTET_TYPE� get_filename� PART_FN_TPL�dictr7 r8 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 r0 r z&Handler %s has an unknown frequency %s)r$ �setattrr r r7 rx )r; �def_freq�freqr r r rV s
� rV c C sV z t �| ��� }W n ty | Y S w |�� }tD ]
}|�|�r(t| S q|S r )r �
decode_binary�lowerrh �lstrip�INCLUSION_SRCH�
startswithr )r> �default�
payload_lcrq r r r �type_from_starts_with# s �
�r� r )'r- �loggingrQ � cloudinitr r r �cloudinit.settingsr r r � getLoggerr* r7 rw r rJ rF �CONTENT_SIGNALSrv rP r� r �sorted�list�keysr� �ABCMetar rC rH rK r_ rl rr rz r| rV r� r r r r �<module> sR
��0)