�
x[h� � � � S SK r S SKrS SKJrJrJrJr S SKJr \ R " \
5 r Sr Sr
SrSr " S S \R 5 rg)
� N)�handlers�mergers�safeyaml�util)�
PER_ALWAYSz
Merge-Typez
#cloud-configz#cloud-config-jsonpz*# Cloud-config part ignored SCHEMA_ERROR: c �F � \ rS rSr\\/rS rS rS r S r
S r S r S r
S rg
) �CloudConfigPartHandler�- c �� � [ R R U [ SS9 S U l UR S5 U l SU; a UR US 5 U l / U l / U l g )N� )�version� cloud_config�cloud_config_path) r �Handler�__init__r � cloud_buf� get_ipath�cloud_fn�
file_names�error_file_names)�self�paths�_kwargss �A/usr/lib/python3/dist-packages/cloudinit/handlers/cloud_config.pyr � CloudConfigPartHandler.__init__2 sa � ����!�!�$�
�A�!�>� ��� ����7��
� �'� )� !�O�O�G�4G�,H� I�D�M� ��� "�� � c � � U R ( d g / nU R ( ah UR S[ U R 5 - 5 U R H nU( d SnUR SU- 5 M" UR S5 U R H nUR [
U 35 M U R bI [ S/nUR U5 UR [ R " U R 5 5 O/ n[ R " U R SR U5 S5 g )Nz# from %s files�?z# %s� �
i� )r r �append�lenr � MERGED_PART_SCHEMA_ERROR_PREFIXr � CLOUD_PREFIX�extendr �dumpsr �
write_file�join)r �
file_lines�fn�
error_file�liness r �_write_cloud_config�*CloudConfigPartHandler._write_cloud_config; s� � ��}�}� ��
� �?�?� � � � /�3�t���3G� H� I��o�o��� �B��!�!�&�B�-�0� &�
� � �b� !� �/�/�J� � � �!@� A�*� � N� O� 0� �>�>� %� ���E�
�L�L�� $� �L�L�� � ����7� 8��E� ����
�
�t�y�y��'7��?r c � � Sn[ S[ - 4 H nUR US5 nU( d M Un O [ R " U5 nUc [ S5 e[
R " U5 n[
R " U5 n/ n U R U5 U R U5 U ( d [
R " S5 n Xi4$ )Nr zX-%szempty cloud configzdict(replace)+list()+str()) � MERGE_HEADER�getr � load_yaml�
ValueErrorr �dict_extract_mergers�string_extract_mergersr% )
r �payload�headers�merge_header_headers�h�tmp_h� payload_yaml� mergers_yaml�mergers_header� all_mergerss
r �_extract_mergers�'CloudConfigPartHandler._extract_mergersU s� � � !� � ��,� 7�8�A��K�K��2�&�E��u�',�$�� 9� �~�~�g�.� � � � � 1�2� 2� �3�3�L�A� � �7�7�8L�M��� ����<�(����>�*��!�8�8�,��K� �*�*r c � � UR 5 n[ R " U[ S9n[ R
R
U5 n[ R SU5 UR U R SS9U l
g )N)�prefixz!Merging by applying json patch %sF)�in_place) �lstripr �strip_prefix_suffix� JSONP_PREFIX� jsonpatch� JsonPatch� from_string�LOG�debug�applyr )r r6 �patchs r � _merge_patch�#CloudConfigPartHandler._merge_patchn s_ � �
�.�.�"���*�*�7�<�H���#�#�/�/��8�� � � �5�u�=� ���T�^�^�e��D��r c �� � U R X5 u p4[ R SU5 [ R " U5 nUR U R U5 U l g )NzMerging by applying %s)r? rJ rK r � construct�merger )r r6 r7 r; �
my_mergers�mergers r � _merge_part�"CloudConfigPartHandler._merge_party sJ � �%)�%:�%:�7�%L�"� � � � �*�J�7��"�"�:�.�� � � �d�n�n�l�C��r c � � / U l S U l g )N)r r )r s r �_reset� CloudConfigPartHandler._reset s � � ��� ��r c � � U[ R :X a U R 5 g U[ R :X a! U R 5 U R 5 g U R
b U R ( d 0 U l U[ R [ :X a U R U5 OU R XF5 S H nUR US5 nM U R R UR 5 5 g ! [ aJ nU R R UR 5 5 [ R# SUU5 S nAg S nAf[$ a [& R( " [ SU5 g f = f)N)r �
� � z2Failed at merging in cloud config part from %s: %sz.Failed at merging in cloud config part from %s)r �
CONTENT_STARTrX � CONTENT_ENDr- r r �INCLUSION_TYPES_MAPrF rN rU �replacer! �stripr3 r rJ �warning� Exceptionr �logexc) r �data�ctype�filenamer6 � frequencyr7 �i�errs r � handle_part�"CloudConfigPartHandler.handle_part� s% � � �H�*�*� *� �K�K�M� � �H�(�(� (� � $� $� &� �K�K�M� � ��~�~�%�T�_�_�!#�����4�4�\�B�B��!�!�'�*�� � ��2�'��#�+�+�A�s�3�� (� �O�O� "� "�8�>�>�#3� 4��� � � !� !� (� (�� � �)9� :� �K�K�D���
�
��
� � �K�K��E�x�
� �s � B'D �
E?�A E�)E?�>E?)r r r r N)�__name__�
__module__� __qualname__�__firstlineno__r$ rF �prefixesr r- r? rN rU rX rl �__static_attributes__� r r r r - s4 � � �l�+�H�#�@�4+�2 E�D� � r r )�loggingrG � cloudinitr r r r �cloudinit.settingsr � getLoggerrn rJ r0 r$ rF r# r r rt r r �<module>ry sQ �� � � 7� 7� )�
����!��� �& � �$� �"N� �t�X� -� -� tr