
    <i                         d dl Z d dlmZmZ d dlmZ d dlmZmZm	Z	m
Z
 d dlmZmZ dZdZh dZ G d	 d
e          Z G d de          ZdS )    N)ABCabstractmethod)ThreadPoolExecutor)AnyMappingOptionalUnion)
HttpClientHttpResponsez)HttpClient/1.0 (+https://example.invalid)g      >@>             c                      e Zd Ze	 	 	 	 ddedeeeedeee	e
eef         f                  deeeef                  dee	         de
deeef         fd	            Ze	 	 	 	 ddedeeeedeee	e
eef         f                  deeeef                  dee	         de
deeef         fd
            Ze	 	 	 	 	 	 ddedee         deeeef                  deeeedeee	e
eef         f                  deeeef                  dee	         de
deeef         fd            Ze	 	 	 	 	 	 ddedee         deeeef                  deeeedeee	e
eef         f                  deeeef                  dee	         de
deeef         fd            Ze	 	 	 	 	 	 ddedee         deeeef                  deeeedeee	e
eef         f                  deeeef                  dee	         de
deeef         fd            Ze	 	 	 	 ddededeeeedeee	e
eef         f                  deeeef                  deeeef                  dee	         defd            ZdS )AsyncHTTPClientNTpathparamsheaderstimeoutexpect_jsonreturnc                 
   K   dS )z!
        Invoke HTTP GET request.N selfr   r   r   r   r   s         /Users/kimhansen/Desktop/03 Workspace/ceo-agents/chl-effectiveness/mcp-servers/whoop/.venv/lib/python3.11/site-packages/redis/asyncio/http/http_client.pygetzAsyncHTTPClient.get          	    c                 
   K   dS )z$
        Invoke HTTP DELETE request.Nr   r   s         r   deletezAsyncHTTPClient.delete   r   r    	json_bodydatac                 
   K   dS )z"
        Invoke HTTP POST request.Nr   r   r   r#   r$   r   r   r   r   s           r   postzAsyncHTTPClient.post,          	r    c                 
   K   dS )z!
        Invoke HTTP PUT request.Nr   r&   s           r   putzAsyncHTTPClient.put=   r(   r    c                 
   K   dS )z#
        Invoke HTTP PATCH request.Nr   r&   s           r   patchzAsyncHTTPClient.patchN   r(   r    methodbodyc                 
   K   dS )z/
        Invoke HTTP request with given method.Nr   )r   r-   r   r   r   r.   r   s          r   requestzAsyncHTTPClient.request_   s       	r    NNNTNNNNNTNNNN)__name__
__module____qualname__r   strr   r   r	   intfloatboollisttupler   r   r   r"   bytesr'   r*   r,   r0   r   r    r   r   r      s        /3#'   CtS#udD%GHHI
 '#s(+, %  
|S 	!   ^  /3#'   CtS#udD%GHHI
 '#s(+, %  
