Release 3.4.2

Author: ptorresred

VERSION

@@ -1 +1 @@
-3.4.1
+3.4.2

resources/lib/service.rb

@@ -609,7 +609,15 @@ def execute(node=nil, service)
     utils = Utils.instance
     saved = false
     protected_services = ['s3', 'redis', 'postgresql'] # Mandatory services that cannot be disabled if only one node is running
-    
+
+    if service == 'postgresql' && !Dir.exist?('/var/lib/pgsql/data')
+      puts 'PostgreSQL already disabled.'
+      return
+    elsif service == 'postgresql' && utils.postgres_master?
+      puts 'ERROR: Cannot disable PostgreSQL on this node because it is the master.'
+      return
+    end
+
     begin
       nodes = utils.check_nodes(node || Socket.gethostname.split(".").first)
       if nodes.count == 0
@@ -790,6 +798,14 @@ def execute(node, *services)
       end
     end
 
+    if services.include?('postgresql') && !Dir.exist?('/var/lib/pgsql/data')
+      puts 'PostgreSQL already disabled.'
+      return
+    elsif services.include?('postgresql') && utils.postgres_master?
+      puts 'ERROR: Cannot stop PostgreSQL on this node because it is the master.'
+      return
+    end
+
     nodes.each do |n|
       node = utils.get_node(n)
 

resources/lib/utils.rb

@@ -78,6 +78,18 @@ def get_logstash_plugins
     logstash_api_query('_node/plugins')
   end
 
+  def postgres_master?
+    pg_data = '/var/lib/pgsql/data'
+    standby_file = File.join(pg_data, 'standby.signal')
+    pg_conf = File.join(pg_data, 'postgresql.conf')
+
+    return false if File.exist?(standby_file) ||
+                    File.read(pg_conf) =~ /primary_conninfo\s*=/ ||
+                    File.read(pg_conf) =~ /promote_trigger_file\s*=/
+
+    true
+  end
+
   #  curl -XGET 'localhost:9600/_node/stats/pipelines/vault-pipeline'
 
   def logstash_api_query(action)