vpn-p2p/nodejs/models/user_ldap.js

'use strict';

const { Client, Attribute, Change } = require('ldapts');
const {Token, InviteToken} = require('./token');
const conf = require('../app').conf.ldap;

const client = new Client({
  url: conf.url,
});


const user_parse = function(data){
	if(data[conf.userNameAttribute]){
		data.username = data[conf.userNameAttribute]
		delete data[conf.userNameAttribute];
	}

	if(data.uidNumber){
		data.uid = data.uidNumber;
		delete data.uidNumber;
	}

	return data;
}

var User = {}

User.backing = "LDAP";

User.keyMap = {
	'username': {isRequired: true, type: 'string', min: 3, max: 500},
	'password': {isRequired: true, type: 'string', min: 3, max: 500},
}

User.list = async function(){
	try{
		await client.bind(conf.bindDN, conf.bindPassword);

		const res = await client.search(conf.searchBase, {
		  scope: 'sub',
		  filter: conf.userFilter,
		});

		await client.unbind();

		return res.searchEntries.map(function(user){return user.uid});
	}catch(error){
		throw error;
	}
};

User.listDetail = async function(){
	try{
		await client.bind(conf.bindDN, conf.bindPassword);

		const res = await client.search(conf.searchBase, {
		  scope: 'sub',
		  filter: conf.userFilter,
		});

		await client.unbind();

		let users = []

		for(let user of res.searchEntries){
			let obj = Object.create(this);
			Object.assign(obj, user_parse(user));
			
			users.push(obj)

		}

		return users;

	}catch(error){
		throw error;
	}
};

User.get = async function(data){
	try{
		if(typeof data !== 'object'){
			let username = data;
			data = {};
			data.username = username;
		}
		
		await client.bind(conf.bindDN, conf.bindPassword);

		let filter = `(&${conf.userFilter}(${conf.userNameAttribute}=${data.username}))`;

		const res = await client.search(conf.searchBase, {
			scope: 'sub',
			filter: filter,
		});

		await client.unbind();

		let user = res.searchEntries[0]

		if(user){
			let obj = Object.create(this);
			Object.assign(obj, user_parse(user));
			
			return obj;
		}else{
			let error = new Error('UserNotFound');
			error.name = 'UserNotFound';
			error.message = `LDAP:${data.username} does not exists`;
			error.status = 404;
			throw error;
		}
	}catch(error){
		throw error;
	}
};

User.exists = async function(data){
	// Return true or false if the requested entry exists ignoring error's.
	try{
		await this.get(data);

		return true
	}catch(error){
		return false;
	}
};

// User.add = async function(data) {
// 	try{
// 		data = objValidate.processKeys(this.keyMap, data);
// 		let systemUser = await linuxUser.addUser(data.username);
// 		await require('util').promisify(setTimeout)(500)
// 		let systemUserPassword = await linuxUser.setPassword(data.username, data.password);

// 		return this.get(data.username);

// 	}catch(error){
// 		if(error.message.includes('exists')){
// 			let error = new Error('UserNameUsed');
// 			error.name = 'UserNameUsed';
// 			error.message = `PAM:${data.username} already exists`;
// 			error.status = 409;

// 			throw error;
// 		}
// 		throw error;
// 	}
// };

// User.addByInvite = async function(data){
// 	try{
// 		let token = await InviteToken.get(data.token);

// 		if(!token.is_valid){
// 			let error = new Error('Token Invalid');
// 			error.name = 'Token Invalid';
// 			error.message = `Token is not valid or as allready been used. ${data.token}`;
// 			error.status = 401;
// 			throw error;
// 		}

// 		let user = await this.add(data);

// 		if(user){
// 			await token.consume({claimed_by: user.username});
// 			return user;
// 		}

// 	}catch(error){
// 		throw error;
// 	}

// };

// User.remove = async function(data){
// 	try{
// 		return await linuxUser.removeUser(this.username);
// 	}catch(error){
// 		throw error;
// 	}
// };

// User.setPassword = async function(data){
// 	try{
// 		await linuxUser.setPassword(this.username, data.password);

// 		return this;
// 	}catch(error){
// 		throw error;
// 	}
// };

User.invite = async function(){
	try{
		let token = await InviteToken.add({created_by: this.username});
		
		return token;

	}catch(error){
		throw error;
	}
};

User.login = async function(data){
	try{
		let user = await this.get(data.username);

		await client.bind(user.dn, data.password);

		await client.unbind();

		return user;

	}catch(error){
		throw error;
	}
};


module.exports = {User};


// (async function(){
// try{
// 	console.log(await User.list());

// 	console.log(await User.listDetail());

// 	console.log(await User.get('wmantly'))

// }catch(error){
// 	console.error(error)
// }
// })()