ruạṛ
a ���fB � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZdZdZed Zed Z ed Z dZ dZ d Z d Zdd d �Zd d� Zdd� Zddd�Zdd� Zdd� Zdd� ZdS )� Nz9/var/lib/oracle-cloud-agent/plugins/oci-alx/alx-osms.sockz /20210615/zupdates/zyum/zksplice/zfPOST %s HTTP/1.1 HOST: 127.0.0.1 Accept: * Content-Type: application/json Content-Length: %d %szHTTP/1.1 200 OK�SUCCESS�FAILUREc C s\ | ||||d�}z|r"t |�|d< W n2 tyV } zt�d| � W Y d}~n d}~0 0 |S )a9 Creates a json style dictionary for yum update body :param status: update status of value "SUCCESS/FAILURE/WARNING" :param exit_code: yum exit code :param tid: yum transaction id in type int if no error occurs. If error happens, value is -1 :param time_started: update start time timestamp in floating point :param time_ended: update end time timestamp in floating point :param message: Error message string in base64 encoding if any error occurs :return: json style dictionary containing request body for /updates/yum POST request )�status�exitCode�tid� timeStarted� timeEnded�message�1Failed to encode alx message to base64 format: %sN�� base64encode� Exception�logging�error)r � exit_coder � time_started� time_endedr �body�e� r �;/usr/share/oracle-cloud-agent/plugins/osms/osms/alxutils.py�create_yum_body s �$r c C sV | |||d�}zt |�|d< W n2 tyP } zt�d| � W Y d}~n d}~0 0 |S )a� Creates a json style dictionary for ksplice update body :param status: update status of value "SUCCESS/FAILURE/WARNING" :param exit_code: ksplice exit code :param output: ksplice command output :param time_started: update start time timestamp in floating point :param time_ended: update end time timestamp in floating point :return: json style dictionary containing request body for /updates/ksplice POST request )r r r r �outputr Nr )r r r r r r r r r r �create_ksplice_body4 s �$r c C s� z�t �|�}t|�}t| ||f }t�tjtj�}|�d� |�t � t � dt � t � d| ||f � |� |� � � |�d�}|�� |W S tjy� } zt �d| � W Y d}~n:d}~0 ty� } zt �d| � W Y d}~n d}~0 0 dS )z� Sends post request to the alx socket using the given body :param path: API request path in alx socket :param body: POST body of type dictionary :return: socket response string or None if error happens g ��@zALX socket %s connectedz+Sending POST request to %s of length %d: %si z#Failed to connect to alx socket: %sN�(Failed to send payload to alx socket: %s)�json�dumps�len� POST_TEMPLATE�socket�AF_UNIX� SOCK_STREAM� settimeout�connect� ALX_SOCKETr �debug�sendall�encode�recv�closer r ) �pathr Zbody_strZcontent_length�payload�sock�response�msgr r r r � post_requestK s" "r/ c C sx t | |||||�}ttt|��}|s0t�d� nDt|vrPt�dt|�|f � n$t�d| � t� dt|�|f � d S )Nz*Did not receive yum post response from alxz+Received yum post response of length %d, %szYum tid %d sent to alx) r �strr/ �YUM_PATHr r �HTTP_OKr �infor% )r r r r r r r � http_responser r r �send_yum_updatese s r5 c C sp z8| d }t |t�r |d }tt|d|t�� | d � W n2 tyj } zt�d| � W Y d }~n d }~0 0 d S )Nr ���� r )� isinstance�tupler5 r �timer r r )�resultr r r r r r �send_failed_yum_resultt s r< c C sr t | ||||�}ttt|��}|s.t�d� n@t|vrNt�dt|�|f � n t�d� t� dt|�|f � d S )Nz.Did not receive ksplice post response from alxz/Received ksplice post response of length %d, %sz"ksplice update outputs sent to alx) r r0 r/ � KSPLICE_PATHr r r2 r r3 r% )r r r r r r r4 r r r �send_ksplice_updates~ s r> c C sF t jdkr t�| �d���� S t| t�r8t�| �d��S t�| �S d S )N)� r zutf-8)�sys� version_info�base64� b64encoder' �decoder8 �unicode)�stringr r r r � s r )N)N)rB r r r r@ r: r$ Z BASE_PATHZ UPDATE_PATHr1 r= r r2 r r r r r/ r5 r< r> r r r r r �<module> s*
cải xoăn