| Server IP : 23.254.227.96 / Your IP : 216.73.216.7 Web Server : Apache/2.4.62 (Unix) OpenSSL/1.1.1k System : Linux hwsrv-1277026.hostwindsdns.com 4.18.0-477.13.1.el8_8.x86_64 #1 SMP Tue May 30 14:53:41 EDT 2023 x86_64 User : viralblo ( 1001) PHP Version : 8.1.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3.6/site-packages/cloudinit/handlers/__pycache__/ |
Upload File : |
3
�� b�& � @ s" d dl Z d dlZd dlmZ d dlmZ d dlmZmZ d dlm Z m
Z
m Z ej e
�ZdZdZdZd ZeegZd
gZd Zd Zd
ddddd
dddddddd�
Zeeej� �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 fd0d1�Z&d4d2d3�Z'dS )5� N)�importer)�log)�
type_utils�util)� FREQUENCIES�
PER_ALWAYS� PER_INSTANCEztext/x-not-multipartzapplication/octet-streamZ__end__Z __begin__ztext/part-handlerzpart-handler-%03dz part-%03dztext/x-include-urlztext/x-include-once-urlztext/x-shellscriptztext/cloud-configztext/upstart-jobztext/cloud-boothookztext/cloud-config-archiveztext/cloud-config-jsonpz text/jinja2ztext/x-shellscript-per-bootz text/x-shellscript-per-instanceztext/x-shellscript-per-once)
z#includez
#include-oncez#!z
#cloud-configz #upstart-jobz
#part-handlerz#cloud-boothookz#cloud-config-archivez#cloud-config-jsonpz## template: jinjaztext/x-shellscript-per-bootz text/x-shellscript-per-instanceztext/x-shellscript-per-oncec C s dt | � S )Nr )�len)�e� r � /usr/lib/python3.6/__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__E s zHandler.__init__c C s dt j| �| j� f S )Nz%s: [%s])r Zobj_name�
list_types)r r r r �__repr__I s zHandler.__repr__c C s, t | d�std��ndd� t| d�D �S d S )N�prefixesz#Missing prefixes subclass attributec S s g | ] }t | �qS r )�INCLUSION_TYPES_MAP)�.0�prefixr r r �
<listcomp>R s z&Handler.list_types.<locals>.<listcomp>)�hasattr�NotImplementedError�getattr)r r r r r L s
zHandler.list_typesc O s
t � �d S )N)r )r �args�kwargsr r r � handle_partV s zHandler.handle_partN)r ) �__name__�
__module__� __qualname__r r r �abc�abstractmethodr" r r r r r D s
r )� metaclassc C s | j }|tkp |tko |tks"d S y| j}t|�}W n tttfk
rR d}Y nX |d }yxtj d| ||||� |dkr�| j
||||||� nB|dkr�| j
|||||� n&|dkr�| j
||||� n td| ��W n, t k
�r t j
td| ||||� Y nX d S )N� z 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 �headersZmod_freqZmod_ver� content_typer r r �run_part[ sF
r9 c C s dt i}t| |d d ||� d S )Nz Content-Type)�
CONTENT_STARTr9 )r3 r4 r r7 r r r �
call_begin� s r; c C s dt i}t| |d d ||� d S )Nz Content-Type)� CONTENT_ENDr9 )r3 r4 r r7 r r r �call_end� s r= c
C s� | d }t | }| d }tjj| d d| �}|jd�s@d| }tj||d� | d }y<ttj |��} t
| | d |� |j | d
d � |d | d< W n$ t k
r� tj
td
||� Y nX d S )NZ handlercountr Z
handlerdirz%sz.pyz%s.pyi� �handlersr4 T)Z initializedr) z7Failed at registering python file: %s (part handler %s))�PART_HANDLER_FN_TMPL�os�path�join�endswithr Z
write_file�
fixup_handlerr �
import_moduler; �registerr1 r2 r/ )
ZpdataZ_ctypeZ _filenamer6 Zcurcount�modnamer Zmodfnamer> r3 r r r �walker_handle_handler� s&
rH c C s� y\t | t�r | jdd�d }n$| d d| � jdd�jdd�d }t|�|krZ|d |� }W n tk
r| | d|� }Y nX |S )N�
r) r � �ignore)�errors)�
isinstance�str�split�decoder �UnicodeDecodeError)Zblob�size�startr r r �_extract_first_or_bytes� s
$ rT c C sZ y
| j d�S ttfk
rB y
| j d�S tk
r< Y nX Y n tk
rT Y nX | S )NZ
string_escapeZunicode_escape)�encode� LookupErrorr, r. )�textr r r �_escape_string� s
rX c C s� |d }|| j d�kr&tjd|� d S |tkr@t| |||� d S | d }||krpt|| | d ||| d |� nN|r�t|d�}dt|� }|tkr�tj d ||� q�tj d
||� n tjd |� d S ) Nz Content-TypeZexcludedz content_type "%s" is excludedr> r4 r � z'%s...'z)Unhandled non-multipart (%s) userdata: %sz0Unhandled unknown content-type (%s) userdata: %szEmpty payload of type %s)
�getr/ r0 �PART_CONTENT_TYPESrH r9 rT rX �NOT_MULTIPART_TYPE�warning)r4 r5 r6 r7 r8 r> rS Zdetailsr r r �walker_callback� s:
r^ c C s� d}x�| j � D ]t}|j� dkr q|j� }|d kr4t}|j� }|sHt| }t|�}tj|� ||d< t j
|�}|||||� |d }qW d S )Nr Z multipartz Content-Typer) ) �walkZget_content_maintypeZget_content_type�
OCTET_TYPE� get_filename� PART_FN_TPL�dictr/ r0 r Zfully_decoded_payload) �msg�callbackr4 Zpartnum�partZctyper5 r7 r6 r r r r_ s
r_ c C sR t | d�st| dd� t | d�s.t| d|� n | j}|rN|tkrNtjd| |� | S )Nr r) r z&Handler %s has an unknown frequency %s)r �setattrr r r/ r] )r3 Zdef_freqZfreqr r r rD s
rD c C sT yt j| �j� }W n tk
r& |S X |j� }x tD ]}|j|�r6t| S q6W |S )N)r Z
decode_binary�lowerrQ �lstrip�INCLUSION_SRCH�
startswithr )r6 �defaultZ
payload_lcrW r r r �type_from_starts_with% s
rm )N)(r& r@ Z cloudinitr r Zloggingr r Zcloudinit.settingsr r r Z getLoggerr# r/ r\ r` r< r: ZCONTENT_SIGNALSr[ r? rb r �sorted�list�keysrj �ABCMetar r9 r; r= rH rT rX r^ r_ rD rm r r r r �<module> sP
0)