h8- dZddlmZddlZddlmZddlmZmZm Z m Z m Z ddl m Z mZddlmZddlmZd d lmZd d lmZer dd lmZmZmZn#e$r dd lmZmZmZYnwxYw ddlmZn#e$r ddlmZYnwxYwGddedZGddedZGddedZe e ej!e"e#fZ$e e ee$fZ%dFdZ&dGdZ'dHd&Z(d'd(d)d*dddej)d+df dId>Z*dddd'd(d)d*dddej)d+df dJdEZ+dS)Ka This module provides some helper functions to allow straightforward publishing of messages in a one-shot manner. In other words, they are useful for the situation where you have a single/multiple messages you want to publish to a broker, then disconnect and nothing else is required. ) annotationsN)Iterable) TYPE_CHECKINGAnyListTupleUnion)CallbackAPIVersionMQTTProtocolVersion) Properties) ReasonCode)mqtt)client) NotRequiredRequired TypedDict)Literalc$eZdZUded<ded<dS) AuthParameter Required[str]usernameNotRequired[str]passwordN__name__ __module__ __qualname____annotations__^/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/paho/mqtt/publish.pyrr/s*""""""r"rF)totalcLeZdZUded<ded<ded<ded<ded<d ed <d S) TLSParameterrca_certsrcertfilekeyfileNotRequired[int] tls_versionciphersNotRequired[bool]insecureNrr!r"r#r&r&4sZ""""!!!!%%%%!!!!######r"r&c8eZdZUded<ded<ded<ded<d S) MessageDictrtopiczNotRequired[paho.PayloadType]payloadr*qosr-retainNrr!r"r#r0r0=sB....!!!!!!r"r0r paho.Clientc|j}t|tr|jdi|dSt|t t fr |j|dStd)zInternal functionz&message must be a dict, tuple, or listNr!) _userdatapopleft isinstancedictpublishtuplelist TypeError)rmessages r# _do_publishr@Hs&&((G'4  B!!!!!!! GeT] + +B    @AAAr"userdata MessagesListc|dkr&t|dkrt|dSdStjt j|)zInternal v5 callbackrN)lenr@r MQTTExceptionpahoconnack_string)rrAflags reason_code propertiess r# _on_connectrKUsXa x==1           !4[!A!ABBBr"collections.deque[MessagesList]midint reason_codesr rJr returnNonecvt|dkr|dSt|dS)zInternal callbackrN)rD disconnectr@)rrArMrOrJs r# _on_publishrT^sA  8}}Fr" localhosti[<tcpmsgshostnamestrport client_id keepalivewillMessageDict | NoneauthAuthParameter | NonetlsTLSParameter | Noneprotocolr transportLiteral['tcp', 'websockets'] proxy_args Any | Nonec \t|tstdt|dkrt dt jtj|tj ||| } | t| _ t| _| | jd i| |rR|d} | r,|d} | | | nt'd| | jd i||et|t*r;|d d }| jd i||r| |n| || |||| dS) a Publish multiple messages to a broker, then disconnect cleanly. This function creates an MQTT client, connects to a broker and publishes a list of messages. Once the messages have been delivered, it disconnects cleanly from the broker. :param msgs: a list of messages to publish. Each message is either a dict or a tuple. If a dict, only the topic must be present. Default values will be used for any missing arguments. The dict must be of the form: msg = {'topic':"", 'payload':"", 'qos':, 'retain':} topic must be present and may not be empty. If payload is "", None or not present then a zero length payload will be published. If qos is not present, the default of 0 is used. If retain is not present, the default of False is used. If a tuple, then it must be of the form: ("", "", qos, retain) :param str hostname: the address of the broker to connect to. Defaults to localhost. :param int port: the port to connect to the broker on. Defaults to 1883. :param str client_id: the MQTT client id to use. If "" or None, the Paho library will generate a client id automatically. :param int keepalive: the keepalive timeout value for the client. Defaults to 60 seconds. :param will: a dict containing will parameters for the client: will = {'topic': "", 'payload':", 'qos':, 'retain':}. Topic is required, all other parameters are optional and will default to None, 0 and False respectively. Defaults to None, which indicates no will should be used. :param auth: a dict containing authentication parameters for the client: auth = {'username':"", 'password':""} Username is required, password is optional and will default to None if not provided. Defaults to None, which indicates no authentication is to be used. :param tls: a dict containing TLS configuration parameters for the client: dict = {'ca_certs':"", 'certfile':"", 'keyfile':"", 'tls_version':"", 'ciphers':", 'insecure':""} ca_certs is required, all other parameters are optional and will default to None if not provided, which results in the client using the default behaviour - see the paho.mqtt.client documentation. Alternatively, tls input can be an SSLContext object, which will be processed using the tls_set_context method. Defaults to None, which indicates that TLS should not be used. :param str transport: set to "tcp" to use the default setting of transport which is raw TCP. Set to "websockets" to use WebSockets as the transport. :param proxy_args: a dictionary that will be given to the client. zmsgs must be an iterablerz msgs is empty)r]rArerfNrrz;The 'username' key was not found, this is required for authr.Fr!)r9rr>rD ValueErrorrFClientr VERSION2 collectionsdeque enable_loggerrT on_publishrK on_connect proxy_setgetusername_pw_setKeyErrorwill_setr:poptls_settls_insecure_settls_set_contextconnect loop_forever)rYrZr\r]r^r_rarcrerfrhrrrr.s r#multipler~jsX dH % %42333 4yyA~~))) [#"4(( F #F#F&&:&&& 088J''  0xx ++H  " "8X 6 6 6 6/00 0 $  c4 (wwz511H FN ! !S ! ! ! 2''111  " "3 ' ' ' NN8T9--- r"r1r2paho.PayloadTyper3r4boolc H||||d}t|g|||||| | | | | dS)a Publish a single message to a broker, then disconnect cleanly. This function creates an MQTT client, connects to a broker and publishes a single message. Once the message has been delivered, it disconnects cleanly from the broker. :param str topic: the only required argument must be the topic string to which the payload will be published. :param payload: the payload to be published. If "" or None, a zero length payload will be published. :param int qos: the qos to use when publishing, default to 0. :param bool retain: set the message to be retained (True) or not (False). :param str hostname: the address of the broker to connect to. Defaults to localhost. :param int port: the port to connect to the broker on. Defaults to 1883. :param str client_id: the MQTT client id to use. If "" or None, the Paho library will generate a client id automatically. :param int keepalive: the keepalive timeout value for the client. Defaults to 60 seconds. :param will: a dict containing will parameters for the client: will = {'topic': "", 'payload':", 'qos':, 'retain':}. Topic is required, all other parameters are optional and will default to None, 0 and False respectively. Defaults to None, which indicates no will should be used. :param auth: a dict containing authentication parameters for the client: Username is required, password is optional and will default to None auth = {'username':"", 'password':""} if not provided. Defaults to None, which indicates no authentication is to be used. :param tls: a dict containing TLS configuration parameters for the client: dict = {'ca_certs':"", 'certfile':"", 'keyfile':"", 'tls_version':"", 'ciphers':", 'insecure':""} ca_certs is required, all other parameters are optional and will default to None if not provided, which results in the client using the default behaviour - see the paho.mqtt.client documentation. Defaults to None, which indicates that TLS should not be used. Alternatively, tls input can be an SSLContext object, which will be processed using the tls_set_context method. :param transport: set to "tcp" to use the default setting of transport which is raw TCP. Set to "websockets" to use WebSockets as the transport. :param proxy_args: a dictionary that will be given to the client. )r1r2r3r4N)r~)r1r2r3r4rZr\r]r^r_rarcrerfrhmsgs r#singlersKP!&fUUC cUHdIy$c y*.....r")rr5)rr5rArB) rr5rArLrMrNrOr rJr rPrQ)rYrBrZr[r\rNr]r[r^rNr_r`rarbrcrdrer rfrgrhrirPrQ)r1r[r2rr3rNr4rrZr[r\rNr]r[r^rNr_r`rarbrcrdrer rfrgrhrirPrQ),__doc__ __future__rrncollections.abcrtypingrrrrr paho.mqtt.enumsr r paho.mqtt.propertiesr paho.mqtt.reasoncodesr rVrrrFrrr ImportErrortyping_extensionsrrr&r0r[ PayloadTyperNr MessageTuplerBr@rKrTMQTTv311r~rr!r"r#rs# #"""""$$$$$$99999999999999CCCCCCCC++++++,,,,,,#:G;;;;;;;;;;; GGGFFFFFFFFFFFFG.""""""" ...--------. ##### #### $$$$$y$$$$"""""iu"""" d.T9:Lk<789L B B B BCCCC     #!%#$(M.3!zzzzz~!%#!%#$(M.3!K.K.K.K.K.K.K.s$ AA! A!%A,, A:9A: