'jSddlZddlZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZddlmZddlmZddlmZmZdd lmZdd lmZmZmZmZmZmZmZm Z Gd d Z!Gd dZ"dS)N)Logger)Lock)OptionalCallableUnionListTupleDict)urlparse)uuid4)SlackClientNotConnectedErrorSlackClientConfigurationError) FrameHeader)_parse_handshake_response_validate_sec_websocket_accept_generate_sec_websocket_key_to_readable_opcode_receive_messages_build_data_frame_for_sending_parse_text_payload _establish_new_socket_connectionc eZdZUeed<dZdS)ConnectionState terminatedcd|_dS)NF)rselfs i/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/slack_sdk/socket_mode/builtin/connection.py__init__zConnectionState.__init__s N)__name__ __module__ __qualname__bool__annotations__r r!rrrs3     r!rc eZdZUeed<eed<eeed<eeeefed<eed<eed<ee ed<eed<ee j ed <ee egd fed <ee e gd fed <ee eeegd fed < d'dededeedeeeefde de dedededed ee egd fd ee e gd fd ee eeegd fdedee jfdZd(dZd(dZdefdZd(dZd)d eeefdd fd!Zd)d eeefdd fd"Zd edd fd#Zd(d$Zd%edd fd&Zd S)* Connectionurlloggerproxy proxy_headers trace_enabledping_pong_trace_enabledlast_ping_pong_time session_idsockNon_message_listeneron_error_listeneron_close_listenerF Socket Mode ping_intervalreceive_timeoutreceive_buffer_sizeall_message_trace_enabledconnection_type_name ssl_contextc||_||_||_||_||_||_||_|jdkrtdtt|_ ||_ | |_ | |_ d|_d|_d|_t#|_t#|_| |_| |_| |_||_||_dS)Nz'Too small receive_buffer_size detected.r)r*r+r,r-r:r;r<rstrr r1r.r=r/r0#consecutive_check_state_error_countr2rsock_receive_locksock_send_lockr3r4r5r>r?)rr*r+r,r-r:r;r<r.r=r/r3r4r5r>r?s rr zConnection.__init__3s$  **.#6  #b ( (/0YZZ Zegg,,*)B&'>$#' 340 !%"ff#6 !2!2$8!&r!returnc z t|j}|j}|jp|jdkrdnd}|jr)|jd|d|d|j dt|j |||j|j |j |j |j|j|j } |jd |j}t%}d |d |jd |d }dd|dD}|jr,|j|jd|j d||j 5||ddddn #1swxYwYt1|\} } } |jr,|j|jd|j d| | dkrht3|| s t5d|jd|j d||_||j dt;jn-d| d| d|j d}|j|dSdS#t>j $r} d} | j!rEtE| j!dkr-tG| j!dtHr | j!d} | Md| d|j d| d}|jr|j%|n|j |d} ~ wwxYw#tL$r} d|j d| d}|jr|j%|n|j ||j'|'| |(Yd} ~ dSd} ~ wwxYw)NwssiPz)Connecting to the address for handshake: :z (session id: )) r1server_hostname server_portr+rEr;r,r-r.r??zGET z$ HTTP/1.1 Host: zw Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: z@ Sec-WebSocket-Version: 13 z c6g|]}|Sr')lstrip).0lines r z&Connection.connect..s 'V'V'V$ 'V'V'Vr! z handshake request (session id: z): utf-8z! handshake response (session id: ez$Invalid response header detected in z7Received an unexpected response for handshake (status: z , response: z, session id: rrz Error code: , error: z.Failed to establish a connection (session id: ))r r*striphostnameportschemer.r+debugr1rrEr;r,r-r?pathqueryrjoinsplitr>sendencoderrr r2pingtimewarningsocketerrorargslen isinstanceint exception Exceptionr4 disconnect)r parsed_urlrYrZr2r]sec_websocket_keymessagereqstatusheaderstextecode error_messages rconnectzConnection.connectbsU !$(.."2"233J&/H"V:3D3M3MCCSUD!  !!uuu4uucgcruuu2R? ( {#2 $ 4j"0"0 , 2 2 2D3 $/>>J,<>>$?$A$A!4%.): ";;'V'V'--PTBUBU'V'V'VWW%K%%4ppVZVeppknpp(33IIcjj11222333333333333333)B$(G(G%%K%%4rrW[WfrrlprrS==9:KWUU:@4C\@@-1_@@@ !%DIII@@49;;@@AAAA_$*__8<__LPO___K''00000 BA<   &*6%c!&kkAoo*QVAY2L2Lo6!9D#$e4$e$et$e$eab$e$e$eM)9 --m<<<< ))-888    kT_kkghkkkM! 1 %%m4444 !!-000%1&&q))) OO          s^B4L+7BI6)F< I6F  I6F C"I66L(BL##L((L++ N:5A:N55N:c|j^|j5|j5|jd|_dddn #1swxYwYdddn #1swxYwY|jd|jddS)Nz,The connection has been closed (session id: rK)r2rErDcloser+infor1rs rrnzConnection.disconnects  9 $ % %+%%IOO%%% $DI%%%%%%%%%%%%%%% % % % % % % % % % % % % % % % ZZZZ[[[[[s3A!A AA A A AA"Ac|jduSN)r2rs r is_activezConnection.is_activesy$$r!c.|dSr~)rnrs rr{zConnection.closes r!payloadc|jrW|jrPt|tr|d}|jd|jd|dt|tj }|j 5|j |j |n!|jr|jdddddS#1swxYwYdS)NrUz'Sending a ping data frame (session id: , payload: rKzOSkipped sending a ping message as the underlying socket is no longer available.)r.r/rjbytesdecoder+r\r1rr OPCODE_PINGrEr2rarrdatas rrczConnection.ping>   s$"> s'5)) 2!..11 K  q4?qqgnqqq r r r,Wk6MNN   y yy$ t$$$$/yK%%&wxxx  y y y y y y y y y y y y y y y y y yACCCc|jrW|jrPt|tr|d}|jd|jd|dt|tj }|j 5|j |j |n!|jr|jdddddS#1swxYwYdS)NrUz'Sending a pong data frame (session id: rrKzOSkipped sending a pong message as the underlying socket is no longer available.)r.r/rjrrr+r\r1rr OPCODE_PONGrEr2rars rpongzConnection.pongrrc |jrPt|tr|d}|jd|jd|dt|tj }|j 5 |j |n-#t$r }td|jd|dd}~wwxYw ddddS#1swxYwYdS)NrUz'Sending a text data frame (session id: rrKzLFailed to send a message as the connection is no longer active (session_id: rW)r.rjrrr+r\r1rr OPCODE_TEXTrEr2rarmr )rrrrvs rrazConnection.sends]   s'5)) 2!..11 K  q4?qqgnqqq r r r,Wk6MNN     t$$$$    3C$(OCC>?CCC  %                  s69C;BC C B;;CCCCc@ |j> ||jdtjnW#tj$rE}|jd|jd|d|Yd}~dSd}~wwxYw|j ttj|j z }|j r2||j kr'|d|jd}|j |||j dzk}|r<|jd|jd|d |dSn#|j d |jdd |_dS#t$r}d |jd t!|jd|d}|j r|j|n|j||xjdz c_|jdkr|Yd}~dSYd}~dSd}~wwxYw)NrJzFUnable to send a ping message. Closing the connection... (session id: z , reason: rKzb seconds have passed since this client last received a pong response from the server (session id: z@The connection seems to be stale. Disconnecting... (session id: z, reason: disconnected for z + seconds)z0This connection is already closed. (session id: rz/Failed to check the state of sock (session id: rWz , message: rr6)r2rcr1rdsslSSLZeroReturnErrorr+r|rnr0rkr.r:r\rCrmtyper"rlrg)rrvdisconnected_secondsrqis_stalerxs r check_statezConnection.check_states. "y$II@@49;;@@AAAA-K$$I)-IIDEIIIOO%%%FFFFF +7+.ty{{T=U/U+V+V()3.BTEW.W.W3??,0O???  ))'2223d6H16LLH ((Z-1_ZZ9MZZZ ))) !!"jX\Xg"j"j"jkkk78D 4 4 4 " " "\ $\\:>q'':J\\WX\\\ ! 1 %%m4444 !!-000  4 4 9 4 471<<!!!!!!!!!=<<<<< "sEE40<E4B :B E4 BB5E4+E44 H>BHHstatec  ddi}d}d}d}|jsN |r>t|j|j|j|j|j}|D] }|\}} |jdurf|rt|j nd} t| |j} | | } | d} n| dz } | | i}|j s||j |j tjkr6|dz }||zdkr(|jd|d |jd d}|j tjkr6|dz }||zdkr(|jd|d |jd d}|duo:|j duo1|j tjkp|j tjko|j } | s/| d kr)|jd |jd| d| d |||j tjkr|| |j tjkr| d}|d}t-|dkrj|d|d}}|j|krO t/||_,#t2$r+}|jd|d|Yd}~\d}~wwxYwf|j tjkr3|j*| d}|||j tjkr|j|t-| dkrSt=jd| dd\}| ddd}|||n|dd| d|_c|rt|j nd} | } |j tj!krO | | dnd} n4#t2$r'}|j"d|Yd}~nd}~wwxYwd|jd| d| d }|j#|ntIj%dn#tLj'$rtIj%dYntP$r0}|j)dkr"|jr|jdng|j*|*|nJd|jd|d }|jr|j+|n|j,||rw | na#t2$rT}d|jd|d }|jr|j+|n|j,|Yd}~nd}~wwxYwd|_Yd}~nd}~wt2$rq}|j*|*|nJd |jd|d }|jr|j+|n|j,|Yd}~nd}~wwxYw|jNd|_dS)!Nrri)r2rDr+r<r=T-rz Received z ping data frame (session id: rKz pong data frame (session id: r6z'Received a new data frame (session id: z , opcode: rrUrJz*Failed to parse a pong message (message: rWz!Hirz#Failed to convert the data to text z0Received an unsupported data frame (session id: g?g{Gz? z_The reason why you got [Errno 9] Bad file descriptor here is the socket is no longer available.z1Got an OSError while receiving data (session id: z"Failed to disconnect (session id: z3Got an exception while receiving data (session id: )-rrrr2rDr+r<r=r.ropcodergetr/rrr\r1rrrr`rifloatr0rmrr3 OPCODE_CLOSEr5structunpackrn OPCODE_BINARYr|rerdsleeprftimeoutOSErrorerrnor4rlrg)rrrepeated_messages ping_count pong_countping_pong_log_summary_sizereceived_messagesrqheaderrrrcountping_pong_to_skip str_messageelementsr1 ping_timervrurwreasonrxdisconnection_errors rrun_until_completionzConnection.run_until_completion)sB&N  %)""T 9S 9>>##i$Sd!Y*.*@#{,0,D262P TTT%$5_9_9'.   -55PV*_*=fm*L*L*L\_F+>tT[+Q+QG3D3H3H3Q3QE$}() % 18%0@-#'#?7FDV[a[h[t#)=K4K#K#K$.!OJ'14N'NRS'S'S(, (9(9-O8R-O-O<@O-O-O-O)*)*)*67 #)=K4K#K#K$.!OJ'14N'NRS'S'S(, (9(9-O8R-O-O<@O-O-O-O)*)*)*67 !'d 2!E$*M$=!E%+]k6M%M%yQWQ^bmbyQy!E)-(D$D . $5"!% 1 1%m48O%m%mOU%m%mbi%m%m%m!"!"!" ">$ "=K,CCC IIdOOOO#]k.EEE*.++g*>*>K'2'8'8'='=H"8}}118@ Xa[I #'?j#@#@%*CHCSCS(@(@+4%*%*%*(, (9(9,u\g,u,urs,u,u)*)*)*)*)*)*)*)*%*$]k.EEE#7C'+{{7';'; $ 8 8 > > >#]k.FFF#5A#&t99>>.4mD$rr(.K.KGT-1!""X__W-E-EF$($:$:4$H$H$H$H$($:$:4$D$D$D OO---/3E,,LR%Z%8%G%G%GWZF9=G%} 0III!`FJFVdkk'.B.B.B\^GG'0!`!`!`$(K$4$45^[\5^5^$_$_$_$_$_$_$_$_!`!i04!i!iKQ!i!i^e!i!i!i$!K//8888_9BJsOOO> ! ! ! 4        7a<>## = =))))$===tDOtt^qttt& -= K11-@@@@ K--m<<<=$(  9 9 9)5**1----${]a]l${${wx${${${M)9 --m<<<< ))-888 9Y"T 9l sIQ=.JQ= J9 J4.Q=4J99D1Q=+PQ= P6P1,Q=1P66AQ==#Y# Y-B(WU+*W+ W 5A W?WW  W Y%A'YY) NNr6r7r8FFFNNNr9N)rFN)r)r"r#r$rBr&rrr r%rr SSLSocketrrmrk SSLContextr ryrnrr{rrrcrrarrrr'r!rr)r)"sI HHH NNN C=DcN++++!!!!!%(((OOO 3= !!!!!(C5$;"78888)d): ;<<<<#x})=t)C DEEEE $26 !"#'#*/(-?CCGLP$104!-'-' -'-'} -'  S#X/ -'  -'-'!-'-'$(-'"&-'&hud{&;<-'$Hi[$->$?@-'$Hc8C=-A4-G$HI-'"-' cn-!-'-'-'-'^VVVVp \ \ \ \%4%%%% y yE#u*- yt y y y y y yE#u*- yt y y y yCD&/"/"/"/"b[ /[ d[ [ [ [ [ [ r!r))#rfrrrdloggingr threadingrtypingrrrrr r urllib.parser uuidr slack_sdk.errorsr r frame_headerr internalsrrrrrrrrrr)r'r!rrs ????????????????!!!!!!XXXXXXXX%%%%%%                            b b b b b b b b b b r!