def init_app_mqtt_client()

in iot_client.py [0:0]

• 31 lines of code
• 3 McCabe index (conditional complexity)

    def init_app_mqtt_client(self):
        print("Connecting MQTT client")

        pk_pem = "\n".join(self.private_key_pem.decode('utf-8').splitlines())
        pk_file = tempfile.NamedTemporaryFile()
        pk_file.write(pk_pem.encode('utf-8'))
        pk_file.flush()

        cert_pem = "\n".join(self.certificate_pem.splitlines())
        cert_file = tempfile.NamedTemporaryFile()
        cert_file.write(cert_pem.encode('utf-8'))
        cert_file.flush()

        self.configureCredentials("/tmp/AmazonRootCA1.pem", pk_file.name, cert_file.name)

        attempts = 0
        time.sleep(1)
        while attempts < 5:
            try:
                self.connect()
                print("MQTT client connected")
                break
            except connectTimeoutException:
                print("Connection timed out, trying again")
                attempts += 1
                continue
        else:
            print("Too many attempts")
            raise Exception

        self.shadow_listener()
        print("Initialized shadow listener")

        print("Reporting initial shadow")
        self.report_shadow(self.shadow)

        self.init_jobs_client()
        print("IoT Client initialization completed")