richdynamix / magestead

require 'json'

class Puppet::Provider::Mongodb < Puppet::Provider

  # Without initvars commands won't work.

  initvars

  commands :mongo => 'mongo'

  # Optional defaults file

  def self.mongorc_file

    if File.file?("#{Facter.value(:root_home)}/.mongorc.js")

      "load('#{Facter.value(:root_home)}/.mongorc.js'); "

    else

      nil

    end

  end

  def mongorc_file

    self.class.mongorc_file

  end

  def self.get_mongod_conf_file

    if File.exists? '/etc/mongod.conf'

      file = '/etc/mongod.conf'

    else

      file = '/etc/mongodb.conf'

    end

    file

  end

  def self.get_conn_string

    file = get_mongod_conf_file

    # The mongo conf is probably a key-value store, even though 2.6 is

    # supposed to use YAML, because the config template is applied

    # based on $::mongodb::globals::version which is the user will not

    # necessarily set. This attempts to get the port from both types of

    # config files.

    config = YAML.load_file(file)

    if config.kind_of?(Hash) # Using a valid YAML file for mongo 2.6

      bindip = config['net.bindIp']

      port = config['net.port']

      shardsvr = config['sharding.clusterRole']

      confsvr = config['sharding.clusterRole']

    else # It has to be a key-value config file

      config = {}

      File.readlines(file).collect do |line|

         k,v = line.split('=')

         config[k.rstrip] = v.lstrip.chomp if k and v

      end

      bindip = config['bind_ip']

      port = config['port']

      shardsvr = config['shardsvr']

      confsvr = config['confsvr']

    end

    if bindip

      first_ip_in_list = bindip.split(',').first

      if first_ip_in_list.eql? '0.0.0.0'

        ip_real = '127.0.0.1'

      else

        ip_real = first_ip_in_list

      end

    end

    if port

      port_real = port

    elsif !port and (confsvr.eql? 'configsvr' or confsvr.eql? 'true')

      port_real = 27019

    elsif !port and (shardsvr.eql? 'shardsvr' or shardsvr.eql? 'true')

      port_real = 27018

    else

      port_real = 27017

    end

    "#{ip_real}:#{port_real}"

  end

  def self.db_ismaster

    cmd_ismaster = 'printjson(db.isMaster())'

    if mongorc_file

        cmd_ismaster = mongorc_file + cmd_ismaster

    end

    out = mongo(['admin', '--quiet', '--host', get_conn_string, '--eval', cmd_ismaster])

    out.gsub!(/ObjectId\(([^)]*)\)/, '\1')

    out.gsub!(/ISODate\((.+?)\)/, '\1 ')

    out.gsub!(/^Error\:.+/, '')

    res = JSON.parse out

    return res['ismaster']

  end

  def db_ismaster

    self.class.db_ismaster

  end

  def self.auth_enabled

    auth_enabled = false

    file = get_mongod_conf_file

    config = YAML.load_file(file)

    if config.kind_of?(Hash)

      auth_enabled = config['security.authorization']

    else # It has to be a key-value store

      config = {}

      File.readlines(file).collect do |line|

        k,v = line.split('=')

        config[k.rstrip] = v.lstrip.chomp if k and v

      end

      auth_enabled = config['auth']

    end

    return auth_enabled

  end

  # Mongo Command Wrapper

  def self.mongo_eval(cmd, db = 'admin', retries = 10, host = nil)

    retry_count = retries

    retry_sleep = 3

    if mongorc_file

        cmd = mongorc_file + cmd

    end

    out = nil

    retry_count.times do |n|

      begin

        if host

          out = mongo([db, '--quiet', '--host', host, '--eval', cmd])

        else

          out = mongo([db, '--quiet', '--host', get_conn_string, '--eval', cmd])

        end

      rescue => e

        Puppet.debug "Request failed: '#{e.message}' Retry: '#{n}'"

        sleep retry_sleep

        next

      end

      break

    end

    if !out

      raise Puppet::ExecutionFailure, "Could not evalute MongoDB shell command: #{cmd}"

    end

    out.gsub!(/ObjectId\(([^)]*)\)/, '\1')

    out.gsub!(/^Error\:.+/, '')

    out

  end

  def mongo_eval(cmd, db = 'admin', retries = 10, host = nil)

    self.class.mongo_eval(cmd, db, retries, host)

  end

  # Mongo Version checker

  def self.mongo_version

  end

  def mongo_version

    self.class.mongo_version

  end

  def mongo_24?

    self.class.mongo_24?

  end

end