[TEMP] debug

Author: Johan De Wit

lib/puppet/provider/mongodb_replset/mongo.rb

@@ -130,6 +130,7 @@ def master_host(members)
   end
 
   def self.replset_properties
+    Puppet.debug('XXXXXXXXX in replset_properties')
     conn_string = conn_string # rubocop:disable Lint/SelfAssignment
     begin
       output = mongo_command('rs.conf()', conn_string)
@@ -144,7 +145,9 @@ def self.replset_properties
       end
       nil
     rescue Puppet::ExecutionFailure => e
+      #if e.message =~ %r{command replSetGetConfig requires authentication} || e.message =~ %r{not authorized on admin to execute command} || e.message =~ %r{no replset config has been received}
       if e.message =~ %r{command replSetGetConfig requires authentication} || e.message =~ %r{not authorized on admin to execute command}
+        Puppet.debug('XXXXXXXXX in replset_properties rescue part')
         output = mongo_command('rs.status()', conn_string)
         if output['members']
           memb = []
@@ -168,36 +171,48 @@ def get_hosts_status(members)
     members.select do |member|
       host = member['host']
       Puppet.debug "Checking replicaset member #{host} ..."
-      status = rs_status(host)
-      raise Puppet::Error, "Can't configure replicaset #{name}, host #{host} is not supposed to be part of a replicaset." if status.key?('errmsg') && status['errmsg'] == 'not running with --replSet'
-
-      if auth_enabled && status.key?('errmsg') && (status['errmsg'].include?('requires authentication') || status['errmsg'].include?('not authorized on admin') || status['errmsg'].include?('Authentication failed'))
-        Puppet.warning "Host #{host} is available, but you are unauthorized because of authentication is enabled: #{auth_enabled}"
-        alive.push(member)
-      end
-
-      # TODO: check here how to get at this place ...
-      if status.key?('errmsg') && status['errmsg'].include?('no replset config has been received')
-        Puppet.debug 'Mongo v4 rs.status() RS not initialized output'
-        alive.push(member)
-      end
-
-      if status.key?('set')
-        raise Puppet::Error, "Can't configure replicaset #{name}, host #{host} is already part of another replicaset." if status['set'] != name
-
-        # This node is alive and supposed to be a member of our set
-        Puppet.debug "Host #{host} is available for replset #{status['set']}"
-        alive.push(member)
-      elsif status.key?('info')
-        Puppet.debug "Host #{host} is alive but unconfigured: #{status['info']}"
-        alive.push(member)
-      end
-    rescue Puppet::ExecutionFailure => e
-      if e.message =~ %r{command replSetGetStatus requires authentication}
-        Puppet.debug("Node #{host} is reachable but requires authentication: RS not initialized")
-        alive.push(member)
-      else
-        Puppet.warning "Can't connect to replicaset member #{host} (Errormsg: #{e.message})."
+      begin
+        status = rs_status(host)
+        Puppet.debug('XXXXXXXXXXXXXX should not get here since I dont have a replicaset')
+        raise Puppet::Error, "Can't configure replicaset #{name}, host #{host} is not supposed to be part of a replicaset." if status.key?('errmsg') && status['errmsg'] == 'not running with --replSet'
+
+#      if auth_enabled && status.key?('errmsg')
+#        Puppet.debug "In auth_enabled && status.key?('errmsg')"
+#        if status['errmsg'].include?('requires authentication') || status['errmsg'].include?('not authorized on admin') || status['errmsg'].include?('Authentication failed')
+#          Puppet.debug "In auth_enabled && status.key?('errmsg') need authentication"
+#          Puppet.warning "Host #{host} is available, but you are unauthorized because of authentication is enabled: #{auth_enabled}"
+#          alive.push(member)
+#        elsif status['errmsg'].include?('no replset config has been received')
+#          Puppet.debug 'Mongo rs.status() RS not initialized output'
+#          alive.push(member)
+#        end
+#      end
+
+        if status.key?('set')
+          raise Puppet::Error, "Can't configure replicaset #{name}, host #{host} is already part of another replicaset." if status['set'] != name
+
+          # This node is alive and supposed to be a member of our set
+          Puppet.debug "Host #{host} is available for replset #{status['set']}"
+          alive.push(member)
+        elsif status.key?('info')
+          Puppet.debug "Host #{host} is alive but unconfigured: #{status['info']}"
+          alive.push(member)
+        end
+      rescue Puppet::ExecutionFailure => e
+        Puppet.debug('XXXXXXXXXXXX in rescue checking connection mebers')
+        if auth_enabled
+          case e.message
+          when %r{no replset config has been received}
+            Puppet.warning('No replicaset config received, needs initialisation')
+          when /Authentication failed/, /not authorized on admin/, /Authentication failed/
+            Puppet.warning "Host #{host} is available, but you are unauthorized because of authentication is enabled: #{auth_enabled}"
+          when /command replSetGetStatus requires authentication/
+            Puppet.warning("Node #{host} is reachable but requires authentication: ReplicaSet not initialized")
+          end
+          alive.push(member)
+        else
+          Puppet.warning "Can't connect to replicaset member #{host} (Errormsg: #{e.message})."
+        end
       end
     end
     alive.uniq!
@@ -410,19 +425,19 @@ def mongo_command(command, host, retries = 4)
   end
 
   def self.mongo_command(command, host = nil, retries = 4)
-    begin
+    #begin
       output = mongo_eval("EJSON.stringify(#{command})", 'admin', retries, host)
-    rescue Puppet::ExecutionFailure => e
-      if e.message =~ %r{no replset config has been received} || e.message =~ %r{Authentication failed}
+    #rescue Puppet::ExecutionFailure => e
+      #if e.message =~ %r{no replset config has been received} || e.message =~ %r{Authentication failed}
+      if output =~ %r{no replset config has been received} || output =~ %r{Authentication failed}
         output = '{}'
-      else
-        Puppet.debug "Got an exception: #{e}"
-        raise
+     # else
+     #   Puppet.debug "Got an exception: #{e}"
+     #   raise
       end
-    end
+    #end
 
     # Hack to avoid non-json empty sets
-    output = '{}' if output =~ %r{no replset config} || output =~ %r{Authentication failed}
     output = '{}' if output == "null\n"
     output = '{}' if output == "\nnull\n"
 

lib/puppet/provider/mongodb_user/mongodb.rb

@@ -78,6 +78,7 @@ def create
         end
       end
 
+      Puppet.debug("XXXXXXXXXX about to create user with command: #{command}")
       mongo_eval("db.runCommand(#{command.to_json})", @resource[:database])
     else
       Puppet.warning 'User creation is available only from master host'