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