h 0 UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlmZmZmZmZmZmZmZmZmZmZm Z ddl!m"Z"ddl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.dd l/m0Z0dd l1m2Z2m3Z3dd l4m5Z5 dd lm6Z6n#e7$r dd l8m6Z6YnwxYwer\ dd lm9Z9n#e7$r dd l8m9Z9YnwxYw ddlm:Z:n#e7$r ddl8m:Z:YnwxYwGdde9Z;Gdde9Z<Gdde:Z= ddl>Z>n #e7$rdZ>YnwxYw ddl?Z?n #e7$rdZ?YnwxYw ej@ZAn#eB$r ejZAYnwxYw ddlCZDdZEn #e7$rdZEYnwxYwe jFdkrejGZHnejHZHe3ZIe(jJZJe(jKZKe(jLZLe(jMZMe(jNZNe(jOZOe(jPZPe(jQZQe(jRZRe(jSZSe(jTZTe(jUZUe(jVZVe(jWZWe(jXZXe&jYZYe&jZZZe&j[Z[e&j\Z\e&j]Z]e&j]ej^e&jYej_e&jZej_e&j[ej`e&j\ejaiZbe%jcZce%jdZde%jeZee%jfZfe%jgZge%jhZhe'jiZje'jkZle'jmZne'joZpe'jqZre'jsZte'juZve'jwZxe'jyZze'j{Z|e)j}Z}e)j~Z~e)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe)jZe*jZe*jZe*jZe+jZe+jZdZded<dZeeeeeedfZeeefZeeegefefZeee6dfZGddeZGddeZed eeeefe)gdfZed eeeefe2ee0dfgdfZeeefZed eee2ee0dfgdfZeeefZed egdfZed ee)gdfZed eee2edfee0dfgdfZeeefZed eee2ee0dfgdfZeeefZed eeegdfZed ed!gdfZed egdfZed eegdfZed eee2e0gdfZeeefZed edgdfZed eeeed"fgdfZed eeee2e0gdfZeeefZed eeee2ee0dfgdfZeeefZed eegdfZed eee0ee2ee2fgdfZeeefZed eeee2ee0dfgdfZeeefZe ZGd#d$eZdLd)ZdMd,ZdNd/ZdOd2Ze je jzdfdPd7ZdQd;ZdRd=ZdSdAZdTdEZGdFdGZGdHd!ZGdId ZGdJdKZdS)Uz This is an MQTT client module. MQTT is a lightweight pub/sub messaging protocol that is easy to implement and suitable for low powered devices. ) annotationsN) TYPE_CHECKINGAnyCallableDictIteratorList NamedTupleSequenceTupleUnioncast) PacketTypes) CallbackAPIVersion ConnackCodeLogLevel MessageState MessageType MQTTErrorCodeMQTTProtocolVersionPahoClientMode_ConnectionState) MQTTMatcher) Properties) ReasonCode ReasonCodes)SubscribeOptions)Literal) TypedDict)Protocolc`eZdZUded<ded<ded<ded<ded<ded <ded <ded <d S) _InPacketintcommandhave_remainingz list[int]remaining_countremaining_multremaining_length bytearraypacket to_processposN__name__ __module__ __qualname____annotations__]/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/paho/mqtt/client.pyr#r#@sg """"r4r#cVeZdZUded<ded<ded<ded<ded<ded<d ed <d S) _OutPacketr$r%midqosr-r,bytesr+MQTTMessageInfo | NoneinfoNr.r3r4r5r7r7KsT  $$$$$$r4r7c6eZdZddZddZdd Zdd Zdd ZdS) SocketLike buffer_sizer$returnr:cdSNr3)selfr?s r5recvzSocketLike.recvU Cr4buffercdSrBr3)rCrFs r5sendzSocketLike.sendWrEr4NonecdSrBr3rCs r5closezSocketLike.closeYrEr4cdSrBr3rKs r5filenozSocketLike.fileno[rEr4flagboolcdSrBr3rCrOs r5 setblockingzSocketLike.setblocking]rEr4N)r?r$r@r:)rFr:r@r$r@rIr@r$rOrPr@rI)r/r0r1rDrHrLrNrSr3r4r5r>r>Tsx                      r4r>TFWindowsCleanStartOptionMQTT_CLEAN_START_FIRST_ONLY0ceZdZUdZded<dS) ConnectFlagsz?Contains additional information passed to `on_connect` callbackrPsession_presentNr/r0r1__doc__r2r3r4r5r]r]s(IIr4r]ceZdZUdZded<dS)DisconnectFlagszBContains additional information passed to `on_disconnect` callbackrP is_disconnect_packet_from_serverNr_r3r4r5rbrbs(LL****r4rbClient MQTTMessage.ceZdZdZdS)WebsocketConnectionErrorz WebsocketConnectionError is a subclass of ConnectionError. It's raised when unable to perform the Websocket handshake. N)r/r0r1r`r3r4r5rgrgs Dr4rg mqtt_errnoMQTTErrorCode | intr@strc|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)rhs r5 error_stringr~#s4%%%{ ~ % % ( ( (VV ~ % %55 ' ' '77 , , ,,, ) ) )44 ) ) ))) | # #&& , , ,## - - -// } $ $&& * * *&& ' ' ' ~ % %(( * * *$$ ) ) )PPr4 connack_codeint | ReasonCodect|trt|S|tkrdS|tkrdS|t krdS|t krdS|tkrdS|tkrdSdS)zJReturn the string associated with a CONNACK result or CONNACK reason code.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.) isinstancerrjCONNACK_ACCEPTED CONNACK_REFUSED_PROTOCOL_VERSION#CONNACK_REFUSED_IDENTIFIER_REJECTED"CONNACK_REFUSED_SERVER_UNAVAILABLE%CONNACK_REFUSED_BAD_USERNAME_PASSWORDCONNACK_REFUSED_NOT_AUTHORIZEDrs r5connack_stringrKs, ++!<   '''%% 9 9 9CC < < <99 ; ; ;88 > > >?? 7 7 74444r4rrc.|tjkrttjdS|tjkrttjdS|tjkrttjdS|tjkrttjdS|tjkrttjdS|tj krttjdSttjdS)aKConvert a MQTTv3 / MQTTv3.1.1 connack result to `ReasonCode`. This is used in `on_connect` callback to have a consistent API. Be careful that the numeric value isn't the same, for example: >>> ConnackCode.CONNACK_REFUSED_SERVER_UNAVAILABLE == 3 >>> convert_connack_rc_to_reason_code(ConnackCode.CONNACK_REFUSED_SERVER_UNAVAILABLE) == 136 It's recommended to compare by names >>> code_to_test = ReasonCode(PacketTypes.CONNACK, "Server unavailable") >>> convert_connack_rc_to_reason_code(ConnackCode.CONNACK_REFUSED_SERVER_UNAVAILABLE) == code_to_test SuccessUnsupported protocol versionzClient identifier not validzServer unavailablezBad user name or passwordzNot authorizedUnspecified error) rrrrCONNACKrrrrrrs r5!convert_connack_rc_to_reason_coder`s{333+-y999{CCC+-/MNNN{FFF+-/LMMM{EEE+-/CDDD{HHH+-/JKKK{AAA+-/?@@@ k)+> ? ??r4rcrc2|tjkrttjdS|tjkrttjdS|tjkrttjdSttjdS)a!Convert an MQTTErrorCode to Reason code. This is used in `on_disconnect` callback to have a consistent API. Be careful that the numeric value isn't the same, for example: >>> MQTTErrorCode.MQTT_ERR_PROTOCOL == 2 >>> convert_disconnect_error_code_to_reason_code(MQTTErrorCode.MQTT_ERR_PROTOCOL) == 130 It's recommended to compare by names >>> code_to_test = ReasonCode(PacketTypes.DISCONNECT, "Protocol error") >>> convert_disconnect_error_code_to_reason_code(MQTTErrorCode.MQTT_ERR_PROTOCOL) == code_to_test rzKeep alive timeoutr)rrmrr DISCONNECTr}rt)rs r5,convert_disconnect_error_code_to_reason_coders} ] ++++0)<<< ] ---+02FGGG ] ---+02EFFF k,.A B BBr4numr$basepaddingcR|dkrtdg}|r0t|d\}}|||0|fdt t ||Ddt|S)z+Convert a number to base-62 representation.rzNumber must be positive or zero>c3(K|] }dV dS)rNr3).0_rs r5 z_base62..s'??a$q'??????r4) ValueErrordivmodappendextendrangelenjoinreversed)rrrdigitsrests ` r5_base62rs  Qww:;;; F "3OO T d4j!!! " MM????5Vg#>#>?????? 778F## $ $$r4subtopicrPct}d||< t||dS#t$rYdSwxYw)zCheck whether a topic matches a subscription. For example: * Topic "foo/bar" would match the subscription "foo/#" or "+/bar" * Topic "non/matching" would not match the subscription "non/+/+" TF)rnext iter_match StopIteration)rrmatchers r5topic_matches_subrs^mmGGCL W   & &'''t uus"9 AA#tuple[socket.socket, socket.socket]ctjtjtjtj}|tjtjd|d|d| \}}tjtjtjtj}| d | d|fn#t$rYnwxYw| \}}| d|||fS)z+TCP/IP socketpair including Windows supportr) 127.0.0.1rFr)socketAF_INET SOCK_STREAM IPPROTO_IP setsockopt SOL_SOCKET SO_REUSEADDRbindlisten getsocknamerSconnectBlockingIOErroracceptrL) listensockifaceportsock1sock2addresss r5_socketpair_compatrs4*F,=??J&+V-@!DDDOO$%%%a((**KE4 M*F,= ? ?E e  {D)****      &&((NE7 e 5>s+D DDs str | bytesr:cZt|tr|dS|S)Nutf-8)rrjencode)rs r5 _force_bytesrs+!S!xx   Hr4payload,str | bytes | bytearray | int | float | Nonebytes | bytearrayc4t|tr|dSt|ttfr"t|dS|dSt|t t fstd|S)Nrasciir4z8payload must be a string, bytearray, int, float or None.)rrjrr$floatr:r* TypeError)rs r5_encode_payloadrs'3'~~g&&&'C<((,7||""7+++s gy1 2 2  F    Nr4c`eZdZdZdZddZddZdd Zdd Zdd Z ddZ ddZ dddZ d dZ dS)!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. )r8 _published _conditionr_iterposr8r$c||_ d|_tj|_t j|_ d|_dSNFr) r8r threading ConditionrrrmrrrCr8s r5__init__zMQTTMessageInfo.__init__s>##-//!.!? D r4r@rjc8t|j|jfSrB)rjrr8rKs r5__str__zMQTTMessageInfo.__str__sDGTX&'''r4Iterator[MQTTErrorCode | int]cd|_|SNr)rrKs r5__iter__zMQTTMessageInfo.__iter__s  r4ric*|SrB)rrKs r5__next__zMQTTMessageInfo.__next__syy{{r4ct|jdkrd|_|jS|jdkrd|_|jSt)Nrr)rrr8rrKs r5rzMQTTMessageInfo.nexts> =A  DM7N ]a  DM8O r4indexcT|dkr|jS|dkr|jStd)Nrrzindex out of range)rr8 IndexError)rCrs r5 __getitem__zMQTTMessageInfo.__getitem__ s1 A::7N aZZ8O122 2r4rIc|j5d|_|jddddS#1swxYwYdS)NT)rrnotifyrKs r5_set_as_publishedz!MQTTMessageInfo._set_as_publisheds _ % %"DO O " " $ $ $ % % % % % % % % % % % % % % % % % %s !6::Ntimeout float | Nonec"|jtkrtd|jtkrn/|jdkr$t dt |j|dnt |z|dn|dz }d fd }|j5|js5|s+|j ||js |+dddn #1swxYwY|jdkr$t dt |jdS) 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: Ng$@r@rPc0dntkS)NF) time_func) timeout_timesr5 timed_outz3MQTTMessageInfo.wait_for_publish..timed_out.s(055ikkL6P Pr4r@rP) rr|rMQTT_ERR_AGAIN RuntimeErrorr~rrrwait)rCr timeout_tenthrrs @r5wait_for_publishz MQTTMessageInfo.wait_for_publishs 7) ) )JKK K W & &  Wq[[Q,tw:O:OQQRR R&ttIKK'4I 'Ws]  Q Q Q Q Q Q_ 4 4o 4iikk 4$$]333o 4iikk 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 7Q;;Q,tw:O:OQQRR R ;s =CCCrPc$|jtjkrtd|jtjkrn/|jdkr$t dt |j|j5|jcdddS#1swxYwYdS)zReturns True if the message associated with this object has been published, else returns False. To wait for this to become true, look at `wait_for_publish`. rrrN) rrr|rrrr~rrrKs r5 is_publishedzMQTTMessageInfo.is_published8s 7m7 7 7JKK K W 4 4 4  Wq[[Q,tw:O:OQQRR R _ # #? # # # # # # # # # # # # # # # # # #s1BB  B )r8r$r@rj)r@r)r@ri)rr$r@rirTrB)rrr@rIr)r/r0r1r` __slots__rrrrrrrrrr3r4r5rrs DI((((    3333%%%% SSSSS>######r4rcjeZdZdZdZddd ZddZddZeddZ e j ddZ dS)rez This is a class that describes an incoming message. It is passed to the `on_message` callback as the message parameter. ) timestampstatedupr8_topicrr9retainr< propertiesrr4r8r$rr:cd|_t|_d|_||_ ||_d|_ d|_ d|_ t||_ d|_ dS)NFr4r) rmqtt_ms_invalidrr r8r rr9r rr<r )rCr8rs r5rzMQTTMessage.__init__Osb$ $  ): H#C(( -1WWr4otherobjectr@rPcPt||jr|j|jkSdS)z$Override the default Equals behaviorF)r __class__r8rCrs r5__eq__zMQTTMessage.__eq__`s* eT^ , , )8uy( (ur4c.|| S)zDefine a non-equality test)rrs r5__ne__zMQTTMessage.__ne__fs;;u%%%%r4rjc6|jdS)zVtopic that the message was published on. This property is read-only. r)r decoderKs r5rzMQTTMessage.topicjs {!!'***r4valuerIc||_dSrB)r rCrs r5rzMQTTMessage.topicrs  r4N)rr4)r8r$rr:)rrr@rPr)rr:r@rI) r/r0r1r`rrrrpropertyrsetterr3r4r5rereIsoIXXXXX" &&&&+++X+ \\r4c eZdZdZejdddedddfdCdZdDdZe dEdZ e j dFdZ e dGdZ e j dHd Z e dGd!Z e j dHd"Z e dId#Zej dJd%Ze dKd&Ze dLd(Zej dMd)Ze dNd*Zej dOd+Ze dNd,Zej dOd-Ze dGd.Zej dHd/Ze dGd0Zej dHd1Ze dNd2Ze dPd4Ze dQd6Zej dRd7ZdSd:ZdTd<ZdDd=ZdUdVd?Z dWdXd@Z dYdZdEZ d[d\dHZ d]d^dTZd_dUZ d`dWZ!d[dadYZ"dDdZZ#d[d\dd]e$dfdbdhZ%dd\dd]e$dfdcdjZ&d[d\dd]e$dfdddkZ'dedfdpZ(dgdqZ)dhdidtZ*dhdiduZ+ djdkd|Z, d[dldZ-dDdZ.dmdZ/dmdZ0 dndodZ1 dpdqdZ2 d[drdZ3dsdtdZ4dgdZ5dmdZ6dgdZ7dudZ8dvdZ9dwdZ:dxdZ; djdydZ<dDdZ=dzdZ> d{d|dZ?dgdZ@dgdZAe d}dZBe d~dZCeCj ddZCddZDe ddZEeEj ddZEddZFe ddZGeGj ddZGddZHe ddZIeIj ddZIddZJe ddZKeKj ddZKddZLe ddZMeMj ddZMddZNe ddZOeOj dd„ZOddĄZPe ddƄZQeQj ddDŽZQddɄZRe dd˄ZSeSj dd̄ZSdd΄ZTe ddЄZUeUj ddфZUddӄZVddքZWe ddׄZXeXj dd؄ZXddلZYddڄZZe ddۄZ[e[j dd܄Z[dd݄Z\dDdބZ]e dd߄Z^e^j ddZ^ddZ_ d[ddZ`ddZaddZbddZcddZddgdZedgdZfddZgdDdZhdGdZiejddZkejddZldgdZmdgdZnddZoddZpddZqddZr dddZsddZtdd Zudd Zvdd Zwdd Zx dndodZy d[ddZz d[ddZ{dmdZ|dDdZ}dDdZ~dDdZ d[ddZdgdZdgdZdgdZdgdZdDdZdDdZdgd Zdd!Zdd#Zdgd$Zdgd%Zdgd&Zdgd'Z dndd+Zdd/Zdd2Zdd5ZdDd6ZdDd7ZdDd8Zejdmd9Zdd;Zdd<Zdd>Zdd?ZddBZdS(rdaMQTT 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()` or `connect_srv()` to connect to a broker * 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. * Or call `loop()` frequently to maintain network traffic flow with the broker * 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. :param CallbackAPIVersion callback_api_version: define the API version for user-callback (on_connect, on_publish,...). This field is required and it's recommended to use the latest version (CallbackAPIVersion.API_VERSION2). See each callback for description of API for each version. The file docs/migrations.rst contains details on how to migrate between version. :param str client_id: 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. :param bool clean_session: 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. :param userdata: 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. :param int protocol: 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. :param transport: use "websockets" to use WebSockets as the transport mechanism. Set to "tcp" to use raw TCP, which is the default. Use "unix" to use Unix sockets as the transport mechanism; note that this option is only available on platforms that support Unix sockets, and the "host" argument is interpreted as the path to the Unix socket file in this case. :param bool manual_ack: normally, when a message is received, the library automatically acknowledges after on_message callback returns. manual_ack=True allows the application to acknowledge receipt after it has completed processing of a message using a the ack() method. This addresses vulnerability to message loss if applications fails while processing a message, or while it pending locally. 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, reason_code, properties): print(f"Connected with result code {reason_code}") client.on_connect = on_connect Callbacks can also be attached using decorators:: mqttc = paho.mqtt.Client() @mqttc.connect_callback() def on_connect(client, userdata, flags, reason_code, properties): print(f"Connected with result code {reason_code}") 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()`. If you wish to suppress exceptions within a callback, you should set ``mqttc.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` rNtcpTFcallback_api_versionr client_id str | None clean_session bool | Noneuserdatarprotocolr transport$Literal['tcp', 'websockets', 'unix']reconnect_on_failurerP manual_ackr@rIc |}|dkr$ttdstd|dvrtd|||_||_||_||_d|_d|_ d|_ d|_ d|_ t|_||_|jt jkrt%jdt(d t+|jt,rtd |jt vrtd t.|_|t2kr|td n$|d}|s|dks|td||_|dks|S|t6kr@t9t;jjd d|_!nd|_!ntE||_!d|_#d|_$ddgddtKdddd|_&tOj(|_)tU|_+tU|_,d|_-d|_.d|_/||_0d|_1d|_2tfj4|_5tOj6|_7tOj6|_8d|_9d|_:d|_;d|_<d|_=d|_>d|_?d|_@d|_Ad|_Bt|_Dd|_Ed|_Fd|_Gd|_Hi|_ItjK|_LtjM|_NtjK|_OtjM|_PtjK|_QtjK|_RtjK|_Sd|_Td|_Ud|_Vd|_Wd|_Xd|_Yd|_Zd|_[d|_\d|_]d|_^d|__d|_`d|_ad|_bd|_cd|_dd|_ed|_fd|_gd|_hd|_id|_jd|_kdS)NunixAF_UNIXz"unix" transport not supported) websocketsr r-z5transport must be "websockets", "tcp" or "unix", not <g@z>Callback API version 1 is deprecated, update to latest versionr)category stacklevelzoUnsupported callback API version: version 2.0 added a callback_api_version, see docs/migrations.rst for details Unsupported callback API versionz&Clean session is not used for MQTT 5.0Trz7A client id must be provided if clean session is False.rutf8r4rrr%r&r'r(r)r+r,r-xrF[/mqtt)llowerhasattrrr _manual_ack _transport _protocol _userdata_sock _sockpairR _sockpairW _keepalive_connect_timeout MQTT_CLIENT _client_mode_callback_api_versionrVERSION1warningswarnDeprecationWarningrrjrZ _clean_startMQTTv5_clean_sessionMQTTv31ruuiduuid4r$r _client_idr _username _passwordr* _in_packet collectionsdeque _out_packetr _last_msg_in _last_msg_out_reconnect_min_delay_reconnect_max_delay_reconnect_delay_reconnect_on_failure_ping_t _last_midr 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_pre_connect _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) rCr!r"r$r&r'r(r*r+s r5rzClient.__init__sOO%%   wvy'A'A =>> > ; ; ;S SSUU U&#!!(, 0404 #'%9"  %);)D D D MP+     d0# 6 6 B   %-? ? ??@@ @!< v  ( !IJJJ)$ $   Oi2oo9J MOOO"/D  ??i/7""")$*,,*:B"G"G"G"N"Nv"V"V"%*955DO'+'+! !nn & & ;F:K:M:M%KK&[[$%!$'!,0%9" &2   # % %   # % % ')#"#$%!6: 37  !$/MM!   "+."2"2(00'n.."+/"3"3!*!1!1&/n&6&6##,>#3#3 04 !& 37".2 !&-1 <@59>B9=5959=A;?8<9=BF&DH(&AE%%)"#(   r4c.|dSrB)_reset_socketsrKs r5__del__zClient.__del__os r4rjc|jS)z Host to connect to. If `connect()` hasn't been called yet, returns an empty string. This property may not be changed if the connection is already open. )rsrKs r5hostz Client.hostr zr4rc||std|std||_dS)Nz8updating host on established connection is not supported Invalid host.)_connection_closedrrrsrs r5rz Client.host{sG&&(( [YZZ Z ._-- - r4r$c|jS)z} Broker TCP port to connect to. This property may not be changed if the connection is already open. )rtrKs r5rz Client.portrr4c|std|dkrtd||_dS)Nz8updating port on established connection is not supportedrInvalid port number.)rrrrtrs r5rz Client.portsI&&(( [YZZ Z A::344 4 r4c|jS)z Client keepalive interval (in seconds). This property may not be changed if the connection is already open. )rErKs r5 keepalivezClient.keepalive r4c|std|dkrtd||_dS)Nz=updating keepalive on established connection is not supportedrzKeepalive must be >=0.)rrrrErs r5rzClient.keepalivesK&&(( `^__ _ 199566 6r4c|jS)z Transport method used for the connection ("tcp" or "websockets"). This property may not be changed if the connection is already open. )r?rKs r5r(zClient.transportrr4Literal['tcp', 'websockets']cZ|std||_dS)Nz=updating transport on established connection is not supported)rrr?rs r5r(zClient.transports1&&(( `^__ _r4c|jS)zj Protocol version used (MQTT v3, MQTT v3.11, MQTTv5) This property is read-only. )r@rKs r5r'zClient.protocols ~r4rc|jS)z Connection establishment timeout in seconds. This property may not be changed if the connection is already open. )rFrKs r5connect_timeoutzClient.connect_timeouts $$r4c|std|dkrtd||_dS)NzCupdating connect_timeout on established connection is not supportedrz!timeout must be a positive number)rrrrFrs r5rzClient.connect_timeoutsL&&(( fdee e C<<@AA A %r4cH|jdS|jdS)zThe username used to connect to the MQTT broker, or None if no username is used. This property may not be changed if the connection is already open. Nr)rUrrKs r5usernamezClient.username' > !4~$$W---r4c|std| d|_dS|d|_dS)Nz 0 that can be partway through the network flow at once This property may not be changed if the connection is already open. )rhrKs r5max_inflight_messageszClient.max_inflight_messagess **r4c|std|dkrtd||_dS)NzIupdating max_inflight_messages on established connection is not supportedrzInvalid inflight.)rrrrhrs r5rzClient.max_inflight_messagessN&&(( ljkk k 199011 1&+###r4c|jS)z Maximum number of message in the outgoing message queue, 0 means unlimited This property may not be changed if the connection is already open. )rjrKs r5max_queued_messageszClient.max_queued_messagess ((r4c|std|dkrtd||_dS)NzGupdating max_queued_messages on established connection is not supportedrzInvalid queue size.)rrrrjrs r5rzClient.max_queued_messagessL&&(( jhii i 199233 3$)!!!r4cH|jdS|jdS)z The topic name a will message is sent to when disconnecting unexpectedly. None if a will shall not be sent. This property is read-only. Use `will_set()` to change its value. Nr)rnrrKs r5 will_topiczClient.will_topic(s)   #4&&w///r4 bytes | Nonec|jS)z The payload for the will message that is sent when disconnecting unexpectedly. None if a will shall not be sent. This property is read-only. Use `will_set()` to change its value. )rorKs r5 will_payloadzClient.will_payload4s !!r4logging.Logger | Nonec|jSrBrrKs r5loggerz Client.logger=s |r4c||_dSrBrrs r5rz Client.loggerAs  r4bufsizer:c|jtd |j|S#tj$r}t |d}~wtj$r(}|t |d}~wt$r0}| td|t|d}~wwxYw)Nself._sock is Nonezsocket was None: %s) rBConnectionErrorrDsslSSLWantReadErrorrSSLWantWriteError_call_socket_register_writeAttributeError _easy_logMQTT_LOG_DEBUG)rCrerrs r5 _sock_recvzClient._sock_recvEs : !"677 7 -:??7++ +# - - -!## ,$ - - -  , , . . .!## , - - - NN 5s < < <!## , -s-2CAC"#B C+B==Cbufcz|jtd |j|S#tj$r}t |d}~wtj$r(}|t |d}~wt $r(}|t |d}~wwxYw)Nr)rBrrHrrrrr)rCrrs r5 _sock_sendzClient._sock_sendTs : !"677 7 -:??3'' '# - - -!## ,$ - - -  , , . . .!## , - - -  , , . . .!## , -s-2B:AB:"#B B:#B55B:c|jsdS |j}d|_|||||dS#|wxYw)z#Close the connection to the server.N)rB_call_socket_unregister_write_call_socket_closerLrCsocks r5 _sock_closezClient._sock_closecsqz  F :DDJ  . .t 4 4 4  # #D ) ) ) JJLLLLLDJJLLLLs 8AA/ sockpair_onlyc|s||jr |jd|_|jr"|jd|_dSdSrB)rrCrLrD)rCrs r5rzClient._reset_socketsqst        ? # O ! ! # # #"DO ? # O ! ! # # #"DOOO # #r4c\|||||dSrB)rr)rCr"r$r&s r5 reinitialisezClient.reinitialise|s2  i99999r4r;pathheadersWebSocketHeaders | Nonec||_||'&x00F r4cd|_dS)zu Disable logging using standard python logging package. This has no effect on the `on_log` callback. NrrKs r5disable_loggerzClient.disable_loggerks r4r:r0rrrr bind_address bind_port clean_startrYr Properties | Nonerc |jtkrd|_n+|tkrt d|rt d|||||||||S)aConnect to a remote broker. This is a blocking call that establishes the underlying connection and transmits a CONNECT packet. Note that the connection status will not be updated until a CONNACK is received and processed (this requires a running network loop, see `loop_start`, `loop_forever`, `loop`...). :param str host: the hostname or IP address of the remote broker. :param int port: 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. :param int 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. :param bool 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. For MQTT v3.1.1, the ``clean_session`` argument of `Client` should be used for similar result. :param Properties 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 V5z Properties only apply to MQTT V5)r@rOrrZr connect_async reconnectrCrrrrrrr s r5rzClient.connectqs@ >V # #)-D & &999 !FGGG E !CDDD 4y'K M M M~~r4domainc tdurtd|3tj}||ddzd} d|}|jrd|}g}t j|t j j D]K} | j dd} | | | j| j| jfLnP#t jjt jjt jjf$r} td || d} ~ wwxYw|D]6} | \} } }} || | |||||cS#t*$rY3wxYwtd ) zConnect to a remote broker. :param str domain: the DNS domain to search for SRV records; if None, try to determine local domain name. :param keepalive, bind_address, clean_start and properties: see `connect()` Fz;No DNS resolver library found, try "pip install dnspython".N.rz _mqtt._tcp.z_secure-mqtt._tcp.zNo answer/NXDOMAIN for SRV in zNo SRV hosts responded)HAVE_DNSrrgetfqdnfindrdnsresolverquery rdatatypeSRVtargetto_textrrpriorityweightNXDOMAINNoAnswer NoNameserversr Exception)rCrrrrrr rranswersansweraddrrrrprior.s r5 connect_srvzClient.connect_srvs u  MOO O >^%%FFKK,,q0112F Q'v''By 32&22G,,,R1BCC I I},,..ss36;GIIII I %s|'XY Q Q QFfFFGGS P Q  F'- $D$f ||D$ <T_aklllll    1222s+BC5D+D&&D+:E E$#E$c|dkrtd|tj|_||_||_||_||_||_ ||_ ||_ tj |_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. Any already established connection will be terminated immediately. :param str host: the hostname or IP address of the remote broker. :param int port: 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. :param int 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. :param bool 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. For MQTT v3.1.1, the ``clean_session`` argument of `Client` should be used for similar result. :param Properties properties: (MQTT v5.0 only) the MQTT v5.0 properties to be sent in the MQTT connect packet. rzInvalid bind port number.N) rrrrcrdrrrrurvrNrkMQTT_CS_CONNECT_ASYNCrs r5rzClient.connect_asyncs}@ q==899 9 &2   ")#'#- &< r4rr8 min_delay max_delaycp|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)rr]r^r_)rCr;r<s r5reconnect_delay_setzClient.reconnect_delay_sets ( ) )(1D %(1D %$(D ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s +//c ~t|jdkrtd|jdkrtdddgddt dddd|_d|_tj|_ | |j D]V}|dd ztkr@|d dkr4|d ,t|d _|d W|j |j5t%|_t%|_d d d n #1swxYwY||j5|j}d d d n #1swxYwY|rN |||jn;#t2$r.}|t6d ||jsYd }~nd }~wwxYw||_|jdd|_ |!|j|"|j#S)zdReconnect the client after a disconnect. Can only be called after connect()/connect_async().rrrrr4r7rr%r9r<Nz&Caught exception in on_pre_connect: %sF)$rrsrrtr*rWrarMQTT_CS_CONNECTINGrdrrZPUBLISHrtrrclearr|rr[r\_messages_reconnect_resetr{on_pre_connectrAr2r MQTT_LOG_ERRr_create_socketrBrSr_call_socket_open _send_connectrE)rCpktrErs r5rzClient.reconnect s tz??a  _-- - :??344 4! !nn    &9  # 0 0C9~$//CJ!OOF H_!3F F --///      - - ) D !*D  - - - - - - - - - - - - - - - &&(((  ! 1 1!0N 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1   tT^4444    "JCQQQ/  ((**  u%%%!& tz***!!$/222s< 'D<<EE"E66E:=E:F G $G  G?rc|j|j1|dt\|_|_||S)a[Process 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. :param int timeout: The time in seconds to wait for incoming/outgoing network traffic before timing out and returning. Returns MQTT_ERR_SUCCESS on success. Returns >0 on error. A ValueError will be raised if timeout < 0NT)r)rCrDrr_loop)rCrs r5loopz Client.loopFsP2 ? "do&=   d  3 3 3/A/C/C ,DOT_zz'"""r4cN|dkrtd|r |jg}ng}d}t|jdr|j}|dkrd}|j |jg}n|j|jg} t j||g|}n#t$r?|jtj tj fvrtj |_tjcYSt$r?|jtj tj fvrtj |_tjcYSt$rtjcYSwxYw|j|dvs|dkr|}|s|j|S|jr\|j|dvrM|dd|j |jdn#t($rYnwxYw|j|dvr|}|s|j|S|S)NrzInvalid timeout.rpendingri')r want_writerBr=rPrCselectrrdrMQTT_CS_DISCONNECTINGMQTT_CS_DISCONNECTEDMQTT_CS_CONNECTION_LOSTrrtr2rz loop_readinsertrDr loop_write loop_misc)rCrwlist pending_bytesrlistsocklistrs r5rMz Client._loopess S==/00 0 ??   ZLEEE 4:y ) ) 1 J..00M 1  G ? "ZLEEZ1E 2}UE2w??HH 4 4 4{#3#IK[Kp"qqq.F  3 3 3 3 4 4 4{#3#IK[Kp"qqq.F  3 3 3 3 2 2 2!1 1 1 1 2 :! $ $ (9(9!!B TZ' ? t(1+== QK  q$* - - - $$U++++"     :! $ $""B TZ' ~~s2 B$$AE ,AE 3E  E :G G"!G"rr PayloadTyper9r rc |jtkr$|t|dkrtd|d}|||dks|dkrtdt |}t|dkrtd|}|dkr4t|} | |||||d | |} | | _ | St||} t| _ || _|| _|| _d | _|| _|j5|jdkrFt|j|jkr)t,j| j_ | jcdddS||jvr)t,j| j_ | jcdddS| |j| j<|jdks|j|jkr|xjd z c_|d kr t8| _n|dkr t<| _| | j|| j| j| j| j| j| j} | t,jkr|xjd zc_t@| _| | j_ | jcdddStB| _t,j"| 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. :param str topic: The topic that the message should be published on. :param 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. :param int qos: The quality of service level to use. :param bool retain: If set to true, the message will be set as the "last known good"/retained message for the topic. :param Properties properties: (MQTT v5.0 only) the MQTT v5.0 properties to be included. Returns a `MQTTMessageInfo` class, which can be used to determine whether the message has been delivered (using `is_published()`) or to block waiting for the message to be delivered (`wait_for_publish()`). The message ID and return code of the publish() call can be found at :py:attr:`info.mid ` and :py:attr:`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. :raises ValueError: 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. :raises ValueError: if qos is not one of 0, 1 or 2 :raises ValueError: if the length of the payload is greater than 268435455 bytes. NrInvalid topic.rrInvalid QoS level.irlFr)#r@rOrrr_raise_for_invalid_topicr _mid_generater _send_publishrrerrrr9r r r r}rjrfrr|r<r8rhrimqtt_ms_wait_for_pubackrmqtt_ms_wait_for_pubrecrqmqtt_ms_publishmqtt_ms_queuedrm) rCrrr9r r  topic_bytes local_payload local_midr<rmessages r5publishzClient.publishsuZ >V # #}E a !1222ll7++  %%k222 77cAgg122 2'00 }   ) )122 2&&(( !88"9--D##; sFE4Q[]]BDGK!)[99G ) G +GOGK#GNGK!+G ( ( (,q00S9K5L5LPTPi5i5i&3&GGLO"< ( ( ( ( ( ( ( (  222&3&GGLO"< ( ( ( ( ( ( ( (3:"7;/.!33t7NQUQl7l7l++q0++axx(? (? ++GKgoW^Wbdkdr,3KwGY[[B];;;//14//(7 &(GLO"<5 ( ( ( ( ( ( ( (8%3GM&3&DGLO"<= ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s&AK(%K( CK(3(K((K,/K,rrc|dn|d|_t|tr|d|_dS||_dS)adSet 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 or more. :param str username: The username to authenticate with. Need have no relationship to the client id. Must be str [MQTT-3.1.3-11]. Set to None to reset client back to not using username/password for broker authentication. :param str password: The password to authenticate with. Optional, set to None if not required. If it is str, then it will be encoded as UTF-8. Nr)rrUrrjrV)rCrrs r5username_pw_setzClient.username_pw_setsT "*!1xw7O7O h $ $ &%__W55DNNN%DNNNr4ct|_dS)aOSets the client in a bridge mode instead of client mode. Must be called before `connect()` to have any effect. Requires brokers that support bridge mode. Under bridge mode, the broker will identify the client as a bridge and not send it's own messages back to it. Hence a subsciption of # is possible without message loops. This feature also correctly propagates the retain flag on the messages. Currently Mosquitto and RSMB support this feature. This feature can be used to create a bridge between multiple broker. N) MQTT_BRIDGErHrKs r5enable_bridge_modezClient.enable_bridge_mode1s(r4c||jtjkp'|jtjtjfvo|jduS)zX Return true if the connection is closed (and not trying to be opened). N)rdrrcrSrTrBrKs r5rzClient._connection_closedAsO K+7 7 G 0 FHXHmnnFsws}BFtF Hr4c,|jtjkS)z~Returns the current status of the connection True if connection exists False if connection is closed )rdrMQTT_CS_CONNECTEDrKs r5 is_connectedzClient.is_connectedIs {.@@@r4 reasoncodeReasonCode | Nonec|jtj|_tStj|_|||S)aDisconnect a connected client from the broker. :param ReasonCode reasoncode: (MQTT v5.0 only) a ReasonCode instance setting the MQTT v5.0 reasoncode to be sent with the disconnect packet. It is optional, the receiver then assuming that 0 (success) is the value. :param Properties 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. )rBrrTrdrqrS_send_disconnect)rCrwr s r5 disconnectzClient.disconnectQs< : *?DK# #*@DK$$Z<<.s<iiheUVt..u559IIiiiiiir4zInvalid subscription filter.F)rtupler@rOrrr:rjrrlistranyrBrq_send_subscribe) rCrr9r}r topic_qos_listtoqs ` r5 subscribezClient.subscribefsSl eU # # #~''!&w!'+;<<Y$WYYYY# s eeS\ * *$ BQww#'' !5666~''?.3777GGAXX$RTTT!'+;<<Y$WYYY#(<<#8#8'"B!C=CJJ!OO$%5666#(<<#8#8#">!? t $ $ B5zzQ !3444N~''!BBDAq%a)9::4q55AEE",-A"B"BB,333"))188G+<+>>yCFFaKKz!eS\7R7RK()9:::"))188G+<+:FFFr4str | list[str]cPd}|tdt|ttfr9t |dkrtd|dg}nt|t rmg}|D]h}t |dkst|ttfstd||di|td|jtj dfS| d||S)aeUnsubscribe the client from one or more topics. :param topic: A single string, or list of strings that are the subscription topics to unsubscribe from. :param 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 ValueError: if topic is None or has zero string length, or is not a string or list. Nr`rrrF) rrr:rjrrrrrBrrq_send_unsubscribe)rCrr  topic_listrs r5 unsubscribezClient.unsubscribes#( =-.. . eeS\ * * 55zzQ !1222,,w//0JJ t $ $ 5J 5 5q66Q;;jUCL&A&A;$%5666!!!((7"3"34444  KLL L : !2D9 9%%eZDDDr4 max_packetsc|j tjSt|jt|jz}|dkrd}t d|D]f}|jtjcS|}|dkr||cS|tj krtj cSgtj S)a6Process 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 `loop_start()` or `loop_forever()`.Nrr) rBrrqrrfrgr _packet_read_loop_rc_handlerrm)rCrrrs r5rVzClient.loop_read"s :  1 1$,--D4E0F0FF ??Kq+&& 6 6Az!$5555""$$BAvv++B/////}333$55554--r4c|j tjS |}|tjkrItj|r|S|S|dkrR| ||r|S|Stj|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 `loop_start()` or `loop_forever()`.Nr) rBrrq _packet_writerrmrQrrrrCrs r5rXzClient.loop_write;s] :  1 1 5##%%B]111$5    5002222224444a++B//   5002222224444 %5   5002222224444   5002222224444s/D#D# D##?E"c2t|jdkS)zCall to determine if there is network data waiting to be written. Useful if you are calling select() yourself rather than using `loop()`, `loop_start()` or `loop_forever()`. r)rrZrKs r5rQzClient.want_writeVs4#$$q((r4c|j tjSt}||jdkr||jz |jkr||jtj tj fvrtj |_tj }ntj |_tj}|d|tjStj S)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 `loop_start()` or `loop_forever()`.NrFpacket_from_brokerv1_rc)rBrrqr_check_keepaliverarErrdrrSrTrmrUr}_do_on_disconnectrt)rCnowrs r5rYzClient.loop_misc\s :  1 1kk  0 that can be part way through their network flow at once. Defaults to 20.N)r)rCrs r5max_inflight_messages_setz Client.max_inflight_messages_set|s&."""r4 queue_sizec\t|tstd||_|S)z\Set the maximum number of messages in the outgoing message queue. 0 means unlimited.zInvalid type of queue size.)rr$rr)rCrs r5max_queued_messages_setzClient.max_queued_messages_sets2*c** <:;; ;#-  r4c||_dS)zESet the user data variable passed to callbacks. May be any data type.NrA)rCr&s r5 user_data_setzClient.user_data_sets !r4c|jS)zEGet the user data variable passed to callbacks. May be any data type.rrKs r5 user_data_getzClient.user_data_gets ~r4cd|t|dkrtd|dks|dkrtd|r$t|tstdt ||_d|_|d|_||_ ||_ ||_ dS) aSet a Will to be sent by the broker in case the client disconnects unexpectedly. This must be called before connect() to have any effect. :param str topic: The topic that the will message should be published on. :param 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. :param int qos: The quality of service level to use for the will. :param bool retain: If set to true, the will message will be set as the "last known good"/retained message for the topic. :param Properties properties: (MQTT v5.0 only) the MQTT v5.0 properties to be included with the will message. Optional - if not set, no properties are sent. :raises ValueError: if qos is not 0, 1 or 2, or if topic is None or has zero string length. See `will_clear` to clear will. Note that will are NOT send if the client disconnect cleanly for example by calling `disconnect()`. Nrr`rrazDThe properties argument must be an instance of the Properties class.Tr) rrrrrrormrrnrprqrl)rCrrr9r r s r5will_setzClient.will_sets< =CJJ!OO-.. . 77cAgg122 2  XjZ@@ XVXX X-W55  <<00" *r4cLd|_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.Fr4rN)rmrnrorprqrKs r5 will_clearzClient.will_clears0  !r4SocketLike | Nonec|jS)z0Return the socket or ssl object for this client.)rBrKs r5rz Client.sockets zr4retry_first_connectioncldrjdurnjtjkrl nW#t $rI|std YnwxYwnrtj }|tj krl |}jdur>tjdkr&tjdkrtj}d|tj kldfd }|sjsdnv |rdnU n?#t $r2tdYnwxYw|S) aThis 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. :param int timeout: The time in seconds to wait for incoming/outgoing network traffic before timing out and returning. :param bool retry_first_connection: Should the first connection attempt be retried on failure. This is independent of the reconnect_on_failure setting. :raises OSError: if the first connection fail unless retry_first_connection=True TzConnection failed, retryingrFr@rPc\jtjtjfvp dupjduS)NFT)rdrrSrTr)runrCsr5 should_exitz(Client.loop_forever..should_exit s;K$4$JL\Lq#rr35L3*d2r4r)rrdrr:rOSError_handle_on_connect_failrr_reconnect_waitrrmrMrrZrfrnr`)rCrrrrrs` @r5 loop_foreverzClient.loop_foreversL* %--{.DDD+NN$$$$+++002221NN&(EGGG((***** + "" K/B 666ZZ(( *d22D,--22 233q88&5BC 666       {}} KD$> K$$&&&;==KCCK(((("KKK44666*,IKKKKKK?" KH s"<ABBE229F.-F.cB|j tjSt\|_|_d|_tj|j d|j |_d|j_ |j tjS)a`This 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. Under the hood, this will call `loop_forever` in a thread, which means that the thread will terminate if you call `disconnect()` NFzpaho-mqtt-client-)r+nameT)rrrprrCrDrrThread _thread_mainrTrdaemonstartrmrKs r5 loop_startzClient.loop_start s < # / /+=+?+?(!& 't/@Gu[_[j[q[q[s[sGuGuvvv "  --r4c|j tjSd|_t j|jkr|jtjS)aZThis 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. This don't guarantee that publish packet are sent, use `wait_for_publish` or `on_publish` to ensure `publish` are sent. NT)rrrprrcurrent_threadrrmrKs r5 loop_stopzClient.loop_stop/ sP <  / /!%  # % % 5 5 L     --r4c|jS)z Return the callback API version used for user-callback. See docstring for each user-callback (`on_connect`, `on_publish`, ...) for details. This property is read-only. )rIrKs r5r!zClient.callback_api_version@ s ))r4CallbackOnLog | Nonec|jS)aThe callback called when the client has log information. Defined to allow debugging. Expected signature is:: log_callback(client, userdata, level, buf) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param int 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. :param str buf: the message itself Decorator: @client.log_callback() (``client`` is the name of the instance which this callback is being attached to) rrKs r5on_logz Client.on_logJ s &|r4funcc||_dSrBrrCrs r5rz Client.on_log_ s  r4(Callable[[CallbackOnLog], CallbackOnLog]cdfd }|S)Nr CallbackOnLogr@c|_|SrB)rrrCs r5 decoratorz&Client.log_callback..decoratord sDKKr4)rrr@rr3rCrs` r5 log_callbackzClient.log_callbackc s)      r4CallbackOnPreConnect | Nonec|jS)aThe callback called immediately prior to the connection is made request. Expected signature (for all callback API version):: connect_callback(client, userdata) :parama Client client: the client instance for this callback :parama userdata: the private user data as set in Client() or user_data_set() Decorator: @client.pre_connect_callback() (``client`` is the name of the instance which this callback is being attached to) )rrKs r5rEzClient.on_pre_connecti s ##r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rEzClient.on_pre_connect{ w  ! ( (#'D  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( !!6Callable[[CallbackOnPreConnect], CallbackOnPreConnect]cdfd }|S)NrCallbackOnPreConnectr@c|_|SrB)rErs r5rz.Client.pre_connect_callback..decorator "&D Kr4)rrr@rr3rs` r5pre_connect_callbackzClient.pre_connect_callback )      r4CallbackOnConnect | Nonec|jS)a The callback called when the broker reponds to our connection request. Expected signature for callback API version 2:: connect_callback(client, userdata, connect_flags, reason_code, properties) Expected signature for callback API version 1 change with MQTT protocol version: * For MQTT v3.1 and v3.1.1 it's:: connect_callback(client, userdata, flags, rc) * For MQTT v5.0 it's:: connect_callback(client, userdata, flags, reason_code, properties) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param ConnectFlags connect_flags: the flags for this connection :param ReasonCode reason_code: the connection reason code received from the broken. In MQTT v5.0 it's the reason code defined by the standard. In MQTT v3, we convert return code to a reason code, see `convert_connack_rc_to_reason_code()`. `ReasonCode` may be compared to integer. :param Properties properties: the MQTT v5.0 properties received from the broker. For MQTT v3.1 and v3.1.1 properties is not provided and an empty Properties object is always used. :param dict flags: response flags sent by the broker :param int rc: the connection result, should have a value of `ConnackCode` 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) )rrKs r5 on_connectzClient.on_connect sfr4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_connect w  ! $ $#D  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $r0Callable[[CallbackOnConnect], CallbackOnConnect]cdfd }|S)NrCallbackOnConnectr@c|_|SrB)rrs r5rz*Client.connect_callback..decorator "DOKr4)rrr@rr3rs` r5connect_callbackzClient.connect_callback rr4CallbackOnConnectFail | Nonec|jS)aThe callback called when the client failed to connect to the broker. Expected signature is (for all callback_api_version):: connect_fail_callback(client, userdata) :param Client client: the client instance for this callback :parama userdata: the private user data as set in Client() or user_data_set() Decorator: @client.connect_fail_callback() (``client`` is the name of the instance which this callback is being attached to) )rrKs r5on_connect_failzClient.on_connect_fail s $$r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_connect_fail w  ! ) )$(D ! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )r8Callable[[CallbackOnConnectFail], CallbackOnConnectFail]cdfd }|S)NrCallbackOnConnectFailr@c|_|SrB)rrs r5rz/Client.connect_fail_callback..decorator #'D Kr4)rrr@rr3rs` r5connect_fail_callbackzClient.connect_fail_callback rr4CallbackOnSubscribe | Nonec|jS)aThe callback called when the broker responds to a subscribe request. Expected signature for callback API version 2:: subscribe_callback(client, userdata, mid, reason_code_list, properties) Expected signature for callback API version 1 change with MQTT protocol version: * For MQTT v3.1 and v3.1.1 it's:: subscribe_callback(client, userdata, mid, granted_qos) * For MQTT v5.0 it's:: subscribe_callback(client, userdata, mid, reason_code_list, properties) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param int mid: matches the mid variable returned from the corresponding subscribe() call. :param list[ReasonCode] reason_code_list: reason codes received from the broker for each subscription. In MQTT v5.0 it's the reason code defined by the standard. In MQTT v3, we convert granted QoS to a reason code. It's a list of ReasonCode instances. :param Properties properties: the MQTT v5.0 properties received from the broker. For MQTT v3.1 and v3.1.1 properties is not provided and an empty Properties object is always used. :param list[int] granted_qos: list of integers that give the QoS level the broker has granted for each of the different subscription requests. Decorator: @client.subscribe_callback() (``client`` is the name of the instance which this callback is being attached to) )rrKs r5 on_subscribezClient.on_subscribe sF!!r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_subscribe sw  ! & &!%D  & & & & & & & & & & & & & & & & & &r4Callable[[CallbackOnSubscribe], CallbackOnSubscribe]cdfd }|S)NrCallbackOnSubscriber@c|_|SrB)rrs r5rz,Client.subscribe_callback..decorator s $D Kr4)rrr@rr3rs` r5subscribe_callbackzClient.subscribe_callback rr4CallbackOnMessage | Nonec|jS)aThe callback called when a message has been received on a topic that the client subscribes to. This callback will be called for every message received unless a `message_callback_add()` matched the message. Expected signature is (for all callback API version): message_callback(client, userdata, message) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param MQTTMessage message: the received message. 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) )rrKs r5 on_messagezClient.on_message s &r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_message/ rr0Callable[[CallbackOnMessage], CallbackOnMessage]cdfd }|S)NrCallbackOnMessager@c|_|SrB)rrs r5rz*Client.message_callback..decorator7 rr4rrr@rr3rs` r5message_callbackzClient.message_callback4 rr4CallbackOnPublish | Nonec|jS)a*The callback 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. See also `wait_for_publish` which could be simpler to use. Expected signature for callback API version 2:: publish_callback(client, userdata, mid, reason_code, properties) Expected signature for callback API version 1:: publish_callback(client, userdata, mid) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param int mid: matches the mid variable returned from the corresponding `publish()` call, to allow outgoing messages to be tracked. :param ReasonCode reason_code: the connection reason code received from the broken. In MQTT v5.0 it's the reason code defined by the standard. In MQTT v3 it's always the reason code Success :parama Properties properties: the MQTT v5.0 properties received from the broker. For MQTT v3.1 and v3.1.1 properties is not provided and an empty Properties object is always used. Note: for QoS = 0, the reason_code and the properties don't really exist, it's the client library that generate them. It's always an empty properties and a success reason code. Because the (MQTTv5) standard don't have reason code for PUBLISH packet, the library create them at PUBACK packet, as if the message was sent with QoS = 1. Decorator: @client.publish_callback() (``client`` is the name of the instance which this callback is being attached to) )rrKs r5 on_publishzClient.on_publish< sRr4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5r zClient.on_publishg rr0Callable[[CallbackOnPublish], CallbackOnPublish]cdfd }|S)NrCallbackOnPublishr@c|_|SrB)r rs r5rz*Client.publish_callback..decoratoro rr4)rrr@rr3rs` r5publish_callbackzClient.publish_callbackl rr4CallbackOnUnsubscribe | Nonec|jS)aThe callback called when the broker responds to an unsubscribe request. Expected signature for callback API version 2:: unsubscribe_callback(client, userdata, mid, reason_code_list, properties) Expected signature for callback API version 1 change with MQTT protocol version: * For MQTT v3.1 and v3.1.1 it's:: unsubscribe_callback(client, userdata, mid) * For MQTT v5.0 it's:: unsubscribe_callback(client, userdata, mid, properties, v1_reason_codes) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param mid: matches the mid variable returned from the corresponding unsubscribe() call. :param list[ReasonCode] reason_code_list: reason codes received from the broker for each unsubscription. In MQTT v5.0 it's the reason code defined by the standard. In MQTT v3, there is not equivalent from broken and empty list is always used. :param Properties properties: the MQTT v5.0 properties received from the broker. For MQTT v3.1 and v3.1.1 properties is not provided and an empty Properties object is always used. :param v1_reason_codes: the MQTT v5.0 reason codes received from the broker for each unsubscribe topic. A list of ReasonCode instances OR a single ReasonCode when we unsubscribe from a single topic. Decorator: @client.unsubscribe_callback() (``client`` is the name of the instance which this callback is being attached to) )rrKs r5on_unsubscribezClient.on_unsubscribet sH##r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_unsubscribe rr8Callable[[CallbackOnUnsubscribe], CallbackOnUnsubscribe]cdfd }|S)NrCallbackOnUnsubscriber@c|_|SrB)rrs r5rz.Client.unsubscribe_callback..decorator rr4)rrr@rr3rs` r5unsubscribe_callbackzClient.unsubscribe_callback rr4CallbackOnDisconnect | Nonec|jS)aThe callback called when the client disconnects from the broker. Expected signature for callback API version 2:: disconnect_callback(client, userdata, disconnect_flags, reason_code, properties) Expected signature for callback API version 1 change with MQTT protocol version: * For MQTT v3.1 and v3.1.1 it's:: disconnect_callback(client, userdata, rc) * For MQTT v5.0 it's:: disconnect_callback(client, userdata, reason_code, properties) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param DisconnectFlag disconnect_flags: the flags for this disconnection. :param ReasonCode reason_code: the disconnection reason code possibly received from the broker (see disconnect_flags). In MQTT v5.0 it's the reason code defined by the standard. In MQTT v3 it's never received from the broker, we convert an MQTTErrorCode, see `convert_disconnect_error_code_to_reason_code()`. `ReasonCode` may be compared to integer. :param Properties properties: the MQTT v5.0 properties received from the broker. For MQTT v3.1 and v3.1.1 properties is not provided and an empty Properties object is always used. :param int 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) )rrKs r5 on_disconnectzClient.on_disconnect sL""r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rzClient.on_disconnect sw  ! ' '"&D  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'r6Callable[[CallbackOnDisconnect], CallbackOnDisconnect]cdfd }|S)NrCallbackOnDisconnectr@c|_|SrB)rrs r5rz-Client.disconnect_callback..decorator s!%D Kr4)rr"r@r"r3rs` r5disconnect_callbackzClient.disconnect_callback rr4CallbackOnSocket | Nonec|jS)aThe callback called just after the socket was opend. This should be used to register the socket to an external event loop for reading. Expected signature is (for all callback API version):: socket_open_callback(client, userdata, socket) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param SocketLike 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) )rrKs r5on_socket_openzClient.on_socket_open s "##r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5r'zClient.on_socket_open rr.Callable[[CallbackOnSocket], CallbackOnSocket]cdfd }|S)NrCallbackOnSocketr@c|_|SrB)r'rs r5rz.Client.socket_open_callback..decorator rr4rr+r@r+r3rs` r5socket_open_callbackzClient.socket_open_callback rr4rr>c8|j5|j}dddn #1swxYwY|rq|j5 |||j|n;#t$r.}|t d||jsYd}~nd}~wwxYwddddS#1swxYwYdSdS)z9Call the socket_open callback with the just-opened socketNz&Caught exception in on_socket_open: %s)r{r'ryrAr2rrFr)rCrr'rs r5rHzClient._call_socket_open so  ! 1 1!0N 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1  (  "N4>>>> NN$&NPSUUU3                    F  B AB  A=$A83B 8A==B  BBc|jS)aThe callback called just before the socket is closed. This should be used to unregister the socket from an external event loop for reading. Expected signature is (for all callback API version):: socket_close_callback(client, userdata, socket) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param SocketLike 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) )rrKs r5on_socket_closezClient.on_socket_close s "$$r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5r2zClient.on_socket_close rrcdfd }|S)Nrr+r@c|_|SrB)r2rs r5rz/Client.socket_close_callback..decorator& rr4r-r3rs` r5socket_close_callbackzClient.socket_close_callback# rr4c8|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{r2ryrAr2rrFr)rCrr2rs r5rzClient._call_socket_close+ so  ! 3 3"2O 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3  (  #OD$.$???? NN$&OQTVVV3                    r0c|jS)aThe callback called when the socket needs writing but can't. This should be used to register the socket with an external event loop for writing. Expected signature is (for all callback API version):: socket_register_write_callback(client, userdata, socket) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param SocketLike 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) rrKs r5on_socket_register_writezClient.on_socket_register_write: s "--r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5r:zClient.on_socket_register_writeM sw  ! 2 2-1D * 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2rcdfd }|S)Nrr+r@c|_|SrBr9rs r5rz8Client.socket_register_write_callback..decoratorU s-1D *Kr4r-r3rs` r5socket_register_write_callbackz%Client.socket_register_write_callbackR rr4c0|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) rBrr{r:rAr2rrFr)rCr:rs r5rz"Client._call_socket_register_writeZ sKz 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)aThe callback called when the socket doesn't need writing anymore. This should be used to unregister the socket from an external event loop for writing. Expected signature is (for all callback API version):: socket_unregister_write_callback(client, userdata, socket) :param Client client: the client instance for this callback :param userdata: the private user data as set in Client() or user_data_set() :param SocketLike 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) rrKs r5on_socket_unregister_writez!Client.on_socket_unregister_writel s &//r4cT|j5||_ddddS#1swxYwYdSrB)r{rrs r5rBz!Client.on_socket_unregister_write sy ! 4 4/3D , 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4rcdfd }|S)Nrr+r@c|_|SrBrArs r5rz:Client.socket_unregister_write_callback..decorator s04D ,Kr4r-r3rs` r5 socket_unregister_write_callbackz'Client.socket_unregister_write_callback s)       r4c.|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) rBrr{rBrAr2rrFr)rCrrBrs r5rz$Client._call_socket_unregister_write sJ!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  Brcallbackrc||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()`. See `on_message` for the expected signature of the callback. Decorator: @client.topic_callback(sub) (``client`` is the name of the instance which this callback is being attached to) Example:: @client.topic_callback("mytopic/#") def handle_mytopic(client, userdata, message): ... Nz&sub and callback must both be defined.)rr{rr)rCrrHs r5message_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 377cdfd }|S)Nrrr@c4||SrB)rJ)rrCrs r5rz(Client.topic_callback..decorator s  % %c4 0 0 0Kr4rr3)rCrrs`` r5topic_callbackzClient.topic_callback s/       r4c|td|j5 |j|=n#t$rYnwxYwddddS#1swxYwYdS)zVRemove a message callback previously registered with `message_callback_add()`.Nzsub must defined.)rr{rrKeyError)rCrs r5message_callback_removezClient.message_callback_remove s ;011 1  !   -c22                      s,A$A 1A1AAArc|rg||jtjtjfvrtj|_t j}|d||tkrtj |_|S)NFr) rrdrrSrTrrmrrtrUrs r5rzClient._loop_rc_handle s  G      {/EGWGlmmm.C "3  " "e2 " F F F # # #*BDK r4c |jddkr |d}t|dkr tjS|d|jd<n#t $rtjcYSt$r2}|td|tjcYd}~Sd}~wt$r2}|td|tjcYd}~Sd}~wwxYw|jddkrH |d}t|dkr tjS|d}|jd |t|jdd kr tj S|jd xx|d z|jd zz cc<|jd d z|jd <nV#t $rtjcYSt$r2}|td|tjcYd}~Sd}~wwxYw|d zdkrn(d|jd<|jd |jd<d}|jddkr) ||jd}t|dkr tjS|jdxxt|zcc<|jdxx|z cc<nV#t $rtjcYSt$r2}|td|tjcYd}~Sd}~wwxYw|dz}|dkr>|j 5t|_dddn #1swxYwYtjS|jddk)d|jd<|}ddgddt#dddd|_|j 5t|_dddn #1swxYwY|S)Nr%rrztimeout on socket: %sfailed to receive on socket: %sr&Tr'r)r(r,dr+r-r4r7)rWrrrrtrr TimeoutErrorrrFrrror|rr[_packet_handler*)rCr%rbyte byte_valuecountdatars r5rzClient._packet_read s0 ?9 % * * 8//!,,w<<1$$(;;-4QZ **# 4 4 4$3333 8 8 8 "93@@@$7777777 8 8 8 "CSJJJ$7777777 8 ?+ , 1 1 `??1--D4yyA~~,??!%aJO$56==jIII4?+<=>>BB,>>O$6777"S(DO>(;; ---T:---)))T1))))# 4 4 4$3333 8 8 8 "CSJJJ$7777777 8 QJEzz(44(1 D%444444444444444$33%ol+a//*"#  " "! !nn     , , ) D  , , , , , , , , , , , , , , , sAC%0 C%9'B& C%& C%3'C C% C%<GH H"'H HH KL!& L!/'LL!L!6MMMO!!O%(O%c  |j}n#t$rtjcYSwxYw ||d|dd}n#t tf$r)|j|tjcYSt$r)|j|tj cYSt$rL}|j|| td|tjcYd}~Sd}~wwxYw|dkr||dxx|zcc<|dxx|z cc<|ddkr4|ddztkrq|d dkrd|j5|j}dddn #1swxYwY|r!|j5 |jt(jkr.t-t.|}|||j|d n|jt(jkr^t-t4|}|||j|d t7t8jt=t8jnt?d n;#t@$r.}| td ||j!sYd}~nd}~wwxYwdddn #1swxYwY|d "|ddztFkr|j$5tK|_&dddn #1swxYwY|'dtj|(|j)tTj+krtTj,|_)tjSn|j|nn|j$5tK|_&dddn #1swxYwYtjS)NTr+r-rSrr,r%r@r9r8r3"Caught exception in on_publish: %sr<Fr)-rZpopleftrrrmrrr appendleftrrrrrFrtrBr{r ryrIrrJrCallbackOnPublish_v1rAVERSION2CallbackOnPublish_v2rrPUBACKrrr2rrrr|rr\rrrdrrSrT)rCr+ write_lengthrr s r5rzClient._packet_writeX sdQ  6)1133 6 6 6$5555 6 8#8$VE]^^4 6 6 "J/ 6 6 6 ++F333$5555" 4 4 4 ++F333$3333 8 8 8 ++F333 "CSJJJ$7777777  8 a|$$$ 4$$$u - ,'1,,y)D0W<<RSASAS!199)-J999999999999999&.!%!8..!.'+'AEWE`'`'`59:NPZ5[5[ (2 4PU(W(W(W(W)-)CGYGb)b)b59:NPZ5[5[ (2 ,0,0N,25M,6{7I,J,J,6{7I,J,J )*)*)*)*/;;].^.^(^'0!.!.!.$(NN(46Z\_%a%a%a+/+C%.(-%.%.%.%.%.!.%...............8v88:::y)D0Z??!0==1:D.===============../4"/"@/((*** ;*:*PPP*:*ODK,==@$$//7777cQ f  - -!*D  - - - - - - - - - - - - - - ---s66)A$$7D#/D# D#ADD#D#FFF,J;.CI43J;4 J,>$J'"J;'J,,J;;J?J?;LL"L3OOOlevelrfmtargsc|j4||z} |||j||n#t$rYnwxYw|j#t|}|jj||g|RdSdSrB)rrAr2r LOGGING_LEVELlog)rCrgrhrir level_stds r5rzClient._easy_log s ; "*C  D$.%====     < #%e,I DL Y 3d 3 3 3 3 3 3 $ #s , 99c&|jdkrdSt}|j5|j}|j}dddn #1swxYwY|j>||z |jks||z |jkr#|jtjkr|j dkr | |j5||_||_ddddS#1swxYwYdS#t$r9| | dtjYdSwxYw| |jtjtjfvrtj|_tj}n tj}| d|dSdSdS)NrFr)rErr|r\r[rBrdrrura _send_pingreqr2rrrrtrSrTrmr})rCr last_msg_out last_msg_inrs r5rzClient._check_keepalive sX ?a   Fkk   , ,-L+K , , , , , , , , , , , , , , , : !s\'9T_'L'LPSVaPaeietPtPt{.@@@T\UVEVEV 0&&(((,00-0*,/)000000000000000000!$$&&&**+0+>+  """;#3#IK[Kp"qqq"2"GDK&7BB&9B&&','/ " !PtPts3>AAC*CC  C ?DDc|j5|xjdz c_|jdkrd|_|jcdddS#1swxYwYdS)Nr)rrbrKs r5rczClient._mid_generate s  % " " NNa NN~&&!">  " " " " " " " " " " " " " " " " " "s)>AAcxd|vsd|vrtdt|dkrtddS)z Check if the topic is a topic without wildcard and valid length. Raise ValueError if the topic isn't valid. +#z'Publish topic cannot contain wildcards.zPublish topic is too long.N)rr)rs r5rbzClient._raise_for_invalid_topic sL 5==DEMMFGG G u::  9:: :  r4ct|dksCt|dks0td|dDsd|vr tjStjS)Nrrwc3LK|]}t|dkd|vpd|vV dS)rrurvN)r)rps r5rz4Client._filter_wildcard_len_check.. s9QQac!ffqjj419) jjjjQQr4/s#/)rrsplitrrprm)rs r5rz!Client._filter_wildcard_len_check se HHMMSXX--QQ399T??QQQQQ.C<< / / 1 1r4c|td|t}|tjkrt |_|S)NzSending PINGREQ)rr_send_simple_commandPINGREQrrmrrars r5rozClient._send_pingreq sH ~'8999  & &w / / / / /$;;DL r4cl|td|tS)NzSending PINGRESP)rrr~PINGRESPrKs r5_send_pingrespzClient._send_pingresp s+ ~'9:::((222r4r8cr|td||t|dS)NzSending PUBACK (Mid: %d)F)rr_send_command_with_midrers r5 _send_pubackzClient._send_puback 1 ~'A3GGG**63>>>r4cr|td||t|dS)NzSending PUBCOMP (Mid: %d)F)rrrPUBCOMPrs r5 _send_pubcompzClient._send_pubcomp s1 ~'BCHHH**7C???r4r+r*r)cg} |dz}|dz}|dkr|dz}|||||dkr|SH)NTrVr)r)rCr+r)remaining_bytesrZs r5_pack_remaining_lengthzClient._pack_remaining_length sr #c)D/36 !##   " "4 ( ( ( MM$   1$$  r4r] bytes | strct|}|tjdt |||dS)N!H)rrstructpackr)rCr+r]s r5 _pack_str16zClient._pack_str16" sKD!! fk$D 22333 dr4r4rr r<r;c t|tstd|r+t|ttfstd|j t jSt|dzdzz|dzz|z} t} | | t|} dt|z| z} | dkrS|j tkr"| td||||||nu| td|||||nT|j tkr#| td ||||||| n!| td |||||| |dkr| dz } |j tkr+|d } n|} | t| z } || | || ||dkr(| t%jd ||j tkr| | | ||t| |||S) Nztopic must be bytes, not strzpayload must be bytes if setrrXrrzHSending 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)rr:rr*rBrrqrBrrr@rOrrrrrrr _packet_queue)rCr8rrr9r r r<r r%r+ payloadlenr)packed_propertiess r5rdzClient._send_publish' s%'' <:;; ;  <:gy/ABB <:;; ; :  1 1cCiA-.#(;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!!'63TBBBr4cr|td||t|dS)NzSending PUBREC (Mid: %d)F)rrrPUBRECrs r5 _send_pubreczClient._send_pubrecv rr4cx|td||tdz|dS)NzSending PUBREL (Mid: %d)rF)rrrPUBRELrs r5 _send_pubrelzClient._send_pubrelz s5 ~'A3GGG**6A:sEBBBr4r%cr|r|dz}d}tjd|||}||||dS)Nrz!BBHrrrr)rCr%r8r r)r+s r5rzClient._send_command_with_mid~ sI   sNGVW.>DD!!'63:::r4cbd}tjd||}|||ddS)Nr!BBr)rCr%r)r+s r5r~zClient._send_simple_command s6UG-=>>!!'61a888r4c t|j}|tkrdnd}dt|zdzdzdzdzt|jz}d}|jt kr,|jdur|dz}n)|jtkr |jr|dz}n |j r|dz}|j rS|dt|j zdzt|j zz }|d|j dzdzz|jdzd zzz}|jE|dt|jzz }|d z}|j|d z}|dt|jzz }|jt krq|jd }n|j}|t|z }|j r5|jd }n|j}|t|z }t(}t+} | ||jt0kr|d z}|| || t7jd t|dt||||||jt kr| |z } || |j|j rK|jt kr| |z } || |j || |j |j=|| |j|j|| |j||_|jt krS|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)NsMQTTsMQIsdprrrTrTrXrV@rrsBBHzQSending CONNECT (u%d, p%d, wr%d, wq%d, wf%d, c%d, k%d) client_id=%s properties=%s zCSending CONNECT (u%d, p%d, wr%d, wq%d, wf%d, c%d, k%d) client_id=%s)!r$r@MQTTv311rrTrOrNrZrrPrmrnrorprqrUrVrkrrlCONNECTr*rrHrqrrrrrErrr) rCr proto_verr'r) connect_flagspacked_connect_propertiespacked_will_propertiesr%r+s r5rIzClient._send_connect s'' '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 $X $ $ $ MM8Y y     >V # # / /F 111 : 9~''00   VT%5 6 6 6   VT%7 8 8 8 > %   VT^ 4 4 4~)  888# >V # # NNc%!+%!+%!+%!+$*$*(     NNU%!+%!+%!+%!+$*$*   !!'61a888r4c`|jtkr|td||n|tdd}t}t }|||jtkrL||H|ttdz d}|dz }|&|}|t|z }| |||jtkr |||z }|||z }| ||ddS)Nz.Sending DISCONNECT reasonCode=%s properties=%szSending DISCONNECTrrT identifierr) r@rOrrrr*rrrrrr)rCrwr r)r%r+ packed_propss r5rzzClient._send_disconnect sC >V # # NN>+[%%     NN>+? @ @ @ g >V # #%)?%!+J!O!J!J!JJ A% )#-??#4#4L$L(9(99$ ##F,<=== >V # #%*//+++)l*F!!'61a888r4topics.Sequence[tuple[bytes, SubscribeOptions | int]]tuple[MQTTErrorCode, int]cd}|jtkr+|d}n|}|t|z }|D]\}}|dt|zdzz }t|dzzdz}t } | ||| ||} | tjd| |jtkr| |z } |D]X\}} | | ||jtkr| | z } C| | Y| td|| |||| | d| fS)NrrrrXrzSending SUBSCRIBE (d%d, m%d) %s)r@rOrr SUBSCRIBEr*rrrcrrrrrr) rCr rr r)packed_subscribe_propertiesrrr%r+rkrs r5rzClient._send_subscribes  >V # #!.5++.8oo.?.?+ $? @ @ @  / /DAq CFF Q .  sax(3. g ##F,<===&&((  fk$ 22333 >V # # 1 1F ! !DAq   VQ ' ' '~''!&&((" a       -       ""7FIqAA9MMr4 list[bytes]cd}|jtkr+|d}n|}|t|z }|D]}|dt|zz }t|dzzdz}t }||||||} | tjd| |jtkr||z }|D]}| |||jtkr | td|| ||n| td|| ||||| d| fS)NrrrXrz$Sending UNSUBSCRIBE (d%d, m%d) %s %sz!Sending UNSUBSCRIBE (d%d, m%d) %sr)r@rOrr UNSUBSCRIBEr*rrrcrrrrrr) rCr rr r)packed_unsubscribe_propertiesrr%r+rks r5rzClient._send_unsubscribeFs  >V # #!07--0:0A0A- $A B B B  + +A CFF *  *S0 g ##F,<===&&((  fk$ 22333 >V # # 3 3F ( (A   VQ ' ' ' ' >V # # NN6      NN3    ""7FIqAA9MMr4cl|jtkr|jtkr|jS|jS|jSrB)r@rOrNrZrrPrKs r5_check_clean_sessionzClient._check_clean_sessionws9 >V # # $???11((& &r4c|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}rirfvaluesrrhr9rgrrer rmqtt_ms_wait_for_pubcompmqtt_ms_resend_pubrelrfrhrCms r5_messages_reconnect_reset_outz$Client._messages_reconnect_reset_outsv  $ - -&'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~rrXrergrrr9popr8rs r5_messages_reconnect_reset_inz#Client._messages_reconnect_reset_ins  #  ((** $/$;$=$=!        &--//   5A::%))!%0000                    s.BABB#&B#cV||dSrB)rrrKs r5rDz Client._messages_reconnect_resets, **,,, ))+++++r4c|||dt|||d}|j||j1 |jt n#t $rYnwxYw|jN|jG|j dr-|j | S| tjS)Nr)r%r8r9r-r,r+r<F)rrZrrDrH sockpair_datarrrryacquirereleaserXrrrm)rCr%r+r8r9r<mpkts r5rzClient._packet_queuesf++   %%% ? & $$]3333"     < D$B$J&..u55 )'//111((( ((***--sA A'&A'cp|jddz}|tkr|S|tkr|S|t kr|dS|tkr|dS|tkr| S|tkr| S|tkr| S|tkr|S|t kr |t$jS|t(kr|S|t,kr0|jt0kr |t$jS|t6d|t$jS)Nr%r@rerzError: Unrecognised command %s)rWr_handle_pingreqr_handle_pingrespre_handle_pubackcomprrB_handle_publishr_handle_pubrecr_handle_pubrelr_handle_connackSUBACK_handle_subackrrmUNSUBACK_handle_unsubackrr@rO_handle_disconnectrrFro)rCcmds r5rYzClient._packet_handlesoi(4/ '>>'')) ) H__((** * F]]**844 4 G^^**955 5 G^^'')) ) F]]&&(( ( F]]&&(( ( G^^'')) ) F]]    ! ! ! 1 1 H__((** * J  4>V#;#;  # # % % % 1 1 NN<)I3 O O O 2 2r4c|jddkr tjS|td|S)Nr)rzReceived PINGREQ)rWrrorrrrKs r5rzClient._handle_pingreqsE ?- .! 3 3 2 2 ~'9:::""$$$r4c|jddkr tjSd|_|t dtjS)Nr)rzReceived PINGRESP)rWrrorarrrmrKs r5rzClient._handle_pingrespsE ?- .! 3 3 2 2  ~':;;;--r4c r|jtkr|jddkr tjSn|jddkr tjS|jtkrt jd|jddd\}}|dkrttdz d}d}nttdz | }ttdz }||jdddn4t jd|jd\}}t|}d}|jtkr|tkrK|j stS|td ||t |_|S|t$kr|jd kr~|j stS|td ||t)t+jjd d|_|S|dkrt2j|_d|_|jtkr|td|||n|td||d|_|j5|j}dddn #1swxYwY|rai}|dz|d<|j 5 |j!tDj#krc|jtkr*tItJ|}|||j&|||ntItN|}|||j&||n|j!tDj(kr_tItR|}tU|ddk}|ttVj}|||j&|||ntYdn;#tZ$r.}|t\d||j/sYd}~nd}~wwxYwdddn #1swxYwY|dkrctj0} |j15|j23D]} ti| _5| j6tnkr)|8t`ccdddS| j9dkr|j 5|:| j;| j<d| j=| j9| j>| j?| j@} dddn #1swxYwY| tj0kr| ccdddSn| j9dkr| j6tkr|xjBdz c_Bt| _6|j 5|:| j;| j<d| j=| j9| j>| j?| j@} dddn #1swxYwY| tj0kr| ccdddSnO| j9dkrC| j6tkr|xjBdz c_Bt| _6|j 5|:| j;| j<d| j=| j9| j>| j?| j@} dddn #1swxYwY| tj0kr| ccdddSn| j6tkru|xjBdz c_Bt| _6|j 5|G| j;} dddn #1swxYwY| tj0kr| ccdddS|8 dddn #1swxYwY| S|dkr|dkr tjHStjS)Nr)rrr+rrTr)aNamerz=Received CONNACK (%s, %s), attempting downgrade to MQTT v3.1.r4z:Received CONNACK (%s, %s), attempting to use non-empty CIDr4r5r6rz'Received CONNACK (%s, %s) properties=%szReceived CONNACK (%s, %s)Fzsession present)r^r3z"Caught exception in on_connect: %srr r)Ir@rOrWrrorunpackrrrrrrr`rrrQrrrTrrRrSr$rrrurdr_rr{rryrIrrJrCallbackOnConnect_v1_mqtt5rACallbackOnConnect_v1_mqtt3rcCallbackOnConnect_v2r]rrr2rFrrmr}rfrrrrrhrXr9rdr8rrr r r rgrirerfrrrrr) rCflagsresultreasonr r flags_dictrrrrs r5rzClient._handle_connacksS >V # #12Q66$667 _/ 0A 5 5 2 2 >V # #$mtx0!466OUF{{$GqL8VWWW! #GqLVDDD'1 55 !!$/(";ABB"?@@@@$mE4?83LMMOUF6v>>FJ >X % %9991-,,"S6 ")~~'''???3..1-,,"P6 #*$*,,*:B"G"G"G"N"Nv"V"V~~''' Q;;*V # # NN I5RXZd f f f f NN ;UF L L L&+"  ! ) )J ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ' J,1DLJ( )($ $ #15G5PPP>V33)-.H*)U)UJ&JtT^,6 LLLL*..H*)U)UJ&J $dnj&JJJJ37I7RRR%)*> %K%K (4,67H,IA,M))) &-)3K4G)H)HJ"   N)"& ++MNNN NN$&JCQQQ3A$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ L Q;;/B(; &; &+2244:&:&A"+++AKw.00)))/// ; &; &; &; &; &; &; &; &uzz!4  !%!3!3 ! !w 7 7 ! ! ! !+,<"4""B               !???#%II'; &; &; &; &; &; &; &; &$@!7o55 33q833&=AG!%!8 " "%)%7%7$%E$%GNN7$;$;$%I$%E$%H$%E/0|&8&"&" " " " " " " " " " " " " " " " "]%CCC') G; &; &; &; &; &; &; &; &H!7o55 33q833&=AG!%!8 " "%)%7%7$%E$%GNN7$;$;$%I$%E$%H$%E/0|&8&"&" " " " " " " " " " " " " " " " "]%CCC') g; &; &; &; &; &; &; &; &d DW(=== 33q833&>AG!%!8>>%)%6%6qu%=%=>>>>>>>>>>>>>>>!]%CCC') u; &; &; &; &; &; &; &; &vOO%%%%u:&; &; &; &; &; &; &; &; &; &; &; &; &; &; &; &zI aZZFQJJ 6 6 2 2s(J<<KKP C;OP  P#$P P  PP  P$'P$A^.^AT ^T# #^&T# '^ A^ AW) ^)W- -^0W- 1^A^AZ4( ^4Z8 8^;Z8 <^4^\:. ^:\> >^\> ^%^^ ^ ctdz }dx}}|jddkrzt|}||jd|jddkr:t |}||jddd\}}|t d||||dtj || dS) NrTr)rr+rXrzReceived DISCONNECT %s %sT)rrrr ) rrWrrrrrrrrrm)rC packet_type reasonCoder props props_lens r5rzClient._handle_disconnects Ao "&& Z ?- . 2 2#K00J   doh7 8 8 812Q66' 44 #-#4#4OH-abb1$3$3 y ~'B!!     #0!      r4c|tddt|jddz d}t j||jd\}}|jtkrDttdz }||\}}d||dD}nMdd t|z}t j||}d |D}ttdz }|j 5|j } dddn #1swxYwY| r%|j 5 |j tjkrc|jtkr*t!t"| } | ||j|||nwt!t&| } | ||j||nN|j tjkr*t!t*| } | ||j|||nt-d n;#t.$r.} |t0d | |jsYd} ~ nd} ~ wwxYwddddS#1swxYwYdSdS) NzReceived SUBACKrr+rrrTc@g|]}ttdz |SrTrrrrcs r5 z)Client._handle_suback..s)]]]Q:fka@@@]]]r4!Bc@g|]}ttdz |Srrrs r5rz)Client._handle_suback..s)VVVQ:fka@@@VVVr4r3z$Caught exception in on_subscribe: %s)rrrrWrrr@rOrrr{rryrIrrJrCallbackOnSubscribe_v1_mqtt5rACallbackOnSubscribe_v1_mqtt3rcCallbackOnSubscribe_v2rr2rFr) rC pack_formatr8r+r rr reasoncodes granted_qosrrs r5rzClient._handle_subacks? ~'8999@3tx899A=@@@  k4?83LMM f >V # ##FaK00J)0088 E9]]&QZQ[Q[J\]]]KK1cCKK/11K - V<V33+/0Ll+[+[L(L $dnc; TTTT,00Ll+[+[L(L $dnc;HHHH37I7RRR'+,BL'Q'Q $   N'& ++MNNN NN$&LcSSS33                    sODD #D 1I3CG:9I: H2$H-(I-H22II Ic |jd}t}|dzdz dk|_|dzdz |_|dzdk|_dt |jdd z d }t j||jd\}}d |d t ||z d }t j||\}}|jtkrt |dkr tj S | d }n#t$rd |}YnwxYw||_|jdkr3dt |d z d }t j||\|_}|jtkrCt!t"dz |_|j|\}} || d}||_|jtkrN|t*d|j|j|j|j||jt |j nG|t*d|j|j|j|j|t |jt-|_|jdkr!||tjS|jdkrB|||jr tjS||jS|jd krV||j} t:|_|j5||j |j<dddn #1swxYwY| Stj S)Nr%rrXrrrrr+rrrrzTOPIC WITH INVALID UTF-8: rTzKReceived PUBLISH (d%d, q%d, r%d, m%d), '%s', properties=%s, ... (%d bytes)zrrmqtt_ms_wait_for_pubrelrr~rg) rCheaderrlrslenr+r print_topicrrrs r5rzClient._handle_publishs+-- !+1 }*  4-A-@3tx899A=@@@ {DOH4MNNv6$66Vt!3666  - V<< >V # #E a 2 2  A,,w//KK! A A A@u@@KKK A ;??1s6{{Q111K$*M+v$F$F !W[& >V # #!+GqL!9!9G &188@@ E9IJJ'F  >V # # NN] W['.'+W/W_1E1E      NNN W['.'+S11    &KK ;!    # #G , , , 1 1 [A    # #G , , , 6$55((555 [A  ""7;//B3GM' 9 918!'+. 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9I 2 2s$-DDD L<<MMc|jr6|dkr||S|dkr||StjS)z send an acknowledgement for a given message id (stored in :py:attr:`message.mid `). only useful in QoS>=1 and ``manual_ack=True`` (option of `Client`) rr)r>rrrrm)rCr8r9s r5ackz Client.ackEsR   /axx((---))#...--r4onc||_dS)a The paho library normally acknowledges messages as soon as they are delivered to the caller. If manual_ack is turned on, then the caller MUST manually acknowledge every message once application processing is complete using `ack()` N)r>)rCr s r5manual_ack_setzClient.manual_ack_setRs r4c`|jtkr|jddkr tjSn|jddkr tjSt jd|jddd\}|jtkr|jddkrttdz }||jddd|jddkrBttdz }||jddd\}}| td||j 5||j vr|j |}|||xjdzc_|jd krQ|j5|}dddn #1swxYwY|tjkr|cdddSdddn #1swxYwY|jr tjS||S) Nr)rrr+rTrXzReceived PUBREL (Mid: %d)rr)r@rOrWrrorrrrrrrr~rgrrrirhr}_update_inflightrmr>r)rCr8rr rrrlrs r5rzClient._handle_pubrel[s >V # #12Q66$667 _/ 0A 5 5 2 2}T4?8#V # #12Q66'! 44 !!$/(";ABB"?@@@?#56::!+FaK!8!8J'1'8'81!""5(7(7$E9 ~'BCHHH  # " "d'''+//44''000''1,''.22055!2244555555555555555];;;! " " " " " " " " " " " " " " " " " " " " " " "&   + 1 1%%c** *s7 AG='G< G=G G=G G==HHc |jD]}|j|jkr|jdkr|jt kr|xjdz c_|jdkr t|_n|jdkr t|_| |j |j d|j |j|j|j|j}|t"jkr|cSt"jcSt"jS)Nrrrrr)rfrrirhr9rrhrerfrdr8rrrr r r rrm)rCrrs r5rzClient._update_inflights#**,, 6 6A&)DDD5199N!:!:++q0++uzz"9!"9++w// #$<,B];;;! $5555--r4c|jtkr|jddkr tjSn|jddkr tjSt jd|jddd\}|jtkr|jddkrttdz }||jddd|jddkrBttdz }||jddd\}}| td||j 5||j vrM|j |}t|_t!|_||cdddS dddn #1swxYwYtjS)Nr)rrr+rTrXzReceived PUBREC (Mid: %d))r@rOrWrrorrrrrrrr}rfrrrrrrm)rCr8rr rrmsgs r5rzClient._handle_pubrecs >V # #12Q66$667 _/ 0A 5 5 2 2}T4?8#V # #12Q66'! 44 !!$/(";ABB"?@@@?#56::!+FaK!8!8J'1'8'81!""5(7(7$E9 ~'BCHHH  $ . .d((((-4 )  ((--  . . . . . . . .( . . . . . . . . . . . . . . .--s A F00F47F4cD|jtkr|jddkr tjSn|jddkr tjSt jd|jddd\}|jtkrY|jddd}ttdz }||\}}d||dD}ng}ttdz }| td||j 5|j }dddn #1swxYwY|rY|j 5 |jtjkr|jtkrGt#t$|}|}t'|dkr|d }|||j|||nt#t*|}|||j|ni|jtjkrEt#t.|}|tt0j}|||j|||nt5d n;#t6$r.} | t8d | |jsYd} ~ nd} ~ wwxYwdddn #1swxYwYtjS) Nr)rTrrr+c@g|]}ttdz |Sr)rrrs r5rz+Client._handle_unsuback..s9   8q=Q777   r4zReceived UNSUBACK (Mid: %d)rrr3z&Caught exception in on_unsubscribe: %s)r@rOrWrrorrrrrrr{rryrIrrJrCallbackOnUnsubscribe_v1_mqtt5rrACallbackOnUnsubscribe_v1_mqtt3rcCallbackOnUnsubscribe_v2rrrr2rFrrm) rCr8r+r rrreasoncodes_listrrrs r5rzClient._handle_unsubacksy >V # #12Q66$667 _/ 0A 5 5 2 2}T4?8#V # #_X.qrr2F#HM22J)0088 E9   +      " #HM22J ~'DcJJJ  ! 1 1!0N 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 $ (# # "15G5PPP>V33-12PR`-a-aNIYK"#34499.>q.A *N $dnc:{TTTT.22PR`-a-aN*N4EEEE37I7RRR)-.F)W)W%-)3K4G)H)HJ&  N,& ++MNNN NN$&NPSUUU3?# # # # # # # # # # # # # # # J--sOD//D36D3J C=IJ  I<$I72J 7I<<J  JJrrrcB|j5|j}dddn #1swxYwY|ru|j5 |jtjkrw|jtkr?tt|}|r|||j ||n|||j |dntt|}|||j |n|jtj krftt|}t|}|t|}|t!t"j}|||j |||nt'dn;#t($r.}|t,d||jsYd}~nd}~wwxYwddddS#1swxYwYdSdS)N)rcr3z%Caught exception in on_disconnect: %s)r{rryrIrrJr@rOrCallbackOnDisconnect_v1_mqtt5rACallbackOnDisconnect_v1_mqtt3rcCallbackOnDisconnect_v2rbrrrrrr2rrFr)rCrrrr rdisconnect_flagsrs r5rzClient._do_on_disconnects ! / / .M / / / / / / / / / / / / / / / ) (( ( '15G5PPP>V33,01NP],^,^M1Q - dDNFJ W W W W - dDNE4 P P P P,01NP],^,^M)M$FFFF37I7RRR(,-Dm(T(T +:=O,,,(">%QRW%X%XF%-)3K4J)K)KJ%   N,"& ++MNNN NN$&MsTTT3I( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ) ) sG  FDE  F F$E=8F=FFFF reason_coderrc6|j5|j}dddn #1swxYwY|r|j5 |jtjkr(t t|}|||j|nN|jtj kr*t t|}|||j|||ntdn;#t$r.}| td||jsYd}~nd}~wwxYwdddn #1swxYwY|j|}|j|jdkrA|xjdzc_|jdkr&|}|t0jkr|St0jS)Nr3r_rr)r{r ryrIrrJrrbrArcrdrr2rrFrrfrr<rr9rirhrrrm)rCr8rr r rrrs r5_do_on_publishzClient._do_on_publish.sZ  ! ) )J ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  (  15G5PPP%)*> %K%K " 4====37I7RRR%)*> %K%K "   N'& ++MNNN NN$&JCQQQ3%               0 $$S)) ""$$$ 7Q;;  # #q ( # #*Q..**,,777I--sG  DB B>=D> C6$C1,D1C66DD  D r&Literal['PUBACK'] | Literal['PUBCOMP']c\|jtkr|jddkr tjSn|jddkr tjS|dkrt nt }|jdz }tj d|jddd\}t|}t|}|jtkru|jddkrd| |jddd|jddkr+| |jddd\}}| td|||j5||jvr%||||} | cdddS dddn #1swxYwYtjS) Nr)rrerTrr+rXzReceived %s (Mid: %d))r@rOrWrrorerrrrrrrrr}rfrrm) rCrpacket_type_enumrr8rr rrrs r5rzClient._handle_pubackcompUs >V # #12Q66$667 _/ 0A 5 5 2 2%(H__66'&,1 }T4?8#V # #12Q66!!$/(";ABB"?@@@?#56::'1'8'81!""5(7(7$E9 ~'>SIII  $  d(((((j*EE         (                --s"FFFrlrec  |j}n#t$rd}YnwxYwg}|j5|,t|j|j}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)Nrz9Caught exception in user defined callback function %s: %sz"Caught exception in on_message: %s)rrr{rrrrrrryrAr2rrFr/r)rCrlron_message_callbacksrrHrs r5rzClient._handle_on_messagess MEE!   EEE  "  ! " " '+D,E,P,PQXQ^,_,_'`'`$'((A--!_ !  " " " " " " " " " " " " " " "-  H(   HT4>7;;;; NN$S )   3                 (  JtT^W==== NN$&JCQQQ3                    s A A==BBC5B('C5( C&2*C!C5!C&&C55C9 <C9 E' DE' E)$E E'EE''E+.E+c&|j5|j}dddn #1swxYwY|rh|j5 |||jn3#t$r&}|t d|Yd}~nd}~wwxYwddddS#1swxYwYdSdS)Nz'Caught exception in on_connect_fail: %s)r{rryrAr2rrF)rCrrs r5rzClient._handle_on_connect_fails  ! 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 BcZ |dd|_dS#d|_wxYw)NT)r)rrrKs r5rzClient._thread_mains<   T  : : :DLLL4DL    s! *ct}|j5|j |j|_n"t |jdz|j|_||jz}dddn #1swxYwY||z }|jtjtj fvrn|j sk|dkrgtj t |d|tz }|jtjtj fvr|j s|dk_dSdSdSdSdSdS)Nrrr) rrr_r]minr^rdrrSrTrtimesleep)rCr target_time remainings r5rzClient._reconnect_waitsmkk  ( 6 6$,(,(A%%(+)A--))%  55K 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 #% {#3#IK[Kp"qqq.rMM Js9a(( ) ) )#ikk1I {#3#IK[Kp"qqq.rMMMMrqqqqq!MrqsAA##A'*A'c*d d}t|tr2||d|dSt|ttfr+t |dko||d|dSd S) Nr@rPcbtduo&|tjtjtjhvo|SrB)rHTTPSOCKS4SOCKS5)ras r5checkz%Client._proxy_is_valid..checks4%H%*elELAAHFG Ir4 proxy_type proxy_addrrrrFr)rrgetrrr)rzr3s r5rzClient._proxy_is_valids I I I I a   5|,,aeeL.A.ABB B D%= ) ) q66Q;4551qt#4#4 45r4dict[str, Any] | NonectdS||jr|jSttjdr$tj|jstj}d|vrstj |d}|j dkrtj |j |jd}|S|j dkrtj|j |jd}|Stj}||rd}t#t%||SdS)N proxy_bypassmqtthttp)r4r5 proxy_portr)r4r5r< proxy_rdnsproxy_usernameproxy_password)rrrwr=urllibrequestr9rs getproxiesparseurlparseschemer/hostnamerr1get_default_proxyrzip)rC env_proxiespartsproxy socks_default proxy_keyss r5 _get_proxyzClient._get_proxysA =4    , , ;  77 !++DJ77 ! .3355K$$ --k&.ABB<6))&+j&+n&+jE !L\W,,&+l&+n&+jE !L/11    . . 8LJJ 6677 7tr4cL|jdkr|}n|}|jr||}|jdkrH||jt||j|j |j|j |j S|S)Nr-r/)rrris_sslr extra_headers) r?_create_unix_socket_connection_create_socket_connectionr_ssl_wrap_socket settimeoutrE_WebsocketWrapperrsrtrrrs r5rGzClient._create_sockets ?f $ $6688DD1133D 9 /((..D ?l * * OODO , , ,$ZZy)";   r4_socket.socketctjtjtj}||j|SrB)rr.rrrs)rC unix_sockets r5rRz%Client._create_unix_socket_connections4mFNF4FGG DJ'''r4c|}|j|jf}|j|jf}|rt j|f|j|d|Stj||j|S)N)rsource_address) rNrsrtrurvrcreate_connectionrFr)rCrKr6sources r5rSz Client._create_socket_connectionsx!! DJ'$do6  h*4o9N_eooinoo o+D$:O`fggg gr4tcp_sock ssl.SSLSocketc|jtd|j } |j||jd}t |jddrd}n;#t j$rt$r|j|d}YnwxYw||j | |r,t j | |j|S)NzGImpossible condition. _ssl_context should never be None if _ssl is TrueF)server_hostnamedo_handshake_on_connectr)rb) rrr wrap_socketrsrrCertificateErrorrUrE do_handshakematch_hostname getpeercert)rCr^ verify_hostssl_socks r5rTzClient._ssl_wrap_socket"s1   $Y ,,  $(44 $ (-5H t(*:EBB $# #       (44(-5HHH  DO,,,  C  x3355tz B B Bs"A5BB)r!rr"r#r$r%r&rr'rr(r)r*rPr+rPr@rIrTr)rrjr@rIrU)rr$r@rI)r@r))rrr@rI)r@r)r@r)rrr@rI)r@r#)rr#r@rI)r@r)r@r)rrr@rI)rr$r@r:)rr:r@r$)F)rrPr@rI)rTN)r"rjr$rPr&rr@rI)r;N)rrjrrr@rIrB)rrr@rI)NNNNNNNN)rr#rr#rr#rrrrrr#rr#rrr@rI)rrPr@rI)r rr@rI)rrr@rI)rrjrr$rr$rrjrr$rrYr rr@r)rr#rr$rrjrr$rrYr rr@r)rrjrr$rr$rrjrr$rrYr rr@rI)rr8)r;r$r<r$r@rI)r@r)rK)rrr@r)NrFN) rrjrr^r9r$r rPr rr@r)rr#rr#r@rIr)NN)rwrxr rr@r)rNN) rr|r9r$r}r~r rr@r)rrr rr@rr)rr$r@r)rr$r@rI)rr$r@rd)r&rr@rI)r@r) rrjrr^r9r$r rPr rr@rI)r@r)rKF)rrrrPr@r)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r)r@r )rr r@rI)r@r)r@r)rrr@rI)r@r)r@r)rrr@rI)r@r )r@r%)rr%r@rI)r@r))rr>r@rI)rrr@rI)rrjrHrr@rI)rrjr@r)rrjr@rI)rrr@r)rgrrhrjrirr@rI)rr:r@rI)rr:r@r)r8r$r@r)r+r*r)r$r@r*)r+r*r]rr@rI)r4rFFNN)r8r$rr:rrr9r$r rPr rPr<r;r rr@r)r%r$r8r$r r$r@r)r%r$r@r)rr$r@r)r r$rrr rr@r)r r$rrr rr@r) r%r$r+r:r8r$r9r$r<r;r@r)r8r$r9r$r@r)r rPr@rI) rrPrrrrxr rr@rI)r8r$rrr rr@r)rr r@r)rlrer@rI)r@r7)r@r>)r@rW)r^rWr@r_)r/r0r1r`rrJrrrrrrrrr(r'rrrrrrrrrrrrrrrr r rrrrZrr8rr>rrNrMrmrorrrrvr{rrrVrXrQrYrrrrrrrrrrr!rrrErrrrrrrrr r rrrrr$r'r.rHr2r6rr:r>rrBrFrrJrMrPrrrrrrc staticmethodrbrrorrrrrrdrrrr~rIrzrrrrrrDrrYrrrrrrr r rrrrrrrrrrrrrNrGrRrSrTr3r4r5rdrdwsccN4F3N "%)(0:?%) P)P)P)P)P)dX [[X [[X      X    X%%%X%&&&&...X._333_3...X._333_3+++X+! , , ,"! ,)))X)*** * 0 0 0X 0"""X"X ]] - - - - - - - -     # # # # #" :::::+/ddddd4*.<<<<<2 $#"+/"&"'++/i(i(i(i(i(V99996%%%%@ (C(,* * * * * \"(C(,.3.3.3.3.3f(C(,.=.=.=.=.=` ) ) ) ) ):3:3:3:3x#####>F F F F F V $(, l(l(l(l(l(^<@&&&&&,(((( HHHHAAAA)-(,=====0+/(, PGPGPGPGPGfGK(E(E(E(E(ET.....255556)))) ....@.... """" $(, -+-+-+-+-+^"""" ',LLLLL\....&...."***X*X( ]] $$$X$"((((2 2 2 X2 h$$$$%%%X% ))))""""""X""H&&&&   X ($$$$( ( ( X( T$$$$#$#$#$X#$J((((%#%#%#X%#N''''$$$X$$((((    %%%X%$))))    ...X.$$222%$2$000X0( &444'&4 )-*6666:     $hhhhTW.W.W.W.r 4 4 4 4$$$$L"""";;;\;222\23333????@@@@"$''+(,MCMCMCMCMC^????CCCC;;;;9999 g9g9g9g9V)-(,$9$9$9$9$9T)- (N(N(N(N(N\)- /N/N/N/N/Nb''''----:    ,,,,(, %.%.%.%.%.N3333>%%%%....l3l3l3l3\    .0000dH3H3H3H3T . . . .(+(+(+(+T....2....6>.>.>.>.H%)(, 33333j%.%.%.%.N....<''''T V V V V    2222,   \ ))))V, hhhh%%%%%%r4ceZdZdZdZdZdZdZdZd+dZ d,dZ d-dZ d.d/dZ d0dZ d1dZd2d Zd1d!Zd1d"Zd2d#Zd2d$Zd,d%Zd3d&Zd3d'Zd4d)Zd*S)5rVrrrr rsocket.socket | ssl.SSLSocketrrjrr$rPrPrrQrcd|_||_||_||_||_||_t |_t |_d|_ d|_ d|_ | |dSr) connectedrrsrt_socket_pathr* _sendbuffer _readbuffer_requested_size _payload_head_readbuffer_head _do_handshake)rCrrrrPrrQs r5rz_WebsocketWrapper.__init__Qsx     $;;$;;  ! =)))))r4r@rIcRt|_t|_dSrB)r*rtrurKs r5rz_WebsocketWrapper.__del__ks $;;$;;r4cLtjj}tj|}|jrd}d}nd}d}||jkr |j}n|jd|j}|dd|d||d d d d }t|tr| |nt|r ||}d d|jdd d|Dd gd }|j|d}d} |jd} n#t($rd} YnwxYw|j| | dkrt/|jdkrdt1|jdvrLdt1|jdvrt5dd} dt1|jdvrd} |jdddd} | d} |d| z}t;j|d}tj|}| |krt5dd}nn'tA|_n| st5d,| r|st5dtA|_d|_!dS) NihttpsPr;: websocketUpgradez://r613r:)Hostr ConnectionOriginzSec-WebSocket-KeyzSec-Websocket-VersionzSec-Websocket-Protocolz zGET z HTTP/1.1c3*K|]\}}|d|VdS): Nr3)rijs r5rz2_WebsocketWrapper._do_handshake..s0JJ11  JJJJJJr4FTrr4 rs connectionrsupgradez2WebSocket handshake error, connection not upgradedssec-websocket-acceptz$258EAFA5-E914-47DA-95CA-C5AB0DC85B11rz-WebSocket handshake error, invalid secret keyzWebSocket handshake error)"rRrSr:base64 b64encoderrtrsrrrupdaterrrsitemsrrrrHrDConnectionResetErrorrurrrjr<rgr|striphashlibsha1digestr*rq)rCrQsec_websocket_key default_port http_schema host_portwebsocket_headersr has_secret has_upgraderZGUIDserver_hash_str server_hashclient_hash_keyclient_hash_digest client_hashs r5ryz_WebsocketWrapper._do_handshakeos JLL.",->?? 9 !L!KKL K 4: % %:II:44 44I"#$4444!2!9!9&!A!A%)&,   mT * * A  $ $] 3 3 3 3 m $ $ A - .? @ @  (4: ( ( ( KKJJ0A0G0G0I0IJJJ J J     6&>>  &!!!  / L |((++'       # #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*.*:*A*A#+%+%%*U4^^A+7&5&;&;&=&=&D&DW&M&M *;*B*B7*K*Kd*R-4\/:P:PQX:Y:Y-Z-Z*&,&67I7P7P7R7R&S&S &+55": O#Q#QQ*.J$-;;   L./JKKK_/ Lb H* H*+FGG G$;;s E'' E65E6opcoder]r* do_maskingcrt}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) NrTrV~rrsrlrU!QzMaximum payload size is 2^63r) r*rosurandomrrrrr) rCrr]rrlengthmask_key mask_flagrs r5 _create_framez_WebsocketWrapper._create_framesOTRZ]]++   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}r4rcR|t|j|jz z }|dkrW|j|}|st |j|t||krt|xj|z c_|j|j|z |jSr)rrurxrrrDConnectionAbortedErrorrr)rCr wanted_bytesr]s r5_buffered_readz _WebsocketWrapper._buffered_readsT%5!6!69N!NO !  <$$\22D .,, ''---4yy<''%% ' 5 >t?T TUUr4r:c d|_d}|j}|j|z}|d}|d}|ddz}|ddzdk}|ddz} | } d} | dkr-|d} tjd | \} n2| dkr,|d } tjd | \} |r|d } |} | | kr| } | dkrU|| }| ,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 |_YdSwxYw)Nrr4rrVrUrrrrrrTF)rxrwrrrrr*rurVOPCODE_CONNCLOSErrrrH OPCODE_PING OPCODE_PONG OPCODE_BINARYOPCODE_CONTINUATIONrrrq)rCrrchunk_startindexchunk_endindexheader1header2rmaskbit lengthbitspayload_lengthrr readindexrrframes r5 _recv_implz_WebsocketWrapper._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**#,;; %&".??? ..):GQHHEL%%e,,,.::: ..)5wCCEL%%e,,,+999VGXGl=l=l&** %%   "DN33 sH9I<IIIct|jdkr[|tjt |}|j|t||_|j |j}|j|d|_t|jdkr|jSdSr) rrtrrVrr*rrvrrrH)rCr]rrs r5 _send_implz_WebsocketWrapper._send_implZs t A % %&&!/4BBE   # #E * * *#&t99D ""4#344+FGG4 t A % %' '1r4c,||SrBrrCrs r5rDz_WebsocketWrapper.recvpv&&&r4c,||SrBrrs r5readz_WebsocketWrapper.readsrr4c,||SrBrrCr]s r5rHz_WebsocketWrapper.sendvt$$$r4c,||SrBrrs r5writez_WebsocketWrapper.writeyrr4c8|jdSrB)rrrLrKs r5rLz_WebsocketWrapper.close|s r4c4|jSrB)rrrNrKs r5rNz_WebsocketWrapper.filenos|""$$$r4cF|jr|jSdSr)rrrrPrKs r5rPz_WebsocketWrapper.pendings) 9 <'')) )1r4rOc:|j|dSrB)rrrSrRs r5rSz_WebsocketWrapper.setblockings   &&&&&r4N) rrorrjrr$rPrPrrjrQrrT)rQrr@rIrj)rr$r]r*rr$r@r*)rr$r@r*)rr$r@r:)r]r:r@r$rUrV)r/r0r1r OPCODE_TEXTrrrrrrryrrrrrDrrHrrLrNrPrSr3r4r5rVrVIszKMKK****4''''bbbbJ?@BVVVV&QQQQf,''''''''%%%%%%%%%%%%''''''r4rV)rhrir@rj)rrr@rj)rrr@r)rrr@r)rr$rrjrr$r@rj)rrjrrjr@rP)r@r)rrr@r:)rrr@r)r` __future__rrrXerrnorrrplatformrRrstringrrr) urllib.parser@urllib.requestrRrKtypingrrrrrr r r r r rpaho.mqtt.packettypesrenumsrrrrrrrrrrrr rrrrsubscribeoptionsrr ImportErrortyping_extensionsr r!r#r7r>rr monotonicrr dns.resolverr&r#systemWSAEWOULDBLOCKEAGAINrrrrBrerrrrrrrrrrAUTH MQTT_LOG_INFOMQTT_LOG_NOTICEMQTT_LOG_WARNINGrFrDEBUGINFOWARNINGERRORrkrrrrrrMQTT_MS_INVALIDrMQTT_MS_PUBLISHrgMQTT_MS_WAIT_FOR_PUBACKreMQTT_MS_WAIT_FOR_PUBRECrfMQTT_MS_RESEND_PUBRELrMQTT_MS_WAIT_FOR_PUBRELrMQTT_MS_RESEND_PUBCOMPmqtt_ms_resend_pubcompMQTT_MS_WAIT_FOR_PUBCOMPrMQTT_MS_SEND_PUBRECmqtt_ms_send_pubrecMQTT_MS_QUEUEDrhrrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}rQrrOrGrqrZr2rrjr:r*r$rr^ HTTPHeaderWebSocketHeadersrPrYr]rbrrCallbackOnConnect_v1rrrrrCallbackOnDisconnect_v1rr"rrrrbrdrr+rrCallbackOnSubscribe_v1rrrrCallbackOnUnsubscribe_v1rrrrrrgr~rrrr ascii_lettersrrrrrrrerdrVr3r4r5rsK #"""""      oooooooooooooooooooooooooo------^^^^^^^^^^^^^^^^^^^^^^ """"""00000000......****))))))))*)0$$$$$$$ 000////////0/####### ///......../I%%%%%Y%%%     X   JJJJ CCCLLLL EEEII IIIHHHHH8? !!  !FF \F                !  %        # & *,$ ( W] GL gl w 7=  /#.#O &1&U#%0%S"(3(Y%!,!K..&>&>$:&>%<'@"6,- 1-!3- 1%;"5"5) %;&=+ #7 1-#7"5  %  '  #( ( 121111 C 3t;< #s(^ :, ":;ZGHwqz)*     :        j   &xd38nm&TVZ&Z[%xd38njRWXbdhXhRi&jlp&pq79SST3 j%PZ\`P`Ja bdh hi.0DDE (C$!67 ((C)G)M N ((Cz3PT?T9UW\]gim]mWn)oqu)u v =?\ \]"Hc?JPUV`bfVfPg#hjn#no46MMN(Cc2D89 h];TAB3 563 4d :;3Z Ld RS.0DDEXsL94?@'3U38_(Mt(ST'3T*=Mz(Z\`(`a;=YYZ!8S#tJ7Gz[_O_I`"acg"gh24JJK!)8S#*>*D!E!)8S#z5Q[]abl]mQmKn*oqu*u!v !?A_!_`#XsCj9I5Q[]aQaKb$cei$ij68PPQ         % % % % P5555*@@@@>CCCC4  44 % % % % % ",    $`#`#`#`#`#`#`#`#F++++++++\P?P?P?P?P?P?P?P?d~C'C'C'C'C'C'C'C'C'C's~B&& B43B4:C CCC C('C(DD%$D%)D..D87D8<E EEEE('E(