Fixes to use MongoDB 3.6

Author: UnderGreen

library/mongodb_replication.py

@@ -45,6 +45,11 @@
             - The port to connect to
         required: false
         default: 27017
+    login_database:
+        description:
+            - The database where login credentials are stored
+        required: false
+        default: admin
     replica_set:
         description:
             - Replica set to connect to (automatically connects to primary for writes)
@@ -69,6 +74,12 @@
         description:
             - Whether to use an SSL connection when connecting to the database
         default: False
+    ssl_cert_reqs:
+        description:
+            - Specifies whether a certificate is required from the other side of the connection, and whether it will be validated if provided.
+        required: false
+        default: "CERT_REQUIRED"
+        choices: ["CERT_REQUIRED", "CERT_OPTIONAL", "CERT_NONE"]
     build_indexes:
         description:
             - Determines whether the mongod builds indexes on this member.
@@ -146,6 +157,7 @@
   sample: "replica"
 '''
 import ConfigParser
+import ssl as ssl_lib
 import time
 from distutils.version import LooseVersion
 try:
@@ -324,11 +336,13 @@ def main():
             login_password=dict(default=None, no_log=True),
             login_host=dict(default='localhost'),
             login_port=dict(default='27017'),
+            login_database=dict(default="admin"),
             replica_set=dict(default=None),
             host_name=dict(default='localhost'),
             host_port=dict(default='27017'),
             host_type=dict(default='replica', choices=['replica','arbiter']),
-            ssl=dict(default='false'),
+            ssl=dict(default=False, type='bool'),
+            ssl_cert_reqs=dict(default='CERT_REQUIRED', choices=['CERT_NONE', 'CERT_OPTIONAL', 'CERT_REQUIRED']),
             build_indexes = dict(type='bool', default='yes'),
             hidden = dict(type='bool', default='no'),
             priority = dict(default='1.0'),
@@ -345,6 +359,7 @@ def main():
     login_password = module.params['login_password']
     login_host = module.params['login_host']
     login_port = module.params['login_port']
+    login_database = module.params['login_database']
     replica_set = module.params['replica_set']
     host_name = module.params['host_name']
     host_port = module.params['host_port']
@@ -359,15 +374,36 @@ def main():
         if replica_set is None:
             module.fail_json(msg='replica_set parameter is required')
         else:
-            client = MongoClient(login_host, int(login_port), replicaSet=replica_set,
-                                 ssl=ssl, serverSelectionTimeoutMS=5000)
-
+            connection_params = {
+                "host": login_host,
+                "port": int(login_port),
+                "username": login_user,
+                "password": login_password,
+                "authsource": login_database,
+                "serverselectiontimeoutms": 5000,
+                "replicaset": replica_set,
+            }
+
+        if ssl:
+            connection_params["ssl"] = ssl
+            connection_params["ssl_cert_reqs"] = getattr(ssl_lib, module.params['ssl_cert_reqs'])
+
+        client = MongoClient(**connection_params)
         authenticate(client, login_user, login_password)
         client['admin'].command('replSetGetStatus')
 
     except ServerSelectionTimeoutError:
         try:
-            client = MongoClient(login_host, int(login_port), ssl=ssl)
+            connection_params = {
+                "host": login_host,
+                "port": int(login_port),
+            }
+
+            if ssl:
+                connection_params["ssl"] = ssl
+                connection_params["ssl_cert_reqs"] = getattr(ssl_lib, module.params['ssl_cert_reqs'])
+
+            client = MongoClient(**connection_params)
             authenticate(client, login_user, login_password)
             if state == 'present':
                 new_host = { '_id': 0, 'host': "{0}:{1}".format(host_name, host_port) }