o
    `j                     @   s6   d dl Zd dlZd dlZd dlZdddZdd ZdS )    Nc                 C   s   |d u r	t d }nt|r|j }d}tj|| d }tt	|d|}t
||}|r@|d |d< t|dkr@|d |d< d	d
 |dg D }|rVt|dg | |S )Nz
.resourcesz(?m)((?:^\s*//.*\n?)+)z.json r   license   docc                 S   s   i | ]	}|d  |d qS )namefields ).0sr   r   ^/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/schemas/load_json.py
<dictcomp>   s    zload_json.<locals>.<dictcomp>commonStructsr   )__package__inspectismodule	importlib	resources	read_textjsonloadsresubfindalllenget_resolve_common_structs)msg_typepackageCOMMENTS_REGEXmsg_jsondatacommentscommon_structsr   r   r   	load_json   s    

r#   c                 C   s   | D ]C}|d }d }| dr |dd  }|r|d  r|}n
|r*|d  r*|}|r:||v r:d|vr:|| |d< d|v rEt|d | qd S )Ntypez[]   r   r   )
startswithisupperr   )r   r"   field
field_typestruct_name
inner_typer   r   r   r      s    
r   )N)importlib.resourcesr   r   r   r   r#   r   r   r   r   r   <module>   s    
