HEX

File: //lib/python3/dist-packages/cloudinit/config/__pycache__/cc_rsyslog.cpython-310.pyc
o

x[h�-�
@s�UdZddlZddlZddlZddlZddlZddlmZmZm	Z	ddl
mZddlm
Z
ddlmZddlmZmZddlmZdd	lmZd
egedgd�Zeed
<dddiiddgdd�Zddgd�ddgd�ddgd�d�Ze�e�Zdefdd�Zd3dd�Zd4dd�Z d e!ded!e!fd"d#�Z"d$d%�Z#d5d&d'�Z$Gd(d)�d)�Z%d6d*d+�Z&d,ed!dfd-d.�Z'd/e(d e
d,ed0e)d!df
d1d2�Z*dS)7z-Rsyslog: Configure system logging via rsyslog�N)�	lifecycle�subp�util)�Cloud)�Config)�
MetaSchema)�ALL_DISTROS�Distro)�loggers)�PER_INSTANCE�
cc_rsyslog�rsyslog)�id�distros�	frequency�activate_by_schema_keys�metaz/etc/rsyslog.dz20-cloud-config.conf�auto�rsyslogdF)�
config_dir�config_filename�service_reload_command�remotes�configs�	check_exe�packages�install_rsyslogz/usr/local/etc/rsyslog.d)rrzsysutils/rsyslogz/usr/pkg/etc/rsyslog.d)�freebsd�openbsd�netbsd�distrocCs4t}t�t�}|j|vrtj|||jgdd�}|S)z�Construct a distro-specific rsyslog config dictionary by merging
       distro specific changes into base config.

    @param distro: String providing the distro class name.
    @returns: Dict of distro configurations for ntp clients.
    T)�reverse)�DISTRO_OVERRIDES�copy�RSYSLOG_CONFIG�osfamilyr�
mergemanydict�name)r �dcfg�cfg�r*�=/usr/lib/python3/dist-packages/cloudinit/config/cc_rsyslog.py�distro_default_rsyslog_config?s


r,cCs(t�|�rdS|durdg}||�dS)aiInstall rsyslog package if not already installed.

    @param install_func: function.  This parameter is invoked with the contents
    of the packages parameter.
    @param packages: list.  This parameter defaults to ['rsyslog'].
    @param check_exe: string.  The name of a binary that indicates the package
    the specified package is already installed.
    Nr
)r�which)�install_funcrrr*r*r+rMs

	rcCs.|dkr|�dd�}|�d|�Stj|dd�S)Nr�rsyslog_svcnamer
z
try-reloadT)�capture)�
get_option�manage_servicer)r �command�servicer*r*r+�
reload_syslog^sr5r)�returnc
Cs"|�di�}t|�}t|�d�t�r4tjddd�d|�d�i}d|vr*|d|d<d|vr4|d|d	<dgtfd	|d	tfd|dtfd
|d
tfd|dttffd|dtfd
|d
tfd|dtff}|D]&\}}}||vrv|||<qht|||�s�t	d|�d|�dt
||�����qh|S)z�Return an updated config.

    Support converting the old top level format into new format.
    Raise a `ValueError` if some top level entry has an incorrect type.
    r
z)The rsyslog key with value of type 'list'z22.2)�
deprecated�deprecated_versionr�rsyslog_filenamer�rsyslog_dirrrrrrrzInvalid type for key `z`. Expected type(s): z. Current type: )�getr,�
isinstance�listr�	deprecate�str�dict�bool�
ValueError�type)r)r �mycfg�
distro_config�fillup�key�default�vtypesr*r*r+�load_configesF���

���rJc
	Cs�g}t|�D]m\}}t|t�r'd|vrt�d|d�q|d}|�d|�}n|}|}|��}|s:t�d|d�qtj�	||�}d}||vrNd}|�
|�zd}	|�d	�sXd	}	tj
|||	|d
�Wqtyst�td|�Yqw|S)N�contentz%No 'content' entry in config entry %s��filenamezEntry %s has an empty filename�ab�wb��
)�omodezFailed to write to %s)�	enumerater<r@�LOG�warningr;�strip�os�path�join�append�endswithr�
write_file�	Exception�logexc)
r�	def_fname�cfg_dir�files�cur_pos�entrKrMrR�endlr*r*r+�apply_rsyslog_changes�s<
�

