'jJ&ddlZddlmZddlmZmZmZmZmZddl Z ddl m Z m Z ddl m Z mZddlmZddlmZdd lmZdd lmZmZmZmZd d lmZdd lmZddlmZGddZ dS)N) SSLContext)OptionalUnionDictAnyList)FormData BasicAuth)_files_to_data_request_with_session)AsyncSlackResponse)show_deprecation_warning_if_any)FileUploadV2Result)convert_bool_to_0_or_1_build_req_args_get_urlget_user_agent)load_http_proxy_from_env)async_default_handlers)AsyncRetryHandlerc8eZdZdZdedddddddddddf deedededeed eed eej d e d ee d eedeedeedee j deeefdZede j fdZdddddddddededee deee efdee dee d ee dee defdZdeded e defd!Zdeeeffd"Zd#edede j ded eedeedefd$ZdS)%AsyncBaseClientzhttps://slack.com/api/NFtokenbase_urltimeoutsslproxysessiontrust_env_in_sessionheadersuser_agent_prefixuser_agent_suffixteam_idloggerretry_handlerscV|dn||_ |ds|dz }||_ ||_ ||_ ||_ ||_ ||_ |pi|_ t| | |j d<i|_ | | |j d<| | ntj t|_| | n t!|_|j*t%|jdkr!t'|j}| ||_dSdSdS)N/z User-Agentr&r)striprendswithrrrr r!r"r#rdefault_paramslogging getLogger__name___loggerrr(lenr)selfrrrrr r!r"r#r$r%r&r'r( env_variables `/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/slack_sdk/web/async_base_client.py__init__zAsyncBaseClient.__init__s\"#]TT  @  %%  OH   2  "   8   /%9! /}" W%34EGX%Y%Y \"   -4D  *!'!3vv9J89T9T 0>0JnnPfPhPh : TZ%5%5%7%7!8!8A!=!=3DLAAL') ('">!=returnc|jS)zThe logger this client uses.)r1)r3s r5r'zAsyncBaseClient.logger^s |r7POST) http_verbfilesdataparamsjsonr#auth api_methodr;r<r=r>r?r@c Kt|j|} |ct|trt |d|d}t|tr|i}||d<d}|pi}||jt|j ||||j |||||j |j  } t|||| | d{VS)aCreate a request and execute the API call to Slack. Args: api_method (str): The target Slack API method. e.g. 'chat.postMessage' http_verb (str): HTTP Verb. e.g. 'POST' files (dict): Files to multipart upload. e.g. {image OR file: file_object OR file_path} data: The body to attach to the request. If a dictionary is provided, form-encoding will take place. e.g. {'key1': 'value1', 'key2': 'value2'} params (dict): The URL parameters to append to the URL. e.g. {'key1': 'value1', 'key2': 'value2'} json (dict): JSON for the body to attach to the request (if files or data is not specified). e.g. {'key1': 'value1', 'key2': 'value2'} headers (dict): Additional request headers auth (dict): A dictionary that consists of client_id and client_secret Returns: (AsyncSlackResponse) The server's response to an HTTP request. Data from the response can be accessed like a dict. If the response included 'next_cursor' it can be iterated on to execute subsequent requests. Raises: SlackApiError: The following Slack API call failed: 'chat.postMessage'. SlackRequestError: Json data can only be submitted as POST requests. N client_id client_secret Authorization) rr;r<r=r-r>r?r#r@rr r;api_urlreq_args)rr isinstancerr encodeupdater#rrr-rr r_send) r3rAr;r<r=r>r?r#r@rGrHs r5api_callzAsyncBaseClient.api_callfs,Z4=*55  $%% K k!2D4IJJ$ ** ? G+/;;==(-Rt|$$$"*.*     ( 333ZZ          r7rGrHc\Kt|} d|vrt|d|d<||||d{V}|D]}|n#|D]}|wxYw||||d}t dii||S)aWSends the request out for transmission. Args: http_verb (str): The HTTP verb. e.g. 'GET' or 'POST'. api_url (str): The Slack API url. e.g. 'https://slack.com/api/chat.postMessage' req_args (dict): The request arguments to be attached to the request. e.g. { json: { 'attachments': [{"pretext": "pre-hello", "text": "text-world"}], 'channel': '#random' } } Returns: The response parsed into a AsyncSlackResponse object. r>rFN)clientr;rGrH)r r_requestcloservalidate)r3r;rGrH open_filesresfr=s r5rLzAsyncBaseClient._sends"$H--  8##%;HXrws|33333333333333''''''''544444888888555555 A@@@@@NNNNNN@@@@@@d d d d d d d d d d r7