Sha256: 2157948d11003db328ced636495174c30454a66afa682468b95286d4631b983f
Contents?: true
Size: 1.96 KB
Versions: 43
Compression:
Stored size: 1.96 KB
Contents
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
Version data entries
43 entries across 43 versions & 1 rubygems