Class: Chef::ApiClient::Registration

Inherits:
Object
  • Object
show all
Defined in:
lib/chef/api_client/registration.rb

Overview

Chef::ApiClient::Registration

Manages the process of creating or updating a Chef::ApiClient on the server and writing the resulting private key to disk. Registration uses the validator credentials for its API calls. This allows it to bootstrap a new client/node identity by borrowing the validator client identity when creating a new client.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, destination) ⇒ Registration

Returns a new instance of Registration.



36
37
38
39
40
# File 'lib/chef/api_client/registration.rb', line 36

def initialize(name, destination)
  @name = name
  @destination = destination
  @server_generated_private_key = nil
end

Instance Attribute Details

#destinationObject (readonly)

Returns the value of attribute destination.



33
34
35
# File 'lib/chef/api_client/registration.rb', line 33

def destination
  @destination
end

#nameObject (readonly)

Returns the value of attribute name.



34
35
36
# File 'lib/chef/api_client/registration.rb', line 34

def name
  @name
end

Instance Method Details

#assert_destination_writable!Object



68
69
70
71
72
# File 'lib/chef/api_client/registration.rb', line 68

def assert_destination_writable!
  if (File.exists?(destination) && !File.writable?(destination)) or !File.writable?(File.dirname(destination))
    raise Chef::Exceptions::CannotWritePrivateKey, "I cannot write your private key to #{destination} - check permissions?"
  end
end

#createObject



91
92
93
94
95
# File 'lib/chef/api_client/registration.rb', line 91

def create
  response = http_api.post("clients", post_data)
  @server_generated_private_key = response["private_key"]
  response
end

#create_or_updateObject



82
83
84
85
86
87
88
89
# File 'lib/chef/api_client/registration.rb', line 82

def create_or_update
  create
rescue Net::HTTPServerException => e
  # If create fails because the client exists, attempt to update. This
  # requires admin privileges.
  raise unless e.response.code == "409"
  update
end

#file_flagsObject



153
154
155
156
157
158
159
160
# File 'lib/chef/api_client/registration.rb', line 153

def file_flags
  base_flags = File::CREAT|File::TRUNC|File::RDWR
  # Windows doesn't have symlinks, so it doesn't have NOFOLLOW
  if defined?(File::NOFOLLOW) && !Chef::Config[:follow_client_key_symlink]
    base_flags |= File::NOFOLLOW
  end
  base_flags
end

#generated_private_keyObject



145
146
147
# File 'lib/chef/api_client/registration.rb', line 145

def generated_private_key
  @generated_key ||= OpenSSL::PKey::RSA.generate(2048)
end

#generated_public_keyObject



149
150
151
# File 'lib/chef/api_client/registration.rb', line 149

def generated_public_key
  generated_private_key.public_key.to_pem
end

#http_apiObject



124
125
126
127
128
# File 'lib/chef/api_client/registration.rb', line 124

def http_api
  @http_api_as_validator ||= Chef::REST.new(Chef::Config[:chef_server_url],
                                            Chef::Config[:validation_client_name],
                                            Chef::Config[:validation_key])
end

#post_dataObject



117
118
119
120
121
# File 'lib/chef/api_client/registration.rb', line 117

def post_data
  post_data = { :name => name, :admin => false }
  post_data[:public_key] = generated_public_key if self_generate_keys?
  post_data
end

#private_keyObject



137
138
139
140
141
142
143
# File 'lib/chef/api_client/registration.rb', line 137

def private_key
  if self_generate_keys?
    generated_private_key.to_pem
  else
    @server_generated_private_key
  end
end

#put_dataObject



107
108
109
110
111
112
113
114
115
# File 'lib/chef/api_client/registration.rb', line 107

def put_data
  base_put_data = { :name => name, :admin => false }
  if self_generate_keys?
    base_put_data[:public_key] = generated_public_key
  else
    base_put_data[:private_key] = true
  end
  base_put_data
end

#runObject

Runs the client registration process, including creating the client on the chef-server and writing its private key to disk. – If client creation fails with a 5xx, it is retried up to 5 times. These retries are on top of the retries with randomized exponential backoff built in to Chef::REST. The retries here are a workaround for failures caused by resource contention in Hosted Chef when creating a very large number of clients simultaneously, (e.g., spinning up 100s of ec2 nodes at once). Future improvements to the affected component should make these retries unnecessary.



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
# File 'lib/chef/api_client/registration.rb', line 52

def run
  assert_destination_writable!
  retries = Config[:client_registration_retries] || 5
  begin
    create_or_update
  rescue Net::HTTPFatalError => e
    # HTTPFatalError implies 5xx.
    raise if retries <= 0
    retries -= 1
    Chef::Log.warn("Failed to register new client, #{retries} tries remaining")
    Chef::Log.warn("Response: HTTP #{e.response.code} - #{e}")
    retry
  end
  write_key
end

#self_generate_keys?Boolean

Whether or not to generate keys locally and post the public key to the server. Delegates to ‘Chef::Config.local_key_generation`. Servers before 11.0 do not support this feature.

Returns:

  • (Boolean)


133
134
135
# File 'lib/chef/api_client/registration.rb', line 133

def self_generate_keys?
  Chef::Config.local_key_generation
end

#updateObject



97
98
99
100
101
102
103
104
105
# File 'lib/chef/api_client/registration.rb', line 97

def update
  response = http_api.put("clients/#{name}", put_data)
  if response.respond_to?(:private_key) # Chef 11
    @server_generated_private_key = response.private_key
  else # Chef 10
    @server_generated_private_key = response["private_key"]
  end
  response
end

#write_keyObject



74
75
76
77
78
79
80
# File 'lib/chef/api_client/registration.rb', line 74

def write_key
  ::File.open(destination, file_flags, 0600) do |f|
    f.print(private_key)
  end
rescue IOError => e
  raise Chef::Exceptions::CannotWritePrivateKey, "Error writing private key to #{destination}: #{e}"
end