Class: Minfra::Cli::HieraLooker

Inherits:
Object
  • Object
show all
Includes:
Logging
Defined in:
lib/minfra/cli/hiera_looker.rb

Instance Method Summary collapse

Methods included from Logging

#debug, #deprecated, #error, #exit_error, #info, #warn

Constructor Details

#initialize(root:, env_name:, env_path:, debug_lookups: false, backends: nil) ⇒ HieraLooker

Returns a new instance of HieraLooker.



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/minfra/cli/hiera_looker.rb', line 9

def initialize(root:, env_name:, env_path:, debug_lookups: false, backends: nil)
  @root = Pathname.new(root)
  @env_name = env_name
  @cache = {}

  @hiera = Hiera.new(config: @root.join('hiera.yaml').to_s)
  # now that hiera has loaded the backends let's patch 'em
  
  Hiera.logger = :noop
  if backends && !backends.empty?
    @hiera.config[:backends] = backends
    Hiera::Config.load_backends
  end

  hiera_main_path = @root.join("hieradata/#{env_path}/#{env_name}.eyaml")

  raise("unknown environment #{@env_name}, I expect a file at #{hiera_main_path}") unless hiera_main_path.exist?

  scope = { 'hieraroot' => @root.to_s, 'env' => @env_name }
  # we have to do this first as the hierarchy definitions only are valid if with the env variables injected
  node_scope = @hiera.lookup('env', {}, scope, nil, :priority)
  @scope = scope.merge(node_scope)

  @special_lookups = @hiera.lookup('lookup_options', {}, scope, nil, :priority)
  @debug_lookups = debug_lookups
  debug("hiera: scope -> #{@scope}") if @debug_lookups
end

Instance Method Details

#l(value, default = nil) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/minfra/cli/hiera_looker.rb', line 37

def l(value, default = nil)
  return @cache[value] if @cache.key?(value)

  values = value.split('.')
  fst_value = values.shift

  lookup_type = if @special_lookups[fst_value]
                  { merge_behavior: @special_lookups[fst_value]['merge'].to_sym }
                else
                  :deep
                end
  retry_attempts = 0
  begin
    result = @hiera.lookup(fst_value, default, @scope, nil, lookup_type)
  rescue GPGME::Error::NoSecretKey
    error("Have no gpg configuration to decrypt your hiera key: #{value}")
    raise Errors::ExitError
  rescue GPGME::Error::BadPassphrase
    error("Your password was wrong for hiera key: #{value}")
    raise Errors::ExitError
  rescue GPGME::Error
    error("Having decrypt problems for hiera key: #{value}, #{$ERROR_INFO.message}")
    raise Errors::ExitError
  rescue Errno::ENOMEM # see https://github.com/ueno/ruby-gpgme/issues/147
    retry_attempts += 1
    sleep 1
    retry if retry_attempts < 5
  end
  result = result.dig(*values) if !values.empty? && result.is_a?(Hash) # we return nil or the scalar value and only drill down on hashes
  result = default if result.nil?
  result = Hashie::Mash.new(result) if result.is_a?(Hash)
  @cache[value] = result
  debug "hiera: #{value} -> #{result.inspect}" if @debug_lookups
  result
end

#l!(value, default = nil) ⇒ Object 



73
74
75
76
77
78
 
# File 'lib/minfra/cli/hiera_looker.rb', line 73

def l!(value, default = nil)
  v = l(value, default)
  raise("Value not found! #{value}") if v.nil?

  v
end