archive-gh-me/thinkjs
1
0
Fork 0
mirror of https://github.com/thinkjs/thinkjs.git synced 2026-02-01 15:23:03 +00:00
Code Issues Projects Releases Wiki Activity

remove auth adapter temperory

Browse Source
This commit is contained in:
lichengyin 2015-10-26 20:04:19 +08:00
parent 03db37c76e
commit f2b6625169
1 changed files with 132 additions and 132 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

264
src/adapter/auth/rbac.js
View File

@ -35,135 +35,135 @@ CREATE TABLE `think_auth_user_role` (
* @type {Class}
*/
export default class extends think.base {
/**
* init
* @param {Number} userId []
* @param {Object} config []
* @param {Object} http []
* @return {} []
*/
init(userId, config, http){
super.init(http);
if (think.isObject(userId)) {
config = userId;
userId = config.id;
}
this.userId = userId;
this.config = think.extend({
type: 1, //auth type, 2 is session auth
user: 'user', //user info table
role: 'auth_role', //role table
rule: 'auth_rule', //rule table
user_role: 'auth_user_role', //user - role relation table
userInfo: null
}, config);
}
/**
* check auth
* @param {String} name [auth type]
* @param {Boolean} and [condition]
* @return {Promise} []
*/
async check(name, and){
if (think.isString(name)) {
name = name.split(',');
}
let authList = this.getAuthList();
if (name.length === 1) {
return authList.indexOf(name[0]) > -1;
}
let logic = and ? 'every' : 'some';
return name[logic](item => {
return authList.indexOf(item) > -1;
});
}
async _getAuthList(){
let data;
if (this.config.type === 1) {
data = await this.flushAuthList();
}else{
let http = this.http;
let key = this.config('auth_key');
think.session(this.http);
let data = await http.session.get(key);
if(think.isEmpty(data)){
data = await this.flushAuthList();
await http.session.set(key, data);
}
}
return data;
}
/**
* get auth list
* @return {Promise} []
*/
async getAuthList(){
let data = await Promise.all([this._getAuthList(), this.getUserInfo()]);
let authList = data[0];
let userInfo = data[1];
let result = [];
authList.forEach(item => {
if (!item.condition) {
result.push(item.name);
}else{
let condition = item.condition.replace(/\w+/, a => `userInfo.${a}`);
/*jslint evil: true */
let fn = new Function('userInfo', `return ${condition}`);
let flag = fn(userInfo);
if (flag) {
result.push(item.name);
}
}
});
return result;
}
/**
* flush auth list
* @return {Promise} []
*/
async flushAuthList(){
let ids = await this.getRuleIds();
let model = this.model();
return model.field('name,condition').table(this.config.table).where({id: ['IN', ids], status: 1}).select();
}
/**
* get user info
* @return {Promise} []
*/
async getUserInfo(){
if (!think.isEmpty(this.config.userInfo)) {
return this.config.userInfo;
}
let data = await this.model().table(this.config.user).where({id: this.userId}).find();
this.config.userInfo = data;
return data;
}
/**
* get rule ids
* @return {Promise} []
*/
async getRuleIds(){
let data = await this.getRoles();
let ids = [];
data.forEach(item => {
let ruleIds = (item.rule_ids || '').split(',');
ids = ids.concat(ruleIds);
});
return ids;
}
/**
* get roles
* @return {Promise} []
*/
getRoles(){
return this.model().table(this.config.user_role).alias('a').join({
table: this.config.role,
as: 'b',
on: ['role_id', 'id']
}).where({
'a.user_id': this.userId,
'b.status': 1
}).select();
}
}
// export default class extends think.base {
// /**
// * init
// * @param {Number} userId []
// * @param {Object} config []
// * @param {Object} http []
// * @return {} []
// */
// init(userId, config, http){
// super.init(http);
// if (think.isObject(userId)) {
// config = userId;
// userId = config.id;
// }
// this.userId = userId;
// this.config = think.extend({
// type: 1, //auth type, 2 is session auth
// user: 'user', //user info table
// role: 'auth_role', //role table
// rule: 'auth_rule', //rule table
// user_role: 'auth_user_role', //user - role relation table
// userInfo: null
// }, config);
// }
// /**
// * check auth
// * @param {String} name [auth type]
// * @param {Boolean} and [condition]
// * @return {Promise} []
// */
// async check(name, and){
// if (think.isString(name)) {
// name = name.split(',');
// }
// let authList = this.getAuthList();
// if (name.length === 1) {
// return authList.indexOf(name[0]) > -1;
// }
// let logic = and ? 'every' : 'some';
// return name[logic](item => {
// return authList.indexOf(item) > -1;
// });
// }
// async _getAuthList(){
// let data;
// if (this.config.type === 1) {
// data = await this.flushAuthList();
// }else{
// let http = this.http;
// let key = this.config('auth_key');
// think.session(this.http);
// let data = await http.session.get(key);
// if(think.isEmpty(data)){
// data = await this.flushAuthList();
// await http.session.set(key, data);
// }
// }
// return data;
// }
// /**
// * get auth list
// * @return {Promise} []
// */
// async getAuthList(){
// let data = await Promise.all([this._getAuthList(), this.getUserInfo()]);
// let authList = data[0];
// let userInfo = data[1];
// let result = [];
// authList.forEach(item => {
// if (!item.condition) {
// result.push(item.name);
// }else{
// let condition = item.condition.replace(/\w+/, a => `userInfo.${a}`);
// /*jslint evil: true */
// let fn = new Function('userInfo', `return ${condition}`);
// let flag = fn(userInfo);
// if (flag) {
// result.push(item.name);
// }
// }
// });
// return result;
// }
// /**
// * flush auth list
// * @return {Promise} []
// */
// async flushAuthList(){
// let ids = await this.getRuleIds();
// let model = this.model();
// return model.field('name,condition').table(this.config.table).where({id: ['IN', ids], status: 1}).select();
// }
// /**
// * get user info
// * @return {Promise} []
// */
// async getUserInfo(){
// if (!think.isEmpty(this.config.userInfo)) {
// return this.config.userInfo;
// }
// let data = await this.model().table(this.config.user).where({id: this.userId}).find();
// this.config.userInfo = data;
// return data;
// }
// /**
// * get rule ids
// * @return {Promise} []
// */
// async getRuleIds(){
// let data = await this.getRoles();
// let ids = [];
// data.forEach(item => {
// let ruleIds = (item.rule_ids || '').split(',');
// ids = ids.concat(ruleIds);
// });
// return ids;
// }
// /**
// * get roles
// * @return {Promise} []
// */
// getRoles(){
// return this.model().table(this.config.user_role).alias('a').join({
// table: this.config.role,
// as: 'b',
// on: ['role_id', 'id']
// }).where({
// 'a.user_id': this.userId,
// 'b.status': 1
// }).select();
// }
// }