
    x[hk                         S SK r S SKJrJr  S SKJr  S SKJr  S SKJrJ	r	  S SK
JrJr  \ R                  " \5      rS\\R                      4S jrS	\S\4S
 jrS\R*                  S\4S jrS\4S jrg)    N)datetimetimezone)Optional)version)handlersinstantiated_handler_registry)errorsidentityreturnc                      [         R                  R                  S5      n [        U [        R
                  5      (       d  gU $ )z'Get instantiated KVP telemetry handler.	telemetryN)r   registered_itemsget
isinstancer   HyperVKvpReportingHandler)kvp_handlers    =/usr/lib/python3/dist-packages/cloudinit/sources/azure/kvp.pyget_kvp_handlerr      s9    /@@DDK k8#E#EFF    reportc                 n    [        5       nUc  [        R                  S5        gUR                  SU 5        g)z/Report to host via PROVISIONING_REPORT KVP key.z.KVP handler not enabled, skipping host report.FPROVISIONING_REPORTT)r   LOGdebug	write_key)r   r   s     r   report_via_kvpr      s4    !#K		BC/8r   errorc                 4    [        U R                  5       5      $ )N)r   as_encoded_report)r   s    r   report_failure_to_hostr    &   s    %11344r   c                  J    [         R                  " 5       n [        R                  " SS[
        R                  " 5        3S[        R                  " [        R                  5      R                  5        3SU  3/5      n[        U5      $ ! [         a  nSU< 3n  S nANS nAff = f)Nzfailed to read vm id: zresult=successzagent=Cloud-Init/z
timestamp=zvm_id=)r
   query_vm_id	Exceptionr	   encode_reportr   version_stringr   nowr   utc	isoformatr   )vm_idid_errorr   s      r   report_success_to_hostr+   *   s    6$$& !! 6 6 89:hll3==?@AUG		
F &!!  6(56s   B 
B"BB")loggingr   r   typingr   	cloudinitr   cloudinit.reportingr   r   cloudinit.sources.azurer	   r
   	getLogger__name__r   r   r   strboolr   ReportableErrorr    r+    r   r   <module>r7      sx   
  '   G 4!("D"DE 3 4 5&"8"8 5T 5" "r   