(\i8- dZddlmZddlZddlmZddlmZmZm Z m Z m Z ddl m Z mZddlmZddlmZd d lmZd d lmZerV dd lmZmZmZ ddlmZGddedZGddedZGddedZe e ejBe"e#fZ$e e ee$fZ%d!dZ&d"dZ' d#dZ(dddddddejRddf d$dZ*ddddddddddejRddf d%d Z+y#e$r dd lmZmZmZYwxYw#e$r ddlmZYwxYw)&a 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<y) AuthParameter Required[str]usernameNotRequired[str]passwordN__name__ __module__ __qualname____annotations__a/home/devuser/fomin/mqttuser/mqtt_project/myenv/lib/python3.12/site-packages/paho/mqtt/publish.pyrr/s""r"rF)totalcJeZdZUded<ded<ded<ded<ded<d ed <y ) TLSParameterrca_certsrcertfilekeyfileNotRequired[int] tls_versionciphersNotRequired[bool]insecureNrr!r"r#r&r&4s&""!!%%!!##r"r&c6eZdZUded<ded<ded<ded<y ) MessageDictrtopiczNotRequired[paho.PayloadType]payloadr*qosr-retainNrr!r"r#r0r0=s.. !!r"r0c|jj}t|tr|jdi|yt|t t fr|j|ytd)zInternal functionz&message must be a dict, tuple, or listNr!) _userdatapopleft isinstancedictpublishtuplelist TypeError)rmessages r# _do_publishr?Hs[&&(G'4 !! GeT] + @AAr"c|dk(rt|dkDr t|yytjt j |)zInternal v5 callbackrN)lenr?r MQTTExceptionpahoconnack_string)ruserdataflags reason_code propertiess r# _on_connectrIUsAa x=1      !4!4[!ABBr"cXt|dk(r|jyt|y)zInternal callbackrN)rA disconnectr?)rrEmid reason_codesrHs r# _on_publishrN^s$  8}Fr" localhosti[<tcpc t|ts tdt|dk(r t dt j tj|tj||| } | jt| _ t| _| | j d i| |rB|j#d} | r$|j#d} | j%| | n t'd|| j(d i||Yt|t*r8|j-d d }| j.d i||r#| j1|n| j3|| j5|||| j7y) 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) client_idrEprotocol transportNrrz;The 'username' key was not found, this is required for authr.Fr!)r8rr=rA ValueErrorrCClientr VERSION2 collectionsdeque enable_loggerrN on_publishrI on_connect proxy_setgetusername_pw_setKeyErrorwill_setr9poptls_settls_insecure_settls_set_contextconnect loop_forever)msgshostnameportrT keepalivewillauthtlsrUrV proxy_argsrrrr.s r#multiplerrjsbX dH %233 4yA~)) [[##""4( F #F#F&:& 88J' xx +H  " "8X 6/0 0 $  c4 wwz51H FNN !S !''1  " "3 ' NN8T9- r"c >||||d}t|g|||||| | | | | y)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)rr)r1r2r3r4rkrlrTrmrnrorprUrVrqmsgs r#singlerus4P!&fUC cUHdIy$c y*.r")r paho.Client)rrvrE MessagesList) rrvrEzcollections.deque[MessagesList]rLintrMr rHr returnNone)rjrwrkstrrlrxrTr{rmrxrnMessageDict | NoneroAuthParameter | NonerpTLSParameter | NonerUr rVLiteral['tcp', 'websockets']rq Any | Noneryrz)r1r{r2zpaho.PayloadTyper3rxr4boolrkr{rlrxrTr{rmrxrnr|ror}rpr~rUr rVrrqrryrz),__doc__ __future__rrZcollections.abcrtypingrrrrr paho.mqtt.enumsr r paho.mqtt.propertiesr paho.mqtt.reasoncodesr rPrrrCrrr ImportErrortyping_extensionsrrr&r0r{ PayloadTyperxr MessageTuplerwr?rIrNMQTTv311rrrur!r"r#rs #$99C+,G;;." # # $y$"iu" d..T9:Lk<789L BC   #B IL \f t~    #!%#$(MM.3!z zz z z  z  z z z"z,zz z~!%#!%#$(MM.3!K. K. K. K.  K.  K.  K.K.K. K. K. K."K.,K.K. K.E GFFG .-.s$ DD0D-,D-0 D>=D>