o
    [۷i0                     @  s   d dl mZ d dlZd dlmZ d dlmZmZm	Z	m
Z
 d dlmZmZmZ d dlmZmZ d dlmZ d dlmZ d d	lmZ d
dlmZ ddlmZ ddlmZmZ ddlmZm Z m!Z!m"Z"m#Z#m$Z$ erld dl%m&Z& G dd deZ'dgZ(dS )    )annotationsN)Mapping)TYPE_CHECKINGAnyget_args
get_origin)JsonTypeAdapterValidationError)deep_updateis_model_class)is_pydantic_dataclass)	FieldInfo)is_union_origin   )_lenient_issubclass   )PydanticBaseEnvSettingsSource)EnvNoneTypeEnvPrefixTarget)_annotation_contains_types_annotation_enum_name_to_val_annotation_is_complex_get_model_fields_union_is_complexparse_env_vars)BaseSettingsc                      s   e Zd ZdZ								d5d6 fddZd7ddZd8ddZd9d#d$Zd:d&d'Z	d;d<d+d,Z	d=d/d0Z
d>d1d2Zd?d3d4Z  ZS )@EnvSettingsSourcezN
    Source class for loading settings values from environment variables.
    Nsettings_clstype[BaseSettings]case_sensitivebool | None
env_prefix
str | Noneenv_prefix_targetEnvPrefixTarget | Noneenv_nested_delimiterenv_nested_max_split
int | Noneenv_ignore_emptyenv_parse_none_strenv_parse_enumsreturnNonec
           
   	     sv   t  |||||||	 |d ur|n| jd| _|d ur|n| jd| _| jp*dd | _t| j| _	| 
 | _d S )Nr&   r'   r      )super__init__configgetr&   r'   maxsplitlenr"   env_prefix_len_load_env_varsenv_vars)
selfr   r    r"   r$   r&   r'   r)   r*   r+   	__class__ ]/home/ubuntu/vllm_env/lib/python3.10/site-packages/pydantic_settings/sources/providers/env.pyr0   '   s    
zEnvSettingsSource.__init__Mapping[str, str | None]c                 C  s   t tj| j| j| jS N)r   osenvironr    r)   r*   r8   r;   r;   r<   r6   G   s   z EnvSettingsSource._load_env_varsfieldr   
field_namestrtuple[Any, str, bool]c                 C  s>   d}|  ||D ]\}}}| j|}|dur nq|||fS )ah  
        Gets the value for field from environment variables and a flag to determine whether value is complex.

        Args:
            field: The field.
            field_name: The field name.

        Returns:
            A tuple that contains the value (`None` if not found), key, and
                a flag to determine whether value is complex.
        N)_extract_field_infor7   r2   )r8   rB   rC   env_val	field_keyenv_namevalue_is_complexr;   r;   r<   get_field_valueJ   s   
z!EnvSettingsSource.get_field_valuevaluer   rJ   boolc           
   
   C  s   |  |\}}| jrt|j|}|du r|n|}|s|rgt|tr#|S |du r5| ||| j}|r3|S dS z	| |||}W n t	yT }	 z
|sJ|	W Y d}	~	nd}	~	ww t|t
ret|| ||| jS |S |durq| ||S dS )a  
        Prepare value for the field.

        * Extract value for nested field.
        * Deserialize value to python object for complex field.

        Args:
            field: The field.
            field_name: The field name.

        Returns:
            A tuple contains prepared value for the field.

        Raises:
            ValuesError: When There is an error in deserializing value for complex field.
        N)_field_is_complexr+   r   
annotation
isinstancer   explode_env_varsr7   decode_complex_value
ValueErrordictr   _coerce_env_val_strict)
r8   rC   rB   rL   rJ   
is_complexallow_parse_failureenum_valenv_val_builter;   r;   r<   prepare_field_value_   s4   

z%EnvSettingsSource.prepare_field_valuetuple[bool, bool]c                 C  sB   |  |rd}d|fS tt|jrt|j|jrd}d|fS dS )za
        Find out if a field is complex, and if so whether JSON errors should be ignored
        FT)FF)field_is_complexr   r   rO   r   metadata)r8   rB   rW   r;   r;   r<   rN      s   
