B C¿ªaã@s–ddlmZmZmZmZddlmZddlmZddl Z ddl Z ddl m Z ddl Z eƒdae d¡Ze e¡Ze ee¡ZdZede  d ¡ƒed e  d ¡ƒee  d ¡ƒee  d ¡ƒee  d¡ƒee  d¡ƒdZe d¡Ze e¡Ze ee¡Zdd„Zdd„Zeje  d ¡ee  d¡ƒe  d ¡e  d¡e  d¡eeeee  d¡ee ƒƒddd Ze ¡Zeeƒe  ¡edƒdd„Z!dd„Z"dS)é)ÚioÚmqttÚauthÚhttp)Úmqtt_connection_builder)Ú load_dotenvN)Úuuid4Féz endpoint: ZENDPOINTzhttp_proxy_options: ZHTTP_PROXY_OPTIONSÚTOPICZ CERT_FILEPATHZPRI_KEY_FILEPATHZ CA_FILEPATHcKstd |¡ƒdS)Nz!Connection interrupted. error: {})ÚprintÚformat)Ú connectionÚerrorÚkwargs©rú1/home/pi/TSA-clean/TSA_voice_assistant/iot_sub.pyÚon_connection_interrupted!srcKsBtd ||¡ƒ|tjjkr>|s>tdƒ| ¡\}}| t¡dS)Nz7Connection resumed. return_code: {} session_present: {}z.on_message_receivedzSubscribing to topic '{}'...r z lcd-message)r'r*ÚcallbackzSubscribed with {}r*) Ú threadingÚEventr r ÚosÚgetenvÚmqtt_connectionZ subscriberÚQoSÚ AT_LEAST_ONCEÚresultÚstr)r r%r-Zsubscribe_futureZ packet_idZsubscribe_resultr)r,rÚmqtt_subscribeFs  r8c CsJytjd|tjjd}|Stk rD}ztd|ƒWdd}~XYnXdS)Nz lcd-message)r'r(r*zerror in pub: )r3Úpublishrr4r5r&r )ÚmessageZpubr+rrrÚ mqtt_publishvs r;)#ÚawscrtrrrrZawsiotrZdotenvrr/r1Úuuidrr"r%ÚEventLoopGroupÚevent_loop_groupÚDefaultHostResolverÚ host_resolverÚClientBootstraprÚ proxy_optionsr r2rrZmtls_from_pathÚintr7r3ÚconnectZconnect_futurer6r8r;rrrrÚsV           0