introduce frozenset of proper cased uri options

Author: sleepyStick

pymongo/asynchronous/uri_parser.py

@@ -29,6 +29,7 @@
     SCHEME_LEN,
     SRV_SCHEME_LEN,
     _check_options,
+    _make_options_case_sensative,
     _validate_uri,
     split_hosts,
     split_options,
@@ -113,7 +114,7 @@ async def parse_uri(
             srv_max_hosts,
         )
     )
-    result["options"] = result["options"].as_dict()
+    result["options"] = _make_options_case_sensative(result["options"])
     return result
 
 

pymongo/common.py

@@ -1083,9 +1083,6 @@ def update(self, other: Mapping[str, Any]) -> None:  # type: ignore[override]
     def cased_key(self, key: str) -> Any:
         return self.__casedkeys[key.lower()]
 
-    def as_dict(self) -> dict[str, Any]:
-        return {self.__casedkeys[k]: self.__data[k] for k in self}
-
 
 def has_c() -> bool:
     """Is the C extension installed?"""

pymongo/synchronous/uri_parser.py

@@ -29,6 +29,7 @@
     SCHEME_LEN,
     SRV_SCHEME_LEN,
     _check_options,
+    _make_options_case_sensative,
     _validate_uri,
     split_hosts,
     split_options,
@@ -113,7 +114,7 @@ def parse_uri(
             srv_max_hosts,
         )
     )
-    result["options"] = result["options"].as_dict()
+    result["options"] = _make_options_case_sensative(result["options"])
     return result
 
 

pymongo/uri_parser_shared.py

@@ -54,6 +54,57 @@
 SRV_SCHEME_LEN = len(SRV_SCHEME)
 DEFAULT_PORT = 27017
 
+URI_OPTIONS = frozenset(
+    [
+        "appname",
+        "authMechanism",
+        "authMechanismProperties",
+        "authSource",
+        "compressors",
+        "connectTimeoutMS",
+        "directConnection",
+        "heartbeatFrequencyMS",
+        "journal",
+        "loadBalanced",
+        "localThresholdMS",
+        "maxIdleTimeMS",
+        "maxPoolSize",
+        "maxConnecting",
+        "maxStalenessSeconds",
+        "minPoolSize",
+        "proxyHost",
+        "proxyPort",
+        "proxyUsername",
+        "proxyPassword",
+        "readConcernLevel",
+        "readPreference",
+        "readPreferenceTags",
+        "replicaSet",
+        "retryReads",
+        "retryWrites",
+        "serverMonitoringMode",
+        "serverSelectionTimeoutMS",
+        "serverSelectionTryOnce",
+        "socketTimeoutMS",
+        "srvMaxHosts",
+        "srvServiceName",
+        "ssl",
+        "tls",
+        "tlsAllowInvalidCertificates",
+        "tlsAllowInvalidHostnames",
+        "tlsCAFile",
+        "tlsCertificateKeyFile",
+        "tlsCertificateKeyFilePassword",
+        "tlsDisableCertificateRevocationCheck",
+        "tlsDisableOCSPEndpointCheck",
+        "tlsInsecure",
+        "w",
+        "waitQueueTimeoutMS",
+        "wTimeoutMS",
+        "zlibCompressionLevel",
+    ]
+)
+
 
 def _unquoted_percent(s: str) -> bool:
     """Check for unescaped percent signs.
@@ -550,3 +601,11 @@ def _validate_uri(
         "options": options,
         "fqdn": fqdn,
     }
+
+
+def _make_options_case_sensative(options: _CaseInsensitiveDictionary) -> dict[str, Any]:
+    case_sensative = {}
+    for option in URI_OPTIONS:
+        if option.lower() in options:
+            case_sensative[option] = options[option]
+    return case_sensative