
    iN                     `   d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlmZ ddl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mZmZmZmZ ddl Z dd
l m!Z!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/ ddl0m1Z1 ddl2m3Z3  G d d          Z4dS )z5A Python module for interacting with Slack's Web API.    N)HTTPResponse)
SSLContext)BinaryIODictList)OptionalUnion)	HTTPError)	urlencode)RequesturlopenOpenerDirectorProxyHandlerHTTPSHandler)FormData	BasicAuth)SlackRequestError)convert_bool_to_0_or_1get_user_agent)_get_event_loop_build_req_args_get_url_files_to_data_request_with_session)show_2020_01_deprecation)SlackResponsec                      e Zd ZdZdeddddddddddfdee         dededeej                 d	ee	         d
ee         de
de
deej                 dee         dee         dee         fdZdddddddddedededeeef         dededededeej        ef         fdZdedededefdZdeeef         fd Zdefd!Zdeeef         fd"Zdi i i i i d#ded$ed%eeef         d&ed'eeef         deeej        f         d(eeef         defd)Zd$ed*eeeeef         f         deeef         fd+Zded,e
d-e
d(edeeef         f
d.Zed/eded0ed1ede
f
d2            Z dS )3
BaseClientzhttps://slack.com/api/N   Ftokenbase_urltimeoutloopsslproxy	run_asyncuse_sync_aiohttpsessionheadersuser_agent_prefixuser_agent_suffixc                 .   |d n|                                 | _        || _        || _        || _        || _        || _        || _        |	| _        |
pi | _	        t          ||          | j	        d<   t          j        t                    | _        || _        d S )Nz
User-Agent)stripr    r!   r"   r$   r%   r&   r'   r(   r)   r   logging	getLogger__name___logger_event_loop)selfr    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   s                P/root/projects/butler/venv/lib/python3.11/site-packages/slack/web/base_client.py__init__zBaseClient.__init__*   s     #]TT
 
" 0}"%34EGX%Y%Y\"(22    POST)	http_verbfilesdataparamsjsonr)   auth
api_methodr8   r9   r:   r;   r<   r=   returnc                   t          | j        |          }	|pi }|                    | j                   t	          | j        |||||||| j        | j        
  
        }
t          |           | j	        s| j
        rw| j        t                      | _        t          j        |                     ||	|
          | j                  }| j	        r|S | j
        r| j                            |          S dS |                     |	|
          S )a  Create 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.
        )
r    r8   r9   r:   r;   r<   r)   r=   r$   r%   Nr8   api_urlreq_args)r#   )rB   rC   )r   r!   updater)   r   r    r$   r%   r   r&   r'   r2   r   asyncioensure_future_sendrun_until_complete
_sync_send)r3   r>   r8   r9   r:   r;   r<   r)   r=   rB   rC   futures               r4   api_callzBaseClient.api_callF   s2   Z 4=*55-Rt|$$$"**
 
 
 	!,,,> 	GT2 	G'#2#4#4 *

Y(
SS%  F ~ $ C'::6BBBC C ??7X?FFFr6   rB   rC   c                 h  K   t          |          }	 d|v rt          |d                   |d<   |                     |||           d{V }|D ]}|                                 n# |D ]}|                                 w xY w| |||| j        d}t          di i ||                                S )aR  Sends 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.
        r;   rA   N)clientr8   rB   rC   r'    )r   r   _requestcloser'   r   validate)r3   r8   rB   rC   
open_filesresfr:   s           r4   rG   zBaseClient._send   s      " $H--
	8##%;HX<N%O%O"	7U]^^^^^^^^C  				Z  				 "  $ 5
 
 //$#//88:::s   :A' 'Bc                Z   K   t          | j        | j        | j        |||           d{V S )zSubmit the HTTP request with the running session or a new session.
        Returns:
            A dictionary of the response data.
        )current_sessionr"   loggerr8   rB   rC   N)r   r(   r"   r1   )r3   r8   rB   rC   s       r4   rO   zBaseClient._request   sU      
 + LL<
 
 
 
 
 
 
 
 
 	
r6   c           	      l   d|v r|d         nd }d|v r|d         nd }d|v r|d         nd }d|v r|d         nd }d|v r|d         nd }|rd|v r|                     d          nd }d|v r|d         nd }	|	vt          |	t                    r|	                                |d<   nIt          |	t                    r|	|d<   n.| j                            d	|	 d
t          |	           d           i }
|r|
                    |           |r|
                    |           | 	                    ||i |
|||          S )Nr;   r:   r9   r<   r)   r    r=   AuthorizationzAs the auth: z: z is unsupported, skipped)r    urlquery_paramsbody_paramsr9   	json_bodyadditional_headers)
get
isinstancer   encodestrr1   warningtyperD   _urllib_api_call)r3   rB   rC   r;   r:   r9   _jsonr)   r    r=   r\   s              r4   rI   zBaseClient._sync_send   s   '/8';';(###)X#5#5x4%,%8%8!!d$*h$6$6  D)2h)>)>(9%%D'-M'V2C2C

7####)X#5#5x4$	** c+/;;==((D#&& c+/(($$%aT%a%aT$ZZ%a%a%abbb 	'v&&& 	%t$$$$$#& % 
 
 	
r6   c                     |                      ||          }t          |d                   t          |d                   t          j        |d                   dS )a  This 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
        rZ   argsstatusr)   body)status_coder)   r:   )_perform_urllib_http_requestintdictr<   loads)r3   rB   rC   responses       r4   _request_for_paginationz"BaseClient._request_for_pagination   s]     44x4PPx122HY/00Jx/00
 
 	
r6   )r    r[   r]   r\   r9   r^   rZ   r[   r]   r\   r^   c                   g }	 t          |          }t          |          }| j        j        t          j        k    rwdt
          dt
          fd}	d |                                D             }
| j                            d| d |	|           d |	|           d |	|           d	| d
|
            i }|:t          |t
                    r$t          |          dk    r|r1|                                D ]\  }}|
                    ||i           |                                D ]\  }}t          |t                    rQt          |                    dd          d          }|                    |           |
                    ||i           kt          |t          t           f          r*|
                    |t#          j        |          i           |
                    ||i           |                     |p| j        t*          d u|d u|          }|||||d}|r!t-          |          }d|v r| d| n| d| }|                     ||          }|                    d          r_	 t+          j        |d                   }nE# t*          j        j        $ r,}dt          |           }t9          j        ||          d }~ww xY wd }|r*t=          j        |          }|
                    |           n|}||d<   t?          | d|||t          |d                   |d         d                                           	 |D ]}|j!        s|"                                 S # |D ]}|j!        s|"                                 w xY w)Nvaluesr?   c                 p    | rt          | t                    si S d |                                 D             S )Nc                 H    i | ]\  }}|t          |t                    rd n| S )z(bytes))r`   bytes.0kvs      r4   
