o aqeMU@sRdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddlmZddlmZmZmZddlmZmZddlmZddlmZdd lmZmZmZmZmZddl Z dd l m!Z!m"Z"ddl#m$Z%dd l#m&Z&dd l'm(Z(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1ddl2m3Z3GdddZ4dS)z5A Python module for interacting with Slack's Web API.N) HTTPResponse) SSLContext)BinaryIODictList)OptionalUnion) HTTPError) urlencode)RequesturlopenOpenerDirector ProxyHandler HTTPSHandler)FormData BasicAuth)SlackRequestError)convert_bool_to_0_or_1get_user_agent)_get_event_loop_build_req_args_get_url_files_to_data_request_with_session)show_2020_01_deprecation) SlackResponsec@seZdZdZdeddddddddddf deedededeejd ee d eed e d e d ee j dee deedeefddZdddddddddedede dee efde de de de deejeffddZdeded e defd!d"Zdeeeffd#d$Zdefd%d&Zdeeeffd'd(Zdiiiiid)ded*ed+eeefd,ed-eeefdeeejfd.eeefdefd/d0Zd*ed1eeeeeffdeeeffd2d3Zded4e d5e d.e deeeff d6d7Zed8eded9ed:ede f d;d<Z dS)= BaseClientzhttps://www.slack.com/api/NFtokenbase_urltimeoutloopsslproxy run_asyncuse_sync_aiohttpsessionheadersuser_agent_prefixuser_agent_suffixc Csp|durdn||_||_||_||_||_||_||_| |_| p#i|_ t | | |j d<t t |_||_dS)Nz User-Agent)striprrr r"r#r$r%r&r'rlogging getLogger__name___logger _event_loop) selfrrr r!r"r#r$r%r&r'r(r)r1V/var/www/html/humari/django-venv/lib/python3.10/site-packages/slack/web/base_client.py__init__*s   zBaseClient.__init__POST) http_verbfilesdataparamsjsonr'auth api_methodr5r6r7r8r9r:returnc Cst|j|} |p i}||jt|j||||||||j|jd } t||j s+|j rR|j dur4t |_ t j|j|| | d|j d} |j rG| S|j rP|j | SdS|j| | dS)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: (SlackResponse) 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. ) rr5r6r7r8r9r'r:r"r#Nr5api_urlreq_args)r!)r>r?)rrupdater'rrr"r#rr$r%r/rasyncio ensure_future_sendrun_until_complete _sync_send) r0r;r5r6r7r8r9r'r:r>r?futurer1r1r2api_callHs: -    zBaseClient.api_callr>r?c st|}z"d|vrt|d|d<|j|||dIdH}W|D]}|q n |D]}|q*w|||||jd}tdii||S)aRSends 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 SlackResponse object. r8r=N)clientr5r>r?r%r1)rr_requestcloser%rvalidate)r0r5r>r? open_filesresfr7r1r1r2rCs(  zBaseClient._sendcs"t|j|j|j|||dIdHS)zSubmit the HTTP request with the running session or a new session. Returns: A dictionary of the response data. )current_sessionr loggerr5r>r?N)rr&r r.)r0r5r>r?r1r1r2rIs zBaseClient._requestc Csd|vr|dnd}d|vr|dnd}d|vr|dnd}d|vr&|dnd}d|vr0|dnd}|r=d|vr=|dnd}d|vrG|dnd} | durrt| trY| |d<nt| trc| |d<n|jd | d t| d i} |r{| ||r| ||j ||i| |||d S) Nr8r7r6r9r'rr: Authorizationz As the auth: z: z is unsupported, skipped)rurl query_params body_paramsr6 json_bodyadditional_headers) get isinstancerencodestrr.warningtyper@_urllib_api_call) r0r>r?r8r7r6_jsonr'rr:rTr1r1r2rEs<     zBaseClient._sync_sendcCs4|j||d}t|dt|dt|ddS)aThis method is supposed to be used only for SlackResponse pagination You can paginate using Python's for iterator as below: for response in client.conversations_list(limit=100): # do something with each response here rRargsstatusr'body) status_coder'r7)_perform_urllib_http_requestintdictr9loads)r0r>r?responser1r1r2_request_for_paginations    z"BaseClient._request_for_pagination)rrSrUrTr6rVrRrSrUrTrVcCsg}z;t|}t|}|jjtjkrCdtdtfdd} dd|D} |jd|d| |d | |d | |d |d | i} |d urt|trt |dkr|rf|D] \} } | | | iqZ|D]8\} } t| t rt | ddd}||| | |iqjt| ttfr| | t| iqj| | | iqj|j|p|jtd u|d u|d}|| |||d}|rt|}d|vr|d|n|d|}|j||d}|drz t|d}Wntjjy}z dt |}t||d }~wwd }|rt|}| |n|}||d<t|d|||t|d|ddd W|D] }|j!s<|"q2S|D] }|j!sK|"qAw)aLPerforms a Slack API request and returns the result. :param token: Slack API Token (either bot token or user token) :param url: a complete URL (e.g., https://www.slack.com/api/chat.postMessage) :param query_params: query string :param json_body: json data structure (it's still a dict at this point), if you give this argument, body_params and files will be skipped :param body_params: form params :param files: files to upload :param additional_headers: request headers to append :return: API response valuesr<cSs$|rt|ts iSdd|DS)NcSs$i|]\}}|t|trdn|qS)z(bytes))rXbytes.0kvr1r1r2 -szGBaseClient._urllib_api_call..convert_params..)rXrfitems)rjr1r1r2convert_params*s z3BaseClient._urllib_api_call..convert_paramscSs&i|]\}}||dkrdn|qS) authorizationz (redacted))lowerrlr1r1r2rp2sz/BaseClient._urllib_api_call..zSending a request - url: z, query_params: z, body_params: z , files: z , json_body: z , headers: Nrutf-8ignorerb)rhas_json has_filesrV)r'r7r8r6r9?&r_rbz#Failed to parse the response body: r8r4r'raF)rHr5r>r?r7r'rcr%)#rr.levelr+DEBUGrfrqdebugrXlenr@rZopenrYappend bytearrayrkioBytesIO_build_urllib_request_headersrr9r rdrWrgdecoderJSONDecodeErrorerr SlackApiErrorcopyrrKclosedrJ)r0rrRrSrUrTr6rVfiles_to_closerrr' request_datarnrorNrequest_headers request_argsqrhresponse_body_dataemessage all_paramsr1r1r2r] s   $        zBaseClient._urllib_api_callr`c Cs@|d}|drt|d}d|d<n|drdt}d|d}|d }t}|d}|D]o\} } t| d d } | r| rd } t| d d } | r\t | t rZ| dn| } d|vrd|d} t | dpld}d| d| dd|d}| } n d| d}t| d} ||||d|d|| q6|||}d||d<t||d<n|drt|d}d|d<nd }t |tr|d}zq|drCtd|||d}d }|jd urt |jtr tjt|j|jdt|jd }n td!|jd"d }|r"|j ||j!d#}n t"||j|j!d$}|j#$p2d}| |}|j%|j#|d%WStd&|t&y}z2|j%|j#d'}|j%d(kri|dd)|dd*<|j#$ppd}| |}||d+<|WYd }~Sd }~wt'y}z |j()d,||d }~ww)-aPerforms an HTTP request and parses the response. :param url: a complete URL (e.g., https://www.slack.com/api/chat.postMessage) :param args: args has "headers", "data", "params", and "json" "headers": Dict[str, str] "data": Dict[str, any] "params": Dict[str, str], "json": Dict[str, any], :return: dict {status: int, headers: Headers, body: str} r'r9application/json;charset=utf-8 Content-Typer7z--------------s --asciis-- readableNz Uploaded filenamerufilenamerzapplication/octet-streamz( Content-Disposition: form-data; name="z "; filename="z" zContent-Type: z s zmultipart/form-data; boundary=zContent-Lengthr8!application/x-www-form-urlencodedhttpr4)methodrRr7r')rhttps)contextzInvalid proxy detected: z must be a str value)r )rr )rar'rbzInvalid URL detected: )rar'iz retry-afterz Retry-Afterrbz.Failed to send a request to Slack API server: )*r9dumpsuuiduuid4rYrrrqgetattrrrXrkdecode mimetypes guess_typereadrZwritegetvaluerr rt startswithr r#urllibrequest build_openerrrr"rrr r r'get_content_charsetcoder Exceptionr.error)r0rRr`r'rbboundary sep_boundary end_boundaryr7keyvaluerr name_attrmimetypetitlereqopenerrespcharsetrrr1r1r2rds                      z'BaseClient._perform_urllib_http_requestrxrycCs`ddi}||j|r|dd|i|r|||r&|ddi|r.|dd|S)NrrrQz Bearer {}r)r@r'formatpop)r0rrxryrVr'r1r1r2rs   z(BaseClient._build_urllib_request_headerssigning_secret timestamp signaturecCsVtdttd|d|}t|}t||tj }d|}t ||S)a Slack creates a unique string for your app and shares it with you. Verify requests from Slack with confidence by verifying signatures using your signing secret. On each HTTP request that Slack sends, we add an X-Slack-Signature HTTP header. The signature is created by combining the signing secret with the body of the request we're sending using a standard HMAC-SHA256 keyed hash. https://api.slack.com/docs/verifying-requests-from-slack#how_to_make_a_request_signature_in_4_easy_steps__an_overview Args: signing_secret: Your application's signing secret, available in the Slack API dashboard data: The raw body of the incoming request - no headers, just the body. timestamp: from the 'X-Slack-Request-Timestamp' header signature: from the 'X-Slack-Signature' header - the calculated signature should match this. Returns: True if signatures matches zqAs this method is deprecated since slackclient 2.6.0, use `from slack.signature import SignatureVerifier` insteadzv0::zv0=) warningswarnDeprecationWarningrZrYhmacnewhashlibsha256 hexdigestcompare_digest)rr7rr format_reqencoded_secret request_hashcalculated_signaturer1r1r2validate_slack_signatures   z#BaseClient.validate_slack_signature)!r- __module__ __qualname__BASE_URLrrZrerAAbstractEventLooprboolaiohttp ClientSessionrfr3rrFuturerrGrCranyrIrErirrr]rdr staticmethodrr1r1r1r2r's     "    T )$     v  q  r)5__doc__rArrrrr9r+rrrr http.clientrr"rtypingrrrrr urllib.errorr urllib.parser urllib.requestr r r rrrrr slack.errorserrorsrr slack.webrrslack.web.async_internal_utilsrrrrrslack.web.deprecationrslack.web.slack_responserrr1r1r1r2s8