�recCszt�d|�\}}|��}Wnty|d}}Ynw|����}d}t|�dkr.|}nt|�dkr9|\}}ntd|��t�d|�}|sMtd|��|�d�}|�d�p[|�d	�}|�d
�}	|�d�rq|�d�sqtd
|��|rw|sw|}t	|||||	d�}
|
�
�|
S)Nz[ ]*[#]+[ ]*rL�zline had multiple spaces: %sz_^(?P<proto>[@]{0,2})(([\[](?P<bracket_addr>[^\]]*)[\]])|(?P<addr>[^:]*))([:](?P<port>[0-9]+))?$zInvalid host specification '%s'�proto�addr�bracket_addr�port�[�]z"host spec had invalid brackets: %s�r'�matchrgrhrj)�re�splitrVrB�lenrn�group�
startswithr[�SyslogRemotesLine�validate)�liner'�data�comment�toksrn�	host_portrgrhrj�tr*r*r+�parse_remotes_line�s>�
�


�r|c@s0eZdZ	d
dd�Zdd�Zdd�Zdd	�ZdS)rtNcCsb|sd}||_||_|sd}|dkrd}n|dkrd}||_||_|dur,t|�|_dSd|_dS)Nz*.*�udp�@�@@�tcp)r'rnrgrh�intrj)�selfr'rnrgrhrjr*r*r+�__init__�s zSyslogRemotesLine.__init__c
CsP|jrzt|j�Wnty}ztd|j�|�d}~ww|js&td��dS)Nzport '%s' is not an integerzaddress is required)rjr�rBrh)r��er*r*r+ru�s�����zSyslogRemotesLine.validatecCsd|j|j|j|j|jfS)Nz.[name=%s match=%s proto=%s address=%s port=%s]rm)r�r*r*r+�__repr__s�zSyslogRemotesLine.__repr__cCs�|jd}|jdkr|d7}n	|jdkr|d7}d|jvr'|d|jd7}n||j7}|jr6|d	|j7}|jr@|d
|j7}|S)N� r}r~r�r�:rkrlz:%sz # %s)rnrgrhrjr')r��bufr*r*r+�__str__s





zSyslogRemotesLine.__str__)NNNNN)�__name__�
__module__�__qualname__r�rur�r�r*r*r*r+rt�s
�	rtcCs�|sdSg}|dur|�|�|��D].\}}|sqz
|�tt||d���WqtyA}zt�d|||�WYd}~qd}~ww|durK|�|�d�|�dS)N)r'z!failed loading remote %s: %s [%s]rQ)rZ�itemsr?r|rBrTrUrY)r�header�footer�linesr'rvr�r*r*r+�remotes_to_rsyslog_cfg$s"
��
r��cloudcCs�z	|j�dd�WntjyYdSw|j�dd�|j��t�tj��|j�dd�t�d�Wd�dS1s?wYdS)z�
    This helper function bundles the necessary steps to disable BSD base syslog
    ``rc(8)`` reads its configuration on start, so after disabling syslogd, we
    need to tell rc to reload its config
    �enabled�syslogdN�disable�onestopzOsyslogd is running before cloud-init! Please report this as bug to the porters!)	r r2r�ProcessExecutionError�reload_init�
contextlib�suppressrT�error)r�r*r*r+� disable_and_stop_bsd_base_syslog6s�
�"�r�r'�argsc

Cs`d|vrt�d|�dSt||j�}|d}|dr&|�t|dddd��|j�dd�}|d	d
ur@t|jj|d|dd
�t	�
�rO|j�d|�t|�|dsZt�d�dSt
|d|d|dd�}|spt�d�dSzt|j|dd�}Wntjy�}	zd}t�dt|	��WYd}	~	nd}	~	ww|r�t��t�|j�t�d||�dSdS)Nr
z;Skipping module named %s, no 'rsyslog' key in configurationrrz# begin remotesz
# end remotes)r�r�r/rTrr)rr�enablez.Empty config rsyslog['configs'], nothing to dorr)rr_r`z0restart of syslog not necessary, no changes mader)r3FzFailed to reload syslog %sz%s configured %s files)rT�debugrJr rZr�r1r�install_packagesr�is_BSDr2r�rer5rr�rUr?r
�
reset_logging�
setup_loggingr))
r'r)r�r�rDrr4�changes�	restartedr�r*r*r+�handleNsd����
�


����r�)Nr
)r)N)NN)+�__doc__r�r#�loggingrWro�	cloudinitrrr�cloudinit.cloudr�cloudinit.configr�cloudinit.config.schemar�cloudinit.distrosrr	�
cloudinit.logr
�cloudinit.settingsrr�__annotations__r$r"�	getLoggerr�rTr,rr5r@rJrer|rtr�r�r?r=r�r*r*r*r+�<module>s`
��
����


/
)+
<"