<dictcomp>zGBaseClient._urllib_api_call.<locals>.convert_params.<locals>.<dictcomp>  s2    eeedaQRAZ5-A-A H		qeeer6   )r`   ro   items)rt   s    r4   convert_paramsz3BaseClient._urllib_api_call.<locals>.convert_params  sA    ! "FD)A)A "!	eeV\VbVbVdVdeeeer6   c                 N    i | ]"\  }}||                                 d k    rdn|#S )authorizationz
(redacted))lowerrx   s      r4   r|   z/BaseClient._urllib_api_call.<locals>.<dictcomp>  s8    yyyVZVWYZ1aggii?.J.JllPQyyyr6   zSending a request - url: z, query_params: z, body_params: z	, files: z, json_body: z, headers: r   utf-8ignorerb)r    has_json	has_filesr^   )r)   r:   r;   r9   r<   ?&rh   rk   z#Failed to parse the response body: r;   r7   r)   rj   F)rM   r8   rB   rC   r:   r)   rl   r'   )#r   r1   levelr.   DEBUGro   r}   debugr`   lenrD   rb   openra   append	bytearrayrw   ioBytesIO_build_urllib_request_headersr    r<   r   rm   r_   rp   decoderJSONDecodeErrorerrSlackApiErrorcopyr   rQ   closedrP   )r3   r    rZ   r[   r]   r\   r9   r^   files_to_closer~   r)   request_datarz   r{   rT   request_headersrequest_argsqrq   response_body_dataemessage
all_paramss                          r4   re   zBaseClient._urllib_api_call   sd    *,U	1,??L0==K|!W]22f4 fD f f f f
 zy^p^v^v^x^xyyy""* * *%3^L%A%A* *$2N;$?$?* * -nU33* * #,	* *
 !(* *   L Zt%<%< Ua 4 + 1 1 3 3 4 41$++QF3333!KKMM 4 4DAq!!S)) 4&*188GX+F+F&M&M&--a000$++QF3333#A	5'9:: 4$++Q
