feat: improve mongodb SCRAM-SHA-1 auth error msg (#549)

Author: amadeusz-ds

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.0.49
+
+* **Improve MongoDB SCRAM-SHA-1 authentication error message**
+
 ## 1.0.48
 
 * **Improve Jira attachment path results**

unstructured_ingest/__version__.py

@@ -1 +1 @@
-__version__ = "1.0.48"  # pragma: no cover
+__version__ = "1.0.49"  # pragma: no cover

unstructured_ingest/processes/connectors/mongodb.py

@@ -90,6 +90,22 @@ def get_client(self) -> Generator["MongoClient", None, None]:
                 "server_api": ServerApi(version=SERVER_API_VERSION),
             }
         with MongoClient(**client_kwargs) as client:
+            # UnsupportedDigestmodError means that SCRAM-SHA-1 is disabled
+            # It uses md5 which is unavailable on FIPS images
+            try:
+                from hashlib import UnsupportedDigestmodError  # type: ignore[attr-defined]
+            except ImportError:
+                from _hashlib import UnsupportedDigestmodError  # type: ignore[attr-defined]
+
+            # Check if the authentication mechanism is supported
+            try:
+                client.admin.command("ping")
+            except UnsupportedDigestmodError as e:
+                raise ConnectionError(
+                    "Authentication using SCRAM-SHA-1 is disabled. "
+                    "Use SCRAM-SHA-256 instead. "
+                    "See: https://www.mongodb.com/docs/manual/core/security-scram/"
+                ) from e
             yield client
 
 
@@ -117,7 +133,7 @@ def precheck(self) -> None:
                 database_names = client.list_database_names()
                 database_name = self.index_config.database
                 if database_name not in database_names:
-                    raise DestinationConnectionError(
+                    raise SourceConnectionError(
                         "database {} does not exist: {}".format(
                             database_name, ", ".join(database_names)
                         )
@@ -303,7 +319,7 @@ def precheck(self) -> None:
                 collection_names = database.list_collection_names()
                 collection_name = self.upload_config.collection
                 if collection_name not in collection_names:
-                    raise SourceConnectionError(
+                    raise DestinationConnectionError(
                         "collection {} does not exist: {}".format(
                             collection_name, ", ".join(collection_names)
                         )