cosmincav / node-rabbitmq-manager Goto Github PK

Client.prototype.listUsers = function(_cb) {
    let path = '/api/users'
    this.getClient.makeRequest(path, _cb)
    return this
}

client.listUsers(function  (err, res) {
            if (err) {
                console.log('listUsers ERR: ', err)
            } else {
                console.log(res)
            }
        })

Client.prototype.addUser = function(body, _cb) {
    let path = '/api/users/';

    if (!body || !body.user) {
        _cb({
            message : 'user not provided'
        })
        return null
    } else {
        path += encodeURIComponent(body.user)
    }

    if (typeof body.password === 'undefined' && typeof body.password_hash === 'undefined') {
        _cb({
            message : 'password or password_hash not provided'
        })
        return null
    }

    const payload = {
        tags: '',
    }

    if (typeof body.password !== 'undefined') {
        payload.password = body.password
    }

    if (typeof body.password_hash !== 'undefined') {
        payload.password_hash = body.password_hash
    }

    if (typeof body.tags !== 'undefined') {
        payload.tags = body.tags
    }
    this.putClient.makeRequest(path, payload, _cb)
    return this
}

client.addUser({
        user: 'Johndoe',
        password: 'xxxxxx',
        tags: 'administrator',
    },
    function  (err, res) {
    if (err) {
        console.log('ERR: ', err)
    } else {
        console.log(res)
    }
})

Client.prototype.deleteUser = function(username, _cb) {
    let path = '/api/users/';

    if (typeof username === 'undefined' || username === null) {
        _cb({
            message : 'username not provided'
        })
        return null
    } else {
        path += encodeURIComponent(username)
    }

    this.deleteClient.makeRequest(path, _cb)
    return this
}

managerClient.deleteUser('Johndoe', function  (err, res) {
    if (err) {
        console.log('ERR: ', err)
    } else {
        console.log(res)
    }
})

Client.prototype..addUserVhostPermissions = function({vhost, user, configure = '.*', write = '.*', read = '.*'}, _cb) {
    if (typeof vhost === 'undefined' || vhost === null) {
        _cb({
            message : 'vhost not provided'
        })
        return null
    }
    if (typeof user === 'undefined' || user === null) {
        _cb({
            message : 'user not provided'
        })
        return null
    }
    let path = `/api/permissions/${encodeURIComponent(vhost)}/${encodeURIComponent(user)}`
    const payload = {
        configure,
        write,
        read,
    }
    this.putClient.makeRequest(path, payload, _cb)
    return this
}

Client.prototype.removeUserVhostPermissions = function({vhost, user}, _cb) {
    if (typeof vhost === 'undefined' || vhost === null) {
        _cb({
            message : 'vhost not provided'
        })
        return null
    }
    if (typeof user === 'undefined' || user === null) {
        _cb({
            message : 'user not provided'
        })
        return null
    }
    let path = `/api/permissions/${encodeURIComponent(vhost)}/${encodeURIComponent(user)}`
    this.deleteClient.makeRequest(path, _cb)
    return this
}