1,>????$++QF3333"@@)tzT)t+#5	 A  O +$%! L  Cl++&)Sjjllqlllllqll88S|8TTH||F## 0?/3z(6:J/K/K&&|3 ? ? ?LCFFLLG+GX>>>? ,0" )!Y{33
!!,////(
%/L"  %'Xi011$X.!&	 	 	 hjj	 $  x GGIII^  x GGIIIs1   I.M) 3J M) K"'K		KA9M) )"Nri   c                >	   |d         }|d         r!t          j        |d                   }d|d<   n |d         rdt          j                     }d|                    d          z   }|d	z   }t          j                    }|d         }|                                D ]J\  }	}
t          |
d
d           }|r|
	                                rd}t          |
dd           }|r,t          |t                    r|                    d          n|}d|v r|d         }t          j        |          d         pd}d|	 d| dd| dz   }|
                                }
n(d|	 d}t!          |
                              d          }
|                    |           |                    |                    d                     |                    d           |                    |
           L|                    |           |                                }d| |d<   t'          |          |d<   n%|d         rt)          |d                   }d|d<   nd }t          |t                     r|                    d          }	 |                                                    d          r+t/          d|||          }d }| j        t          | j        t                     rNt2          j                            t9          | j        | j        d          t;          | j                            }nt?          d | j         d!          d }|r|                     || j!        "          }ntE          || j        | j!        #          }|j#        $                                pd}|                                                    |          }|j%        |j#        |d$S t?          d%|           # tL          $ r}|j%        |j#        d&}|j%        d'k    r|d         d(         |d         d)<   |j#        $                                pd}|                                                    |          }||d*<   |cY d }~S d }~wtN          $ r$}| j(        )                    d+|            |d }~ww xY w),Nr)   r<   application/json;charset=utf-8Content-Typer:   z--------------s   
