blob: e31d9bdf03a12c599b7d7a57757059ccdd78a551 (
plain)
1
2
3
4
5
6
7
8
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
require 'chef/chef_fs/file_system/rest_list_entry'
require 'chef/chef_fs/data_handler/organization_invites_data_handler'
require 'chef/json_compat'
class Chef
module ChefFS
module FileSystem
# /organizations/NAME/invitations.json
# read data from:
# - GET /organizations/NAME/association_requests
# write data to:
# - remove from list: DELETE /organizations/NAME/association_requests/id
# - add to list: POST /organizations/NAME/association_requests
class OrganizationInvitesEntry < RestListEntry
def initialize(name, parent, exists = nil)
super(name, parent)
@exists = exists
end
def data_handler
Chef::ChefFS::DataHandler::OrganizationInvitesDataHandler.new
end
# /organizations/foo/invites.json -> /organizations/foo/association_requests
def api_path
File.join(parent.api_path, 'association_requests')
end
def exists?
parent.exists?
end
def delete(_recurse)
raise Chef::ChefFS::FileSystem::OperationNotAllowedError.new(:delete, self)
end
def write(contents)
desired_invites = minimize_value(Chef::JSONCompat.parse(contents, :create_additions => false))
actual_invites = _read_json.inject({}) { |h,val| h[val['username']] = val['id']; h }
invites = actual_invites.keys
(desired_invites - invites).each do |invite|
begin
rest.post(api_path, { 'user' => invite })
rescue Net::HTTPServerException => e
if e.response.code == '409'
Chef::Log.warn("Could not invite #{invite} to organization #{org}: #{api_error_text(e.response)}")
else
raise
end
end
end
(invites - desired_invites).each do |invite|
rest.delete(File.join(api_path, actual_invites[invite]))
end
end
end
end
end
end
|
