Update src/agri_predict/config.py

src/agri_predict/config.py

@@ -9,7 +9,6 @@ load_dotenv()
 
 def get_collections():
     """Return a dict with MongoDB collections used by the app.
-
     Loads `MONGO_URI` from environment and connects with TLS CA validation.
     Raises RuntimeError if `MONGO_URI` is missing.
     """
@@ -17,7 +16,14 @@ def get_collections():
     if not mongo_uri:
         raise RuntimeError("MONGO_URI is not set in the environment")
 
-    client = MongoClient(mongo_uri, tlsCAFile=certifi.where())
+    # Check if it's a cloud cluster (mongodb+srv or contains mongodb.net)
+    # Use SSL for cloud clusters, skip SSL for self-hosted instances
+    if "mongodb+srv" in mongo_uri or "mongodb.net" in mongo_uri:
+        client = MongoClient(mongo_uri, tlsCAFile=certifi.where())
+    else:
+        # Self-hosted MongoDB - connect without SSL
+        client = MongoClient(mongo_uri)
+    
     db = client["AgriPredict"]
     
     # Create indexes for better query performance (safe to call multiple times)