�
E�g� � �F � U d dl Z d dlZd dlmZmZmZmZmZmZm Z ddl
m Z m Z dZ
d dlZ eej d� � Zn# e$ r dZdZY nw xY wej ej z Zej ej z Z G d� d e � � Z G d
� d e � � Zee eef ZereneZ ee d < dS )
� N)�Any�Dict�List�Optional�Tuple�Type�Union� )�AbstractResolver�
ResolveResult)�ThreadedResolver�
AsyncResolver�DefaultResolver� getaddrinfoFc
� � e Zd ZdZd deej ddfd�Zdej fde
de d ej de
e fd
�Zd
d �ZdS )r
z�Threaded resolver.
Uses an Executor for synchronous getaddrinfo() calls.
concurrent.futures.ThreadPoolExecutor is used by default.
N�loop�returnc �: � |pt j � � | _ d S �N)�asyncio�get_running_loop�_loop)�selfr s �`/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/aiohttp/resolver.py�__init__zThreadedResolver.__init__ s � ��7�W� 5� 7� 7��
�
�
� r �host�port�familyc � � K � | j � ||t j |t j �� � � d {V ��}g }|D ]�\ }}}}}|t j k rct
|� � dk r�,|d r9| j � |t � � � d {V ��\ } }
t |
� � }n%|d d� \ } }n|t j
k sJ �|\ } }|� t || |||t �� � � � ��|S )N)�typer �flags� � ��hostnamer r r �protor" )r r �socket� SOCK_STREAM�
AI_ADDRCONFIG�AF_INET6�len� getnameinfo�_NAME_SOCKET_FLAGS�int�AF_INET�appendr �_NUMERIC_SOCKET_FLAGS) r r r r �infos�hosts�_r' �address�
resolved_host�_ports r �resolvezThreadedResolver.resolve! so � � � � �j�,�,� � ��#���&� -�
�
�
�
�
�
�
�
�� &(��,1� � � (�F�A�u�a���� �(�(��w�<�<�!�#�#� ��1�:� 6� 26��1G�1G� �!3�2� 2� ,� ,� ,� ,� ,� ,�(�M�5� �u�:�:�D�D�*1�"�1�"�+�'�M�4�4� �� �/�/�/�/�&-�#�
�t� �L�L� � !�&� �!� �/�
� � �
�
�
�
� � r c � �
K � d S r � �r s r �closezThreadedResolver.closeM s � � � � �r r �r N)�__name__�
__module__� __qualname__�__doc__r r �AbstractEventLoopr r( r0 �strr/ �
AddressFamilyr r r9 r= r; r r r
r
s� � � � � � �� � 8� 8�X�g�&?� @� 8�D� 8� 8� 8� 8� &'�v�~�*� *��*� "�*�06�0D�*�
�m� �*� *� *� *�X
�
�
�
�
�
r r
c �� � e Zd ZdZ ddeej dededdfd�Zde j
fd e d
e d e j
dee fd �Zde j
fd e d
e d e deee ef fd
�Zdd�ZdS )r z9Use the `aiodns` package to make asynchronous DNS lookupsNr �args�kwargsr c � � t �t d� � �t j |i |��| _ t | j d� � s| j | _ d S d S )Nz Resolver requires aiodns library�
gethostbyname)�aiodns� RuntimeError� DNSResolver� _resolver�hasattr�_resolve_with_queryr9 )r r rG rH s r r zAsyncResolver.__init__T s[ � � �>� � A�B�B� B� �+�T�<�V�<�<����t�~��7�7� 4� �3�D�L�L�L� 4� 4r r r r r c � � K � | j � ||t j |t j �� � � d {V ��}nT# t
j j $ r=}t |j � � dk r
|j d nd}t d |� � |�d }~ww xY wg }|j D �]}|j } |j
}|t j k r�t | � � dk r[| d rS| j � | d � d� � g| dd � �R t" � � � d {V ��}
|
j } nY| d � d� � } | d }n5|t j k sJ �| d � d� � } | d }|� t+ || ||dt, �� � � � ��|st d d� � �|S )N)r r! r r" r
�DNS lookup failedr# r �asciir% )rN r r( r) r* rK �error�DNSErrorr, rG �OSError�nodes�addrr r+ r- �decoder. �noder0 r1 r r2 ) r r r r �resp�exc�msgr4 rZ r6 �resultr7 s r r9 zAsyncResolver.resolvec s$ � � � �
.� � �3�3����'� � �*� 4� � � � � � � � �D�D�� �|�$� .� .� .�!$�S�X� � �!�!3�!3�#�(�1�+�+�9L�C��$��$�$�#� -����� .���� &(���J� � �D�MQ�Y�G��[�F��� �(�(��w�<�<�!�#�#���
�#� $(�>�#=�#=� ���*�*�7�3�3�B�g�a�b�b�k�B�B�*�$� $� � � � � � �F� %+�K�M�M�$+�A�J�$5�$5�g�$>�$>�M�"�1�:�D�D� �� �/�/�/�/� '��
� 1� 1�'� :� :�
� �q�z�� �L�L� � !�&� �!��/�
� � �
�
�
�
� � 5��$� 3�4�4� 4�� s �9> �B�8B
�
Bc
� � K � |t j k rd}nd} | j � ||� � � d {V ��}nT# t j j $ r=}t |j � � dk r
|j d nd}t d |� � |�d }~ww xY wg }|D ]-} |�
|| j ||dt j d�� � �.|st d d� � �|S )N�AAAA�Ar
rR r r% )
r( r+ rN �queryrK rT rU r, rG rV r1 r �AI_NUMERICHOST)
r r r r �qtyper[ r\ r] r4 �rrs
r rP z!AsyncResolver._resolve_with_query� s � � � � �V�_� $� $��E�E��E� .� � �-�-�d�E�:�:�:�:�:�:�:�:�D�D���|�$� .� .� .�!$�S�X� � �!�!3�!3�#�(�1�+�+�9L�C��$��$�$�#� -����� .���� ���
�
�B� �L�L� $� �G� � $� � #� 2�
� �
�
�
�
� � 5��$� 3�4�4� 4�� s �!; �B �8B�B c � �< K � | j � � � d S r )rN �cancelr< s r r= zAsyncResolver.close� s � � � � �� � � � � � � r r r> )r? r@ rA rB r r rC r r r( r0 rD r/ rE r r r9 r rP r= r; r r r r Q s � � � � � �C�C� 59�
4�
4��w�0�1�
4� �
4� �
4�
�
4�
4�
4�
4� &'�v�~�1� 1��1� "�1�06�0D�1�
�m� �1� 1� 1� 1�h &'�f�n� � �� � "� �03� �
�d�3��8�n� � � � � �@ � � � � � r r r ) r r( �typingr r r r r r r �abcr r �__all__rK rO rM �aiodns_default� ImportErrorrc �AI_NUMERICSERVr2 �NI_NUMERICHOST�NI_NUMERICSERVr. r
r � _DefaultTyper �__annotations__r; r r �<module>rr st �� �����
�
�
�
� @� @� @� @� @� @� @� @� @� @� @� @� @� @� @� @� @� @� 0� 0� 0� 0� 0� 0� 0� 0�
B����M�M�M� �W�V� /� �?�?�N�N��� � � �
�F��N�N�N�����
�-��0E�E� ��*�V�-B�B� �7
� 7
� 7
� 7
� 7
�'� 7
� 7
� 7
�tf � f � f � f � f �$� f � f � f �R �E�-�)9�9�:�;� �1?� U�
�
�EU�� � U� U� U� U� Us �= � A �A