444 MqttConnectionProfilesDialog |
444 MqttConnectionProfilesDialog |
445 ) |
445 ) |
446 dlg = MqttConnectionProfilesDialog( |
446 dlg = MqttConnectionProfilesDialog( |
447 self.__client, self.__plugin.getPreferences("BrokerProfiles"), |
447 self.__client, self.__plugin.getPreferences("BrokerProfiles"), |
448 parent=self) |
448 parent=self) |
449 if dlg.exec_() == QDialog.Accepted: |
449 if dlg.exec() == QDialog.Accepted: |
450 profilesDict = dlg.getProfiles() |
450 profilesDict = dlg.getProfiles() |
451 self.__plugin.setPreferences("BrokerProfiles", profilesDict) |
451 self.__plugin.setPreferences("BrokerProfiles", profilesDict) |
452 self.__populateProfileComboBox() |
452 self.__populateProfileComboBox() |
453 else: |
453 else: |
454 from .MqttConnectionOptionsDialog import ( |
454 from .MqttConnectionOptionsDialog import ( |
455 MqttConnectionOptionsDialog |
455 MqttConnectionOptionsDialog |
456 ) |
456 ) |
457 dlg = MqttConnectionOptionsDialog( |
457 dlg = MqttConnectionOptionsDialog( |
458 self.__client, self.__connectionOptions, parent=self) |
458 self.__client, self.__connectionOptions, parent=self) |
459 if dlg.exec_() == QDialog.Accepted: |
459 if dlg.exec() == QDialog.Accepted: |
460 self.__connectionOptions = dlg.getConnectionOptions() |
460 self.__connectionOptions = dlg.getConnectionOptions() |
461 if self.__connectionOptions["TlsEnable"]: |
461 if self.__connectionOptions["TlsEnable"]: |
462 port = self.brokerPortComboBox.currentText().strip() |
462 port = self.brokerPortComboBox.currentText().strip() |
463 if port == "1883": |
463 if port == "1883": |
464 # it is default non-encrypted port => set to TLS port |
464 # it is default non-encrypted port => set to TLS port |
562 os.path.exists(payloadFile) and |
562 os.path.exists(payloadFile) and |
563 os.path.getsize(payloadFile) <= 268435455 |
563 os.path.getsize(payloadFile) <= 268435455 |
564 ): |
564 ): |
565 # payload size limit is 268,435,455 bytes |
565 # payload size limit is 268,435,455 bytes |
566 try: |
566 try: |
567 f = open(payloadFile, "rb") |
567 with open(payloadFile, "rb") as f: |
568 payloadStr = f.read() |
568 payloadStr = f.read() |
569 f.close() |
|
570 except EnvironmentError as err: |
569 except EnvironmentError as err: |
571 E5MessageBox.critical( |
570 E5MessageBox.critical( |
572 self, |
571 self, |
573 self.tr("Read Payload from File"), |
572 self.tr("Read Payload from File"), |
574 self.tr("""<p>The file <b>{0}</b> could not be read.""" |
573 self.tr("""<p>The file <b>{0}</b> could not be read.""" |
675 if not res: |
674 if not res: |
676 return |
675 return |
677 |
676 |
678 fn = Utilities.toNativeSeparators(fn) |
677 fn = Utilities.toNativeSeparators(fn) |
679 try: |
678 try: |
680 f = open(fn, "w") |
679 with open(fn, "w") as f: |
681 f.write(self.messagesEdit.toPlainText()) |
680 f.write(self.messagesEdit.toPlainText()) |
682 f.close() |
|
683 except EnvironmentError as err: |
681 except EnvironmentError as err: |
684 E5MessageBox.critical( |
682 E5MessageBox.critical( |
685 self, |
683 self, |
686 self.tr("Save Messages"), |
684 self.tr("Save Messages"), |
687 self.tr("""<p>The file <b>{0}</b> could not be written.""" |
685 self.tr("""<p>The file <b>{0}</b> could not be written.""" |
732 if not res: |
730 if not res: |
733 return |
731 return |
734 |
732 |
735 fn = Utilities.toNativeSeparators(fn) |
733 fn = Utilities.toNativeSeparators(fn) |
736 try: |
734 try: |
737 f = open(fn, "w") |
735 with open(fn, "w") as f: |
738 f.write(self.logEdit.toPlainText()) |
736 f.write(self.logEdit.toPlainText()) |
739 f.close() |
|
740 except EnvironmentError as err: |
737 except EnvironmentError as err: |
741 E5MessageBox.critical( |
738 E5MessageBox.critical( |
742 self, |
739 self, |
743 self.tr("Save Log Messages"), |
740 self.tr("Save Log Messages"), |
744 self.tr("""<p>The file <b>{0}</b> could not be written.""" |
741 self.tr("""<p>The file <b>{0}</b> could not be written.""" |