z#EnvSettingsSource._field_is_complexFieldInfo | Any | NonekeyFieldInfo | Nonec                 C  s   |sdS t |tr|jn|}t|D ]}| |||}|r!|  S qtt|tr/t|d S t|s7t	|r{t
|}| D ];\}}	| |	|D ]0\}
}}
|du sT|rc||ks\||krb|	    S qI| | kss| | kry|	    S qIq?dS )aK  
        Find the field in a sub model by key(env name)

        By having the following models:

            ```py
            class SubSubModel(BaseSettings):
                dvals: Dict

            class SubModel(BaseSettings):
                vals: list[str]
                sub_sub_model: SubSubModel

            class Cfg(BaseSettings):
                sub_model: SubModel
            ```

        Then:
            next_field(sub_model, 'vals') Returns the `vals` field of `SubModel` class
            next_field(sub_model, 'sub_sub_model') Returns `sub_sub_model` field of `SubModel` class

        Args:
            field: The field.
            key: The key (env name).
            case_sensitive: Whether to search for key case sensitively.

        Returns:
            Field if it finds the next field otherwise `None`.
        N)rP   r   rO   r   
next_fieldr   r   rT   r   r   r   itemsrF   lower)r8   rB   r`   r    rO   type_type_has_keyfieldsrC   f_rI   r;   r;   r<   rc      s.     zEnvSettingsSource.next_fieldr7   dict[str, Any]c                   s  j si S |j}|tu ptt|t}fdd||D }i }| D ]\ }zt fdd|D }	W n	 ty@   Y q&w  t	|	d }
|

j j^ }}|}|}|D ]}||j}t|tro||i }qZ||j}|s||r|rt|tr|\}}jrt|j|}|du r|n|}n|rt|g }d}nd\}}|rzt|tr|nd}|||}W n ty } z
|s|W Y d}~nd}~ww t|tr||vst|tr|| i kr||||< q&|S )a  
        Process env_vars and extract the values of keys containing env_nested_delimiter into nested dictionaries.

        This is applied to a single field, hence filtering by env_var prefix.

        Args:
            field_name: The field name.
            field: The field.
            env_vars: Environment variables.

        Returns:
            A dictionary contains extracted values from nested env values.
        c                   s    g | ]\}}}|  j  qS r;   )r&   ).0rj   rI   rA   r;   r<   
<listcomp>   s    z6EnvSettingsSource.explode_env_vars.<locals>.<listcomp>c                 3  s    | ]
}  |r|V  qd S r>   )
startswith)rl   prefix)rI   r;   r<   	<genexpr>   s    z5EnvSettingsSource.explode_env_vars.<locals>.<genexpr>NT)TT)r&   rO   rT   r   r   rF   rd   nextStopIterationr4   splitr3   rc   r    rP   
setdefaultr   rN   r+   r   r   rR   rS   r   rU   )r8   rC   rB   r7   annis_dictprefixesresultrG   ro   env_name_without_prefixkeyslast_keyenv_vartarget_fieldr`   rV   allow_json_failurerX   
field_inforZ   r;   )rI   r8   r<   rQ      sd   





z"EnvSettingsSource.explode_env_varsc                 C  s   z5| j dr*t|tr-|dur0|| jkr|W S t|jtfdds3t|j	|W S W |S W |S W |S W |S  t
y?   Y |S w )a   
        Coerce environment string values based on field annotation if model config is `strict=True`.

        Args:
            field: The field.
            value: The value to coerce.

        Returns:
            The coerced value if successful, otherwise the original value.
        strictNT)is_instance)r1   r2   rP   rD   r*   r   rO   r   r	   validate_pythonr
   )r8   rB   rL   r;   r;   r<   rU     s$   
z(EnvSettingsSource._coerce_env_val_strictc                 C  s   | j j d| jd| jdS )Nz(env_nested_delimiter=z, env_prefix_len=))r:   __name__r&   r5   rA   r;   r;   r<   __repr__/  s   zEnvSettingsSource.__repr__)NNNNNNNN)r   r   r    r!   r"   r#   r$   r%   r&   r#   r'   r(   r)   r!   r*   r#   r+   r!   r,   r-   )r,   r=   )rB   r   rC   rD   r,   rE   )
rC   rD   rB   r   rL   r   rJ   rM   r,   r   )rB   r   r,   r\   r>   )rB   r_   r`   rD   r    r!   r,   ra   )rC   rD   rB   r   r7   r=   r,   rk   )rB   ra   rL   r   r,   r   )r,   rD   )r   
__module____qualname____doc__r0   r6   rK   r[   rN   rc   rQ   rU   r   __classcell__r;   r;   r9   r<   r   "   s(    
 


.
8
Dr   ))
__future__r   _annotationsr?   collections.abcr   typingr   r   r   r   pydanticr   r	   r
   pydantic._internal._utilsr   r   pydantic.dataclassesr   pydantic.fieldsr   typing_inspection.introspectionr   utilsr   baser   typesr   r   r   r   r   r   r   r   pydantic_settings.mainr   r   __all__r;   r;   r;   r<   <module>   s&     	  
