Apply #2165 changes to async code

Author: sfc-gh-pczajka

src/snowflake/connector/aio/_connection.py

@@ -11,6 +11,7 @@
 import pathlib
 import sys
 import uuid
+import warnings
 from contextlib import suppress
 from io import StringIO
 from logging import getLogger
@@ -496,6 +497,26 @@ def _init_connection_parameters(
             elif "streamlit" in sys.modules:
                 connection_init_kwargs["application"] = "streamlit"
 
+        if "insecure_mode" in connection_init_kwargs:
+            warn_message = "The 'insecure_mode' connection property is deprecated. Please use 'disable_ocsp_checks' instead"
+            warnings.warn(
+                warn_message,
+                DeprecationWarning,
+                stacklevel=2,
+            )
+
+            if (
+                "disable_ocsp_checks" in connection_init_kwargs
+                and connection_init_kwargs["disable_ocsp_checks"]
+                != connection_init_kwargs["insecure_mode"]
+            ):
+                logger.warning(
+                    "The values for 'disable_ocsp_checks' and 'insecure_mode' differ. "
+                    "Using the value of 'disable_ocsp_checks."
+                )
+            else:
+                self._disable_ocsp_checks = connection_init_kwargs["insecure_mode"]
+
         self.converter = None
         self.query_context_cache: QueryContextCache | None = None
         self.query_context_cache_size = 5

src/snowflake/connector/aio/_ocsp_asn1crypto.py

@@ -27,7 +27,7 @@ def extract_certificate_chain(self, connection: ResponseHandler):
                 "Please open an issue on the Snowflake Python Connector GitHub repository "
                 "and provide your execution environment"
                 " details: https://github.com/snowflakedb/snowflake-connector-python/issues/new/choose."
-                "As a workaround, you can create the connection with `insecure_mode=True` to skip OCSP Validation."
+                "As a workaround, you can create the connection with `disable_ocsp_checks=True` to skip OCSP Validation."
             )
 
         cert_map = OrderedDict()

src/snowflake/connector/aio/_ocsp_snowflake.py

@@ -206,7 +206,7 @@ async def validate(
 
         telemetry_data = OCSPTelemetryData()
         telemetry_data.set_cache_enabled(self.OCSP_CACHE_SERVER.CACHE_SERVER_ENABLED)
-        telemetry_data.set_insecure_mode(False)
+        telemetry_data.set_disable_ocsp_checks(False)
         telemetry_data.set_sfc_peer_host(hostname)
         telemetry_data.set_fail_open(self.is_enabled_fail_open())
 

src/snowflake/connector/aio/_ssl_connector.py

@@ -53,12 +53,10 @@ async def connect(
             and protocol is not None
             and not getattr(protocol, "_snowflake_ocsp_validated", False)
         ):
-            if self._snowflake_ocsp_mode == OCSPMode.INSECURE:
-                log.info(
-                    "THIS CONNECTION IS IN INSECURE "
-                    "MODE. IT MEANS THE CERTIFICATE WILL BE "
-                    "VALIDATED BUT THE CERTIFICATE REVOCATION "
-                    "STATUS WILL NOT BE CHECKED."
+            if self._snowflake_ocsp_mode == OCSPMode.DISABLE_OCSP_CHECKS:
+                log.debug(
+                    "This connection does not perform OCSP checks. "
+                    "Revocation status of the certificate will not be checked against OCSP Responder."
                 )
             else:
                 await self.validate_ocsp(req.url.host, protocol)