Class: Puppet::Provider::ElasticUserRoles

Inherits:
ElasticYaml
  • Object
show all
Defined in:
lib/puppet/provider/elastic_user_roles.rb

Overview

Provider to help manage file-based X-Pack user/role configuration files.

Class Method Summary collapse

Class Method Details

.parse(text) ⇒ Object

Override the ancestor ‘parse` method to process a users/roles file managed by the Elasticsearch user tools.



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
 
# File 'lib/puppet/provider/elastic_user_roles.rb', line 10

def self.parse(text)
  lines = text.split("\n").map(&:strip).select do |line|
    # Strip comments
    (!line.start_with? '#') && !line.empty?
  end
  lines = lines.map do |line|
    # Turn array of roles into array of users that have the role
    role, users = line.split(':')
    users.split(',').map do |user|
      { user => [role] }
    end
  end
  lines = lines.flatten.reduce({}) do |hash, user|
    # Gather up user => role hashes by append-merging role lists
    hash.merge(user) { |_, o, n| o + n }
  end
  lines = lines.map do |user, roles|
    # Map those hashes into what the provider expects
    {
      name: user,
      roles: roles
    }
  end
  lines.to_a
end

.skip_record?(_record) ⇒ Boolean

Returns:

  • (Boolean) 


56
57
58
 
# File 'lib/puppet/provider/elastic_user_roles.rb', line 56

def self.skip_record?(_record)
  false
end

.to_file(records) ⇒ Object

Represent this user/role record as a correctly-formatted config file.



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/puppet/provider/elastic_user_roles.rb', line 37

def self.to_file(records)
  debug "Flushing: #{records.inspect}"
  records = records.map do |record|
    record[:roles].map do |r|
      { [record[:name]] => r }
    end
  end
  records = records.flatten.map(&:invert).reduce({}) do |acc, role|
    acc.merge(role) { |_, o, n| o + n }
  end
  records = records.delete_if do |_, users|
    users.empty?
  end
  records = records.map do |role, users|
    "#{role}:#{users.join(',')}"
  end
  "#{records.join("\n")}\n"
end