>qa^V FddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZddlmZ ddlZddlZddlZddlZddlZddlZdZ ddlZn #e$rYnwxYwdZ ddlZn #e$rYnwxYw ddlmZddlmZn#e$r ddlZddlZYnwxYw ej Z!n#e"$r ejZ!YnwxYw ddl#Z$d Z%n #e$rd Z%YnwxYwej&d krej'Z(nej(Z( e)n #e*$re+Z)YnwxYwd Z,d Z-dZ.ej/dd kre0Z1e0Z2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAdZBdZCd ZDdZEdZFeFejGeBejHeCejHeDejIeEejJiZKdZLdZMdZNd ZOd ZPdZQdZRdZSdZTd ZUdZVdZWdZXd ZYd ZZdZ[d Z\d!Z]dZ^d"Z_d#Z`dZadZbdZcd Zdd ZedZfd Zgd!ZhdZid"Zjd$Zkd%Zld&Zmd'Znd(Zod)ZpdZqdZrdZsd Ztd*ZuGd+d,evZwd-Zxd.Zyejzej{zdfd/Z|d0Z}d1Z~Gd2d3eZGd4d5eZGd6d7eZGd8d9eZdS):N) MQTTMatcher) Properties) ReasonCodes)SubscribeOptions)parse)requestTFWindows 0@P`p 0ceZdZdS)WebsocketConnectionErrorN)__name__ __module__ __qualname__D/opt/windhager/venv/lib/python3.11/site-packages/paho/mqtt/client.pyr+r+sDr0r+c|tkrdS|tkrdS|tkrdS|tkrdS|tkrdS|t krdS|t krdS|tkrdS|tkrd S|tkrd S|tkrd S|tkrd S|tkrd S|tkrdS|tkrdS|tkrdS|t krdSdS)z=Return the error string associated with an mqtt error number.z No error.zOut of memory.zEA network protocol error occurred when communicating with the broker.z$Invalid function arguments provided.z&The client is not currently connected.zThe connection was refused.z#Message not found (internal error).zThe connection was lost.zA TLS error occurred.Payload too large.zThis feature is not supported.zAuthorisation failed.zAccess denied by ACL.zUnknown error.zError defined by errno.zMessage queue full.z?Client or broker did not communicate in the keepalive interval.)MQTT_ERR_SUCCESSMQTT_ERR_NOMEMMQTT_ERR_PROTOCOLMQTT_ERR_INVALMQTT_ERR_NO_CONNMQTT_ERR_CONN_REFUSEDMQTT_ERR_NOT_FOUNDMQTT_ERR_CONN_LOST MQTT_ERR_TLSMQTT_ERR_PAYLOAD_SIZEMQTT_ERR_NOT_SUPPORTED MQTT_ERR_AUTHMQTT_ERR_ACL_DENIEDMQTT_ERR_UNKNOWNMQTT_ERR_ERRNOMQTT_ERR_QUEUE_SIZEMQTT_ERR_KEEPALIVE) mqtt_errnos r1 error_stringrFs4%%%{ ~ % % ( ( (VV ~ % %55 ' ' '77 , , ,,, ) ) )44 ) ) ))) | # #&& , , ,## - - -// } $ $&& * * *&& ' ' ' ~ % %(( * * *$$ ) ) )PPr0c|tkrdS|tkrdS|tkrdS|tkrdS|tkrdS|t krdSdS)z3Return the string associated with a CONNACK result.zConnection Accepted.z2Connection Refused: unacceptable protocol version.z(Connection Refused: identifier rejected.z'Connection Refused: broker unavailable.z.Connection Refused: bad user name or password.z#Connection Refused: not authorised.z#Connection Refused: unknown reason.)CONNACK_ACCEPTED CONNACK_REFUSED_PROTOCOL_VERSION#CONNACK_REFUSED_IDENTIFIER_REJECTED"CONNACK_REFUSED_SERVER_UNAVAILABLE%CONNACK_REFUSED_BAD_USERNAME_PASSWORDCONNACK_REFUSED_NOT_AUTHORIZED) connack_codes r1connack_stringrOst'''%% 9 9 9CC < < <99 ; ; ;88 > > >?? 7 7 74444r0c8|dksJg}|r0t|d\}}|||0|fdtt ||Ddt |S)z+Convert a number to base-62 representation.r>c3(K|] }dV dS)rNr/).0_bases r1 zbase62..s'??a$q'??????r0)divmodappendextendrangelenjoinreversed)numrUpaddingdigitsrests ` r1base62rcs !8888 F "3OO T d4j!!! " MM????5Vg#>#>?????? 778F## $ $$r0ct}d||< t||dS#t$rYdSwxYw)zCheck whether a topic matches a subscription. For example: foo/bar would match the subscription foo/# or +/bar non/matching would not match the subscription non/+/+ TF)rnext iter_match StopIteration)subtopicmatchers r1topic_matches_subrks^mmGGCL W   & &'''t uus"9 AActjtjtjtj}|tjtjd|d|d| \}}tjtjtjtj}| d | d|fn#t$rYnwxYw| \}}| d|||fS)z+TCP/IP socketpair including Windows supportr) 127.0.0.1rrrm)socketAF_INET SOCK_STREAM IPPROTO_IP setsockopt SOL_SOCKET SO_REUSEADDRbindlisten getsockname setblockingconnectBlockingIOErroracceptclose) listensockifaceportsock1sock2addresss r1_socketpair_compatrs4*F,=??J&+V-@!DDDOO$%%%a((**KE4 M*F,= ? ?E a  {D)****      &&((NE7 a 5>s+D DDcNeZdZdZdZdZdZdZdZdZ dZ d Z d d Z d Z d S)MQTTMessageInfozThis is a class returned from Client.publish() and can be used to find out the mid of the message that was published, and to determine whether the message has been published, and/or wait until it is published. )mid _published _conditionrc_iterposcn||_d|_tj|_d|_d|_dSNFr)rr threading Conditionrrrselfrs r1__init__zMQTTMessageInfo.__init__1s2#-// r0c8t|j|jfSN)strrrrs r1__str__zMQTTMessageInfo.__str__8sDGTX&'''r0cd|_|SNr)rrs r1__iter__zMQTTMessageInfo.__iter__;s  r0c*|Sr)rers r1__next__zMQTTMessageInfo.__next__?syy{{r0ct|jdkrd|_|jS|jdkrd|_|jSt)Nrrr)rrrrgrs r1rezMQTTMessageInfo.nextBs> =A  DM7N ]a  DM8O r0cT|dkr|jS|dkr|jStd)Nrrzindex out of range)rr IndexError)rindexs r1 __getitem__zMQTTMessageInfo.__getitem__Ls1 A::7N aZZ8O122 2r0c|j5d|_|jddddS#1swxYwYdS)NT)rrnotifyrs r1_set_as_publishedz!MQTTMessageInfo._set_as_publishedTs _ % %"DO O " " $ $ $ % % % % % % % % % % % % % % % % % %s !6::Nc|jtkrtd|jtkrn/|jdkr$t dt |jzdnt jzdndz }fd}|j5|js5|s+|j ||js |+ddddS#1swxYwYdS)aBlock until the message associated with this object is published, or until the timeout occurs. If timeout is None, this will never time out. Set timeout to a positive number of seconds, e.g. 1.2, to enable the timeout. Raises ValueError if the message was not queued due to the outgoing queue being full. Raises RuntimeError if the message was not published for another reason. +Message is not queued due to ERR_QUEUE_SIZErMessage publish failed: %sNg$@c:dntjkSNF)time)timeout timeout_timesr1 timed_outz3MQTTMessageInfo.wait_for_publish..timed_outns#O55|1K Kr0) rrC ValueErrorMQTT_ERR_AGAIN RuntimeErrorrFrrrwait)rr timeout_tenthrrs ` @r1wait_for_publishz MQTTMessageInfo.wait_for_publishYs] 7) ) )JKK K W & &  Wq[[;|DG?T?TUVV V&ttDIKK'4I 'Ws]  L L L L L L_ 4 4o 4iikk 4$$]333o 4iikk 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s=CC #C c|jtkrtd|jtkrn/|jdkr$t dt |jz|j5|jcdddS#1swxYwYdS)zgReturns True if the message associated with this object has been published, else returns False.rrrN)rrCrrrrFrrrs r1 is_publishedzMQTTMessageInfo.is_publishedus 7) ) )JKK K W & &  Wq[[;|DG?T?TUVV V _ # #? # # # # # # # # # # # # # # # # # #s'A;;A?A?r)r,r-r.__doc__ __slots__rrrrrerrrrr/r0r1rr)s DI(((   333%%% 44448 # # # # #r0rc`eZdZdZdZd dZdZdZedZ e j d Z d S) MQTTMessagea This is a class that describes an incoming or outgoing message. It is passed to the on_message callback as the message parameter. Members: topic : String. topic that the message was published on. payload : Bytes/Byte array. the message payload. qos : Integer. The message Quality of Service 0, 1 or 2. retain : Boolean. If true, the message is a retained message and not fresh. mid : Integer. The message id. properties: Properties class. In MQTT v5.0, the properties associated with the message. ) timestampstatedupr_topicpayloadqosretaininfo propertiesrr0cd|_t|_d|_||_||_d|_d|_d|_t||_ dS)NrFr0) rmqtt_ms_invalidrrrrrrrrr)rrris r1rzMQTTMessage.__init__sM$    #C(( r0cPt||jr|j|jkSdS)z$Override the default Equals behaviorF) isinstance __class__rrothers r1__eq__zMQTTMessage.__eq__s* eT^ , , )8uy( (ur0c.|| S)zDefine a non-equality test)rrs r1__ne__zMQTTMessage.__ne__s;;u%%%%r0c6|jdS)Nutf-8)rdecoders r1rizMQTTMessage.topics{!!'***r0c||_dSr)rrvalues r1rizMQTTMessage.topics  r0N)rr0) r,r-r.rrrrrpropertyrisetterr/r0r1rrs  oI ) ) ) ) &&&++X+ \\r0rceZdZdZdddeddfdZdZdZd Zd Z dd Z dd Z ddZ ddZ ddZdZdZddZdZddddedfdZdddedfdZddddedfdZddZdZdd!Zdd"Zdd#Zdd$Zd%Zd&Zdd'Zdd(Z dd)Z!dd*Z"dd+Z#d,Z$d-Z%d.Z&d/Z'd0Z(d1Z)dd2Z*d3Z+d4Z,dd5Z-d6Z.dd7Z/e0d8Z1e1j2d9Z1d:Z3e0d;Z4e4j2d<Z4d=Z5e0d>Z6e6j2d?Z6d@Z7e0dAZ8e8j2dBZ8dCZ9e0dDZ:e:j2dEZ:dFZ;e0dGZe>j2dKZ>dLZ?e0dMZ@e@j2dNZ@dOZAe0dPZBeBj2dQZBdRZCdSZDe0dTZEeEj2dUZEdVZFdWZGe0dXZHeHj2dYZHdZZId[ZJe0d\ZKeKj2d]ZKd^ZLdd_ZMd`ZNdaZOdbZPddcZQddZRdeZSdfZTdgZUdhZVeWdiZXeWdjZYdkZZdlZ[dmZ\dnZ]doZ^dpZ_ddrZ`dsZadtZbduZcdvZddwZeddxZfddyZgddzZhd{Zid|Zjd}Zkd~ZlddZmdZndZodZpdZqdZrdZsdZtdZudZvdZwdZxddZydZzdZ{dZ|dZ}dZ~dZeWdZdZdZdS)ClientatMQTT version 3.1/3.1.1/5.0 client class. This is the main class for use communicating with an MQTT broker. General usage flow: * Use connect()/connect_async() to connect to a broker * Call loop() frequently to maintain network traffic flow with the broker * Or use loop_start() to set a thread running to call loop() for you. * Or use loop_forever() to handle calling loop() for you in a blocking * function. * Use subscribe() to subscribe to a topic and receive messages * Use publish() to send messages * Use disconnect() to disconnect from the broker Data returned from the broker is made available with the use of callback functions as described below. Callbacks ========= A number of callback functions are available to receive data back from the broker. To use a callback, define a function and then assign it to the client: def on_connect(client, userdata, flags, rc): print("Connection returned " + str(rc)) client.on_connect = on_connect Callbacks can also be attached using decorators: client = paho.mqtt.Client() @client.connect_callback() def on_connect(client, userdata, flags, rc): print("Connection returned " + str(rc)) **IMPORTANT** the required function signature for a callback can differ depending on whether you are using MQTT v5 or MQTT v3.1.1/v3.1. See the documentation for each callback. All of the callbacks as described below have a "client" and an "userdata" argument. "client" is the Client instance that is calling the callback. "userdata" is user data of any type and can be set when creating a new client instance or with user_data_set(userdata). If you wish to suppress exceptions within a callback, you should set `client.suppress_exceptions = True` The callbacks are listed below, documentation for each of them can be found at the same function name: on_connect, on_connect_fail, on_disconnect, on_message, on_publish, on_subscribe, on_unsubscribe, on_log, on_socket_open, on_socket_close, on_socket_register_write, on_socket_unregister_write rWNtcpTc |dvrtd|z||_||_||_d|_d\|_|_d|_d|_ t|_ |tkr|tdn$|d}|s|d ks|td ||_ |d ks|@|tkr-tt!jjd |_nd |_n||_t)|jt*r|jd|_d|_d|_ddgddt3d ddd|_t7j|_t=|_t=|_ d|_!d|_"d|_#||_$d|_%d|_&tN|_(t7j)|_*t7j)|_+d|_,d|_-d|_.d|_/d|_0d|_1d |_2d |_3d|_4d|_5tm|_7d |_8d|_9d |_:d|_;i|_<t{j>|_?t{j@|_At{j>|_Bt{j@|_Ct{j>|_Dt{j>|_Et{j>|_Fd|_Gd|_Hd|_Id|_Jd|_Kd|_Ld|_Md|_Nd|_Od|_Pd|_Qd|_Rd|_Sd|_Td|_Ud|_Vd|_Wd|_Xd|_Yd|_Zd|_[d|_\d|_]dS)a]client_id is the unique client id string used when connecting to the broker. If client_id is zero length or None, then the behaviour is defined by which protocol version is in use. If using MQTT v3.1.1, then a zero length client id will be sent to the broker and the broker will generate a random for the client. If using MQTT v3.1 then an id will be randomly generated. In both cases, clean_session must be True. If this is not the case a ValueError will be raised. clean_session is a boolean that determines the client type. If True, the broker will remove all information about this client when it disconnects. If False, the client is a persistent client and subscription information and queued messages will be retained when the client disconnects. Note that a client will never discard its own outgoing messages on disconnect. Calling connect() or reconnect() will cause the messages to be resent. Use reinitialise() to reset a client to its original state. The clean_session argument only applies to MQTT versions v3.1.1 and v3.1. It is not accepted if the MQTT version is v5.0 - use the clean_start argument on connect() instead. userdata is user defined data of any type that is passed as the "userdata" parameter to callbacks. It may be updated at a later point with the user_data_set() function. The protocol argument allows explicit setting of the MQTT version to use for this client. Can be paho.mqtt.client.MQTTv311 (v3.1.1), paho.mqtt.client.MQTTv31 (v3.1) or paho.mqtt.client.MQTTv5 (v5.0), with the default being v3.1.1. Set transport to "websockets" to use WebSockets as the transport mechanism. Set to "tcp" to use raw TCP, which is the default. ) websocketsrz/transport must be "websockets" or "tcp", not %sNNN<g@z&Clean session is not used for MQTT 5.0TrWz7A client id must be provided if clean session is False.r`r0rrrcommandhave_remainingremaining_countremaining_multremaining_lengthpacket to_processposxF[/mqtt)^lowerr _transport _protocol _userdata_sock _sockpairR _sockpairW _keepalive_connect_timeout MQTT_CLIENT _client_modeMQTTv5_clean_sessionMQTTv31rcuuiduuid4int _client_idrunicodeencode _username _password bytearray _in_packet collectionsdeque _out_packet time_func _last_msg_in _last_msg_out_reconnect_min_delay_reconnect_max_delay_reconnect_delay_reconnect_on_failure_ping_t _last_mid mqtt_cs_new_state OrderedDict _out_messages _in_messages_max_inflight_messages_inflight_messages_max_queued_messages_connect_properties_will_properties_will _will_topic _will_payload _will_qos _will_retainr_on_message_filtered_host_port _bind_address _bind_port_proxyrLock_in_callback_mutexRLock_callback_mutex_msgtime_mutex_out_message_mutex_in_message_mutex_reconnect_delay_mutex_mid_generate_mutex_thread_thread_terminate_ssl _ssl_context _tls_insecure_logger_registered_write_on_log _on_connect_on_connect_fail _on_subscribe _on_message _on_publish_on_unsubscribe_on_disconnect_on_socket_open_on_socket_close_on_socket_register_write_on_socket_unregister_write_websocket_path_websocket_extra_headers_mqttv5_first_connectsuppress_exceptions)r client_id clean_sessionuserdataprotocol transportreconnect_on_failures r1rzClient.__init__sF ??  $9 9 9AIMOO O#//++!! +8( #' v  ( !IJJJ)$ $   Oi2oo9J MOOO"/D  ??i/7"""()92"F"F"F"%'DO dow / / >"o44W==DO! !nn',..%KK&[[$%!$'! $%9" ! (466'355&(#"#$%!#' $  !$/MM!   "+."2"2(00'n.."+/"3"3!*!1!1&/n&6&6##,>#3#3  !&  " !&  $!#"# $)-&+/(&(,%%)"#(   r0c.|dSr)_reset_socketsrs r1__del__zClient.__del__{s r0c |j|S#tj$rttj$r|twxYwr)rrecvsslSSLWantReadErrorrzSSLWantWriteError_call_socket_register_write)rbufsizes r1 _sock_recvzClient._sock_recv~sl ":??7++ +# " " "! !$ " " "  , , . . .! ! "s AAc |j|S#tj$rttj$r|tt$r|twxYwr)rsendrNrOrzrPrQ)rbufs r1 _sock_sendzClient._sock_sends ":??3'' '# " " "! !$ " " "  , , . . .! ! " " "  , , . . .! ! "s A$Bc|jsdS |j}d|_|||||dS#|wxYw)z#Close the connection to the server.N)r_call_socket_unregister_write_call_socket_closer|)rsocks r1 _sock_closezClient._sock_closesqz  F :DDJ  . .t 4 4 4  # #D ) ) ) JJLLLLLDJJLLLLs 8AA/Fc|dkr||jr |jd|_|jr"|jd|_dSdSr)r\rr|r)r sockpair_onlys r1rJzClient._reset_socketssw E ! !       ? # O ! ! # # #"DO ? # O ! ! # # #"DOOO # #r0c\|||||dSr)rJr)rrCrDrEs r1 reinitialisezClient.reinitialises0  i99999r0rc||_||'&x00F r0cd|_dSr)r1rs r1disable_loggerzClient.disable_loggerrs  r0rrrc |jtkrd|_n/|tkrt d|dkrt d|||||||||S)aConnect to a remote broker. host is the hostname or IP address of the remote broker. port is the network port of the server host to connect to. Defaults to 1883. Note that the default port for MQTT over SSL/TLS is 8883 so if you are using tls_set() the port may need providing. keepalive: Maximum period in seconds between communications with the broker. If no other messages are being exchanged, this controls the rate at which the client will send ping messages to the broker. clean_start: (MQTT v5.0 only) True, False or MQTT_CLEAN_START_FIRST_ONLY. Sets the MQTT v5.0 clean_start flag always, never or on the first successful connect only, respectively. MQTT session data (such as outstanding messages and subscriptions) is cleared on successful connect when the clean_start flag is set. properties: (MQTT v5.0 only) the MQTT v5.0 properties to be sent in the MQTT connect packet. Tz#Clean start only applies to MQTT V5Nz Properties only apply to MQTT V5)rrrAMQTT_CLEAN_START_FIRST_ONLYr connect_async reconnectrhostr keepalive bind_address bind_port clean_startrs r1ryzClient.connectus& >V # #)-D & &999 !FGGGT!! !CDDD 4y'K M M M~~r0c tdurtd|3tj}||ddzd} d|z}|jrd|z}g}t j|t j j D]K}|j dd} | | |j|j|jfLnK#t jjt jjt jjf$rtd |zwxYw|D]5}|\} } } } || | ||||cS#t*$rY2wxYwtd ) zConnect to a remote broker. domain is the DNS domain to search for SRV records; if None, try to determine local domain name. keepalive, bind_address, clean_start and properties are as for connect() FzXNo DNS resolver library found, try "pip install dnspython" or "pip3 install dnspython3".N.rz _mqtt._tcp.%sz_secure-mqtt._tcp.%sr"z No answer/NXDOMAIN for SRV in %szNo SRV hosts responded)HAVE_DNSrrngetfqdnfindr.dnsresolverquery rdatatypeSRVtargetto_textrYrpriorityweightNXDOMAINNoAnswer NoNameserversry Exception)rdomainrrrrrranswersansweraddrrrpriors r1 connect_srvzClient.connect_srvs u  jll l >^%%FFKK,,q0112F L 6)By 5+f4G,,,R1BCC I I},,..ss36;GIIII I %s|'XY L L L?6JKK K L  F'- $D$f ||D$ <V`aaaaa    1222s BCAD&5E EEc|t|dkrtd|dkrtd|dkrtd|dkr;|9tjdksdtjcxkrd krnntd |dkrtd ||_||_||_||_||_||_ ||_ t|_ dS) aConnect to a remote broker asynchronously. This is a non-blocking connect call that can be used with loop_start() to provide very quick start. host is the hostname or IP address of the remote broker. port is the network port of the server host to connect to. Defaults to 1883. Note that the default port for MQTT over SSL/TLS is 8883 so if you are using tls_set() the port may need providing. keepalive: Maximum period in seconds between communications with the broker. If no other messages are being exchanged, this controls the rate at which the client will send ping messages to the broker. clean_start: (MQTT v5.0 only) True, False or MQTT_CLEAN_START_FIRST_ONLY. Sets the MQTT v5.0 clean_start flag always, never or on the first successful connect only, respectively. MQTT session data (such as outstanding messages and subscriptions) is cleared on successful connect when the clean_start flag is set. properties: (MQTT v5.0 only) the MQTT v5.0 properties to be sent in the MQTT connect packet. Use the Properties class. Nr Invalid host.Invalid port number.zKeepalive must be >=0.rWrr r rr rz(bind_address requires Python 2.7 or 3.2.zInvalid bind port number.) r\rsys version_inforrrr r! _clean_startrmqtt_cs_connect_asyncrrs r1rzClient.connect_asyncs( <3t99>>_-- - 199344 4 q==566 6 2  ,":&((FS5E,N,N,N,N,N,N,N,N,N !KLLL q==899 9  #)#'#- + r0rrcp|j5||_||_d|_ddddS#1swxYwYdS)ah Configure the exponential reconnect delay When connection is lost, wait initially min_delay seconds and double this time every attempt. The wait is capped at max_delay. Once the client is fully connected (e.g. not only TCP socket, but received a success CONNACK), the wait timer is reset to min_delay. N)r*rr r )r min_delay max_delays r1reconnect_delay_setzClient.reconnect_delay_sets ( ) )(1D %(1D %$(D ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s +//c @t|jdkrtd|jdkrtdddgddt dddd|_t j|_|j 5t|_ t|_ dddn #1swxYwYd|_ t|_|||}|jr|j } |j||jd }t/|jd r|jjrd}n;#t2j$rt$r|j|d }YnwxYw||j||r,t3j||j|j d krG||jtC||j|j|j|j"|j#}||_$|j$%dd|_&|'|(|jS) zdReconnect the client after a disconnect. Can only be called after connect()/connect_async().rrrrr0rNF)server_hostnamedo_handshake_on_connectri)rr))r\rrrrrrrrr'rrrr rrr\_messages_reconnect_reset_create_socket_connectionr.r0r/ wrap_socketrjrirNCertificateError settimeoutr do_handshakematch_hostname getpeercertrWebsocketWrapperr?r@rrxr2_call_socket_open _send_connect)rr[ verify_hosts r1rzClient.reconnects tz??a  _-- - :??344 4! !nn',..   - - ) D !*D  - - - - - - - - - - - - - - - !   &&(((--// 9 C#00K ((44$(J,15 D-/?@@()8("'K'      (44,15  OODO , , ,       C"4#3#3#5#5tzBBB ?l * * OODO , , ,#D$*dj$)$($8$:WYYD  q!!!!&    !!$/222s$>'B11B58B5"E!!5FF?c|j|j1|dt\|_|_||S)amProcess network events. It is strongly recommended that you use loop_start(), or loop_forever(), or if you are using an external event loop using loop_read(), loop_write(), and loop_misc(). Using loop() on it's own is no longer recommended. This function must be called regularly to ensure communication with the broker is carried out. It calls select() on the network socket to wait for network events. If incoming data is present it will then be processed. Outgoing commands, from e.g. publish(), are normally sent immediately that their function is called, but this is not always possible. loop() will also attempt to send any remaining outgoing messages, which also includes commands that are part of the flow for messages with QoS>0. timeout: The time in seconds to wait for incoming/outgoing network traffic before timing out and returning. max_packets: Not currently used. Returns MQTT_ERR_SUCCESS on success. Returns >0 on error. A ValueError will be raised if timeout < 0NT)r^)rrrJr_loop)rr max_packetss r1loopz Client.loopBsP4 ? "do&=   d  3 3 3/A/C/C ,DOT_zz'"""r0c|dkrtd |j}|j||jg}n#t $rg}YnwxYwd}t |jdr|j}|dkrd}|j |jg}n|j|jg} tj ||g|}n;#t$r tcYSt$r tcYSt$r tcYSwxYw|j|dvs|dkr|}|s|j|S|jr\|j|dvrM|dd|j |jdn#t"$rYnwxYw|j|dvr|}|s|j|S|S)NgzInvalid timeout.rpendingri')rrpopleft appendleftrrrjrrselect TypeErrorr;rrA loop_readinsertrMrz loop_write loop_misc)rrrwlist pending_bytesrlistsocklistrs r1rz Client._loopbs] S==/00 0 %--//F   ' ' / / /ZLEE   EEE  4:y ) ) 1 J..00M 1  G ? "ZLEEZ1E $}UE2w??HH & & &% % % % & & && % % % $ $ $$ # # # $ :! $ $ (9(9!!B TZ' ? t(1+== QK  q$* - - - $$U++++"     :! $ $""B TZ' ~~sA;A A"!A"<CD 'D 9D  D ;F F#"F#c  |jtkr$|t|dkrtd|d}||t krtd|dks|dkrtdt|tr|d}nrt|ttfr|}nSt|ttfr#t|d}n|d }ntd t|d krtd |}|dkr4t!|}||||||d ||} | |_|St'||} t)| _|| _|| _|| _d | _|| _|j5|jdkrAt|j|jkr$t<| j_| jcdddS||jvr$t<| j_| jcdddS| |j| j <|j!dks|j"|j!kr|xj"dz c_"|dkr tF| _$n|dkr tJ| _$|| j || j| j| j| j| j| j} | tLur|xj"dzc_"tN| _$| | j_| jcdddStP| _$t | j_| jcdddS#1swxYwYdS)aPublish a message on a topic. This causes a message to be sent to the broker and subsequently from the broker to any clients subscribing to matching topics. topic: The topic that the message should be published on. payload: The actual message to send. If not given, or set to None a zero length message will be used. Passing an int or float will result in the payload being converted to a string representing that number. If you wish to send a true int/float, use struct.pack() to create the payload you require. qos: The quality of service level to use. retain: If set to true, the message will be set as the "last known good"/retained message for the topic. properties: (MQTT v5.0 only) the MQTT v5.0 properties to be included. Use the Properties class. Returns a MQTTMessageInfo class, which can be used to determine whether the message has been delivered (using info.is_published()) or to block waiting for the message to be delivered (info.wait_for_publish()). The message ID and return code of the publish() call can be found at info.mid and info.rc. For backwards compatibility, the MQTTMessageInfo class is iterable so the old construct of (rc, mid) = client.publish(...) is still valid. rc is MQTT_ERR_SUCCESS to indicate success or MQTT_ERR_NO_CONN if the client is not currently connected. mid is the message ID for the publish request. The mid value can be used to track the publish request by checking against the mid argument in the on_publish() callback if it is defined. A ValueError will be raised if topic is None, has zero length or is invalid (contains a wildcard), except if the MQTT version used is v5.0. For v5.0, a zero length topic can be used when a Topic Alias has been set. A ValueError will be raised if qos is not one of 0, 1 or 2, or if the length of the payload is greater than 268435455 bytes.NrInvalid topic.rz'Publish topic cannot contain wildcards.rInvalid QoS level.asciir08payload must be a string, bytearray, int, float or None.ir3Fr))rrr\rr_topic_wildcard_len_checkr4rrbytesrrfloatrr _mid_generater _send_publishrrrrrrrrrr(rrrCrrrrmqtt_ms_wait_for_pubackrmqtt_ms_wait_for_pubrecr8mqtt_ms_publishmqtt_ms_queued) rrirrrr local_payload local_midrrmessages r1publishzClient.publishsN >V # #}E a !1222 W%%  ) )% 0 04D D DFGG G 77cAgg122 2 gw ' ' L#NN733MM %!3 4 4 L#MM #u . . LLL//88MM _MMJLL L }   ) )122 2&&(( !88"9--D##5-feT:WWBDGK!)U33G ) G +GOGK#GNGK!+G ( ( (,q00S9K5L5LPTPi5i5i&9GLO"< ( ( ( ( ( ( ( (  222&9GLO"< ( ( ( ( ( ( ( (3:"7;/.!33t7NQUQl7l7l++q0++axx(? (? ++GKQXQ\^e^l,3KwGY[[B---//14//(7 &(GLO"<5 ( ( ( ( ( ( ( (8%3GM&6GLO"<= ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s&,AM89 M8&CM8#M88M<?M<c|dn|d|_||_t|jtr!|jd|_dSdS)aNSet a username and optionally a password for broker authentication. Must be called before connect() to have any effect. Requires a broker that supports MQTT v3.1. username: The username to authenticate with. Need have no relationship to the client id. Must be unicode [MQTT-3.1.3-11]. Set to None to reset client back to not using username/password for broker authentication. password: The password to authenticate with. Optional, set to None if not required. If it is unicode, then it will be encoded as UTF-8. Nr)rrrrr)rusernamepasswords r1username_pw_setzClient.username_pw_sets`"*!1xw7O7O! dng . . <!^227;;DNNN < .s<iiheUVt..u559IIiiiiiir0zInvalid subscription filter.F)rtuplerrrr basestringrr\listrYanyrr8_send_subscribe) rriroptionsrtopic_qos_listtoqs ` r1 subscribezClient.subscribePs` eU # # #~''!&w!'+;<<Y$WYYYY# s eZ ( (" BQww#'' !5666~''?.3777GGAXX$RTTT!'+;<<Y$WYYY#(<<#8#8'"B!C=CJJ!OO$%5666#(<<#8#8#">!? t $ $ BN~''!BBDAq%a)9::4q55AEE",-A"B"BB,333"))188G+<+>>yCFFaKKz!Z7P7PK()9:::"))188G+<+:FFFr0c*d}|tdt|tr9t|dkrtd|dg}n{t|t rfg}|D]a}t|dkst|tstd||db|td|j tdfS| d||S)aRUnsubscribe the client from one or more topics. topic: A single string, or list of strings that are the subscription topics to unsubscribe from. properties: (MQTT v5.0 only) a Properties instance setting the MQTT v5.0 properties to be included. Optional - if not set, no properties are sent. Returns a tuple (result, mid), where result is MQTT_ERR_SUCCESS to indicate success or (MQTT_ERR_NO_CONN, None) if the client is not currently connected. mid is the message ID for the unsubscribe request. The mid value can be used to track the unsubscribe request by checking against the mid argument in the on_unsubscribe() callback if it is defined. Raises a ValueError if topic is None or has zero string length, or is not a string or list. NrrrrF) rrrr\rrrYrr8_send_unsubscribe)rrir topic_listr s r1 unsubscribezClient.unsubscribes$ =-.. . eZ ( ( 55zzQ !1222,,w//0JJ t $ $ 5J 5 5q66Q;;jJ&?&?;$%5666!!!((7"3"34444  KLL L : $d+ +%%eZDDDr0c^|jtSt|jt|jz}|dkrd}t d|D]W}|j tcS|}|dkr||cS|tkr tcSXtS)a3Process read network events. Use in place of calling loop() if you wish to handle your client reads as part of your own application. Use socket() to obtain the client socket to call select() or equivalent on. Do not use if you are using the threaded interface loop_start().Nrr) rr8r\rrr[ _packet_read_loop_rc_handlerr4)rrrTrs r1rzClient.loop_reads : # #$,--D4E0F0FF ??Kq+&& ( (Az!''''""$$BAvv++B/////~%%''''&r0c|jtS |}|tkrDt|r|S|S|dkrR|||r|S|St|r|S|S#|r|w|wxYw)aProcess write network events. Use in place of calling loop() if you wish to handle your client writes as part of your own application. Use socket() to obtain the client socket to call select() or equivalent on. Use want_write() to determine if there is data waiting to be written. Do not use if you are using the threaded interface loop_start().Nr) rr8 _packet_writerr4 want_writerQrYr)rrrs r1rzClient.loop_writesQ : # # 5##%%B^##'    5002222224444a++B//   5002222224444 (   5002222224444   5002222224444s%D3D D?Ec |j}|j|dS#t$rYdSwxYw)zCall to determine if there is network data waiting to be written. Useful if you are calling select() yourself rather than using loop(). TF)rrrr)rrs r1rzClient.want_write6sY %--//F   ' ' / / /4   55 s37 AAcJ|jtSt}||jdkrb||jz |jkrO||jtkrt}nt}| |tStS)zProcess miscellaneous network events. Use in place of calling loop() if you wish to call select() or equivalent on. Do not use if you are using the threaded interface loop_start().Nr) rr8r_check_keepaliver rr\rrr4rD_do_on_disconnectr;)rnowrs r1rzClient.loop_miscAs : # #kk  |dkrtd||_dS)z~Set the maximum number of messages with QoS>0 that can be part way through their network flow at once. Defaults to 20.rzInvalid inflight.N)rr)rinflights r1max_inflight_messages_setz Client.max_inflight_messages_set\s* a<<011 1&.###r0c|dkrtdt|tstd||_|S)z\Set the maximum number of messages in the outgoing message queue. 0 means unlimited.rzInvalid queue size.zInvalid type of queue size.)rrrr)r queue_sizes r1max_queued_messages_setzClient.max_queued_messages_setcsJ >>233 3*c** <:;; ;$.! r0cdS)z%No longer used, remove in version 2.0Nr/)rretrys r1message_retry_setzClient.message_retry_setms r0c||_dS)zESet the user data variable passed to callbacks. May be any data type.N)r)rrEs r1 user_data_setzClient.user_data_setqs !r0c|t|dkrtd|dks|dkrtd|dkr$t|tstdt|tr|d|_nt|ttfr||_n]t|ttfr(t|d|_n|d |_ntd d |_ |d|_||_||_||_dS) a'Set a Will to be sent by the broker in case the client disconnects unexpectedly. This must be called before connect() to have any effect. topic: The topic that the will message should be published on. payload: The message to send as a will. If not given, or set to None a zero length message will be used as the will. Passing an int or float will result in the payload being converted to a string representing that number. If you wish to send a true int/float, use struct.pack() to create the payload you require. qos: The quality of service level to use for the will. retain: If set to true, the will message will be set as the "last known good"/retained message for the topic. properties: (MQTT v5.0 only) a Properties instance setting the MQTT v5.0 properties to be included with the will message. Optional - if not set, no properties are sent. Raises a ValueError if qos is not 0, 1 or 2, or if topic is None or has zero string length. NrrrrzDThe properties argument must be an instance of the Properties class.rrr0rT)r\rrrrrrrrrrrrrrrrr)rrirrrrs r1will_setzClient.will_setus_( =CJJ!OO-.. . 77cAgg122 2   jZ&H&H VXX X gw ' ' L!(!8!8D   %!3 4 4 L!(D   #u . . L!$W!4!4W!=!=D   _!$D  JLL L  <<00" *r0cLd|_d|_d|_d|_d|_dS)z| Removes a will that was previously configured with will_set(). Must be called before connect() to have any effect.Fr0rN)rrrrrrs r1 will_clearzClient.will_clears0  !r0c|jS)z0Return the socket or ssl object for this client.)rrs r1rnz Client.sockets zr0cJdrjdurnjtkrs n^#tt f$rI|std YnwxYwnr t}|tkr] |}jdur4tj dkrtjdkrd}d|tk]fd}|sjsdn} |rdn\ nF#tt f$r2tdYnwxYw |S)a@This function calls the network loop functions for you in an infinite blocking loop. It is useful for the case where you only want to run the MQTT client loop in your program. loop_forever() will handle reconnecting for you if reconnect_on_failure is true (this is the default behavior). If you call disconnect() in a callback it will return. timeout: The time in seconds to wait for incoming/outgoing network traffic before timing out and returning. max_packets: Not currently used. retry_first_connection: Should the first connection attempt be retried on failure. This is independent of the reconnect_on_failure setting. Raises OSError/WebsocketConnectionError on first connection failures unless retry_first_connection=True TzConnection failed, retryingrrFc>jtkp dupjduS)NFT)rrr-)runrsr1 should_exitz(Client.loop_forever..should_exits({&;;mse|mtOeimOmmr0)r-rrrOSErrorr+_handle_on_connect_fail _easy_logMQTT_LOG_DEBUG_reconnect_waitr4rr\rrr )rrrretry_first_connectionrr3r2s` @r1 loop_foreverzClient.loop_foreversL& %--{333+NN$$$$!9:+++002221NN&(EGGG((***** + " K!B(((ZZ(( *d22D,--22 233q88BC((( n n n n n n{}} KD$> K$$&&&;==KCCK((((#%=>KKK44666*,IKKKKKK7 K@ s#7ABBEAFFc|jtSt\|_|_d|_t j|j|_d|j_ |j dS)zThis is part of the threaded client interface. Call this once to start a new thread to process network traffic. This provides an alternative to repeatedly calling loop() yourself. NF)rT) r,r7rrrr-rThread _thread_maindaemonstartrs r1 loop_startzClient.loop_startsj < #! !+=+?+?(!& 't/@AAA "  r0c|jtSd|_tj|jkr"|jd|_dSdS)aThis is part of the threaded client interface. Call this once to stop the network thread previously created with loop_start(). This call will block until the network thread finishes. The force parameter is currently ignored. NT)r,r7r-rcurrent_threadr])rforces r1 loop_stopzClient.loop_stop sW < ! !!%  # % % 5 5 L     DLLL 6 5r0c|jS)z_If implemented, called when the client has log information. Defined to allow debugging.r3rs r1on_logz Client.on_logs |r0c||_dS)a Define the logging callback implementation. Expected signature is: log_callback(client, userdata, level, buf) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() level: gives the severity of the message and will be one of MQTT_LOG_INFO, MQTT_LOG_NOTICE, MQTT_LOG_WARNING, MQTT_LOG_ERR, and MQTT_LOG_DEBUG. buf: the message itself Decorator: @client.log_callback() (```client``` is the name of the instance which this callback is being attached to) NrFrfuncs r1rGz Client.on_logs" r0cfd}|S)Nc|_|Sr)rGrJrs r1 decoratorz&Client.log_callback..decorator2sDKKr0r/rrNs` r1 log_callbackzClient.log_callback1$     r0c|jS)zRIf implemented, called when the broker responds to our connection request.)r4rs r1 on_connectzClient.on_connect7s r0cT|j5||_ddddS#1swxYwYdS)a Define the connect callback implementation. Expected signature for MQTT v3.1 and v3.1.1 is: connect_callback(client, userdata, flags, rc) and for MQTT v5.0: connect_callback(client, userdata, flags, reasonCode, properties) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() flags: response flags sent by the broker rc: the connection result reasonCode: the MQTT v5.0 reason code: an instance of the ReasonCode class. ReasonCode may be compared to integer. properties: the MQTT v5.0 properties returned from the broker. An instance of the Properties class. For MQTT v3.1 and v3.1.1 properties is not provided but for compatibility with MQTT v5.0, we recommend adding properties=None. flags is a dict that contains response flags from the broker: flags['session present'] - this flag is useful for clients that are using clean session set to 0 only. If a client with clean session=0, that reconnects to a broker that it has previously connected to, this flag indicates whether the broker still has the session information for the client. If 1, the session still exists. The value of rc indicates success or not: 0: Connection successful 1: Connection refused - incorrect protocol version 2: Connection refused - invalid client identifier 3: Connection refused - server unavailable 4: Connection refused - bad username or password 5: Connection refused - not authorised 6-255: Currently unused. Decorator: @client.connect_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r4rIs r1rSzClient.on_connect=szR ! $ $#D  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ !!cfd}|S)Nc|_|Sr)rSrMs r1rNz*Client.connect_callback..decoratorj"DOKr0r/rOs` r1connect_callbackzClient.connect_callbackirQr0c|jS)zOIf implemented, called when the client failed to connect to the broker.)r5rs r1on_connect_failzClient.on_connect_failos $$r0cT|j5||_ddddS#1swxYwYdS)a Define the connection failure callback implementation Expected signature is: on_connect_fail(client, userdata) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() Decorator: @client.connect_fail_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r5rIs r1r[zClient.on_connect_failusy ! ) )$(D ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )rUcfd}|S)Nc|_|Sr)r[rMs r1rNz/Client.connect_fail_callback..decorator#'D Kr0r/rOs` r1connect_fail_callbackzClient.connect_fail_callbackrQr0c|jS)zOIf implemented, called when the broker responds to a subscribe request.)r6rs r1 on_subscribezClient.on_subscribes !!r0cT|j5||_ddddS#1swxYwYdS)a Define the subscribe callback implementation. Expected signature for MQTT v3.1.1 and v3.1 is: subscribe_callback(client, userdata, mid, granted_qos) and for MQTT v5.0: subscribe_callback(client, userdata, mid, reasonCodes, properties) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() mid: matches the mid variable returned from the corresponding subscribe() call. granted_qos: list of integers that give the QoS level the broker has granted for each of the different subscription requests. reasonCodes: the MQTT v5.0 reason codes received from the broker for each subscription. A list of ReasonCodes instances. properties: the MQTT v5.0 properties received from the broker. A list of Properties class instances. Decorator: @client.subscribe_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r6rIs r1rbzClient.on_subscribesy0 ! & &!%D  & & & & & & & & & & & & & & & & & &rUcfd}|S)Nc|_|Sr)rbrMs r1rNz,Client.subscribe_callback..decorators $D Kr0r/rOs` r1subscribe_callbackzClient.subscribe_callbackrQr0c|jS)a#If implemented, called when a message has been received on a topic that the client subscribes to. This callback will be called for every message received. Use message_callback_add() to define multiple callbacks that will be called for specific topic filters.)r7rs r1 on_messagezClient.on_messages r0cT|j5||_ddddS#1swxYwYdS)a1 Define the message received callback implementation. Expected signature is: on_message_callback(client, userdata, message) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() message: an instance of MQTTMessage. This is a class with members topic, payload, qos, retain. Decorator: @client.message_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r7rIs r1rhzClient.on_messagey  ! $ $#D  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $rUcfd}|S)Nc|_|Sr)rhrMs r1rNz*Client.message_callback..decoratorrXr0r/rOs` r1message_callbackzClient.message_callbackrQr0c|jS)aIf implemented, called when a message that was to be sent using the publish() call has completed transmission to the broker. For messages with QoS levels 1 and 2, this means that the appropriate handshakes have completed. For QoS 0, this simply means that the message has left the client. This callback is important because even if the publish() call returns success, it does not always mean that the message has been sent.)r8rs r1 on_publishzClient.on_publishs r0cT|j5||_ddddS#1swxYwYdS)aK Define the published message callback implementation. Expected signature is: on_publish_callback(client, userdata, mid) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() mid: matches the mid variable returned from the corresponding publish() call, to allow outgoing messages to be tracked. Decorator: @client.publish_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r8rIs r1rozClient.on_publishrjrUcfd}|S)Nc|_|Sr)rorMs r1rNz*Client.publish_callback..decoratorrXr0r/rOs` r1publish_callbackzClient.publish_callbackrQr0c|jS)zRIf implemented, called when the broker responds to an unsubscribe request.)r9rs r1on_unsubscribezClient.on_unsubscribes ##r0cT|j5||_ddddS#1swxYwYdS)a Define the unsubscribe callback implementation. Expected signature for MQTT v3.1.1 and v3.1 is: unsubscribe_callback(client, userdata, mid) and for MQTT v5.0: unsubscribe_callback(client, userdata, mid, properties, reasonCodes) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() mid: matches the mid variable returned from the corresponding unsubscribe() call. properties: the MQTT v5.0 properties received from the broker. A list of Properties class instances. reasonCodes: the MQTT v5.0 reason codes received from the broker for each unsubscribe topic. A list of ReasonCodes instances Decorator: @client.unsubscribe_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r9rIs r1ruzClient.on_unsubscribesy, ! ( (#'D  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (rUcfd}|S)Nc|_|Sr)rurMs r1rNz.Client.unsubscribe_callback..decorator"&D Kr0r/rOs` r1unsubscribe_callbackzClient.unsubscribe_callbackrQr0c|jS)zLIf implemented, called when the client disconnects from the broker. )r:rs r1 on_disconnectzClient.on_disconnect s ""r0cT|j5||_ddddS#1swxYwYdS)a Define the disconnect callback implementation. Expected signature for MQTT v3.1.1 and v3.1 is: disconnect_callback(client, userdata, rc) and for MQTT v5.0: disconnect_callback(client, userdata, reasonCode, properties) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() rc: the disconnection result The rc parameter indicates the disconnection state. If MQTT_ERR_SUCCESS (0), the callback was called in response to a disconnect() call. If any other value the disconnection was unexpected, such as might be caused by a network error. Decorator: @client.disconnect_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r:rIs r1r|zClient.on_disconnect&sy, ! ' '"&D  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'rUcfd}|S)Nc|_|Sr)r|rMs r1rNz-Client.disconnect_callback..decorator@s!%D Kr0r/rOs` r1disconnect_callbackzClient.disconnect_callback?rQr0c|jS)z7If implemented, called just after the socket was opend.)r;rs r1on_socket_openzClient.on_socket_openEs ##r0cT|j5||_ddddS#1swxYwYdS)aADefine the socket_open callback implementation. This should be used to register the socket to an external event loop for reading. Expected signature is: socket_open_callback(client, userdata, socket) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() sock: the socket which was just opened. Decorator: @client.socket_open_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r;rIs r1rzClient.on_socket_openJsy  ! ( (#'D  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (rUcfd}|S)Nc|_|Sr)rrMs r1rNz.Client.socket_open_callback..decorator^ryr0r/rOs` r1socket_open_callbackzClient.socket_open_callback]rQr0cB|j5|j}dddn #1swxYwY|rv|j5 |||j|jn;#t $r.}|td||jsYd}~nd}~wwxYwddddS#1swxYwYdSdS)z9Call the socket_open callback with the just-opened socketNz&Caught exception in on_socket_open: %s) r&rr$rrrr6 MQTT_LOG_ERRrB)rrerrs r1rzClient._call_socket_opencsq  ! 1 1!0N 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1  (  "N4DDDD NN$&NPSUUU3                    sF  BA  B B$A=8B=BBBBc|jS)z8If implemented, called just before the socket is closed.)r<rs r1on_socket_closezClient.on_socket_closers $$r0cT|j5||_ddddS#1swxYwYdS)aNDefine the socket_close callback implementation. This should be used to unregister the socket from an external event loop for reading. Expected signature is: socket_close_callback(client, userdata, socket) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() sock: the socket which is about to be closed. Decorator: @client.socket_close_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r<rIs r1rzClient.on_socket_closewsy  ! ) )$(D ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )rUcfd}|S)Nc|_|Sr)rrMs r1rNz/Client.socket_close_callback..decoratorr_r0r/rOs` r1socket_close_callbackzClient.socket_close_callbackrQr0c8|j5|j}dddn #1swxYwY|rq|j5 |||j|n;#t$r.}|t d||jsYd}~nd}~wwxYwddddS#1swxYwYdSdS)zACall the socket_close callback with the about-to-be-closed socketNz'Caught exception in on_socket_close: %s)r&rr$rrr6rrB)rr[rrs r1rZzClient._call_socket_closeso  ! 3 3"2O 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3  (  #OD$.$???? NN$&OQTVVV3                    sF  B AB  A=$A83B 8A==B  BBc|jS)z?If implemented, called when the socket needs writing but can't.r=rs r1on_socket_register_writezClient.on_socket_register_writes --r0cT|j5||_ddddS#1swxYwYdS)aqDefine the socket_register_write callback implementation. This should be used to register the socket with an external event loop for writing. Expected signature is: socket_register_write_callback(client, userdata, socket) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() sock: the socket which should be registered for writing Decorator: @client.socket_register_write_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r=rIs r1rzClient.on_socket_register_writesy  ! 2 2-1D * 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2rUcfd}|S)Nc|_|SrrrMs r1rNz8Client.socket_register_write_callback..decorators-1D *Kr0r/rOs` r1socket_register_write_callbackz%Client.socket_register_write_callbackrQr0c0|jr|jrdSd|_|j5|j}dddn #1swxYwY|rV |||j|jdS#t $r/}|td||jsYd}~dSd}~wwxYwdS)zBCall the socket_register_write callback with the unwritable socketNTz0Caught exception in on_socket_register_write: %s) rr2r&rrrr6rrB)rrrs r1rQz"Client._call_socket_register_writesKz T3  F!%  ! E E'+'D $ E E E E E E E E E E E E E E E $  (($.$*66666    "TVY[[[/    s$377A B$$BBc|jS)zDIf implemented, called when the socket doesn't need writing anymore.r>rs r1on_socket_unregister_writez!Client.on_socket_unregister_writes //r0cT|j5||_ddddS#1swxYwYdS)a{Define the socket_unregister_write callback implementation. This should be used to unregister the socket from an external event loop for writing. Expected signature is: socket_unregister_write_callback(client, userdata, socket) client: the client instance for this callback userdata: the private user data as set in Client() or userdata_set() sock: the socket which should be unregistered for writing Decorator: @client.socket_unregister_write_callback() (```client``` is the name of the instance which this callback is being attached to) N)r&r>rIs r1rz!Client.on_socket_unregister_writesy  ! 4 4/3D , 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4rUcfd}|S)Nc|_|SrrrMs r1rNz:Client.socket_unregister_write_callback..decorators/3D ,Kr0r/rOs` r1 socket_unregister_write_callbackz'Client.socket_unregister_write_callbackrQr0c.|p|j}|r|jsdSd|_|j5|j}dddn #1swxYwY|rQ |||j|dS#t $r/}|td||jsYd}~dSd}~wwxYwdS)zBCall the socket_unregister_write callback with the writable socketNFz2Caught exception in on_socket_unregister_write: %s) rr2r&rrrr6rrB)rr[rrs r1rYz$Client._call_socket_unregister_writesH!tz 41  F!&  ! I I)-)H & I I I I I I I I I I I I I I I &  **4FFFFF    "VX[]]]/   s$7;;A B#$B  Bc||td|j5||j|<ddddS#1swxYwYdS)aRegister a message callback for a specific topic. Messages that match 'sub' will be passed to 'callback'. Any non-matching messages will be passed to the default on_message callback. Call multiple times with different 'sub' to define multiple topic specific callbacks. Topic specific callbacks may be removed with message_callback_remove().Nz&sub and callback must both be defined.)rr&r)rrhcallbacks r1message_callback_addzClient.message_callback_add s  s{EFF F  ! 6 6-5D %c * 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6s 377cfd}|S)Nc4||Sr)r)rJrrhs r1rNz(Client.topic_callback..decorator s  % %c4 0 0 0Kr0r/)rrhrNs`` r1topic_callbackzClient.topic_callback s*      r0c|td|j5 |j|=n#t$rYnwxYwddddS#1swxYwYdS)zTRemove a message callback previously registered with message_callback_add().Nzsub must defined.)rr&rKeyError)rrhs r1message_callback_removezClient.message_callback_remove s ;011 1  !   -c22                      s,A$A 1A1AAAc|rA||jtkrt}||||Sr)r\rrr4r)rrrs r1rzClient._loop_rc_handle' sJ  3      {333%  " "2z 2 2 2 r0c :|jddkr |d}t|dkrtSt jd|\}||jd<nL#t $r tcYSt$r-}| td|tcYd}~Sd}~wwxYw|jddkrC |d}t|dkrtSt jd|\}|jd |t|jdd krtS|jd xx|d z|jd zz cc<|jd d z|jd <nL#t $r tcYSt$r-}| td|tcYd}~Sd}~wwxYw|d zdkrn#d|jd<|jd |jd<d}|jddkr ||jd}t|dkrtS|jdxxt|zcc<|jdxx|z cc<nL#t $r tcYSt$r-}| td|tcYd}~Sd}~wwxYw|dz}|dkr9|j 5t|_dddn #1swxYwYtS|jddkd|jd<|}ddgddt#dddd|_|j 5t|_dddn #1swxYwY|S)Nrrrz!Bfailed to receive on socket: %srTrr rrrrdrrr0r)rrSr\r;structunpackrzrConnectionErrorr6rrYr6r'rr_packet_handler)rrrbytecountdatars r1rzClient._packet_read2 s ?9 % * * 5//!,,w<<1$$--!=w77-4 **# & & &%%%%" * * * "CSJJJ))))))) * ?+ , 1 1 `??1--D4yyA~~11"M$55EDO$56==dCCC4?+<=>>BB00O$6777s do6F&G>-- ---T:---)))T1))))# & & &%%%%" * * * "CSJJJ))))))) * QJEzz(44(1 D%444444444444444%%%ol+a//*"#  " "! !nn  , , ) D  , , , , , , , , , , , , , , , sA$$B-7 B-"B("B-(B-FG! G*"G GG J K K("K KK*L  LL0NNNc |j}n#t$r tcYSwxYw ||d|dd}n#t t f$r$|j|tcYSt$r$|j|tcYSt$rG}|j|| td|tcYd}~Sd}~wwxYw|dkr|dxx|zcc<|dxx|z cc<|ddkrR|ddztkr|d dkr|j5|j}dddn #1swxYwY|rt|j5 |||j|d n;#t&$r.}| td ||jsYd}~nd}~wwxYwdddn #1swxYwY|d |ddzt,krg|j5t1|_dddn #1swxYwY|t|tSn|j|nn|j5t1|_dddn #1swxYwYtS) NTrrrrrrrrr"Caught exception in on_publish: %sr)rrrr4rWAttributeErrorrrrzrrr6rr;PUBLISHr&ror$rrrBr DISCONNECTr'rrrr\)rr write_lengthrros r1rzClient._packet_write s7  ()1133 ( ( ('''' ( *#8$VE]^^4 6 6 "J/ ( ( ( ++F333''''" & & & ++F333%%%%" * * * ++F333 "CSJJJ)))))))  * a|$$$ 4$$$u - ,'1,,y)D0W<<RSASAS!199)-J999999999999999& .!%!8..!.$.J(,dnfUm%M%M%M%M'0!.!.!.$(NN(46Z\_%a%a%a+/+C%.(-%.%.%.%.%.!. ...............v88:::y)D0Z??!0==1:D.===============../?@@@((***// @$//7777o7 r  - -!*D  - - - - - - - - - - - - - - - s11)A2D*D? DG;7III=KK!$K!c|j4||z} |||j||n#t$rYnwxYw|j#t|}|jj||g|RdSdSr)rGrrr1 LOGGING_LEVELlog)rlevelfmtargsrV level_stds r1r6zClient._easy_log s ; "*C  D$.%====     < #%e,I DL Y 3d 3 3 3 3 3 3 $ #s , 99c|jdkrtSt}|j5|j}|j}dddn #1swxYwY|j||z |jks||z |jkr|jtkr|j dkr | |j5||_||_ddddS#1swxYwYdS#t$r2| | tYdSwxYw| |jtkrt}nt }| |dSdSdSr)rr4rr'rrrrrr  _send_pingreqrr\rr;rrD)rr last_msg_out last_msg_inrs r1rzClient._check_keepalive s ?a  # #kk   , ,-L+K , , , , , , , , , , , , , , , : !s\'9T_'L'LPSVaPaeietPtPt{///DLA4E4E0&&((( ,00-0*,/)000000000000000000 !???$$&&&**+=>>>>>>?  """;"777)BB+B&&r*****' " !PtPts5AA AC)CC  C 8D Dc|j5|xjdz c_|jdkrd|_|jcdddS#1swxYwYdS)Nr)r+r rs r1rzClient._mid_generate s  % " " NNa NN~&&!">  " " " " " " " " " " " " " " " " " "s)>AAcTd|vsd|vst|dkrtStS)N+#)r\r7r4)ris r1rz Client._topic_wildcard_len_check s1 5==DEMMSZZ%-?-?! !# #r0ct|dksCt|dks0td|dDsd|vrtStS)Nrrc3LK|]}t|dkd|vpd|vV dS)rrrN)r\)rSps r1rVz4Client._filter_wildcard_len_check.. s9QQac!ffqjj419) jjjjQQr0/s#/)r\r splitr7r4)rhs r1rz!Client._filter_wildcard_len_check s_ HHMMSXX--QQ399T??QQQQQ.C<<! !# #r0c|td|t}|tkrt |_|S)NzSending PINGREQ)r6r7_send_simple_commandPINGREQr4rr )rrs r1rzClient._send_pingreq sF ~'8999  & &w / / ! ! !$;;DL r0cl|td|tS)NzSending PINGRESP)r6r7rPINGRESPrs r1_send_pingrespzClient._send_pingresp# s+ ~'9:::((222r0cr|td||t|dS)NzSending PUBACK (Mid: %d)F)r6r7_send_command_with_midPUBACKrs r1 _send_pubackzClient._send_puback' 1 ~'A3GGG**63>>>r0cr|td||t|dS)NzSending PUBCOMP (Mid: %d)F)r6r7rPUBCOMPrs r1 _send_pubcompzClient._send_pubcomp+ s1 ~'BCHHH**7C???r0cg} |dz}|dz}|dkr|dz}|||||dkr|SH)NTrr)rY)rrrremaining_bytesrs r1_pack_remaining_lengthzClient._pack_remaining_length/ sp #c)D/36 !##   " "4 ( ( ( MM$   1$$  r0ct|tr|d}|t jdt |||dS)Nr!H)rrrrZrpackr\)rrrs r1 _pack_str16zClient._pack_str16> sa dG $ $ (;;w''D fk$D 22333 dr0r0c t|tst|ts|J|jtSt|dzdzz|dzz|z} t } | | t|} dt|z| z} | dkrS|jtkr"| td||||||nu| td|||||nT|jtkr#| td||||||| n!| td|||||| |dkr| dz } |jtkr+|d } n| } | t| z } | | | || ||dkr(| t!j d ||jtkr| | | ||t| |||S) Nrr rrzHSending PUBLISH (d%d, q%d, r%d, m%d), '%s', properties=%s (NULL payload)z9Sending PUBLISH (d%d, q%d, r%d, m%d), '%s' (NULL payload)zISending PUBLISH (d%d, q%d, r%d, m%d), '%s', properties=%s, ... (%d bytes)z:Sending PUBLISH (d%d, q%d, r%d, m%d), '%s', ... (%d bytes)r)rrrr8rrrYr\rrr6r7rrrrZr _packet_queue)rrrirrrrrrrr payloadlenrpacked_propertiess r1rzClient._send_publishD steW-- 6j W77 6")"5"5"5 : # #cCiA-.#(;fD g\\ s5zz>J6 ??~''"^fc5* "Ofc5 ~''"_fc5*j "Pfc5* 77  !  >V # #!$+!!$.OO$5$5! $5 6 6 6  ##F,<=== ''' 77 MM&+dC00 1 1 1 >V # # MM+ , , , g!!'63TBBBr0cr|td||t|dS)NzSending PUBREC (Mid: %d)F)r6r7rPUBRECrs r1 _send_pubreczClient._send_pubrec rr0cx|td||tdz|dS)NzSending PUBREL (Mid: %d)rF)r6r7rPUBRELrs r1 _send_pubrelzClient._send_pubrel s5 ~'A3GGG**6A:sEBBBr0cr|r|dz}d}tjd|||}||||dS)Nrrz!BBHrrrr)rrrrrrs r1rzClient._send_command_with_mid sI   sNGVW.>DD!!'63:::r0cbd}tjd||}|||ddS)Nr!BBr)rrrrs r1rzClient._send_simple_command s6UG-=>>!!'61a888r0c |j}|tkrdnd}dt|zdzdzdzdzt|jz}d}|jtkr.|jdkr|dz}n)|jt kr |jr|dz}n |jr|dz}|j rS|dt|j zdzt|j zz }|d|j dzdzz|j dzd zzz}|jE|dt|jzz }|d z}|j|d z}|dt|jzz }|jtkrq|jd }n|j}|t|z }|j r5|jd }n|j}|t|z }t&}t)} | ||jt.kr|d z}|| || t5jd t7t|zdzt||||||jtkr| |z } || |j|j rK|jtkr| |z } || |j || |j |j=|| |j|j|| |j||_|jtkrS|t>d|d zdz |d zdz |dzd z |dzdz |dzdz |dzdz ||j|j nL|t>d|d zdz |d zdz |dzd z |dzdz |dzdz |dzdz ||j | || ddS)NsMQTTsMQIsdprrrTr r r rrrrsBBHzQSending CONNECT (u%d, p%d, wr%d, wq%d, wf%d, c%d, k%d) client_id=%s properties=%sr rrzCSending CONNECT (u%d, p%d, wr%d, wq%d, wf%d, c%d, k%d) client_id=%s)!rMQTTv311r\rrrrrArrrrrrrrrrrCONNECTrrYrrrrZrrrrr6r7r) rr proto_verrFr connect_flagspacked_connect_propertiespacked_will_propertiesrrs r1rzClient._send_connect sN '83377s8}},q0 DO,,- >V # # D((% "&AAAdF`A%   " T !M : 1 D$%%!&()!*,/0B,C,C!D D  Tdnt&;%AB"T)a/1 1M > % C$7$7 7 7  T !M~)%  ADN(;(;$;; >V # #'/,3)),0,D,I,I,K,K) $= > > > z @(0-4**-1-B-G-G-I-I* C(>$?$??  g   + +  I ##F,<=== fk$S]]););";f"Dc(mmU]_hjw"+-- . . . >V # # / /F 111 : 9~''00   VT%5 6 6 6   VT%7 8 8 8 > %   VT^ 4 4 4~)  888# >V # # NNc%!+%!+%!+%!+$*$*(     NNU%!+%!+%!+%!+$*$*   !!'61a888r0cp|jtkr|td||n|tdd}t}t }|||jtkrL||H|ttdz d}|dz }|&|}|t|z }| |||jtkr(|dkr"||z }|dkr||z }| ||ddS)Nz.Sending DISCONNECT reasonCode=%s properties=%szSending DISCONNECTrr  identifierr) rrr6r7rrrYrrr\rr)rrrrrr packed_propss r1rzClient._send_disconnect sK >V # # NN>+[%%     NN>+? @ @ @ g >V # #%)?%!,Z1_!K!K!KJ A% )#-??#4#4L$L(9(99$ ##F,<=== >V # #T!!*//+++%%l*F!!'61a888r0cd}|jtkr+|d}n|}|t|z }|D]\}}|dt|zdzz }t|dzzdz}t } | ||| ||} | tjd| |jtkr| |z } |D]X\}} | | ||jtkr| | z } C| | Y| td|| |||| | d| fS)Nrrrr rzSending SUBSCRIBE (d%d, m%d) %s)rrrr\ SUBSCRIBErrYrrrZrrr6r7r) rrtopicsrrpacked_subscribe_propertiesr rTrrrrs r1r zClient._send_subscribe' s >V # #!.5++.8oo.?.?+ $? @ @ @  / /DAq CFF Q .  sax(3. g ##F,<===&&((  fk$ 22333 >V # # 1 1F ! !DAq   VQ ' ' '~''!&&((" a       -       ""7FIqAA9MMr0cd}|jtkr+|d}n|}|t|z }|D]}|dt|zz }t|dzzdz}t }||||||} | tjd| |jtkr||z }|D]}| |||jtkr | td|| ||n| td|| ||||| d| fS)Nrrr rz$Sending UNSUBSCRIBE (d%d, m%d) %s %sz!Sending UNSUBSCRIBE (d%d, m%d) %sr)rrrr\ UNSUBSCRIBErrYrrrZrrr6r7r) rrrrrpacked_unsubscribe_propertiesr rrrs r1rzClient._send_unsubscribeL s >V # #!07--0:0A0A- $A B B B  + +A CFF *  *S0 g ##F,<===&&((  fk$ 22333 >V # # 3 3F ( (A   VQ ' ' ' ' >V # # NN6      NN3    ""7FIqAA9MMr0cl|jtkr|jtkr|jS|jS|jSr)rrrrrArrs r1_check_clean_sessionzClient._check_clean_sessionx s9 >V # # $???11((& &r0c|j5d|_|jD]}d|_|jdks|j|jkr|jdkr t|_<|jdkr$|jtkrd|_ t|_k|jdkrx| r$|jtkrd|_ t|_|jtkr t|_|jtkrd|_ t|_t|_ ddddS#1swxYwYdS)NrrTr)r(rrvaluesrrrrrrrr mqtt_ms_wait_for_pubcompmqtt_ms_resend_pubrelrrrms r1_messages_reconnect_reset_outz$Client._messages_reconnect_reset_out sv  $ - -&'D #'..00 - - .!33t7NQUQl7l7luzz"1!7&===$(AE"1!4466 : w/99(,&5AGG w*BBB*?#$7.E#E#E,0AE*9,AGG1 - - - - - - - - - - - - - - - - - - -sDD33D7:D7cX|j5|r&tj|_ ddddS|jD]4}d|_|jdkr |j|j 45 ddddS#1swxYwYdS)Nrr) r)r rrrr rrpoprrs r1_messages_reconnect_reset_inz#Client._messages_reconnect_reset_in s  #  ((** $/$;$=$=!        &--//   5A::%))!%0000                    s.BABB#&B#cV||dSr)rrrs r1rz Client._messages_reconnect_reset s, **,,, ))+++++r0c|||dt|||d}|j||j1 |jt n#t $rYnwxYw|jN|jG|j dr-|j | S| tS)Nr)rrrrrrrF)r\rrYrrU sockpair_datarzr,r=r$acquirereleaserrQr4)rrrrrrmpkts r1rzClient._packet_queue sf++ %%% ? & $$]3333"     < D$B$J&..u55 )'//111((( ((***sA A'&A'c6|jddz}|tkr|S|tkr|S|t kr|dS|tkr|dS|tkr| S|tkr| S|tkr| S|tkr|S|t kr|S|t$kr|S|t(kr$|jt,kr|S|t2d|t4S)NrrrrzError: Unrecognised command %s)rr_handle_pingreqr_handle_pingrespr_handle_pubackcomprr_handle_publishr_handle_pubrecr_handle_pubrelCONNACK_handle_connackSUBACK_handle_subackUNSUBACK_handle_unsubackrrr_handle_disconnectr6rr6)rcmds r1rzClient._packet_handle smoi(4/ '>>'')) ) H__((** * F]]**844 4 G^^**955 5 G^^'')) ) F]]&&(( ( F]]&&(( ( G^^'')) ) F]]&&(( ( H__((** * J  4>V#;#;**,, , NN<)I3 O O O$ $r0c|jddkrtS|td|S)NrrzReceived PINGREQ)rr6r6r7rrs r1rzClient._handle_pingreq sB ?- .! 3 3$ $ ~'9:::""$$$r0c|jddkrtSd|_|tdt S)NrrzReceived PINGRESP)rr6r r6r7r4rs r1rzClient._handle_pingresp s? ?- .! 3 3$ $  ~':;;;r0c  |jtkr|jddkrtSn|jddkrtS|jtkrt jd|jddd\}}|dkrd}d}n|t tdz |}ttdz }||jdddn#t jd|jd\}}|jtkr|tkrK|j stS| td ||t|_|S|t krv|jd krk|j stS| td ||t%t'jjd |_|S|dkrt,|_d|_|jtkr| td|||n| td||d|_|j5|j}dddn #1swxYwY|ri}|dz|d<|j5 |jtkr|||j|||n|||j||n;#t<$r.}| t>d||j sYd}~nd}~wwxYwdddn #1swxYwY|dkr1d}|j!5|j"#D]} tI| _%| j&tNkr)|(tRccdddS| j*dkr|j5|+| j,| j-.d| j/| j*| j0| j1| j2}dddn #1swxYwY|dkr|ccdddSn| j*dkr| j&tfkr|xj4dz c_4tj| _&|j5|+| j,| j-.d| j/| j*| j0| j1| j2}dddn #1swxYwY|dkr|ccdddSn;| j*dkr/| j&tfkr|xj4dz c_4tl| _&|j5|+| j,| j-.d| j/| j*| j0| j1| j2}dddn #1swxYwY|dkr|ccdddSn{| j&tnkrk|xj4dz c_4tp| _&|j5|9| j,}dddn #1swxYwY|dkr|ccdddS|( dddn #1swxYwY|S|dkr |dkrttStS)Nrrrrrr rz=Received CONNACK (%s, %s), attempting downgrade to MQTT v3.1.r0z:Received CONNACK (%s, %s), attempting to use non-empty CIDrrrz'Received CONNACK (%s, %s) properties=%szReceived CONNACK (%s, %s)Fzsession presentz"Caught exception in on_connect: %srrr);rrrr6rrrr#rrrIr r6r7rrrJrrcrrrrrr rAr&rSr$rrrrBr(rr rrrrrr4rrrrirrrrrrrrrrrrr9) rflagsresultreasonrrS flags_dictrrrs r1r$zClient._handle_connack s( >V # #12Q66((7 _/ 0A 5 5$ $ >V # #$mtx0!466OUF{{! $W\fEEE'1 55 !!$/(";ABB"?@@@@$mE4?83LMMOUF >X % %9991-,,"S6 ")~~'''???3..1-,,"P6 #))92"F"F"F~~''' Q;;+DK$(D ! >V # # NN I5RXZd f f f f NN ;UF L L L&+"  ! ) )J ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  J,1DLJ( )(   ~//" 4(2FJHHHH#  $.*fFFF NN$&JCQQQ3                Q;;B(; &; &+2244:&:&A"+++AKw.00)))/// ; &; &; &; &; &; &; &; &uzz!4  !%!3!3 ! !w 7 7 ! ! ! !+,<"4""B               77#%II'; &; &; &; &; &; &; &; &$#!7o55 33q833&=AG!%!8 " "%)%7%7$%E$%GNN7$;$;$%I$%E$%H$%E/0|&8&"&" " " " " " " " " " " " " " " " "Qww') G; &; &; &; &; &; &; &; &H!7o55 33q833&=AG!%!8 " "%)%7%7$%E$%GNN7$;$;$%I$%E$%H$%E/0|&8&"&" " " " " " " " " " " " " " " " "Qww') g; &; &; &; &; &; &; &; &d 'W(=== 33q833&>AG!%!8>>%)%6%6qu%=%=>>>>>>>>>>>>>>>!Qww') u; &; &; &; &; &; &; &; &vOO%%%%u:&; &; &; &; &; &; &; &; &; &; &; &; &; &; &; &zI aZZFQJJ( ($ $sI22I69I6L8K  L L$K>9L>LLLL-AYY(AP; YP YP  Y(AY(AS; YS YS  Y(AY)AV< YV YV  Y)4YX8 YX Y X Y%YY Y ctdz }dx}}|jddkrzt|}||jd|jddkr:t |}||jddd\}}|t d|||||tS)Nr rrrr rzReceived DISCONNECT %s %s) rrrrrr6r7rr4)r packet_type reasonCoderprops props_lens r1r)zClient._handle_disconnect s Ao "&& Z ?- . 2 2$[11J   doh7 8 8 812Q66' 44 #-#4#4OH-abb1$3$3 y ~'B!!    Z444r0c|tddtt|jddz zdz}t j||jd\}}|jtkrttdz }||\}}g}||dD]S}tj ddkrt|}|ttdz | Tn*d d t|zz}t j||} |j5|j} dddn #1swxYwY| r|j5 |jtkr| ||j|||n| ||j|| n;#t($r.} |t*d | |jsYd} ~ nd} ~ wwxYwdddn #1swxYwYt.S) NzReceived SUBACKrrrsr rr r!Bz$Caught exception in on_subscribe: %s)r6r7rr\rrrrrrr%rrordrYrr&rbr$rrrrBr4) r pack_formatrrrr7r8 reasoncodesc granted_qosrbrs r1r&zClient._handle_suback s ~'8999ST_X%>!?!?!!CDDDsJ  k4?83LMM f >V # ##FaK00J)0088 E9KIJJ' K K#A&**AA"";v{q#I#I#IJJJJ K c&kk 11K - V<slenrri print_topicr7r8s r1r zClient._handle_publish s} +--}* }*  4-ST_X%>!?!?!!CDDDsJ {DOH4MNNvCIIo+c#f++2D.E.EEK  - V<< >V # #E a$ $  D,,w//KK! D D D6UCKKK D ;??S[[1_!5!55;K$*M+v$F$F !W[& >V # #!+GqL!9!9G &188@@ E9IJJ'F  >V # # NN] W['.'+W/W_1E1E      NNN W['.'+S11    &KK ;!    # #G , , ,# # [A    # #G , , ,$$W[11 1 [A  ""7;//B3GM' 9 918!'+. 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9I$ $s$D&&EEM##M'*M'c|jtkr|jddkrtSn|jddkrtSt jd|jd\}|td||j5||j vr|j |}| ||xj dzc_ |j dkrL|j5|}dddn #1swxYwY|t kr|cdddSdddn #1swxYwY||S)NrrrrzReceived PUBREL (Mid: %d)rr)rrrr6rrr6r7r)rrrDrrr(_update_inflightr4r)rrrrs r1r"zClient._handle_pubrel s >V # #12Q66((7 _/ 0A 5 5$ $}T4?8#<== ~'BCHHH  # " "d'''+//44''000''1,''.22055!2244555555555555555---! " " " " " " " " " " " " " " " " " " " " " " "&!!#&&&s7AD3"D7 D3D D3 D D33D7:D7c |jD]}|j|jkr|jdkr|jt kr|xjdz c_|jdkr t|_n|jdkr t|_| |j |j d|j |j|j|j|j}|dkr|cSt"cSt"S)Nrrrrr/)rr rrrrrrrrrrirrrrrr4)rrrs r1rJzClient._update_inflight, s#**,, ( (A&)DDD5199N!:!:++q0++uzz"9!"9++w// #$<,BQww! ''''r0cp|jtkr|jddkrtSn|jddkrtSt jd|jddd\}|jtkr|jddkrt tdz }||jddd|jddkrBttdz }||jddd\}}| td||j 5||j vrM|j |}t|_t|_||cdddS dddn #1swxYwYt$S)Nrrrrr r zReceived PUBREC (Mid: %d))rrrr6rrrrrr6r7r(rrrrrrr4)rrr6rr7r8msgs r1r!zClient._handle_pubrecE s >V # #12Q66((7 _/ 0A 5 5$ $}T4?8#V # #12Q66(155 !!$/(";ABB"?@@@?#56::!+FaK!8!8J'1'8'81!""5(7(7$E9 ~'BCHHH  $ . .d((((-4 )  ((--  . . . . . . . .( . . . . . . . . . . . . . . . sA F&&F*-F*c2|jtkr|jddkrtSn|jddkrtSt jd|jddd\}|jtkr|jddd}t tdz }||\}}g}||dD]S}tj ddkrt|}| ttdz |Tt|d kr|d}|td ||j5|j}dddn #1swxYwY|r|j5 |jtkr|||j|||n|||j|n;#t($r.} |t*d | |jsYd} ~ nd} ~ wwxYwdddn #1swxYwYt.S) Nrr rrrrr rrzReceived UNSUBACK (Mid: %d)z&Caught exception in on_unsubscribe: %s)rrrr6rrrr'rrr=rYrr\r6r7r&rur$rrrrBr4) rrrrr7r8r?r@rurs r1r(zClient._handle_unsuback` s >V # #12Q66((7 _/ 0A 5 5$ $}T4?8#V # #_X.qrr2F#HM22J)0088 E9KIJJ' M M#A&**AA"";x1}#K#K#KLLLL;1$$)!n  ~'DcJJJ  ! 1 1!0N 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1  (   ~//& $.#z;PPPP'tT^SAAA NN$&NPSUUU3                sNE22E69E6H7G?H G8 $G3.H3G88HH H c|j5|j}dddn #1swxYwY|r|j5 |jtkr|||j||n|||j|n;#t $r.}|td||j sYd}~nd}~wwxYwddddS#1swxYwYdSdS)Nz%Caught exception in on_disconnect: %s) r&r|r$rrrrr6rrB)rrrr|rs r1rzClient._do_on_disconnect s  ! / / .M / / / / / / / / / / / / / / /  (   ~//%  $."jBBBB& dDNB??? NN$&MsTTT3                    sF  B16A)(B1) B!3$BB1B!!B11B58B5c0|j5|j}dddn #1swxYwY|rn|j5 |||j|n;#t$r.}|t d||jsYd}~nd}~wwxYwdddn #1swxYwY|j |}|j |j dkr<|xj dzc_ |jdkr!|}|t kr|St S)Nrrr)r&ror$rrr6rrBrrrrrrrrJr4)rrrorrMrs r1_do_on_publishzClient._do_on_publish s  ! ) )J ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  (  JtT^S9999 NN$&JCQQQ3                $$S)) ""$$$ 7Q;;  # #q ( # #*Q..**,,)))IsF  B AB  A=$A83B 8A==B  BBc0|jtkr|jddkrtSn|jddkrtS|dkrtnt }|dz }t jd|jddd\}|jtkr|jddkrt|}||jddd|jddkr:t|}||jddd\}}| td|||j 5||j vr#||}|cdddS dddn #1swxYwYtS) Nrrrr rrr zReceived %s (Mid: %d))rrrr6rrrrrrr6r7r(rrQr4) rr*r5rr6rr7r8rs r1rzClient._handle_pubackcomp s >V # #12Q66((7 _/ 0A 5 5$ $ #xffW !Q& }T4?8#V # #12Q66(55 !!$/(";ABB"?@@@?#56::!+K!8!8J'1'8'81!""5(7(7$E9 ~'>SIII  $  d(((((--         (                 s FF  F c d} |j}n#t$rd}YnwxYwg}|j5|7|j|jD]}||t |dkr|j}nd}dddn #1swxYwY|D]v}|j5 |||j |nA#t$r4}| td|j ||jsYd}~nd}~wwxYwdddn #1swxYwYw|rq|j5 |||j |n;#t$r.}| td||jsYd}~nd}~wwxYwddddS#1swxYwYdSdS)NFrz9Caught exception in user defined callback function %s: %sz"Caught exception in on_message: %s)rirCr&rrfrYr\rhr$rrr6rr,rB)rrmatchedrion_message_callbacksrrhrs r1rDzClient._handle_on_message s MEE!   EEE  "  ! " " $ 9 D DW] S S::H(//9999'((A--!_ !  " " " " " " " " " " " " " " "-  H(   HT4>7;;;; NN$S )   3                 (  JtT^W==== NN$&JCQQQ3                    s AB  BB D"B54D5 C3?*C.)D.C33DD D E4D,+E4, E$6$EE4E$$E44E8;E8c&|j5|j}dddn #1swxYwY|rh|j5 |||jn3#t$r&}|t d|Yd}~nd}~wwxYwddddS#1swxYwYdSdS)Nz'Caught exception in on_connect_fail: %s)r&r[r$rrr6r)rr[rs r1r5zClient._handle_on_connect_fail s  ! 3 3"2O 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3  V( V VV#OD$.9999 VVVNN$&OQTVVVVVVVVV V V V V V V V V V V V V V V V V V V V VsF  BAB A4A/*B/A44BB Bc2|ddS)NT)r9)r:rs r1r=zClient._thread_mains 66666r0ct}|j5|j |j|_n"t |jdz|j|_||jz}dddn #1swxYwY||z }|jtkr_|js\|dkrXtj t |d|tz }|jtkr|js|dkPdSdSdSdSdSdS)Nrrr) rr*r rminr rrr-rsleep)rr target_time remainings r1r8zClient._reconnect_wait sQkk  ( 6 6$,(,(A%%(+)A--))%  55K 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 #% {333.4MM Js9a(( ) ) )#ikk1I {333.4MMMM433333!M43sAA##A'*A'c(d}t|tr2||d|dSt|ttfr+t |dko||d|dSdS)Nc|tduo3|ttjtjtjgvo|Sr)rsetHTTPSOCKS4SOCKS5)r as r1checkz%Client._proxy_is_valid..check!s<%Mej%, EFFFMKL Nr0 proxy_type proxy_addrrrrF)rrbgetrrr\)rrds r1rzClient._proxy_is_valids N N N a   5|,,aeeL.A.ABB B D%= ) ) q66Q;4551qt#4#4 45r0cBtdS||jr|jSttdrt j|jst j}d|vrhtj |d}|j dkrtj |j |j d}|S|j dkrtj|j |j d}|Stj}||rd}t!t#||SdS)N proxy_bypassmqtthttp)rerf proxy_portr)rerfrl proxy_rdnsproxy_usernameproxy_password)rrr"rjurllib_dot_requestrir getproxiesurllib_dot_parseurlparseschemer`hostnamerrbget_default_proxyrbzip)r env_proxiespartsproxy socks_default proxy_keyss r1 _get_proxyzClient._get_proxy,s1 =4    , , ;  *N;; !"/ ;; !,799K$$(1+f2EFF<6))&+j&+n&+jE !L\W,,&+l&+n&+jE !L/11    . . 8LJJ 6677 7tr0c\|}|j|jf}|j|jf}t jdksdt jcxkrdkrnntj||j S|rtj|f|j |d|Stj||j |S)Nrrr)r)rsource_address) r}rrr r!rrrncreate_connectionrr)rrzrsources r1rz Client._create_socket_connectionWs!! DJ'$do6  f $ $1A(J(J(J(JF(J(J(J(J(J+D$:OPPP P  h*4o9N_eooinoo o+D$:O`fggg gr0)F)rWTN)rNr)NNNNNNN)rr)rr)r)NrFNr)rNNr)rrF)r0rFFNN)r,r-r.rrrrKrSrWr\rJr`rfrlrrxrrrrryrrrrrrrrrrrrrrrrrr"r%r(r*r,r.rnr:r@rDrrGrrPrSrYr[r`rbrfrhrmrorsrurzr|rrrrrrrZrrrQrrrYrrrrrrr6rr staticmethodrrrrrrrrrrrrrrrr rr rrrrrrrr$r)r&r r"rJr!r(rrQrrDr5r=r8rr}rr/r0r1rrs 99v"$4$"e$L)L)L)L)\""" " " "    # # # #:::: dddd(<<<<4T(T(T(T(l9996%%%2"&"PQ7D    >"&" ;'3'3'3'3R(,rVW"=$',',',',T ) ) ) )L3L3L3\####@? ? ? ? Bq(q(q(q(f<<<<&((( 000 = = = =HGHGHGHGT&E&E&E&EP    255556      6///   """.+.+.+.+`"""FFFFP        X  ]]$   X )$)$)$V %%X% )))  ""X" &&&4   X $$$$    X  $$$$ $$X$ (((0 ##X# '''0 $$X$((($   %%X%)))$   ..X.$22%$2$ $00X0 &44'&4$ &666"       dddL= = = ~ 4 4 4+++>"""$$\$$$\$333???@@@    ACACACACF???CCC;;;999 e9e9e9N 9 9 9 9D#N#N#N#NJ*N*N*N*NX'''---:   ,,,    >%%%:%%%   R%R%R%h   &# # # JD%D%D%L'''>   2   6& & & P$   0   8)))X V V V777222,  \ )))Vhhhhhr0rceZdZdZdZdZdZdZdZdZ dZ d Z dd Z d Z d Zd ZdZdZdZdZdZdZdZdZdS)rrrrrr!r#cd|_||_||_||_||_||_t |_t |_d|_ d|_ d|_ | |dSr) connectedr.rr_socket_pathr _sendbuffer _readbuffer_requested_size _payload_head_readbuffer_head _do_handshake)rrnrris_sslrd extra_headerss r1rzWebsocketWrapper.__init__psv     $;;$;;  ! =)))))r0c"d|_d|_dSr)rrrs r1rKzWebsocketWrapper.__del__sr0ctjj}tj|}d|ddd||dddd }t|tr| |nt|r ||}d d |d d | Dd g d}|j|d }d } |jd}|j||dkrt'|jdkrdt)|j dvrLdt)|j dvrt-dd}dt)|j dvrd}|jdddd} |  d} |d|z} t3j| d} tj| } | | krt-dd}nn't9|_n|st-d|r|st-dt9|_d|_dS)Nz{self._host:s}:{self._port:d}r websocketUpgradez%https://{self._host:s}:{self._port:d}utf813rj)Hostr ConnectionOriginzSec-WebSocket-KeyzSec-Websocket-VersionzSec-Websocket-Protocolz zGET {self._path} HTTP/1.1c3HK|]\}}d||VdS)z{}: {}N)format)rSijs r1rVz1WebsocketWrapper._do_handshake..sH?? Aq!1--??????r0FTr rs connectionrsupgradez2WebSocket handshake error, connection not upgradedssec-websocket-acceptz$258EAFA5-E914-47DA-95CA-C5AB0DC85B11z: z-WebSocket handshake error, invalid secret keyzWebSocket handshake error)rrrbase64 b64encoderrrrbupdatercr]itemsrrrUrMrrZr\rrr+rstriphashlibsha1digestrr) rrsec_websocket_keywebsocket_headersrF has_secret has_upgraderGUID server_hash client_hashs r1rzWebsocketWrapper._do_handshakes JLL.",->??4:::EE"#=DD$DOO!2!9!9&!A!A%)&,   mT * * A  $ $] 3 3 3 3 m $ $ A - .? @ @  ' . .D . 9 9 KK??$5$;$;$=$=??? ? ?     6&>>  &!!!  + L<$$Q''D   # #D ) ) )u}}t'((1,,$D,<(=(=(C(C(E(E(L(LW(U(UUU%S1A-B-B-H-H-J-J-Q-QRY-Z-ZZZ": T#V#VV+/K/#d6F2G2G2M2M2O2O2V2VW^2_2___E&*&6&=&=#'%'%%*U4^^A'7 &1&7&7&9&9&@&@&I&I &7&>&>w&G&G$&N &-l;3E3Eg3N3N&O&O &,&6{7I7I7K7K&L&L &+55": O#Q#QQ*.J$-;;   L./JKKKW+ LZ H* H*+FGG G$;;r0crt}t|}ttjd}|}|d|z|dkr||dz|zn|dkr4||dzdz|t jd|z }nI|dkr4||dzdz|t jd |z }ntd |d kr0t|D]}||xx||dzzcc<||z}||zS) Nr r~r rrlr!QzMaximum payload size is 2^63r) rr\osurandomrYrrrr[) ropcoder do_maskingrFlengthmask_key mask_flagrs r1 _create_framezWebsocketWrapper._create_framesMTRZ]]++   fvo&&& C<< MM)q.61 2 2 2 2 e^^ MM)q.3. / / / fk$// /FF ( ( ( MM)q.3. / / / fk$// /FF;<< < >>v 3 3U x 22 d?D}r0cR|t|j|jz z }|dkrW|j|}|st |j|t||krt|xj|z c_|j|j|z |jSr)r\rrrrMConnectionAbortedErrorrZrz)rr wanted_bytesrs r1_buffered_readzWebsocketWrapper._buffered_readsT%5!6!69N!NO !  <$$\22D .,, ''---4yy<''%% ' 5 >t?T TUUr0c d|_d}|j}|j|z}|d}|d}|ddz}|ddzdk}|ddz} | } d} | dkr-|d} tjd| \} n2| dkr,|d } tjd | \} |r|d } |} | | kr| } | dkrU|| }|r,t || D]}||xx| |d zzcc<||| }| |_nt }| | krt |_d|_|tj kr;| tj |d}|j ||tj kr;| tj|d}|j ||tjks|tjkr| dkr|St"#t$$r d |_Yd SwxYw)Nrrr(rrrrrrrr Fr0)rrrrrr[rrrOPCODE_CONNCLOSErrrU OPCODE_PING OPCODE_PONG OPCODE_BINARYOPCODE_CONTINUATIONrzrr)rrr1chunk_startindexchunk_endindexheader1header2rmaskbit lengthbitspayload_lengthrr readindexrrframes r1 _recv_implzWebsocketWrapper._recv_implsN $%D !F#1 !/&8N))!,,G))!,,Gaj4'FqzD(T1G!!*t+J'NHT!!++A.."(-e"<"<t##++A.."(-e"<"< 2..q11'I ))* 1}}--i88>!&'7!C!C>>(519*== !1)!;<%.""#++N**#,;; %&"->>> ..(97AGGEL%%e,,,-999 ..(4gqBBEL%%e,,,*888FFVFjr?r@rArBrCrDrrrrrr+rFrOra ascii_lettersrcrkrobjectrrrrr/r0r1rs    """"""$$$$$$......    JJJJ   D   LLLL   D (0000004444444((('''''''''' (II IIIHHHHH 8? !!  !FF \FOOOOO   A!GJ                 GM7<W\go'-  #$ &'#%&"()%!"            z   % % % P555$]V%991%%%%",W#W#W#W#W#fW#W#W#t+++++&+++\t2ht2ht2ht2ht2hVt2ht2ht2hnem'm'm'm'm'vm'm'm'm'm'slAA&%A&,A11A98A9= B BBB&& B54B59CC  C 0C33C=<C=