chore: add test to ssl_ca_cert

Author: bednar

tests/test_InfluxDBClient.py

@@ -25,24 +25,22 @@ def test_TrailingSlashInUrl(self):
         self.assertEqual('http://localhost:8086', self.client.api_client.configuration.host)
 
     def test_ConnectToSelfSignedServer(self):
-        import http.server
-        import ssl
+        self._start_http_server()
 
-        # Disable unverified HTTPS requests
-        import urllib3
-        urllib3.disable_warnings()
+        self.client = InfluxDBClient(f"https://localhost:{self.httpd.server_address[1]}",
+                                     token="my-token", verify_ssl=False)
+        health = self.client.health()
 
-        # Configure HTTP server
-        self.httpd = http.server.HTTPServer(('localhost', 0), ServerWithSelfSingedSSL)
-        self.httpd.socket = ssl.wrap_socket(self.httpd.socket, certfile=f'{os.path.dirname(__file__)}/server.pem',
-                                            server_side=True)
+        self.assertEqual(health.message, 'ready for queries and writes')
+        self.assertEqual(health.status, "pass")
+        self.assertEqual(health.name, "influxdb")
 
-        # Start server at background
-        self.httpd_thread = threading.Thread(target=self.httpd.serve_forever)
-        self.httpd_thread.start()
+    def test_certificate_file(self):
+        self._start_http_server()
 
         self.client = InfluxDBClient(f"https://localhost:{self.httpd.server_address[1]}",
-                                     token="my-token", verify_ssl=False)
+                                     token="my-token", verify_ssl=True,
+                                     ssl_ca_cert=f'{os.path.dirname(__file__)}/server.pem')
         health = self.client.health()
 
         self.assertEqual(health.message, 'ready for queries and writes')
@@ -95,6 +93,20 @@ def test_init_from_env_ssl_ca_cert(self):
 
         self.assertEqual("/my/custom/path/to/cert", self.client.api_client.configuration.ssl_ca_cert)
 
+    def _start_http_server(self):
+        import http.server
+        import ssl
+        # Disable unverified HTTPS requests
+        import urllib3
+        urllib3.disable_warnings()
+        # Configure HTTP server
+        self.httpd = http.server.HTTPServer(('localhost', 0), ServerWithSelfSingedSSL)
+        self.httpd.socket = ssl.wrap_socket(self.httpd.socket, certfile=f'{os.path.dirname(__file__)}/server.pem',
+                                            server_side=True)
+        # Start server at background
+        self.httpd_thread = threading.Thread(target=self.httpd.serve_forever)
+        self.httpd_thread.start()
+
 
 class ServerWithSelfSingedSSL(http.server.SimpleHTTPRequestHandler):
     def _set_headers(self):