File: //var/opt/nydus/ops/primordial/__pycache__/jsonutils.cpython-39.pyc
a
�,�h� � @ s d dl Z d dlZd dlmZmZ d dlZd dlZd dlmZ d dlm Z m
Z
m Z d dl m
Z d dl mZ d dlmZ dZd Ze�e�Ze e e f e e e f ed
�d d �Ze e e f ed
�dd�Ze
ed�dd�Z ee
d�dd�Z G dd� de�Z e� d�Z G dd� de�Z!dS )� N)� JSONEncoder� JSONDecoder)�
import_module)�Any�Callable�Dict)�validate)�
exceptions)�CANONICAL_TIMESTRING_FORMATg �?� )� json_dict� schema_dict�returnc C sD | dus J �|dusJ �zt | |� W dS tjy> Y dS 0 dS )a Test that json_dict dictionary conforms to the swagger schema provided.
:param json_dict: A dictionary of values
:param schema_dict: A dict representation of swagger schema
:returns: True or False
:raises AssertionError: if either is None
NTF)�
json_validate�json_exceptionsZValidationError)r r
� r �E/opt/nydus/tmp/pip-target-wkfpz8uv/lib/python/primordial/jsonutils.py�validate_swagger s
r )r r c C s t j| tddd�S )aY Return a pretty-formatted string containing the values in json_dict.
:param json_dict: A dictionary or other object that is serializable as a json string
:returns: a (unicode) string representation with a default format of sorted keys and indent of 4 spaces
:raises TypeError: if the thing in question cannot be json serialized
T)�,�:)�cls� sort_keys�
separators)�json�dumps�DateTimeEncoder)r r r r �pretty_json_str& s r )�funcr c C s d| j | jf S )z�Create a string for a python function in a module.
Class and object methods not supported currently.
:param func: a python function
:returns: a string representing this function
z%s.%s)�
__module__�__name__)r r r r � func_to_str0 s r )�func_strr c C s* | � d�}|�� }td�|��}t||�S )a= Use importlib to turn a string into a function.
At the moment, this is limited to module functions and not classes.
:param func_str: the string representation of a function, e.g. ``tests.test_workflow.ex_tst_func``
:returns: a python function
:raises ImportError: if the function does not exist
�.)�split�popr �join�getattr)r! Z funcnotation�symbol�moduler r r � str_to_func; s
r) c @ s e Zd ZdZeed�dd�ZdS )r �Uses our canonical format.)�objr c C s( t |tj�r|�t�}n t�| |�}|S �N)�
isinstance�datetime�strftimer
r �default)�selfr+ �retr r r r0 L s zDateTimeEncoder.defaultN)r r � __qualname__�__doc__r r0 r r r r r J s r z:^(\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2}):(\d{2}).(\d{6})Z$c s8 e Zd ZdZ� fdd�Zeeef ed�dd�Z� ZS )�DateTimeDecoderr* c s t � j|d| ji|�� d S )N� object_hook)�super�__init__�dict_to_object)r1 �args�kwargs�� __class__r r r8 Z s zDateTimeDecoder.__init__)�dr c C s< |� � D ].\}}t|t�rt�|�rtj�|t�||< q|S r, )�itemsr- �str�DATETIME_REGEX�matchr. �strptimer
)r1 r> �key�valuer r r r9 ] s z DateTimeDecoder.dict_to_object) r r r3 r4 r8 r r r9 �
__classcell__r r r< r r5 X s r5 )"r. r r r �logging�re� importlibr �typingr r r Z
jsonschemar r r r Zprimordial.constantsr
ZDELAY_INCREASE_SECSZ MAX_RETRIES� getLoggerr �LOGGER�boolr r@ r r r) r �compilerA r5 r r r r �<module> s&
"