blob: bcb6b94edf4eac51b969af7443eb3036ef65eb05 (
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
60
61
62
63
64
65
|
require_relative "rest_list_entry"
require_relative "../../data_handler/organization_invites_data_handler"
require_relative "../../../json_compat"
class Chef
module ChefFS
module FileSystem
module ChefServer
# /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 display_path
"/invitations.json"
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::HTTPClientException => 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
end
|