--asciis   --
readablezUploaded filenamer   filenamer   zapplication/octet-streamz(
Content-Disposition: form-data; name="z"; filename="z"
zContent-Type: z
s   
zmultipart/form-data; boundary=zContent-Lengthr;   !application/x-www-form-urlencodedhttpr7   )methodrZ   r:   r)   )r   https)contextzInvalid proxy detected: z must be a str value)r"   )r   r"   )rj   r)   rk   zInvalid URL detected: )rj   r)   i  zretry-afterzRetry-Afterrk   z.Failed to send a request to Slack API server: )*r<   dumpsuuiduuid4ra   r   r   r}   getattrr   r`   rw   decode	mimetypes
guess_typereadrb   writegetvaluer   r   r   
startswithr   r%   urllibrequestbuild_openerr   r   r$   r   r   r"   r   r)   get_content_charsetcoder
   	Exceptionr1   error)r3   rZ   ri   r)   rk   boundarysep_boundaryend_boundaryr:   keyvaluer   r   	name_attrmimetypetitlereqopenerrespcharsetr   r   s                         r4   rm   z'BaseClient._perform_urllib_http_requestc  s   y/< (	:d6l++D&FGN##&\ %	6
66H$xw'?'??L')3L:<<D<D"jjll " "
U"5*d;; 7 0 0 7.H 'vt < <I  l@J9V[@\@\#k9#3#3G#<#<#<bk!T))#'
#3(3H==a@^D^HfSffW_fff98999:  "JJLLEESSSSEJJ--g66E

<(((

5<<00111

7###

5!!!!JJ|$$$==??D&Qx&Q&QGN#(+D		G$%%(^ 	T(^,,D&IGN##DdC   	(;;w''D(	
 yy{{%%f-- TV4QQQ37:)!$*c22 m!'!<!<($*tz)R)RSS(:::" "
 00k4:0k0k0klll 04 P!;;sDL;AADD"3$,OOOD,::<<G IIKK..w77"&)dSSS#$BS$B$BCCC 		 		 		f;;Dv}}15i1OY.i3355@G00DDLKKKKKK 	 	 	LUPSUUVVVI	s2   =EO" O" "
R,A9Q+%R+R8RRr   r   c                 *   ddi}|                     | j                   |r*|                     dd                    |          i           |r|                     |           |r|                     ddi           |r|                    dd            |S )Nr   r   rY   z	Bearer {}r   )rD   r)   formatpop)r3   r    r   r   r^   r)   s         r4   r   z(BaseClient._build_urllib_request_headers  s     "#FGt|$$$ 	INNO[-?-?-F-FGHHH 	/NN-... 	ONNN,LMNNN 	.KK---r6   signing_secret	timestamp	signaturec                 B   t          j        dt                     t                              d| d|           }t                              |           }t          j        ||t          j                  	                                }d| }t          j
        ||          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://docs.slack.dev/authentication/verifying-requests-from-slack/

        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` insteadzv0::zv0=)warningswarnDeprecationWarningrb   ra   hmacnewhashlibsha256	hexdigestcompare_digest)r   r:   r   r   
format_reqencoded_secretrequest_hashcalculated_signatures           r4   validate_slack_signaturez#BaseClient.validate_slack_signature  s    0 	J	
 	
 	

 ZZ 8i 8 8$ 8 899
N33x
GNKKUUWW3\33"#7CCCr6   )!r0   
__module____qualname__BASE_URLr   rb   rn   rE   AbstractEventLoopr   boolaiohttpClientSessionro   r5   r	   r   Futurer   rK   rG   r   anyrO   rI   rr   r   r   re   rm   r   staticmethodr   rN   r6   r4   r   r   '   s       'H  $ 48$(#!&37"&+/+/   }    	 
 w01  j!  }      '/0  $  $C=  $C=       @  &*NG NG NGNG 	NG
 NG D(N#NG NG NG NG NG 
w~},	-NG NG NG NGh#;S #;3 #;$ #;= #; #; #; #;J
c3h 
 
 
 
$
} 
 
 
 
@
DcN 
 
 
 
$ ')&(')-/a a a a 	a
 38na a #s(^a CO$a !cNa 
a a a aFY3 Yd3SRUXCV>W Y\`adfiai\j Y Y Y Yv$(59OS	c3h   $  DC  Ds  Ds  D_b  Dgk  D  D  D \ D  D  Dr6   r   )5__doc__rE   r   r   r   r   r<   r.   r   r   r   r   http.clientr   r$   r   typingr   r   r   r   r	   urllib.errorr
   urllib.parser   urllib.requestr   r   r   r   r   r   r   r   slack.errorserrorsr   r   	slack.webr   r   slack.web.async_internal_utilsr   r   r   r   r   slack.web.deprecationr   slack.web.slack_responser   r   rN   r6   r4   <module>r      s(   ; ;     				          $ $ $ $ $ $       ' ' ' ' ' ' ' ' ' ' " " " " " " " " " " " " " " " " " " " " W W W W W W W W W W W W W W  ' ' ' ' ' ' ' '       * * * * * * < < < < < < < <              ; : : : : : 2 2 2 2 2 2JD JD JD JD JD JD JD JD JD JDr6   