5SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r SSK 7 SSKJr S/r"S S 5r"S S 5r"S S\5rg)aL websocket - WebSocket client library for Python Copyright (C) 2010 Hiroki Ohtani(liris) This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA N)ABNF) WebSocketgetdefaulttimeout)*)_logging WebSocketAppc \rSrSrSrSrSrg) Dispatcher+cXlX lgNapp ping_timeoutselfrrs !lib/third_party/websocket/_app.py__init__Dispatcher.__init__, (c^URRR(a[R"URRR4SSUR5upEnU(a U"5(dgU"5 URRR(aMggN)rsock connectedselectr)rr read_callbackcheck_callbackrwes rreadDispatcher.read0sohhmm%%mmXX]]''*BD4E4EGGA!$   hhmm%%%rrN)__name__ __module__ __qualname____firstlineno__rr$__static_attributes__rrrr r +s )rr c&\rSrSrSrSrSrSrg) SSLDispacther9cXlX lgrrrs rrSSLDispacther.__init__:rrcURRR(aSUR5nU(a U"5(dgU"5 URRR(aMRggr)rrrr)rrrr r!s rr$SSLDispacther.read>sGhhmm%% A$   hhmm%%%rcURRRnUR5(aU/$[R"U4SSUR5up#nU$r)rrpendingrr)rrr!r"r#s rrSSLDispacther.selectFsLxx}}!! <<>>7N--"b$2C2CDarrN)r&r'r(r)rr$rr*rrrr,r,9s)rr,c\rSrSrSrS Sjr\R4SjrSr Sr SSjr S r S r S rS rg)r NzW Higher level of APIs are provided. The interface is like JavaScript WebSocket object. NcXlUbUO/UlXlX0lX@lXlXPlX`lXplXl Xl SUl Xl SUl SUlSUlXlg)a url: websocket url. header: custom header for websocket handshake. on_open: callable object which is called at opening websocket. this function has one argument. The argument is this class object. on_message: callable object which is called when received data. on_message has 2 arguments. The 1st argument is this class object. The 2nd argument is utf-8 string which we get from the server. on_error: callable object which is called when we get error. on_error has 2 arguments. The 1st argument is this class object. The 2nd argument is exception object. on_close: callable object which is called when closed the connection. this function has one argument. The argument is this class object. on_cont_message: callback object which is called when receive continued frame data. on_cont_message has 3 arguments. The 1st argument is this class object. The 2nd argument is utf-8 string which we get from the server. The 3rd argument is continue flag. if 0, the data continue to next frame data on_data: callback object which is called when a message received. This is called before on_message or on_cont_message, and then on_message or on_cont_message is called. on_data has 4 argument. The 1st argument is this class object. The 2nd argument is utf-8 string which we get from the server. The 3rd argument is data type. ABNF.OPCODE_TEXT or ABNF.OPCODE_BINARY will be came. The 4th argument is continue flag. if 0, the data continue keep_running: this parameter is obsolete and ignored. get_mask_key: a callable to produce new mask keys, see the WebSocket.set_mask_key's docstring for more information subprotocols: array of available sub protocols. default is None. NFr)urlheadercookieon_open on_messageon_dataon_erroron_closeon_pingon_pongon_cont_message keep_running get_mask_keyr last_ping_tm last_pong_tm subprotocols)rr8r9r;r<r>r?r@rArBrCrDr:rGr=s rrWebSocketApp.__init__TsqT & 2f   $     .!( (rczUR(aURRX5S:Xa [S5eg)z send message. data: message to send. If you set opcode to OPCODE_TEXT, data must be utf-8 string or unicode. opcode: operation code of data. default is OPCODE_TEXT. rzConnection is already closed.N)rsend"WebSocketConnectionClosedException)rdataopcodes rrJWebSocketApp.sends4yyDIINN48A=4/1 1>rc |SUlUR(a$URR"S0UD6 SUlgg)z close websocket connection. FNr)rCrclose)rkwargss rrPWebSocketApp.closes2" 99 IIOO %f %DI rcfURU5(d_[R"5UlUR(aURR 5 URU5(dM^gg![ a/n[ R"SRU55 SnAgSnAff=f)Nz send_ping routine terminated: {}) waittimerErping Exceptionrwarningformat)rintervaleventexs r _send_pingWebSocketApp._send_pingsy**X&& $ D yyIINN$ **X&& !$$%G%N%Nr%RSsA77 B0%B++B0c^^^^^TbTS::aSmT(aU(aUT::a [S5eU(d/nU(d0nTR(a [S5eSmSTlSTlSTlS UUU4Sjjm[ TR XTRSLU U(aSOSS9TlTRR[55 TRRTRTRTRUXgUTRXU US 9 U (dTRT5n TR!TR"5 U(aW[$R&"5m[$R("TR*UT4S 9mTR-S5 TR/5 UU4S jnUU4S jnU R1TRRUU5 g![2[4[64aXnTR!TR8U5 [;U[65(aeT"5 [;U[45(+sSnA$SnAff=f)a run event loop for WebSocket framework. This loop is infinite loop and is alive during websocket is available. sockopt: values for socket.setsockopt. sockopt must be tuple and each element is argument of sock.setsockopt. sslopt: ssl socket optional dict. ping_interval: automatically send "ping" command every specified period(second) if set to 0, not send automatically. ping_timeout: timeout(second) if the pong message is not received. http_proxy_host: http proxy host name. http_proxy_port: http proxy port. If not set, set to 80. http_no_proxy: host names, which doesn't use proxy. skip_utf8_validation: skip utf8 validation. host: update host header. origin: update origin header. dispatcher: customize reading data from socket. suppress_origin: suppress outputting origin header. Returns ------- False if caught KeyboardInterrupt True if other exception was raised during a loop Nrz#Ensure ping_interval > ping_timeoutzsocket is already openedTcr>T(a5TR5(a TR5 TR5 STlTR(aTRR 5 TR U(a UROS5nTR"TR/UQ76 STlg)z Tears down the connection. If close_frame is set, we will invoke the on_close handler with the statusCode and reason from there. FN) isAlivesetjoinrCrrP_get_close_argsrL _callbackr?) close_frame close_argsr[rthreads rteardown*WebSocketApp.run_forever..teardowns| &..**  %D yy !--$/   T;J NN4== 6: 6DIrF)sockoptssloptfire_cont_frameskip_utf8_validationenable_multithread) r9r:http_proxy_hosthttp_proxy_port http_no_proxyhttp_proxy_authrGhostoriginsuppress_origin proxy_type)targetargsc>TR(dT"5$TRRS5upU[R:XaT"U5$U[R :Xa'TR TRUR5 gU[R:XaA[R"5Tl TR TRUR5 gU[R:XaTR(anTR TRURUR UR"5 TR TRURUR"5 gURn[$R&(a%U[R(:XaUR+S5nTR TRX!R S5 TR TR,U5 g)NTutf-8)rCrrecv_data_framer OPCODE_CLOSE OPCODE_PINGrer@rL OPCODE_PONGrUrFrA OPCODE_CONTrBr=rMfinsixPY3 OPCODE_TEXTdecoder<)op_codeframerLrris rr$&WebSocketApp.run_forever..read sa((#:%!%!:!:4!@d///#E?* 0 00NN4<<<  0 00(, D%NN4<<< 0 00T5I5INN4<<#(<<<NN4#7#7#(::uyy: !::Dww7d.>.>#>#{{73NN4<<||TJNN4??D9rc0>T(a[R"5TR- T:nTRTR- S:nTRTR- T:nTR(a U(aU(dU(a [S5eg)Nrzping/pong timed outT)rUrErFWebSocketTimeoutException)has_timeout_expired$has_pong_not_arrived_after_last_pinghas_pong_arrived_too_laterrs rcheck'WebSocketApp.run_forever..check%s} *.))+8I8I*IL*X';?;L;LtO`O`;`cd;d8040A0ADDUDU0UXd0d-)) 3!EIb78MNNrr)WebSocketExceptionrrCrErFrrDrB settimeoutrconnectr8r9r:rGcreate_dispatcherrer; threadingEventThreadr] setDaemonstartr$rWKeyboardInterrupt SystemExitr> isinstance)rrkrl ping_intervalrrprqrrrsrnrtru dispatcherrvrwr$rr#r[rirhs` ` @@@r run_foreverWebSocketApp.run_foreversB  # (9L Mm|.K$%JK KGF 99$%?@ @   "G 8!!!7 $ 4 4D @%9+84e EDI II !2!4 5 II  T[[ / / /d>O>O/%  '!33LA NN4<< (!)"))??-1GI  &  4  OODIINND% 8,j9 8 NN4==! ,!Z(( J!!%677 7  8s E$G%%I:A I I IcU=(d SnURR5(a [X5$[X5$)N )ris_sslr,r )rrtimeouts rrWebSocketApp.create_dispatcher:s5$" 99     / /$((rc"[RS:aKUR(a7[[R "UR5R 5S:wa/$OJUR(a7[[R"UR5R 5S:wa/$U(a\[U5S:aMS[R"USS5-[R"USS5-nUSSRS5nX#/$SS/$) z}this functions extracts the code, reason from the close body if they exists, and if the self.on_close except three arguments )rrrrNr{) sys version_infor?leninspect getargspecrygetfullargspecrbyte2intr)rrLcodereasons rrdWebSocketApp._get_close_argsAs   f $==C(:(:4==(I(N(N$OST$T %U==C(>(>t}}(M(R(R$SWX$X CINd1Qi003<<Qq 3JJD!"X__W-F> !d|rc|U(a,[R"U5(aU"U6 gU"U/UQ76 gg![a|n[R"SR X55 [R "5(a3[R"5u pE[R"U5 SnAgSnAgSnAff=f)Nzerror from callback {}: {}) rismethodrWrerrorrYisEnabledForDebugrexc_info tracebackprint_tb)rcallbackryr#_tbs rreWebSocketApp._callbackSs  +##H--dOT)D)  +;BB8OP--//"||~HAq&&r**0 +s 5 5 B;A-B66B;)r:rDr9rCrErFr?rBr=r>r<r;r@rArrGr8) NNNNNNNNTNNNN)NNrNNNNNFNNNFN)r&r'r(r)__doc__rrrrJrPr]rrrdrer*rrrr r Nsk $(9=6:!%>B" ;)z!% 0 0 10426:>8<).7;8< H8T)$ +r)rrrrrrUrr_abnfr_corerr _exceptionsr__all__r r,objectr rrrrs^,   /    *Q+6Q+r