U Zj8-@sdZddlmZddlZddlmZddlmZmZm Z m Z m Z ddl m Z mZddlmZddlmZd d lmZd d lmZerXzdd lmZmZmZWn(ek rdd lmZmZmZYnXzddlmZWn ek rddlmZYnXGdddeddZGdddeddZGdddeddZe e ej!e"e#fZ$e e ee$fZ%dd ddZ&dddddZ'dddd d!d"d#d$d%Z(d&d'd(d)dddej)d*df dd+dd+dd,d-d.d/d0d1d"d2 d3d4Z*dddd&d'd(d)dddej)d*df d+d5dd6d+dd+dd,d-d.d/d0d1d"d7d8d9Z+dS):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@seZdZUded<ded<dS) AuthParameter Required[str]usernameNotRequired[str]passwordN__name__ __module__ __qualname____annotations__rrT/var/www/html/TRUCKING_PROJECT/venv/lib/python3.8/site-packages/paho/mqtt/publish.pyr/s rF)totalc@s>eZdZUded<ded<ded<ded<ded<d ed <d S) TLSParameterrca_certsrcertfilekeyfileNotRequired[int]Z tls_versionciphersNotRequired[bool]insecureNrrrrr r"4s r"c@s.eZdZUded<ded<ded<ded<d S) MessageDictrtopiczNotRequired[paho.PayloadType]payloadr&qosr(retainNrrrrr r*=s r*z paho.ClientcCsH|j}t|tr"|jf|n"t|ttfr<|j|ntddS)zInternal functionz&message must be a dict, tuple, or listN)Z _userdatapopleft isinstancedictpublishtuplelist TypeError)rmessagerrr _do_publishHs    r7 MessagesList)ruserdatacCs2|dkrt|dkr.t|ntt|dS)zInternal v5 callbackrN)lenr7rZ MQTTExceptionpahoZconnack_string)rr9flagsZ reason_code propertiesrrr _on_connectUs  r>zcollections.deque[MessagesList]intr r None)rr9mid reason_codesr=returncCs"t|dkr|nt|dS)zInternal callbackrN)r:Z disconnectr7)rr9rArBr=rrr _on_publish^s  rD localhosti[<ZtcpstrzMessageDict | NonezAuthParameter | NonezTLSParameter | Noner zLiteral[('tcp', 'websockets')]z Any | None) msgshostnameport client_id keepalivewillauthtlsprotocol transport proxy_argsrCc Cst|tstdt|dkr&tdtjtj|t ||| d} | t | _ t| _| dk rj| jf| |r|d} | r|d} | | | ntd|dk r| jf||dk rt|tr|d d }| jf||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)rLr9rQrRNrrz;The 'username' key was not found, this is required for authr)F)r0rr5r: ValueErrorr;ZClientr ZVERSION2 collectionsdequeZ enable_loggerrDZ on_publishr>Z on_connectZ proxy_setgetZusername_pw_setKeyErrorZwill_setr1popZtls_setZtls_insecure_setZtls_set_contextconnectZ loop_forever)rIrJrKrLrMrNrOrPrQrRrSrrrr)rrr multiplejsBL           r[zpaho.PayloadTypebool)r+r,r-r.rJrKrLrMrNrOrPrQrRrSrCc Cs0||||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. )r+r,r-r.N)r[)r+r,r-r.rJrKrLrMrNrOrPrQrRrSmsgrrr singles Hr^),__doc__ __future__rrUcollections.abcrtypingrrrrrZpaho.mqtt.enumsr r Zpaho.mqtt.propertiesr Zpaho.mqtt.reasoncodesr rFrrr;rrr ImportErrortyping_extensionsrrr"r*rHZ PayloadTyper?r\Z MessageTupler8r7r>rDZMQTTv311r[r^rrrr sf         &