>qa% dZddlmZddlZ ddlmZn#e$r ddlmZYnwxYwddlmZddlm Z d Z d Z d Z d Zd dddddde jddf dZdddd dddddde jddf dZdS)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)clientc|j}t|tr|jdi|dSt|t t fr |j|dStd)zInternal functionz&message must be a dict, tuple, or listN) _userdatapopleft isinstancedictpublishtuplelist TypeError)rmessages E/opt/windhager/venv/lib/python3.11/site-packages/paho/mqtt/publish.py _do_publishr"s&&((G'4  B!!!!!!! GeT] + +B    @AAAc|dkr&t|dkrt|dSdStjt j|zInternal callbackrN)lenrr MQTTExceptionpahoconnack_string)ruserdataflagsrcs r _on_connectr /sX Qww x==1           !4R!8!8999rc*t||||dS)zInternal v5 callbackN)r )rrrr propertiess r_on_connect_v5r#9s%,,,,,rcvt|dkr|dSt|dSr)r disconnectr)rrmids r _on_publishr'=sA 8}}Fr localhosti[<tcpc t|tstdtj|t j||| } t| _|tj j kr t| _ n t| _ | | jd i| |rR|d} | r,|d} | | | nt%d| | jd i||et|t(r;|dd}| 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. 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 authinsecureFr )r rrrClient collectionsdequer' on_publishrrMQTTv5r# on_connectr proxy_setgetusername_pw_setKeyErrorwill_setrpoptls_settls_insecure_settls_set_contextconnect loop_forever)msgshostnameportr- keepalivewillauthtlsr.r/ proxy_argsrr0r1r2s rmultiplerLGsB dH % %42333[9{7H7N7N"*iAAAF$F4;%%%*'&&:&&& 088J''  0xx ++H  " "8X 6 6 6 6/00 0 $  c4 (wwz511H FN ! !S ! ! ! 2''111  " "3 ' ' ' NN8T9--- rFc H||||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)rL)rNrOrPrQrErFr-rGrHrIrJr.r/rKmsgs rsinglerSsKtG3 H HC cUHdIy$c y*.....r)__doc__ __future__rr4collections.abcr ImportErrorr)rrrrr r#r'MQTTv311rLrSr rrrYsT '&&&&&%(((((((%%%$$$$$$$$% B B B:::---(dbBTtdmjjjjZAekbt$dmu=.=.=.=.=.=.s  ##