File: //usr/lib/python3.9/site-packages/ansible/utils/__pycache__/jsonrpc.cpython-39.pyc
a
�)g� � @ s~ d dl mZmZmZ eZd dlZd dlZd dlZd dl m
Z
d dl m Z d dl
mZmZ d dlmZ e� ZG dd� de�ZdS ) � )�absolute_import�division�print_functionN)�to_text)�ConnectionError)� binary_type� text_type)�Displayc @ sp e Zd Ze� Zdd� Zdd� Zdd� Zddd �Zdd
d �Z dd d
�Z
ddd�Z ddd�Z ddd�Z
d dd�ZdS ) �
JsonRpcServerc C s t �t|dd��}|�d�}|�d�s0|�d�rB| �� }t �|�S |�d�\}}t| d|�d�� d }| jD ]}t ||d �}|rl q�ql|s�| �
� }t �|�}�nhz||i |��} W n� t �y. }
zbt �
t�� � z| j|
jt|
�d �}W n$ t�y | jt|
�d
�}Y n0 t �|�}W Y d }
~
n�d }
~
0 t�y~ }
z8t �
t�� � | jt|
dd�d
�}t �|�}W Y d }
~
n�d }
~
0 0 t| t��r�d | v �r�| }n
| �| �}zt �|�}W nR t�y }
z8t �
t�� � | jt|
dd�d
�}t �|�}W Y d }
~
n
d }
~
0 0 t| d� |S ) NZsurrogate_then_replace)�errors�methodzrpc.�_�params� _identifier�id��code�message)�data�jsonrpc)�json�loadsr �get�
startswith�invalid_request�dumps�setattr�_objects�getattr�method_not_foundr �displayZvvv� traceback�
format_exc�errorr �AttributeError�internal_error� Exception�
isinstance�dict�response�delattr) �selfZrequestr r# �args�kwargsZ
rpc_method�objr) �result�exc� r1 �9/usr/lib/python3.9/site-packages/ansible/utils/jsonrpc.py�handle_request sN
z JsonRpcServer.handle_requestc C s | j �|� d S )N)r �add)r+ r. r1 r1 r2 �registerK s zJsonRpcServer.registerc C s d| j d�S )Nz2.0)r r )r )r+ r1 r1 r2 �headerN s zJsonRpcServer.headerNc C sJ | � � }t|t�rt|�}t|t�s>d|d< ttj|dd��}||d< |S )N�pickleZ result_typer )Zprotocolr/ )r6 r' r r r r7 r )r+ r/ r) r1 r1 r2 r) Q s
zJsonRpcServer.responsec C s* | � � }||d�}|r ||d< ||d< |S )Nr r r# )r6 )r+ r r r r) r# r1 r1 r2 r# [ s
zJsonRpcServer.errorc C s | � dd|�S )NiD���z Parse error�r# �r+ r r1 r1 r2 � parse_errord s zJsonRpcServer.parse_errorc C s | � dd|�S )Ni����zMethod not foundr8 r9 r1 r1 r2 r g s z JsonRpcServer.method_not_foundc C s | � dd|�S )Ni����zInvalid requestr8 r9 r1 r1 r2 r j s z JsonRpcServer.invalid_requestc C s | � dd|�S )Ni����zInvalid paramsr8 r9 r1 r1 r2 �invalid_paramsm s z JsonRpcServer.invalid_paramsc C s | � dd|�S )Ni����zInternal errorr8 r9 r1 r1 r2 r% p s z JsonRpcServer.internal_error)N)N)N)N)N)N)N)�__name__�
__module__� __qualname__�setr r3 r5 r6 r) r# r: r r r; r% r1 r1 r1 r2 r
s 4
r
)Z
__future__r r r �typeZ
__metaclass__r r7 r! Zansible.module_utils._textr Z ansible.module_utils.connectionr Zansible.module_utils.sixr r Zansible.utils.displayr r �objectr
r1 r1 r1 r2 �<module> s