U Zj @sUdZddlmZddlZddlZddlZddlZddlZddlZddl 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 l4m5Z5zdd lm6Z6Wn"e7k rldd l8m6Z6YnXer zdd lm9Z9Wn"e7k rdd l8m9Z9YnXzddlm:Z:Wn"e7k rddl8m:Z:YnXGddde9Z;Gddde9ZZ>Wne7k r2dZ>YnXz ddl?Z?Wne7k rZdZ?YnXz ej@ZAWneBk rejZAYnXzddlCZDdZEWne7k rdZEYnXe FdkrejGZHnejHZHe3ZIe(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<dZeeeeeedfZeeefZeeegefefZeee6dfZGdddeZGdddeZed 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$d$eZd%d&d'd(d)Zd*d&d+d,d-Zd.d/d+d0d1Zd2d/d3d4d5Ze je jdfd6d&d6d&d7d8d9Zd&d&d:d;dd?d@dAZdBdCdDdEdFZdGdHdIdJdKZGdLdMdMZGdNd!d!ZGdOd d ZGdPdQdQZdS)Rz 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@sNeZdZUded<ded<ded<ded<ded<ded <ded <ded <d S) _InPacketintcommandhave_remainingz list[int]remaining_countremaining_multremaining_length bytearraypacket to_processposN__name__ __module__ __qualname____annotations__r1r1S/var/www/html/TRUCKING_PROJECT/venv/lib/python3.8/site-packages/paho/mqtt/client.pyr!@s r!c@sFeZdZUded<ded<ded<ded<ded<ded<d ed <d S) _OutPacketr"r#midqosr+r*bytesr)MQTTMessageInfo | NoneinfoNr,r1r1r1r2r3Ks r3c@sXeZdZdddddZdddddZd d d d Zdd d dZdd dddZdS) SocketLiker"r6) buffer_sizereturncCsdSNr1)selfr:r1r1r2recvUszSocketLike.recv)bufferr;cCsdSr<r1)r=r?r1r1r2sendWszSocketLike.sendNoner;cCsdSr<r1r=r1r1r2closeYszSocketLike.closecCsdSr<r1rCr1r1r2fileno[szSocketLike.filenoboolflagr;cCsdSr<r1r=rHr1r1r2 setblocking]szSocketLike.setblockingN)r-r.r/r>r@rDrErJr1r1r1r2r9Ts r9TFWindowsCleanStartOptionMQTT_CLEAN_START_FIRST_ONLY0c@seZdZUdZded<dS) ConnectFlagsz?Contains additional information passed to `on_connect` callbackrFsession_presentNr-r.r/__doc__r0r1r1r1r2rPs rPc@seZdZUdZded<dS)DisconnectFlagszBContains additional information passed to `on_disconnect` callbackrF is_disconnect_packet_from_serverNrRr1r1r1r2rTs rTClient MQTTMessage.c@seZdZdZdS)WebsocketConnectionErrorz WebsocketConnectionError is a subclass of ConnectionError. It's raised when unable to perform the Websocket handshake. N)r-r.r/rSr1r1r1r2rXsrXMQTTErrorCode | intstr) mqtt_errnor;cCs|tkr dS|tkrdS|tkr$dS|tkr0dS|tkr>> 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) rrqrrCONNACKrrrsrtrurvrwr1r1r2!convert_connack_rc_to_reason_code`s            r}rrcr;cCsN|tjkrttjdS|tjkr,ttjdS|tjkrBttjdSttjdS)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 ryzKeep alive timeoutr{)rr]rr DISCONNECTrmrd)rr1r1r2,convert_disconnect_error_code_to_reason_codes      rr")numbasepaddingr;csf|dkrtdg}|r6t|d\}}||q|fddtt||Ddt|S)z+Convert a number to base-62 representation.rzNumber must be positive or zero>c3s|]}dVqdS)rNr1).0_rr1r2 sz_base62..) ValueErrordivmodappendextendrangelenjoinreversed)rrrdigitsrestr1rr2_base62s"rrF)subtopicr;cCs>t}d||<zt||WdStk r8YdSXdS)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/+/+" TFN)rnext iter_match StopIteration)rrmatcherr1r1r2topic_matches_subsrz#tuple[socket.socket, socket.socket]rBcCsttjtjtj}|tjtjd|d|d| \}}ttjtjtj}| dz| d|fWnt k rYnX| \}}| d|||fS)z+TCP/IP socketpair including Windows supportr) 127.0.0.1rFr)socketAF_INET SOCK_STREAM IPPROTO_IP setsockopt SOL_SOCKET SO_REUSEADDRbindlisten getsocknamerJconnectBlockingIOErroracceptrD)Z listensockZifaceportZsock1Zsock2addressr1r1r2_socketpair_compats.      rz str | bytesr6)sr;cCst|tr|dS|S)Nutf-8)rprZencode)rr1r1r2 _force_bytess  rz,str | bytes | bytearray | int | float | Nonebytes | bytearray)payloadr;cCsVt|tr|dSt|ttfr0t|dS|dkrtdt|j|dkrJdnt||dkr`dn|d}ddfdd }|j |js|s|j |qW5QRX|jdkrtdt|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$@rFrBcsdkr dStkS)NF) time_funcr1Z timeout_timer1r2 timed_out.sz3MQTTMessageInfo.wait_for_publish..timed_out) rrlrMQTT_ERR_AGAIN RuntimeErrorrnrrrwait)r=rZ timeout_tenthrr1rr2wait_for_publishs      z MQTTMessageInfo.wait_for_publishrFc Csf|jtjkrtdn,|jtjkr$n|jdkrBtdt|j|j|jW5QRSQRXdS)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) rrrlrrrrnrrrCr1r1r2 is_published8s    zMQTTMessageInfo.is_published)N)r-r.r/rS __slots__rrrrrrrrrr1r1r1r2rs  rc@sneZdZdZdZdddddd Zd d d d dZd d d ddZeddddZ e j dddddZ dS)rWz This is a class that describes an incoming message. It is passed to the `on_message` callback as the message parameter. ) timestampstatedupr4_topicrr5retainr8 propertiesrrr"r6)r4rcCsDd|_t|_d|_||_||_d|_d|_d|_t ||_ d|_ dS)NFrr) rmqtt_ms_invalidrrr4rrr5rrr8r)r=r4rr1r1r2rOs zMQTTMessage.__init__objectrF)otherr;cCst||jr|j|jkSdS)z$Override the default Equals behaviorF)rp __class__r4r=rr1r1r2__eq__`s  zMQTTMessage.__eq__cCs || S)zDefine a non-equality test)rrr1r1r2__ne__fszMQTTMessage.__ne__rZrBcCs |jdS)zVtopic that the message was published on. This property is read-only. r)rdecoderCr1r1r2rjszMQTTMessage.topicrAvaluer;cCs ||_dSr<)rr=rr1r1r2rrsN)rr) r-r.r/rSrrrrpropertyrsetterr1r1r1r2rWIsc @s eZdZdZejdddedddfddd d d d d d dd ddZddddZe ddddZ e j dddddZ e ddddZ e j dddddZ e ddddZ e j dddd dZ e d dd!d"Zej d#ddd$d"Ze d dd%d&Ze d'dd(d)Zej d'ddd*d)Ze ddd+d,Zej dddd-d,Ze ddd.d/Zej dddd0d/Ze ddd1d2Zej dddd3d2Ze ddd4d5Zej dddd6d5Ze ddd7d8Ze d9dd:d;Ze dZej dZdd@dAdBdCZd@ddDdEdFZdddGdHZdd ddIdJdKZddd d ddLdMdNZdddPddQdRdSZddTddUdVdWZdddddXdYdddZdd[ d\d]Zd ddd^d_Z d dd`dadbZ!dddd'd dmdddZ?dmdddZ@dmdddZAe dddd„ZBe ddddńZCeCj dddƜddńZCddddʄZDe dddd̈́ZEeEj dddƜdd̈́ZEddddфZFe ddddԄZGeGj dddƜddԄZGdddd؄ZHe ddddۄZIeIj dddƜddۄZIdddd߄ZJe ddddZKeKj dddƜddZKddddZLe ddddZMeMj dddƜddZMddddZNe ddddZOeOj dddƜddZOddddZPe ddddZQeQj dddƜddZQddddZRe ddddZSeSj dddƜddZSddddZTe ddddZUeUj dddƜddZUdddd ZVd dd d d ZWe ddddZXeXj dddƜddZXddddZYd dd ddZZe ddddZ[e[j dddƜddZ[ddddZ\ddddZ]e ddddZ^e^j dddƜddZ^dddd Z_dddd d!d"Z`dd#dd$d%d&Zaddd'd(d)Zbddd'd*d+Zcdmdmd,d-d.Zddmdd/d0Zedmdd1d2Zfd3dd dd4d5d6Zgddd7d8Zhddd9d:Ziejd@dd;d<d=Zkejd@dmd'd>d?Zldmdd@dAZmdmddBdCZnddmdDdEdFZoddmdDdGdHZpdIddIdJdKdLZqdIdMddNdOdPZrddd@dRdd d dSdldmdT dUdVZsddmdDdWdXZtddmdDdYdZZuddddmd[d\d]Zvddmd^d_d`ZwddmdadbdcZxdddldmddddeZydddfdldgdhdidjZzdddkdldgdhdldmZ{d ddndoZ|dddpdqZ}dddrdsZ~dddtduZddd@dddSdmdvdwdxZdmddydzZdmdd{d|Zdmdd}d~ZdmdddZddddZddddZdmdddZdddmdddZd ddddZdmdddZdmdddZdmdddZdmdddZdd dmddlddddZddddmdddZddmdddZdddddZddddZddddZddddZejd dddZddddZd dddZddddZddddZdddddZdS(rVaMQTT 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` rNtcpTFrz str | Nonez bool | Nonerrz&Literal[('tcp', 'websockets', 'unix')]rFrA) callback_api_version client_id clean_sessionuserdataprotocol transportreconnect_on_failure manual_ackr;c Cs|}|dkr$ttds$tdn|dkr:td|||_||_||_||_d|_d|_ d|_ d|_ d|_ t |_||_|jtjkrtjdtd d t|jtrtd |jtkrtd t|_|tkr|dk rtd n4|dkrd}|s |dks|dkr td||_|dks&|dkrT|tkrLttjdd d|_!nd|_!n t"||_!d|_#d|_$ddgddt%dddd|_&t'(|_)t*|_+t*|_,d|_-d|_.d|_/||_0d|_1d|_2t3j4|_5t'6|_7t'6|_8d|_9d|_:d|_;d|_d|_?d|_@d|_Ad|_BtC|_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) websocketsrrz5transport 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.rutf8rrrr#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_versionrVERSION1warningswarnDeprecationWarningrprZrN _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) r=rrrrrrrrr1r1r2rs                zClient.__init__rBcCs |dSr<)_reset_socketsrCr1r1r2__del__oszClient.__del__rZcCs|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. )r<rCr1r1r2hostrsz Client.hostrcCs&|std|std||_dS)Nz8updating host on established connection is not supported Invalid host.)_connection_closedrrr<rr1r1r2rd{s r"cCs|jS)z} Broker TCP port to connect to. This property may not be changed if the connection is already open. )r=rCr1r1r2rsz Client.portcCs*|std|dkr td||_dS)Nz8updating port on established connection is not supportedrInvalid port number.)rfrrr=rr1r1r2rs cCs|jS)z Client keepalive interval (in seconds). This property may not be changed if the connection is already open. )rrCr1r1r2 keepaliveszClient.keepalivecCs*|std|dkr td||_dS)Nz=updating keepalive on established connection is not supportedrzKeepalive must be >=0.)rfrrrrr1r1r2rhs cCs|jS)z Transport method used for the connection ("tcp" or "websockets"). This property may not be changed if the connection is already open. )rrCr1r1r2rszClient.transportzLiteral[('tcp', 'websockets')]cCs|std||_dS)Nz=updating transport on established connection is not supported)rfrrrr1r1r2rscCs|jS)zj Protocol version used (MQTT v3, MQTT v3.11, MQTTv5) This property is read-only. )r rCr1r1r2rszClient.protocolrcCs|jS)z Connection establishment timeout in seconds. This property may not be changed if the connection is already open. )rrCr1r1r2connect_timeoutszClient.connect_timeoutcCs*|std|dkr td||_dS)NzCupdating connect_timeout on established connection is not supportedrz!timeout must be a positive number)rfrrrrr1r1r2ris cCs|jdkrdS|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)rrrCr1r1r2usernames zClient.usernamecCs0|std|dkr d|_n |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. )r1rCr1r1r2max_inflight_messagesszClient.max_inflight_messagescCs*|std|dkr td||_dS)NzIupdating max_inflight_messages on established connection is not supportedrzInvalid inflight.)rfrrr1rr1r1r2rls cCs|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. )r3rCr1r1r2max_queued_messagesszClient.max_queued_messagescCs*|std|dkr td||_dS)NzGupdating max_queued_messages on established connection is not supportedrzInvalid queue size.)rfrrr3rr1r1r2rms cCs|jdkrdS|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)r7rrCr1r1r2 will_topic(s zClient.will_topicz bytes | NonecCs|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. )r8rCr1r1r2 will_payload4szClient.will_payloadzlogging.Logger | NonecCs|jSr<rOrCr1r1r2logger=sz Client.loggercCs ||_dSr<rprr1r1r2rqAsr6)bufsizer;c Cs|jdkrtdz|j|WStjk rL}z t|W5d}~XYnjtjk r~}z|t|W5d}~XYn8tk r}z| t d|t|W5d}~XYnXdS)Nself._sock is Nonezsocket was None: %s) r ConnectionErrorr>sslSSLWantReadErrorrSSLWantWriteError_call_socket_register_writeAttributeError _easy_logMQTT_LOG_DEBUG)r=rrerrr1r1r2 _sock_recvEs  zClient._sock_recv)bufr;c Cs|jdkrtdz|j|WStjk rL}z t|W5d}~XYndtjk r~}z|t|W5d}~XYn2tk r}z|t|W5d}~XYnXdS)Nrs)r rtr@rurvrrwrx)r=r~r|r1r1r2 _sock_sendTs zClient._sock_sendcCs>|js dSz$|j}d|_||||W5|XdS)z#Close the connection to the server.N)r rD_call_socket_unregister_write_call_socket_closer=sockr1r1r2 _sock_closecs zClient._sock_close) sockpair_onlyr;cCs<|s ||jr"|jd|_|jr8|jd|_dSr<)rr rDr )r=rr1r1r2rbqs  zClient._reset_sockets)rrrr;cCs|||||dSr<)rbr)r=rrrr1r1r2 reinitialise|szClient.reinitialiserWebSocketHeaders | None)pathheadersr;cCs4||_|dk r0t|ts t|r(||_ntddS)a Set the path and headers for a websocket connection :param str path: a string starting with / which should be the endpoint of the mqtt connection on the remote server :param headers: can be either a dict or a callable object. If it is a dict then the extra items in the dict are added to the websocket headers. If it is a callable, then the default websocket headers are passed into this function and the result is used as the new headers. NzL'headers' option to ws_set_options has to be either a dictionary or callable)r^rpdictcallabler_r)r=rrr1r1r2ws_set_optionsszClient.ws_set_optionszssl.SSLContext | None)contextr;cCsF|jdk rtd|dkr"t}d|_||_t|drB|j |_dS)a.Configure network encryption and authentication context. Enables SSL/TLS support. :param context: an ssl.SSLContext object. By default this is given by ``ssl.create_default_context()``, if available. Must be called before `connect()`, `connect_async()` or `connect_srv()`.Nz$SSL/TLS has already been configured.Tcheck_hostname)rMrrucreate_default_contextrLrrrN)r=rr1r1r2tls_set_contexts  zClient.tls_set_contextzssl.VerifyMode | Nonez int | Nonezlist[str] | None) ca_certscertfilekeyfile cert_reqs tls_versioncipherskeyfile_passwordalpn_protocolsr;c CsDtdkrtdttds"td|dkr>ttjds>td|dkrntj}ttdr^tj}nttdrntj}t|} |dk r| ||dk r| ||||tj krt| d rd | _ |dkrtj n|| _ |dk r| |n| |dk rttd ds td | ||| |tj kr6|d n |d dS)a Configure network encryption and authentication options. Enables SSL/TLS support. :param str ca_certs: a string path to the Certificate Authority certificate files that are to be treated as trusted by this client. If this is the only option given then the client will operate in a similar manner to a web browser. That is to say it will require the broker to have a certificate signed by the Certificate Authorities in ca_certs and will communicate using TLS v1,2, but will not attempt any form of authentication. This provides basic network encryption but may not be sufficient depending on how the broker is configured. By default, on Python 2.7.9+ or 3.4+, the default certification authority of the system is used. On older Python version this parameter is mandatory. :param str certfile: PEM encoded client certificate filename. Used with keyfile for client TLS based authentication. Support for this feature is broker dependent. Note that if the files in encrypted and needs a password to decrypt it, then this can be passed using the keyfile_password argument - you should take precautions to ensure that your password is not hard coded into your program by loading the password from a file for example. If you do not provide keyfile_password, the password will be requested to be typed in at a terminal window. :param str keyfile: PEM encoded client private keys filename. Used with certfile for client TLS based authentication. Support for this feature is broker dependent. Note that if the files in encrypted and needs a password to decrypt it, then this can be passed using the keyfile_password argument - you should take precautions to ensure that your password is not hard coded into your program by loading the password from a file for example. If you do not provide keyfile_password, the password will be requested to be typed in at a terminal window. :param cert_reqs: the certificate requirements that the client imposes on the broker to be changed. By default this is ssl.CERT_REQUIRED, which means that the broker must provide a certificate. See the ssl pydoc for more information on this parameter. :param tls_version: the version of the SSL/TLS protocol used to be specified. By default TLS v1.2 is used. Previous versions are allowed but not recommended due to possible security problems. :param str ciphers: encryption ciphers that are allowed for this connection, or None to use the defaults. See the ssl pydoc for more information. Must be called before `connect()`, `connect_async()` or `connect_srv()`.NzThis platform has no SSL/TLS. SSLContextz@Python 2.7.9 and 3.2 are the minimum supported versions for TLS.load_default_certszca_certs must not be None.PROTOCOL_TLS_CLIENT PROTOCOL_TLSrFHAS_ALPNz#SSL library has no support for ALPNT)rurrrPROTOCOL_TLSv1_2rr set_ciphersload_cert_chain CERT_NONEr CERT_REQUIRED verify_modeload_verify_locationsrgetattrset_alpn_protocolsrtls_insecure_set) r=rrrrrrrrrr1r1r2tls_setsB5           zClient.tls_setcCs2|jdkrtd||_t|jdr.| |j_dS)apConfigure verification of the server hostname in the server certificate. If value is set to true, it is impossible to guarantee that the host you are connecting to is not impersonating your server. This can be useful in initial server testing, but makes it possible for a malicious third party to impersonate your server through DNS spoofing, for example. Do not use this function in a real system. Setting value to true means there is no point using encryption. Must be called before `connect()` and after either `tls_set()` or `tls_set_context()`.Nz9Must configure SSL context before using tls_insecure_set.r)rMrrNrrrr1r1r2r s  zClient.tls_insecure_set) proxy_argsr;cKs0tdkrtdn||s&tdn||_dS)aConfigure proxying of MQTT connection. Enables support for SOCKS or HTTP proxies. Proxying is done through the PySocks library. Brief descriptions of the proxy_args parameters are below; see the PySocks docs for more info. (Required) :param proxy_type: One of {socks.HTTP, socks.SOCKS4, or socks.SOCKS5} :param proxy_addr: IP address or DNS name of proxy server (Optional) :param proxy_port: (int) port number of the proxy server. If not provided, the PySocks package default value will be utilized, which differs by proxy_type. :param proxy_rdns: boolean indicating whether proxy lookup should be performed remotely (True, default) or locally (False) :param proxy_username: username for SOCKS5 proxy, or userid for SOCKS4 proxy :param proxy_password: password for SOCKS5 proxy Example:: mqttc.proxy_set(proxy_type=socks.HTTP, proxy_addr='1.2.3.4', proxy_port=4231) Nz,PySocks must be installed for proxy support.z)proxy_type and/or proxy_addr are invalid.)socksr_proxy_is_validr@)r=rr1r1r2 proxy_set;s    zClient.proxy_set)rqr;cCs*|dkr |jdk rdStt}||_dS)a Enables a logger to send log messages to :param logging.Logger logger: if specified, that ``logging.Logger`` object will be used, otherwise one will be created automatically. See `disable_logger` to undo this action. N)rOlogging getLoggerr-rq)r=rqr1r1r2 enable_logger[s   zClient.enable_loggercCs d|_dS)zu Disable logging using standard python logging package. This has no effect on the `on_log` callback. NrprCr1r1r2disable_loggerkszClient.disable_loggerrrrrMzProperties | Noner)rdrrh bind_address bind_port clean_startrr;c CsL|jtkrd|_n|tkr"td|r.td|||||||||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 rr`rNr connect_async reconnectr=rdrrhrrrrr1r1r2rqs  zClient.connect)domainrhrrrrr;c Cs6tdkrtd|dkr6t}||ddd}zdd|}|jrRd|}g}tj|tj j D].} | j dd} | | | j| j| jfqhWnDtjjtjjtjjfk r} ztd || W5d} ~ XYnX|D]D} | \} } }}z|| | |||||WStk r&YqXqtd dS) 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_DNSrrgetfqdnfindrLdnsresolverqueryZ rdatatypeZSRVtargetZto_textrrpriorityweightZNXDOMAINZNoAnswerZ NoNameserversr Exception)r=rrhrrrrZrrZanswersZansweraddrr|rdrpriorr1r1r2 connect_srvs4   "" zClient.connect_srvcCsV|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) rrrr,r-rdrrhr>r?rr4MQTT_CS_CONNECT_ASYNCrr1r1r2rs zClient.connect_asyncrr) min_delay max_delayr;c Cs(|j||_||_d|_W5QRXdS)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)rHr&r'r()r=rrr1r1r2reconnect_delay_setszClient.reconnect_delay_setc Csxt|jdkrtd|jdkr(tdddgddtdddd|_d|_tj|_ | |j D]B}|dd @t kr`|d dkr`|d d k r`t |d _|d q`|j |jt|_t|_W5QRX||j |j}W5QRX|rDz|||jWn<tk rB}z|td ||js2W5d }~XYnX||_|jdd|_ |!|j|"|j#S)zdReconnect the client after a disconnect. Can only be called after connect()/connect_async().rrergrrrrr#r5r8Nz&Caught exception in on_pre_connect: %sF)$rr<rr=r(r r*rZMQTT_CS_CONNECTINGr-rr#PUBLISHrdrrclearrErr$r%_messages_reconnect_resetrDon_pre_connectr rrz MQTT_LOG_ERRra_create_socketr rJrP_call_socket_open _send_connectr)r=Zpktrr|r1r1r2r sV   (     zClient.reconnect?rcCs8|jdks|jdkr.|jddt\|_|_||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)r r rbr_loop)r=rr1r1r2loopFs z Client.loopcCs|dkrtd|r"|jg}ng}d}t|jdr@|j}|dkrLd}|jdkr`|jg}n |j|jg}zt||g|}Wntk r|jt j t j fkrt j |_t jYStk r|jt j t j fkrt j |_t jYStk rt jYSX|j|dks|dkr:|}|s6|jdkr:|S|jr|j|dkr|dd|jz|jdWntk rYnX|j|dkr|}|s|jdkr|S|S)NrzInvalid timeout.rpendingri')r want_writer rrr selectrr-rMQTT_CS_DISCONNECTINGMQTT_CS_DISCONNECTEDMQTT_CS_CONNECTION_LOSTrrdrrj loop_readinsertr>r loop_write loop_misc)r=rZwlistZ pending_bytesZrlistZsocklistrr1r1r2resP         z Client._loop PayloadTyper)rrr5rrr;c Cs*|jtkr&|dkst|dkr&td|d}|||dksJ|dkrRtdt|}t|dkrntd|}|dkrt|} | |||||d | |} | | _ | St ||} t | _ || _|| _|| _d | _|| _|j@|jdkrt|j|jkrtj| j_ | jW5QRS||jkrDtj| j_ | jW5QRS| |j| j<|jdksj|j|jkr|jd 7_|d krt| _n|dkrt| _| | j|| j| j| j| j| j| j} | tjkr|jd 8_t | _| | j_ | jW5QRSt!| _tj"| j_ | jW5QRSW5QRXdS) 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.ir\Fr)#r rrrr_raise_for_invalid_topicr _mid_generater _send_publishrrWrrrr5rrrrFr3r/rrlr8r4r1r2mqtt_ms_wait_for_pubackrmqtt_ms_wait_for_pubrecramqtt_ms_publishmqtt_ms_queuedr]) r=rrr5rrZ topic_bytesZ local_payload local_midr8rmessager1r1r2publishsv-              zClient.publish)rjrkr;cCs:|dkr dn|d|_t|tr0|d|_n||_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)rrrprZr)r=rjrkr1r1r2username_pw_sets zClient.username_pw_setcCs t|_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_BRIDGErrCr1r1r2enable_bridge_mode1szClient.enable_bridge_modecCs(|jtjkp&|jtjtjfko&|jdkS)zX Return true if the connection is closed (and not trying to be opened). N)r-rr,rrr rCr1r1r2rfAs zClient._connection_closedcCs |jtjkS)z~Returns the current status of the connection True if connection exists False if connection is closed )r-rMQTT_CS_CONNECTEDrCr1r1r2 is_connectedIszClient.is_connectedzReasonCode | None) reasoncoderr;cCs*|jdkrtj|_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. N)r rrr-rar_send_disconnect)r=rrr1r1r2 disconnectQs zClient.disconnectzqstr | tuple[str, int] | tuple[str, SubscribeOptions] | list[tuple[str, int]] | list[tuple[str, SubscribeOptions]]zSubscribeOptions | Nonez tuple[MQTTErrorCode, int | None])rr5optionsrr;c s>d}t|tr<jtkr4|\}}t|ts.zInvalid subscription filter.F)rptupler rrrr6rZrrlistranyr ra_send_subscribe) r=rr5rrZtopic_qos_listtoqr1rCr2 subscribefsfV             (  zClient.subscribezstr | list[str])rrr;cCsd}|dkrtdt|ttfrDt|dkr6td|dg}nJt|trg}|D]6}t|dkstt|ttfs|td||dqV|dkrtd|jdkrt j 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. NrrrrF) rrpr6rZrrrrr rra_send_unsubscribe)r=rrZ topic_listrr1r1r2 unsubscribes$    zClient.unsubscribe) max_packetsr;cCs|jdkrtjSt|jt|j}|dkr0d}td|D]J}|jdkrRtjS|}|dkrp||S|tj kr:tj Sq:tj 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) r rrarr/r0r _packet_read_loop_rc_handlerr])r=rrrr1r1r2r"s     zClient.loop_readcCsr|jdkrtjSz@|}|tjkr.tjW&S|dkrD| |WStjWSW5|rd|n|XdS)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) r rrarrxr _packet_writerr]rr=rr1r1r2r;s    zClient.loop_writecCst|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)rr#rCr1r1r2rVszClient.want_writecCs|jdkrtjSt}||jdkr||j|jkr||jt j t j fkrbt j |_tj }nt j |_tj}|jd|dtjStj 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)r rrar_check_keepaliver*rrr-rrrr]rrm_do_on_disconnectrd)r=nowrr1r1r2r\s" zClient.loop_misc)inflightr;cCs ||_dS)z~Set the maximum number of messages with QoS>0 that can be part way through their network flow at once. Defaults to 20.N)rl)r=rr1r1r2max_inflight_messages_set|sz Client.max_inflight_messages_set) queue_sizer;cCst|tstd||_|S)z\Set the maximum number of messages in the outgoing message queue. 0 means unlimited.zInvalid type of queue size.)rpr"rrm)r=rr1r1r2max_queued_messages_sets zClient.max_queued_messages_set)rr;cCs ||_dS)zESet the user data variable passed to callbacks. May be any data type.Nr )r=rr1r1r2 user_data_setszClient.user_data_setcCs|jS)zEGet the user data variable passed to callbacks. May be any data type.rrCr1r1r2 user_data_getszClient.user_data_getcCs||dkst|dkrtd|dks,|dkr4td|rJt|tsJtdt||_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()`. NrrrrzDThe properties argument must be an instance of the Properties class.Tr) rrrprrr8r6rr7r9r:r5)r=rrr5rrr1r1r2will_sets  zClient.will_setcCs"d|_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.FrrN)r6r7r8r9r:rCr1r1r2 will_clears zClient.will_clearzSocketLike | NonecCs|jS)z0Return the socket or ssl object for this client.)r rCr1r1r2rsz Client.socket)rretry_first_connectionr;cs4drjjdkrqjjtjkrjz Wqhtk rb|sJtd YqhXqqjqr0t j }|t j kr |}jdkrvt jdkrvt jdkrvt j}dqvddfdd }|s܈jsdqj |rdqjz Wqjtk r,tdYqjXqj|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, retryingrFrFrBcs$jtjtjfkp"dkp"jdkS)NFT)r-rrrrKr1runr=r1r2 should_exit s z(Client.loop_forever..should_exit)rKr-rrrOSError_handle_on_connect_failrzr{_reconnect_waitrr]rrr#r/r^r))r=rrrrr1rr2 loop_foreversV           zClient.loop_forevercCsZ|jdk rtjSt\|_|_d|_tj|j d|j d|_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-)rnameT)rJrr`rr r rKrThread _thread_mainrrdaemonstartr]rCr1r1r2 loop_start s  zClient.loop_startcCs4|jdkrtjSd|_t|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)rJrr`rKrcurrent_threadrr]rCr1r1r2 loop_stop/ s   zClient.loop_stopcCs|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. )rrCr1r1r2r@ szClient.callback_api_versionzCallbackOnLog | NonecCs|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) rQrCr1r1r2on_logJ sz Client.on_logfuncr;cCs ||_dSr<r'r=r*r1r1r2r(_ sz(Callable[[CallbackOnLog], CallbackOnLog]csdddfdd }|S)N CallbackOnLogr)cs |_|Sr<)r(r*rCr1r2 decoratord sz&Client.log_callback..decoratorr1r=r.r1rCr2 log_callbackc szClient.log_callbackzCallbackOnPreConnect | NonecCs|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) )rRrCr1r1r2ri szClient.on_pre_connectc Cs|j ||_W5QRXdSr<)rDrRr+r1r1r2r{ sz6Callable[[CallbackOnPreConnect], CallbackOnPreConnect]csdddfdd }|S)NCallbackOnPreConnectr)cs |_|Sr<)rr-rCr1r2r. sz.Client.pre_connect_callback..decoratorr1r/r1rCr2pre_connect_callback szClient.pre_connect_callbackzCallbackOnConnect | NonecCs|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) )rSrCr1r1r2 on_connect s3zClient.on_connectc Cs|j ||_W5QRXdSr<)rDrSr+r1r1r2r3 sz0Callable[[CallbackOnConnect], CallbackOnConnect]csdddfdd }|S)NCallbackOnConnectr)cs |_|Sr<)r3r-rCr1r2r. sz*Client.connect_callback..decoratorr1r/r1rCr2connect_callback szClient.connect_callbackzCallbackOnConnectFail | NonecCs|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) )rTrCr1r1r2on_connect_fail szClient.on_connect_failc Cs|j ||_W5QRXdSr<)rDrTr+r1r1r2r6 sz8Callable[[CallbackOnConnectFail], CallbackOnConnectFail]csdddfdd }|S)NCallbackOnConnectFailr)cs |_|Sr<)r6r-rCr1r2r. sz/Client.connect_fail_callback..decoratorr1r/r1rCr2connect_fail_callback szClient.connect_fail_callbackzCallbackOnSubscribe | NonecCs|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) )rUrCr1r1r2 on_subscribe s#zClient.on_subscribec Cs|j ||_W5QRXdSr<)rDrUr+r1r1r2r9 sz4Callable[[CallbackOnSubscribe], CallbackOnSubscribe]csdddfdd }|S)NCallbackOnSubscriber)cs |_|Sr<)r9r-rCr1r2r. sz,Client.subscribe_callback..decoratorr1r/r1rCr2subscribe_callback szClient.subscribe_callbackzCallbackOnMessage | NonecCs|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) )rVrCr1r1r2 on_message szClient.on_messagec Cs|j ||_W5QRXdSr<)rDrVr+r1r1r2r</ sz0Callable[[CallbackOnMessage], CallbackOnMessage]csdddfdd }|S)NCallbackOnMessager)cs |_|Sr<)r<r-rCr1r2r.7 sz*Client.message_callback..decoratorr1r/r1rCr2message_callback4 szClient.message_callbackzCallbackOnPublish | NonecCs|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) )rWrCr1r1r2 on_publish< s)zClient.on_publishc Cs|j ||_W5QRXdSr<)rDrWr+r1r1r2r?g sz0Callable[[CallbackOnPublish], CallbackOnPublish]csdddfdd }|S)NCallbackOnPublishr)cs |_|Sr<)r?r-rCr1r2r.o sz*Client.publish_callback..decoratorr1r/r1rCr2publish_callbackl szClient.publish_callbackzCallbackOnUnsubscribe | NonecCs|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) )rXrCr1r1r2on_unsubscribet s$zClient.on_unsubscribec Cs|j ||_W5QRXdSr<)rDrXr+r1r1r2rB sz8Callable[[CallbackOnUnsubscribe], CallbackOnUnsubscribe]csdddfdd }|S)NCallbackOnUnsubscriber)cs |_|Sr<)rBr-rCr1r2r. sz.Client.unsubscribe_callback..decoratorr1r/r1rCr2unsubscribe_callback szClient.unsubscribe_callbackzCallbackOnDisconnect | NonecCs|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) )rYrCr1r1r2 on_disconnect s&zClient.on_disconnectc Cs|j ||_W5QRXdSr<)rDrYr+r1r1r2rE sz6Callable[[CallbackOnDisconnect], CallbackOnDisconnect]csdddfdd }|S)NCallbackOnDisconnectr)cs |_|Sr<)rEr-rCr1r2r. sz-Client.disconnect_callback..decoratorr1r/r1rCr2disconnect_callback szClient.disconnect_callbackzCallbackOnSocket | NonecCs|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) )rZrCr1r1r2on_socket_open szClient.on_socket_openc Cs|j ||_W5QRXdSr<)rDrZr+r1r1r2rH sz.Callable[[CallbackOnSocket], CallbackOnSocket]csdddfdd }|S)NCallbackOnSocketr)cs |_|Sr<)rHr-rCr1r2r. sz.Client.socket_open_callback..decoratorr1r/r1rCr2socket_open_callback szClient.socket_open_callbackr9)rr;c Cs~|j |j}W5QRX|rz|jRz|||j|Wn8tk rn}z|td||js^W5d}~XYnXW5QRXdS)z9Call the socket_open callback with the just-opened socketz&Caught exception in on_socket_open: %sN)rDrHrBr rrzrra)r=rrHr|r1r1r2r szClient._call_socket_opencCs|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) )r[rCr1r1r2on_socket_close szClient.on_socket_closec Cs|j ||_W5QRXdSr<)rDr[r+r1r1r2rK scsdddfdd }|S)NrIr)cs |_|Sr<)rKr-rCr1r2r.& sz/Client.socket_close_callback..decoratorr1r/r1rCr2socket_close_callback# szClient.socket_close_callbackc Cs~|j |j}W5QRX|rz|jRz|||j|Wn8tk rn}z|td||js^W5d}~XYnXW5QRXdS)zACall the socket_close callback with the about-to-be-closed socketz'Caught exception in on_socket_close: %sN)rDrKrBr rrzrra)r=rrKr|r1r1r2r+ szClient._call_socket_closecCs|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) r\rCr1r1r2on_socket_register_write: szClient.on_socket_register_writec Cs|j ||_W5QRXdSr<)rDr\r+r1r1r2rNM scsdddfdd }|S)NrIr)cs |_|Sr<rMr-rCr1r2r.U sz8Client.socket_register_write_callback..decoratorr1r/r1rCr2socket_register_write_callbackR sz%Client.socket_register_write_callbackc Cs|jr |jrdSd|_|j |j}W5QRX|rz|||j|jWn8tk r~}z|td||jsnW5d}~XYnXdS)zBCall the socket_register_write callback with the unwritable socketNTz0Caught exception in on_socket_register_write: %s) r rPrDrNr rrzrra)r=rNr|r1r1r2rxZ s( z"Client._call_socket_register_writecCs|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) r]rCr1r1r2on_socket_unregister_writel sz!Client.on_socket_unregister_writec Cs|j ||_W5QRXdSr<)rDr]r+r1r1r2rQ scsdddfdd }|S)NrIr)cs |_|Sr<rPr-rCr1r2r. sz:Client.socket_unregister_write_callback..decoratorr1r/r1rCr2 socket_unregister_write_callback sz'Client.socket_unregister_write_callbackc Cs|p|j}|r|jsdSd|_|j |j}W5QRX|rz|||j|Wn8tk r}z|td||jstW5d}~XYnXdS)zBCall the socket_unregister_write callback with the writable socketNFz2Caught exception in on_socket_unregister_write: %s) r rPrDrQr rrzrra)r=rrQr|r1r1r2r s"  z$Client._call_socket_unregister_writer=)rcallbackr;c Cs8|dks|dkrtd|j||j|<W5QRXdS)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.)rrDr;)r=rrSr1r1r2message_callback_add szClient.message_callback_add)rr;csdddfdd }|S)Nr=r)cs||Sr<)rTr-r=rr1r2r. s z(Client.topic_callback..decoratorr1)r=rr.r1rUr2topic_callback szClient.topic_callbackc CsH|dkrtd|j(z |j|=Wntk r8YnXW5QRXdS)zVRemove a message callback previously registered with `message_callback_add()`.Nzsub must defined.)rrDr;KeyErrorrUr1r1r2message_callback_remove s zClient.message_callback_remover~cCsN|r:||jtjtjfkr,tj|_tj}|jd|d|tkrJtj |_|S)NFr) rr-rrrrr]r rdrrr1r1r2r szClient._loop_rc_handlec Cs"|jddkrz|d}Wntk r6tjYStk rn}z|td|tjWYSd}~XYnZt k r}z|td|tjWYSd}~XYn"Xt |dkrtjS|d|jd<|jddkrz|d}WnVtk rtjYSt k r<}z|td|tjWYSd}~XYn|Xt |dkrRtjS|d}|jd |t |jddkrtj S|jd |d @|jd 7<|jd d |jd <|d @dkrؐqqd|jd<|jd |jd <d}|jd dkrz||jd }WnVtk r(tjYSt k rb}z|td|tjWYSd}~XYn>Xt |dkrxtjS|jd t |8<|jd|7<|d8}|dkr|j t|_W5QRXtjSqd|jd<|}ddgddtdddd|_|j t|_W5QRX|S)Nr#rrztimeout on socket: %sfailed to receive on socket: %sr$r%r'r&r*dr)r+rr)r r}rrr TimeoutErrorrzrrdrrrr_rErr$_packet_handler()r=r#r|byteZ byte_valuecountdatarr1r1r2r s           zClient._packet_readc Csz|j}Wntk r(tjYSXz||d|dd}Wnttfk rr|j|tjYSt k r|j|tj YSt k r}z(|j|| t d|tjWYSd}~XYnX|dkr|d|8<|d|7<|ddkr|dd@tkr"|ddkr"|j |j}W5QRX|r|jzt|jtjkrtt|}|||j|d nD|jtjkrtt|}|||j|d ttjttjntd Wn<t k r }z| t d ||j!sW5d}~XYnXW5QRX|d "|dd@t#kr|j$t%|_&W5QRX|j'd tjd|(|j)t*j+kr|t*j,|_)tjSn |j|qqq|j$t%|_&W5QRXtjS)Nr)r+rYrr*r#rr5r4r"Caught exception in on_publish: %sr8Fr)-r#popleftrrr]rryr appendleftrrrrzrrdrrDr?rBrrrr CallbackOnPublish_v1r VERSION2CallbackOnPublish_v2rrPUBACKrrrrarrrErr%r rr-rrr)r=r)Z write_lengthr|r?r1r1r2rX s            zClient._packet_writer)levelfmtargsr;cGsh|jdk r>||}z|||j||Wntk r<YnX|jdk rdt|}|jj||f|dSr<)r(r rrO LOGGING_LEVELlog)r=rjrkrlr~Z level_stdr1r1r2rz s  zClient._easy_logc Cs|jdkrdSt}|j|j}|j}W5QRX|jdk r |||jks\|||jkr |jtjkr|j dkrz | Wn,t k r| |j dtjdYn X|j||_||_W5QRXn>| |jtjtjfkrtj|_tj}ntj}|j d|ddS)NrFr)rrrEr%r$r r-rrr* _send_pingreqrrr rrdrrr]rm)r=r Z last_msg_outZ last_msg_inrr1r1r2r  s8 *  zClient._check_keepalivec CsB|j2|jd7_|jdkr&d|_|jW5QRSQRXdS)Nr)rIr+rCr1r1r2r s  zClient._mid_generate)rr;cCs0d|ksd|krtdt|dkr,tddS)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)rr1r1r2r s zClient._raise_for_invalid_topiccCsHt|dks8t|dks8tdd|dDs8d|kr>tjStjSdS)Nrrscss*|]"}t|dkrd|kp d|kVqdS)rrqrrN)r)rpr1r1r2r s z4Client._filter_wildcard_len_check../s#/)rrsplitrr`r])rr1r1r2r sz!Client._filter_wildcard_len_checkcCs,|td|t}|tjkr(t|_|S)NzSending PINGREQ)rzr{_send_simple_commandPINGREQrr]rr*rr1r1r2ro s    zClient._send_pingreqcCs|td|tS)NzSending PINGRESP)rzr{rwPINGRESPrCr1r1r2_send_pingresp s zClient._send_pingresp)r4r;cCs|td||t|dS)NzSending PUBACK (Mid: %d)F)rzr{_send_command_with_midrirr1r1r2 _send_puback szClient._send_pubackcCs|td||t|dS)NzSending PUBCOMP (Mid: %d)F)rzr{r{PUBCOMPrr1r1r2 _send_pubcomp szClient._send_pubcompr()r)r'r;cCsJg}|d}|d}|dkr$|dO}|||||dkr|SqdS)Nr\r)r)r=r)r'Zremaining_bytesr`r1r1r2_pack_remaining_length s  zClient._pack_remaining_lengthz bytes | str)r)rbr;cCs,t|}|tdt|||dS)N!H)rrstructpackr)r=r)rbr1r1r2 _pack_str16" szClient._pack_str16rrr7) r4rrr5rrr8rr;c  Cst|tstd|r,t|ttfs,td|jdkrB|d>B|B} t} | | t |} dt || } | dkr|j t kr| t d||||||n| t d|||||n>|j t kr| t d ||||||| n| t d |||||| |dkr| d7} |j t krD|dkr0d } n|} | t | 7} || | || ||dkrx| td ||j t kr| | | ||t| |||S) Nztopic must be bytes, not strzpayload must be bytes if setrrLrrzHSending 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)rpr6rr(r rrarrrr rrzr{rrrrr _packet_queue)r=r4rrr5rrr8rr#r)Z payloadlenr'Zpacked_propertiesr1r1r2r' s               zClient._send_publishcCs|td||t|dS)NzSending PUBREC (Mid: %d)F)rzr{r{PUBRECrr1r1r2 _send_pubrecv szClient._send_pubreccCs |td||tdB|dS)NzSending PUBREL (Mid: %d)rF)rzr{r{PUBRELrr1r1r2 _send_pubrelz szClient._send_pubrel)r#r4rr;cCs0|r |dO}d}td|||}||||dS)Nrz!BBHrrrr)r=r#r4rr'r)r1r1r2r{~ s zClient._send_command_with_mid)r#r;cCs"d}td||}|||ddS)Nr!BBr)r=r#r'r)r1r1r2rw szClient._send_simple_command)rhr;c Cs4t|j}|tkrdnd}dt|ddddt|j}d}|jtkr||jdkrb|dO}q|jtkr|jr|dO}n|j r|dO}|j r|dt|j dt|j 7}|d|j d@d>B|jd@d >BO}|jdk r |dt|j7}|d O}|jdk r |d O}|dt|j7}|jtkr|jdkr>d }n |j}|t|7}|j r|jdkrnd }n |j}|t|7}t}t} | ||jtkr|d O}|| || td t|dt||||||jtkr| |7} || |j|j r<|jtkr | |7} || |j || |j |jdk rp|| |j|jdk rp|| |j||_|jtkr|td|d @d?|d @d?|d@d ?|d@d?|d@d?|d@d?||j|j nN|td|d @d?|d @d?|d@d ?|d@d?|d@d?|d@d?||j | || ddS)NsMQTTsMQIsdprrrTrZrLr\@rrZsBBHzQSending 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 MQTTv311rrrrrNr`rr6r7r8r9r:rrr4rr5CONNECTr(rrrrrrrrrzr{r) r=rhZ proto_verrr' connect_flagsZpacked_connect_propertiesZpacked_will_propertiesr#r)r1r1r2r s                                    zClient._send_connectcCs|jtkr|td||n |tdd}t}t}|||jtkr|dk sZ|dk r|dkrrttd?dd}|d7}|dk r|}|t |7}| |||jtkr|dk r||7}|dk r||7}| ||ddS)Nz.Sending DISCONNECT reasonCode=%s properties=%szSending DISCONNECTrrZ identifierr) r rrzr{rr(rrrrrr)r=rrr'r#r)Z packed_propsr1r1r2r s2        zClient._send_disconnectz.Sequence[tuple[bytes, SubscribeOptions | int]]ztuple[MQTTErrorCode, int])rtopicsrr;c Cs d}|jtkr0|dkrd}n|}|t|7}|D]\}}|dt|d7}q4t|d>BdB}t} | ||| ||} | t d| |jtkr| |7} |D]6\}} | | ||jtkr| | 7} q| | q| t d|| |||| | d| fS)NrrrrLrzSending SUBSCRIBE (d%d, m%d) %s)r rrr SUBSCRIBEr(rrrrrrrzr{r) r=rrrr'Zpacked_subscribe_propertiesrrr#r)rrr1r1r2rs:          zClient._send_subscribez list[bytes]c Csd}|jtkr0|dkrd}n|}|t|7}|D]}|dt|7}q4t|d>BdB}t}||||||} | t d| |jtkr||7}|D]}| ||q|jtkr| t d|| ||n| t d|| ||||| d| fS)NrrrLrz$Sending UNSUBSCRIBE (d%d, m%d) %s %sz!Sending UNSUBSCRIBE (d%d, m%d) %sr)r rrr UNSUBSCRIBEr(rrrrrrrzr{r) r=rrrr'Zpacked_unsubscribe_propertiesrr#r)rr1r1r2rFsF       zClient._send_unsubscribecCs,|jtkr"|jtkr|jS|jSn|jSdSr<)r rrrNr`rrCr1r1r2_check_clean_sessionws   zClient._check_clean_sessionc Cs|jd|_|jD]}d|_|jdks8|j|jkr|jdkrJt|_q|jdkrl|jt krdd|_ t|_q|jdkr| r|jtkrd|_ t|_q|jt krt |_q|jtkrd|_ t|_qt|_qW5QRXdS)NrrTr)rFr2r/valuesrr1r5rrrrrmqtt_ms_wait_for_pubcompmqtt_ms_resend_pubrelrrr=mr1r1r2_messages_reconnect_reset_outs,       z$Client._messages_reconnect_reset_outc Csf|jV|r(t|_W5QRdS|jD]$}d|_|jdkr2|j|j q2q2W5QRXdS)Nrr) rGrr!r.r0rrr5popr4rr1r1r2_messages_reconnect_reset_ins  z#Client._messages_reconnect_reset_incCs||dSr<)rrrCr1r1r2rsz Client._messages_reconnect_reset)r#r)r4r5r8r;cCs|||dt|||d}|j||jdk rTz|jtWntk rRYnX|jdkr|jdkr|j dr|j | S| tjS)Nr)r#r4r5r+r*r)r8F)rr#rr r@ sockpair_datarrJr\rBacquirereleaserrxrr])r=r#r)r4r5r8Zmpktr1r1r2rs(     zClient._packet_queuecCs|jdd@}|tkr|S|tkr.|S|tkr@|dS|tkrR|dS|tkrb| S|t krr| S|t kr| S|tkr|S|tkr|tjS|tkr|S|tkr|jtkr|tjS|td|tjSdS)Nr#rrir}zError: Unrecognised command %s)r rx_handle_pingreqry_handle_pingrespri_handle_pubackcompr}r_handle_publishr_handle_pubrecr_handle_pubrelr|_handle_connackSUBACK_handle_subackrr]UNSUBACK_handle_unsubackrr r_handle_disconnectrzrr_)r=cmdr1r1r2r_s6  zClient._packet_handlecCs(|jddkrtjS|td|S)Nr'rzReceived PINGREQ)r rr_rzr{rzrCr1r1r2rs zClient._handle_pingreqcCs,|jddkrtjSd|_|tdtjS)Nr'rzReceived PINGRESP)r rr_r*rzr{r]rCr1r1r2rs  zClient._handle_pingrespc Cs^|jtkr |jddkr4tjSn|jddkr4tjS|jtkrtd|jddd\}}|dkrzttd?dd}d}qttd?|d }t td?}||jdddn"td|jd\}}t |}d}|jt krd|t kr|j stS|td ||t|_|S|tkrd|jd krd|j s2tS|td ||ttjd dd|_|S|dkr|tj|_d|_|jtkr|td|||n|td||d|_|j |j}W5QRX|ri}|d@|d<|j z|j!t"j#kr>|jtkr"t$t%|}|||j&|||nt$t'|}|||j&||nZ|j!t"j(krt$t)|}t*|ddkd}|dkr|t t+j}|||j&|||nt,dWn<t-k r}z|t.d||j/sƂW5d}~XYnXW5QRX|dkr:tj0} |j16|j23D]"} t4| _5| j6t7kr<|8t0W5QRS| j9dkr|j 2|j:| j;| j<d| j=| j9| j>| j?| j@d} W5QRX| tj0kr | W5QRSnv| j9dkr6| j6tAkr |jBd7_BtC| _6|j 2|j:| j;| j<d| j=| j9| j>| j?| j@d} W5QRX| tj0kr | W5QRSn| j9dkr | j6tAkr|jBd7_BtD| _6|j 2|j:| j;| j<d| j=| j9| j>| j?| j@d} W5QRX| tj0kr | W5QRSn^| j6tEkr |jBd7_BtF| _6|j |G| j;} W5QRX| tj0kr | W5QRS|8qW5QRX| S|dkrT|dkrTtjHStjSdS)Nr'rrr)rrZrz)ZaNamerz=Received CONNACK (%s, %s), attempting downgrade to MQTT v3.1.rz:Received CONNACK (%s, %s), attempting to use non-empty CIDrrrrz'Received CONNACK (%s, %s) properties=%szReceived CONNACK (%s, %s)Fzsession present)rQrz"Caught exception in on_connect: %srrr)Ir rr rr_runpackrr|rr}rrrr)rzr{rrrsrrrrr"rrrr-r(r`rDr3rBrrrr CallbackOnConnect_v1_mqtt5r CallbackOnConnect_v1_mqtt3rgCallbackOnConnect_v2rPrrrrrar]rFr/rrrrrrr5rr4rrrrrrr2rrrrrrb) r=flagsresultreasonrr3Z flags_dictrr|rrr1r1r2rsX                                 zClient._handle_connackcCstd?}d}}|jddkrht|}||jd|jddkrht|}||jddd\}}|td||||jdt j ||d dS) NrZr'rr)rLrzReceived DISCONNECT %s %sT)r r rr) rr rrrrzr{rr rr])r= packet_type reasonCoderprops props_lenr1r1r2rs*zClient._handle_disconnectc Cs|tddt|jddd}t||jd\}}|jtkrxtt d?}||\}}dd||dD}n8d d t|}t||}d d|D}tt d?}|j |j } W5QRX| r|j z|j tjkr,|jtkrtt| } | ||j|||ntt| } | ||j||n4|j tjkrXtt| } | ||j|||ntd Wn<tk r} z|td | |jsW5d} ~ XYnXW5QRXdS)NzReceived SUBACKrr)rrrZcSsg|]}ttd?|dqSrZrrrrcr1r1r2 sz)Client._handle_suback..!BcSsg|]}ttd?|dqSrrrr1r1r2rsrz$Caught exception in on_subscribe: %s)rzr{rr rrr rrrrDr9rBrrrr CallbackOnSubscribe_v1_mqtt5r CallbackOnSubscribe_v1_mqtt3rgCallbackOnSubscribe_v2rrrra) r= pack_formatr4r)rrr reasoncodesZ granted_qosr9r|r1r1r2rsf          zClient._handle_subackc CsT|jd}t}|d@d?dk|_|d@d?|_|d@dk|_dt|jdd d }t||jd\}}d |d t||d }t||\}}|jt krt|dkrt j Sz| d }Wnt k rd |}YnX||_|jdkrdt|d d }t||\|_}|jt krPttd?|_|j|\}} || d}||_|jt kr|td|j|j|j|j||jt|j n&|td|j|j|j|j|t|jt|_|jdkr||t jS|jdkr |||jrt jS||jSnF|jd krJ||j} t|_|j||j |j<W5QRX| St j SdS)Nr#rrLrrrrr)rrrrzTOPIC WITH INVALID UTF-8: rZzKReceived PUBLISH (d%d, q%d, r%d, m%d), '%s', properties=%s, ... (%d bytes)z`). only useful in QoS>=1 and ``manual_ack=True`` (option of `Client`) rr)rr|r~rr])r=r4r5r1r1r2ackEs   z Client.ack)onr;cCs ||_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)r=rr1r1r2manual_ack_setRszClient.manual_ack_setc Csp|jtkr |jddkr4tjSn|jddkr4tjStd|jddd\}|jtkr|jddkrttd?}||jddd|jddkrt td?}||jddd\}}| t d||j x||j krJ|j |}|||jd8_|jd krJ|j|}W5QRX|tjkrJ|W5QRSW5QRX|jrbtjS||SdS) Nr'rrr)rZrLzReceived PUBREL (Mid: %d)rr)r rr rr_rrrrrrzr{rGr0rrr2r1rF_update_inflightr]rr~)r=r4rrrrrrr1r1r2r[s:         zClient._handle_pubrelc Cs|jD]}|j|jkr|jdkr|jtkr|jd7_|jdkrNt|_n|jdkr^t|_|j |j |j d|j |j|j|j|jd}|tjkr|Sq tjSq tjS)Nrrrrr)r/rr2r1r5rrrrrr4rrrrrrrr])r=rrr1r1r2rs*       zClient._update_inflightc Cs"|jtkr |jddkr4tjSn|jddkr4tjStd|jddd\}|jtkr|jddkrttd?}||jddd|jddkrt td?}||jddd\}}| t d||j @||j kr|j |}t|_t|_||W5QRSW5QRXtjS)Nr'rrr)rZrLzReceived PUBREC (Mid: %d))r rr rr_rrrrrrzr{rFr/rrrrrr])r=r4rrrrmsgr1r1r2rs.       zClient._handle_pubrecc Cs|jtkr |jddkr4tjSn|jddkr4tjStd|jddd\}|jtkr|jddd}ttd?}||\}}dd||dD}ng}ttd?}| t d||j |j }W5QRX|r|j z|jtjkrP|jtkr6tt|}|}t|d kr"|d }|||j|||ntt|}|||j|nH|jtjkrtt|}|dkr|ttj}|||j|||ntd Wn<tk r} z| td | |jsƂW5d} ~ XYnXW5QRXtjS) Nr'rZrrr)cSsg|]}ttd?|dqSr)rrrr1r1r2rsz+Client._handle_unsuback..zReceived UNSUBACK (Mid: %d)rrrz&Caught exception in on_unsubscribe: %s)r rr rr_rrrrrzr{rDrBrBrrrr CallbackOnUnsubscribe_v1_mqtt5rr CallbackOnUnsubscribe_v1_mqtt3rgCallbackOnUnsubscribe_v2rr|rrrrar]) r=r4r)rrrZreasoncodes_listrBrr|r1r1r2rsr            zClient._handle_unsuback)r r rrr;c Cs8|j |j}W5QRX|r4|jz|jtjkr|jtkrrtt |}|r`|||j ||q|||j |dqtt |}|||j |n^|jtj krtt |}t|d}|dkrt|}|dkrttj}|||j |||ntdWn<tk r(}z|td||jsW5d}~XYnXW5QRXdS)N)rUrz%Caught exception in on_disconnect: %s)rDrErBrrrr rr CallbackOnDisconnect_v1_mqtt5r CallbackOnDisconnect_v1_mqtt3rgCallbackOnDisconnect_v2rTrrrrrrrzrra)r=r r rrrEZdisconnect_flagsr|r1r1r2r sL         zClient._do_on_disconnectrr)r4 reason_coderr;c Cs|j |j}W5QRX|r|jz\|jtjkrLtt|}|||j|n2|jtj krvtt |}|||j|||nt dWn8t k r}z| td||jsW5d}~XYnXW5QRX|j|}|j|jdkr|jd8_|jdkr|}|tjkr|StjS)Nrrcrr)rDr?rBrrrr rfr rgrhrrrzrrar/rr8rr5r2r1rrr])r=r4rrr?r|rrr1r1r2_do_on_publish.sF          zClient._do_on_publishz&Literal['PUBACK'] | Literal['PUBCOMP'])rr;c Cs&|jtkr |jddkr4tjSn|jddkr4tjS|dkr@tnt}|jd?}t d|jddd\}t |}t |}|jtkr|jddkr| |jddd|jddkr| |jddd\}}| t d|||j0||jkr||||} | W5QRSW5QRXtjS) Nr'rrirZrr)rLzReceived %s (Mid: %d))r rr rr_rir}rrrrrrzr{rFr/rr]) r=rZpacket_type_enumrr4rrrrrr1r1r2rUs.    zClient._handle_pubackcomprW)rr;c CsDz |j}Wntk r"d}YnXg}|j8|dk rJt|j|j}t|dkr^|j}nd}W5QRX|D]f}|jVz|||j |Wn<t k r}z| t d|j ||jsW5d}~XYnXW5QRXqp|r@|jVz|||j |Wn<t k r4}z| t d||js$W5d}~XYnXW5QRXdS)Nrz9Caught exception in user defined callback function %s: %sz"Caught exception in on_message: %s)rrrDrr;rrr<rBr rrzrr-ra)r=rrZon_message_callbacksr<rSr|r1r1r2rssH    zClient._handle_on_messagec Cst|j |j}W5QRX|rp|jHz|||jWn0tk rd}z|td|W5d}~XYnXW5QRXdS)Nz'Caught exception in on_connect_fail: %s)rDr6rBr rrzr)r=r6r|r1r1r2rszClient._handle_on_connect_failcCsz|jddW5d|_XdS)NT)r)rJrrCr1r1r2r!szClient._thread_mainc Cst}|j8|jdkr"|j|_nt|jd|j|_||j}W5QRX||}|jtjtj fkr|j s|dkrt t|d|t}qRdS)Nrrr) rrHr(r&minr'r-rrrrKtimesleep)r=r Z target_time remainingr1r1r2rs"  zClient._reconnect_waitcCsbdddd}t|tr.||d|dSt|ttfrZt|dkoX||d|d Sd SdS) NrFrBcSs tdk o|tjtjtjhko|Sr<)rHTTPZSOCKS4SOCKS5)rar1r1r2checks z%Client._proxy_is_valid..check proxy_type proxy_addrrrrF)rprgetrrr)rtrr1r1r2rs  zClient._proxy_is_validzdict[str, Any] | NonecCstdkr dS||jr|jSttjdr8tj|jstj}d|krtj |d}|j dkrztj |j |jd}|S|j dkrtj|j |jd}|St}||rd}tt||SdS)N proxy_bypassmqtthttp)rr proxy_portr)rrrZ proxy_rdnsZproxy_usernameZproxy_password)rrr@rurllibrequestrr< getproxiesparseurlparseschemerhostnamerrZget_default_proxyrzip)r= env_proxiespartsproxyZ socks_default proxy_keysr1r1r2 _get_proxys6       zClient._get_proxycCsd|jdkr|}n|}|jr,||}|jdkr`||jt||j|j |j|j |j dS|S)Nrrrrdris_sslr extra_headers) r_create_unix_socket_connection_create_socket_connectionrL_ssl_wrap_socket settimeoutr_WebsocketWrapperr<r=r^r_rr1r1r2rs       zClient._create_socketz_socket.socketcCs ttjtj}||j|Sr<)rrrrr<)r=Z unix_socketr1r1r2rs z%Client._create_unix_socket_connectioncCsT|}|j|jf}|j|jf}|r>tj|f|j|d|Stj||j|dSdS)N)rsource_address) rr<r=r>r?rcreate_connectionrr)r=rrsourcer1r1r2rs   z Client._create_socket_connectionz ssl.SSLSocket)tcp_sockr;cCs|jdkrtd|j }z|jj||jdd}Wn:tjk rJYn6tk rl|jj|dd}YnXt|jddrd}||j | |rt | |j|S)NzGImpossible condition. _ssl_context should never be None if _ssl is TrueF)server_hostnamedo_handshake_on_connect)rr) rMrrN wrap_socketr<ruCertificateErrorrrr do_handshakematch_hostname getpeercert)r=rZ verify_hostssl_sockr1r1r2r"s2    zClient._ssl_wrap_socket)F)rTN)rN)N)NNNNNNNN)N)rr)r)r)NrFN)N)NN)rNN)N)r)NrFN)rF)N)rrFFNN)NN)N)N)N)NN)r-r.r/rSrrrrrcrrdrrrhrrrirjrkrlrmrnrorqr}rrrbrrrrrrrrrNrrrrrrrrrrrfrrrrrrrrrrrrrrrrr$r&rr(r0rr2r3r5r6r8r9r;r<r>r?rArBrDrErGrHrJrrKrLrrNrOrxrQrRrrTrVrXrrrrzr r staticmethodrrrorzr|r~rrrrrr{rwrrrrrrrrrr_rrrrrrrrrrrrr rrrrr!rrrrrrrr1r1r1r2rVwsNg             k  .30 <Ko * / N 4$*%' jY &  *O k* . 1   "' /2J  *D5'*  + c@seZdZdZdZdZdZdZdZddd d dd d d dZ ddddZ d ddddZ d5d dd ddddZ d ddddZ d ddddZdd d d!d"Zd ddd#d$Zd ddd%d&Zdd d d'd(Zdd d d)d*Zddd+d,Zd dd-d.Zd dd/d0Zd dd1d2d3Zd4S)6rrrrr zsocket.socket | ssl.SSLSocketrZr"rFrrcCsTd|_||_||_||_||_||_t|_t|_d|_ d|_ d|_ | |dSr) connectedrLr<r=_socket_pathr( _sendbuffer _readbuffer_requested_size _payload_head_readbuffer_head _do_handshake)r=rrdrrrrr1r1r2rQs z_WebsocketWrapper.__init__rArBcCst|_t|_dSr<)r(rrrCr1r1r2rcksz_WebsocketWrapper.__del__)rr;cCsDtj}t|}|jr$d}d}nd}d}||jkr@|j}n|jd|j}|dd|d||d d d d }t |t r| |nt |r||}d d|jdd dd|Dd gd }|j|d}d} z|jd} Wntk rd} YnX|j| | dkrt|jdkrdt|jdkrxdt|jdkrttdnd} dt|jdkrd} |jdddd} | d} |d| }t|d}t|}| |krtdnd}nqt |_q| std q| r*|s2td t |_d|_!dS)!NihttpsPr:Z websocketUpgradez://rZ13r)Hostr ConnectionZOriginzSec-WebSocket-KeyzSec-Websocket-VersionzSec-Websocket-Protocolz zGET z HTTP/1.1css |]\}}|d|VqdS): Nr1)rijr1r1r2rsz2_WebsocketWrapper._do_handshake..Frr rs connectionrsupgradez2WebSocket handshake error, connection not upgradedTssec-websocket-acceptz$258EAFA5-E914-47DA-95CA-C5AB0DC85B11r z-WebSocket handshake error, invalid secret keyzWebSocket handshake error)"rrr6base64 b64encoderLr=r<rrprupdaterrritemsrrr@r>ConnectionResetErrorrrrrZrrXrvstriphashlibsha1digestr(r)r=rZsec_websocket_key default_portZ http_schema host_portZwebsocket_headersrZ has_secretZ has_upgrader`ZGUIDZserver_hash_strZ server_hashZclient_hash_keyZclient_hash_digestZ client_hashr1r1r2ros                z_WebsocketWrapper._do_handshaker()opcoderb do_maskingr;c Cst}t|}ttd}|}|d|B|dkrJ||d>|Bn`|dkrv||d>dB|td|7}n4|dkr||d>dB|td |7}ntd |d krt|D]}||||dN<q||}||S) NrZr\~rrprlr[!QzMaximum payload size is 2^63r) r(rosurandomrrrrr) r=r/rbr0rlengthmask_keyZ mask_flagrr1r1r2 _create_frames& z_WebsocketWrapper._create_frame)r5r;cCsr|t|j|j}|dkrN|j|}|s2tn |j|t||krNt|j|7_|j|j||jSr)rrrrr>ConnectionAbortedErrorrr)r=r5Z wanted_bytesrbr1r1r2_buffered_reads   z _WebsocketWrapper._buffered_readr6cCszd|_d}|j}|j|}|d}|d}|dd@}|dd@dk}|dd@} | } d} | dkr|d} td | \} n | dkr|d } td | \} |r|d } |} | | kr| } | dkr|| }| dk rt|| D]}||| |d N<q||| }| |_nt}| | krt|_d|_|tj krb| tj |d}|j ||tj kr| tj|d}|j ||tjks|tjkr| dkr|WStWntk rd |_YdSXdS)Nrrrr\r[r1rrrr2rZF)rrr9rrrr(rrOPCODE_CONNCLOSEr7rr@ OPCODE_PING OPCODE_PONG OPCODE_BINARYOPCODE_CONTINUATIONrrtr)r=r5rZchunk_startindexZchunk_endindexZheader1Zheader2r/ZmaskbitZ lengthbitsZpayload_lengthr6rZ readindexrrframer1r1r2 _recv_implsp                 z_WebsocketWrapper._recv_impl)rbr;cCspt|jdkr6|tjt|}|j|t||_|j |j}|j|d|_t|jdkrh|jSdSdSr) rrr7rr>r(rrrr@)r=rbr@r5r1r1r2 _send_implZs  z_WebsocketWrapper._send_implcCs ||Sr<rAr=r5r1r1r2r>psz_WebsocketWrapper.recvcCs ||Sr<rCrDr1r1r2readssz_WebsocketWrapper.readcCs ||Sr<rBr=rbr1r1r2r@vsz_WebsocketWrapper.sendcCs ||Sr<rFrGr1r1r2writeysz_WebsocketWrapper.writecCs|jdSr<)rrDrCr1r1r2rD|sz_WebsocketWrapper.closecCs |jSr<)rrErCr1r1r2rEsz_WebsocketWrapper.filenocCs|jr|jSdSdSr)rLrrrCr1r1r2rs z_WebsocketWrapper.pendingrGcCs|j|dSr<)rrJrIr1r1r2rJsz_WebsocketWrapper.setblockingN)r)r-r.r/r?Z OPCODE_TEXTr>r;r<r=rrcrr7r9rArBr>rEr@rHrDrErrJr1r1r1r2rIs,e!S r)rS __future__rr$r!errnor*rr3platformrrstringrrr urllib.parserurllib.requestrrtypingrrrrrrr r r r r Zpaho.mqtt.packettypesrenumsrrrrrrrrrrrrrrrrZsubscribeoptionsrr ImportErrortyping_extensionsrr r!r3r9rur monotonicrryZ dns.resolverrrsystemZWSAEWOULDBLOCKEAGAINrrr|rrirrr}rrrrrxryrZAUTHZ MQTT_LOG_INFOZMQTT_LOG_NOTICEZMQTT_LOG_WARNINGrr{DEBUGINFOWARNINGERRORrmrqrrrsrtrurvZMQTT_MS_INVALIDrZMQTT_MS_PUBLISHrZMQTT_MS_WAIT_FOR_PUBACKrZMQTT_MS_WAIT_FOR_PUBRECrZMQTT_MS_RESEND_PUBRELrZMQTT_MS_WAIT_FOR_PUBRELrZMQTT_MS_RESEND_PUBCOMPZmqtt_ms_resend_pubcompZMQTT_MS_WAIT_FOR_PUBCOMPrZMQTT_MS_SEND_PUBRECZmqtt_ms_send_pubrecZMQTT_MS_QUEUEDrrr]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrrrrrrNr0rrZr6r(r"rrZ HTTPHeaderZWebSocketHeadersrFrMrPrTrrZCallbackOnConnect_v1rr4r7rrZCallbackOnDisconnect_v1rrFr,r=r1rfrhr@rIrrZCallbackOnSubscribe_v1rr:rrZCallbackOnUnsubscribe_v1rrCrrtrXrnrxr}rr ascii_lettersrrrrrrrWrVrr1r1r1r2s 4 ,                  &  &    " " " ( c.q