U >qa% @sdZddlmZddlZzddlmZWn ek rHddlmZYnXddlmZddlm Z d d Z d d Z d dZ ddZddddddde jddf ddZdddddddddde jddf ddZdS)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. )absolute_importN)Iterable)mqtt)clientcCsH|j}t|tr"|jf|n"t|ttfr<|j|ntddS)zInternal functionz&message must be a dict, tuple, or listN)Z _userdatapopleft isinstancedictZpublishtuplelist TypeError)rmessagerT/var/www/html/flasktest/Project_env/lib/python3.8/site-packages/paho/mqtt/publish.py _do_publish"s    rcCs2|dkrt|dkr.t|ntt|dSzInternal callbackrN)lenrr MQTTExceptionpahoZconnack_string)ruserdataflagsrcrrr _on_connect/s  rcCst||||dS)zInternal v5 callbackN)r)rrrrZ propertiesrrr_on_connect_v59srcCs"t|dkr|nt|dSr)rZ disconnectr)rrZmidrrr _on_publish=s  rZ localhosti[<Ztcpc Cst|tstdtj|t||| d} t| _|t j j krDt | _ nt| _ | dk r^| jf| |r|d} | r|d} | | | ntd|dk r| jf||dk rt|tr|dd}| 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. 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) hostname : a string containing the address of the broker to connect to. Defaults to localhost. port : the port to connect to the broker on. Defaults to 1883. client_id : the MQTT client id to use. If "" or None, the Paho library will generate a client id automatically. keepalive : the keepalive timeout value for the client. Defaults to 60 seconds. 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. 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. 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. transport : set to "tcp" to use the default setting of transport which is raw TCP. Set to "websockets" to use WebSockets as the transport. proxy_args: a dictionary that will be given to the client. zmsgs must be an iterable) client_idrprotocol transportNusernamepasswordz;The 'username' key was not found, this is required for authinsecureF)r rr rZClient collectionsdequerZ on_publishrrZMQTTv5rZ on_connectrZ proxy_setgetZusername_pw_setKeyErrorZwill_setr popZtls_setZtls_insecure_setZtls_set_contextconnectZ loop_forever)Zmsgshostnameportr keepalivewillauthtlsrr proxy_argsrr!r"r#rrrmultipleGs:A           r1Fc Cs0||||d}t|g|||||| | | | | dS)a1 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. topic : the only required argument must be the topic string to which the payload will be published. payload : the payload to be published. If "" or None, a zero length payload will be published. qos : the qos to use when publishing, default to 0. retain : set the message to be retained (True) or not (False). hostname : a string containing the address of the broker to connect to. Defaults to localhost. port : the port to connect to the broker on. Defaults to 1883. client_id : the MQTT client id to use. If "" or None, the Paho library will generate a client id automatically. keepalive : the keepalive timeout value for the client. Defaults to 60 seconds. 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. 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. 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. transport : set to "tcp" to use the default setting of transport which is raw TCP. Set to "websockets" to use WebSockets as the transport. proxy_args: a dictionary that will be given to the client. )topicpayloadqosretainN)r1)r2r3r4r5r*r+rr,r-r.r/rr r0msgrrrsingles :r7)__doc__ __future__rr$collections.abcr ImportErrorrrrrrrrrZMQTTv311r1r7rrrrs>       m