CA file seems to be issue. Ignore it for this sample

Author: TwistedTwigleg

.github/workflows/ci_run_x509_connect_cfg.json

@@ -18,11 +18,6 @@
             "secret": "ci/PubSub/key",
             "filename": "tmp_key.pem"
         },
-        {
-            "name": "--x509_ca_file",
-            "secret": "ci/PubSub/ca",
-            "filename": "tmp_ca.pem"
-        },
         {
             "name": "--x509_endpoint",
             "secret": "ci/X509/endpoint_credentials"

samples/utils/command_line_utils.py

@@ -250,7 +250,8 @@ def build_websocket_x509_mqtt_connection(self, on_connection_interrupted, on_con
         x509_tls_options = io.TlsContextOptions.create_client_with_mtls_from_path(
                     self.get_command_required(self.m_cmd_x509_cert),
                     self.get_command_required(self.m_cmd_x509_key))
-        # x509_tls_options.ca_dirpath = self.get_command(self.m_cmd_x509_ca)
+        if (self.get_command(self.m_cmd_x509_ca) != None):
+            x509_tls_options.ca_dirpath = self.get_command(self.m_cmd_x509_ca)
         x509_tls_context = io.ClientTlsContext(x509_tls_options)
 
         x509_provider = auth.AwsCredentialsProvider.new_x509(

samples/x509_connect.py

@@ -35,9 +35,6 @@ def on_connection_resumed(connection, return_code, session_present, **kwargs):
 
 
 if __name__ == '__main__':
-    # TMP - enable logging
-    io.init_logging(io.LogLevel.Error, 'stderr')
-
     # Create a connection using X509 authentication to connect
     # Note: The data for the connection is gotten from cmdUtils.
     # (see build_websocket_x509_mqtt_connection for implementation)
@@ -52,11 +49,7 @@ def on_connection_resumed(connection, return_code, session_present, **kwargs):
     connect_future = mqtt_connection.connect()
 
     # Future.result() waits until a result is available
-    try:
-        connect_future.result()
-    except Exception as e:
-        print (e)
-        raise RuntimeError(e)
+    connect_future.result()
     print("Connected!")
 
     # Disconnect