require 'resolv'

module GitlabCtl
  class PostgreSQL
    class EE
      class << self
        def get_primary
          consul_enable = node_attributes.dig('consul', 'enable')
          postgresql_service_name = node_attributes.dig('patroni', 'scope')

          raise 'Consul agent is not enabled on this node' unless consul_enable

          raise 'PostgreSQL service name is not defined' if postgresql_service_name.nil? || postgresql_service_name.empty?

          result = []
          Resolv::DNS.open(nameserver_port: [['127.0.0.1', consul_dns_port]]) do |dns|
            ['master', 'standby-leader'].each do |postgresql_primary_service_name|
              result = dns.getresources("#{postgresql_primary_service_name}.#{postgresql_service_name}.service.consul", Resolv::DNS::Resource::IN::SRV).map do |srv|
                "#{dns.getaddress(srv.target)}:#{srv.port}"
              end

              return result unless result.empty?
            end
          end

          raise 'PostgreSQL Primary could not be found via Consul DNS'
        end

        def consul_dns_port
          node_attributes.dig('consul', 'configuration', 'ports', 'dns') || 8600
        end

        private

        def node_attributes
          @node_attributes ||= GitlabCtl::Util.get_node_attributes
        end
      end
    end
  end
end