def get_attr(conninfo, credentials, path=None, id_=None):
    assert (path is not None) ^ (id_ is not None)
    ref = unicode(path) if path else unicode(id_)
    uri = build_files_uri([ref, "info", "attributes"])

    method = "GET"
    return request.rest_request(conninfo, credentials, method, unicode(uri))

def smb_modify_share(conninfo, credentials, id_, share_name,
        fs_path, description, read_only, allow_guest_access,
        allow_fs_path_create=False, if_match=None,
        access_based_enumeration_enabled=None):
    id_ = unicode(id_)
    allow_fs_path_create_ = "true" if allow_fs_path_create else "false"

    if_match = if_match if if_match is None else unicode(if_match)

    method = "PUT"
    uri = "/v1/smb/shares/%s?allow-fs-path-create=%s" % \
        (id_, allow_fs_path_create_)

    share_info = {
        'id': id_,
        'share_name':         unicode(share_name),
        'fs_path':            unicode(fs_path),
        'description':        unicode(description),
        'read_only':          bool(read_only),
        'allow_guest_access': bool(allow_guest_access)
    }

    # "ABE enabled" is an optional field. It may be absent if we use this client
    # code with the clusters running previous versions of qfsd.
    if access_based_enumeration_enabled is not None:
        share_info['access_based_enumeration_enabled'] = \
            bool(access_based_enumeration_enabled)

    return request.rest_request(conninfo, credentials, method, uri,
        body=share_info, if_match=if_match)

def list_group(conninfo, credentials, group_id):
    group_id = int(group_id)

    method = "GET"
    uri = "/v1/groups/%d" % group_id

    return request.rest_request(conninfo, credentials, method, uri)

def unpack_identity(conninfo, credentials, auth_id):
    auth_id = int(auth_id)

    method = "GET"
    uri = "/v1/users/" + str(auth_id) + "/unpack-identity"

    return request.rest_request(conninfo, credentials, method, uri)

def iops_get(conninfo, credentials, specific_type=None):
    method = 'GET'
    uri = UriBuilder(path='/v1/analytics/iops')
    if specific_type:
        uri.add_query_param('type', specific_type)

    return request.rest_request(conninfo, credentials, method, str(uri))

def list_groups_for_user(conninfo, credentials, user_id):
    user_id = int(user_id)

    method = "GET"
    uri = "/v1/users/%d/groups/" % user_id

    return request.rest_request(conninfo, credentials, method, uri)

def current_activity_get(conninfo, credentials, specific_type=None):
    method = "GET"
    uri = UriBuilder(path="/v1/analytics/activity/current")
    if specific_type:
        uri.add_query_param('type', specific_type)

    return request.rest_request(conninfo, credentials, method, str(uri))

def delete_group(conninfo, credentials, group_id):
    group_id = int(group_id)

    method = "DELETE"
    uri = "/v1/groups/%d" % group_id

    return request.rest_request(conninfo, credentials, method, uri)

def nfs_list_share(conninfo, credentials, id_):
    id_ = unicode(id_)

    method = "GET"
    uri = "/v1/nfs/shares/%s" % id_

    return request.rest_request(conninfo, credentials, method, uri)

def group_get_members(conninfo, credentials, group_id):
    group_id = int(group_id)

    method = "GET"
    uri = "/v1/groups/%d/members/" % group_id

    return request.rest_request(conninfo, credentials, method, uri)

def set_file_attr(conninfo, credentials, mode, owner, group, size,
                  creation_time, modification_time, change_time, id_,
                  if_match=None):
    uri = build_files_uri([id_, "info", "attributes"])
    if_match = None if not if_match else unicode(if_match)

    method = "PATCH"

    config = {}
    if mode:
        config['mode'] = unicode(mode)
    if owner:
        config['owner'] = unicode(owner)
    if group:
        config['group'] = unicode(group)
    if size:
        config['size'] = unicode(size)
    if creation_time:
        config['creation_time'] = unicode(creation_time)
    if modification_time:
        config['modification_time'] = \
            unicode(modification_time)
    if change_time:
        config['change_time'] = unicode(change_time)

    return request.rest_request(conninfo, credentials, method, unicode(uri),
        body=config, if_match=if_match)

def delete_user(conninfo, credentials, user_id):
    user_id = int(user_id)

    method = "DELETE"
    uri = "/v1/users/%d" % user_id

    return request.rest_request(conninfo, credentials, method, uri)

def smb_delete_share(conninfo, credentials, id_):
    id_ = unicode(id_)

    method = "DELETE"
    uri = "/v1/smb/shares/%s" % id_

    return request.rest_request(conninfo, credentials, method, uri)

def get_file_attr(conninfo, credentials, id_, snapshot=None):
    method = "GET"
    uri = build_files_uri([id_, "info", "attributes"])

    if snapshot:
        uri.add_query_param('snapshot', snapshot)

    return request.rest_request(conninfo, credentials, method, unicode(uri))

def set_node_identify_light(conninfo, credentials, node, light_visible):
    method = "POST"
    uri = "/v1/cluster/nodes/{}/identify".format(node)

    body = {'light_visible': light_visible}

    return request.rest_request(conninfo, credentials, method, uri,
                                body=body)

def get_file_samples(conninfo, credentials, path, count, by_value):
    method = "GET"

    uri = build_files_uri([path, 'sample']).append_slash()
    uri.add_query_param('by-value', by_value)
    uri.add_query_param('limit', count)

    return request.rest_request(conninfo, credentials, method, unicode(uri))

def group_remove_member(conninfo, credentials, group_id, member_id):
    group_id = int(group_id)
    member_id = int(member_id)

    method = "DELETE"
    uri = "/v1/groups/%d/members/%d" % (group_id, member_id)

    return request.rest_request(conninfo, credentials, method, uri)

def set_user_password(conninfo, credentials, user_id, new_password):
    user_id = int(user_id)
    new_password = util.parse_ascii(new_password, 'password')

    method = "POST"
    uri = "/v1/users/%d/setpassword" % user_id
    body = { 'new_password' : new_password }

    return request.rest_request(conninfo, credentials, method, uri, body=body)

def group_add_member(conninfo, credentials, group_id, member_id):
    group_id = int(group_id)
    member_id = member_id if member_id is None else str(member_id)

    method = "POST"
    uri = "/v1/groups/%d/members/" % group_id
    body = { 'member_id' : member_id if member_id is not None else '' }

    return request.rest_request(conninfo, credentials, method, uri, body=body)

def get_node_chassis_status(conninfo, credentials, node=None):
    method = "GET"

    if node is not None:
        uri = "/v1/cluster/nodes/{}/chassis".format(node)
    else:
        uri = "/v1/cluster/nodes/chassis/"

    return request.rest_request(conninfo, credentials, method, uri)