|S 	!   ^  $(,0 /3#'   C= uUCZ()	
 CtS#udD%GHHI
 '#s(+, %  
|S 	!   ^   $(,0 /3#'   C= uUCZ()	
 CtS#udD%GHHI
 '#s(+, %  
|S 	!   ^   $(,0 /3#'   C= uUCZ()	
 CtS#udD%GHHI
 '#s(+, %  
|S 	!   ^   /3,0#'   CtS#udD%GHHI
	 '#s(+, uUCZ() % 
   ^  r    r   c                   d   e Zd ZdZddededdfdZ	 	 	 	 dd	ed
ee	ee
deeeeeef         f                  dee	eef                  dee         dede
eef         fdZ	 	 	 	 dd	ed
ee	ee
deeeeeef         f                  dee	eef                  dee         dede
eef         fdZ	 	 	 	 	 	 dd	edee         dee
eef                  d
ee	ee
deeeeeef         f                  dee	eef                  dee         dede
eef         fdZ	 	 	 	 	 	 dd	edee         dee
eef                  d
ee	ee
deeeeeef         f                  dee	eef                  dee         dede
eef         fdZ	 	 	 	 	 	 dd	edee         dee
eef                  d
ee	ee
deeeeeef         f                  dee	eef                  dee         dede
eef         fdZ	 	 	 	 dded	ed
ee	ee
deeeeeef         f                  dee	eef                  dee
eef                  dee         defdZdS )AsyncHTTPClientWrapperzN
    An async wrapper around sync HTTP client with thread pool execution.
    
   clientmax_workersr   Nc                 >    || _         t          |          | _        dS )a  
        Initialize a new HTTP client instance.

        Args:
            client: Sync HTTP client instance.
            max_workers: Maximum number of concurrent requests.

        The client supports both regular HTTPS with server verification and mutual TLS
        authentication. For server verification, provide CA certificate information via
        ca_file, ca_path or ca_data. For mutual TLS, additionally provide a client
        certificate and key via client_cert_file and client_key_file.
        )rB   N)rA   r   	_executor)r   rA   rB   s      r   __init__zAsyncHTTPClientWrapper.__init__u   s!     +DDDr    Tr   r   r   r   r   c           	         K   t          j                    }|                    | j        | j        j        |||||           d {V S N)asyncioget_event_looprun_in_executorrD   rA   r   r   r   r   r   r   r   loops          r   r   zAsyncHTTPClientWrapper.get   sa       %''))NDKOT67G[
 
 
 
 
 
 
 
 	
r    c           	         K   t          j                    }|                    | j        | j        j        |||||           d {V S rG   )rH   rI   rJ   rD   rA   r"   rK   s          r   r"   zAsyncHTTPClientWrapper.delete   sh       %''))NK
 
 
 
 
 
 
 
 	
r    r#   r$   c                    K   t          j                    }|                    | j        | j        j        |||||||	  	         d {V S rG   )rH   rI   rJ   rD   rA   r'   	r   r   r#   r$   r   r   r   r   rL   s	            r   r'   zAsyncHTTPClientWrapper.post   sn       %''))NK

 

 

 

 

 

 

 

 
	
r    c                    K   t          j                    }|                    | j        | j        j        |||||||	  	         d {V S rG   )rH   rI   rJ   rD   rA   r*   rO   s	            r   r*   zAsyncHTTPClientWrapper.put   sm       %''))NKO

 

 

 

 

 

 

 

 
	
r    c                    K   t          j                    }|                    | j        | j        j        |||||||	  	         d {V S rG   )rH   rI   rJ   rD   rA   r,   rO   s	            r   r,   zAsyncHTTPClientWrapper.patch   sn       %''))NK

 

 

 

 

 

 

 

 
	
r    r-   r.   c           
         K   t          j                    }|                    | j        | j        j        ||||||           d {V S rG   )rH   rI   rJ   rD   rA   r0   )r   r-   r   r   r   r.   r   rL   s           r   r0   zAsyncHTTPClientWrapper.request   sk       %''))NK	
 	
 	
 	
 	
 	
 	
 	
 		
r    )r@   r1   r2   r3   )r4   r5   r6   __doc__r
   r8   rE   r7   r   r   r	   r9   r:   r;   r<   r   r   r   r"   r=   r'   r*   r,   r0   r   r    r   r?   r?   p   s        E Ez E ET E E E E* /3#' 
 

 CtS#udD%GHHI

 '#s(+,
 %
 
 
|S 	!
 
 
 
( /3#' 
 

 CtS#udD%GHHI

 '#s(+,
 %
 
 
|S 	!
 
 
 
0 $(,0 /3#' 
 

 C=
 uUCZ()	

 CtS#udD%GHHI

 '#s(+,
 %
 
 
|S 	!
 
 
 
8 $(,0 /3#' 
 

 C=
 uUCZ()	

 CtS#udD%GHHI

 '#s(+,
 %
 
 
|S 	!
 
 
 
8 $(,0 /3#' 
 

 C=
 uUCZ()	

 CtS#udD%GHHI

 '#s(+,
 %
 
 
|S 	!
 
 
 
> /3,0#'
 

 
 CtS#udD%GHHI
	
 '#s(+,
 uUCZ()
 %
 

 
 
 
 
 
r    r?   )rH   abcr   r   concurrent.futuresr   typingr   r   r   r	   redis.http.http_clientr
   r   DEFAULT_USER_AGENTDEFAULT_TIMEOUTRETRY_STATUS_CODESr   r?   r   r    r   <module>r[      s     # # # # # # # # 1 1 1 1 1 1 0 0 0 0 0 0 0 0 0 0 0 0 ; ; ; ; ; ; ; ;@ ... ` ` ` ` `c ` ` `FY
 Y
 Y
 Y
 Y
_ Y
 Y
 Y
 Y
 Y
r    