core: add perm scopes

This commit is contained in:
undefined committed 2020-10-06 18:16:39 +08:00
1 parent 4b7f18baaa
commit efc7e2863d
5 files changed
+22 -10

No files matched your search

+1 -1
View File
@@ -12,7 +12,7 @@
"jest": "node build/jest", "jest": "node build/jest",
"debug": "node --async-stack-traces --trace-deprecation --enable-source-maps build/start --debug", "debug": "node --async-stack-traces --trace-deprecation --enable-source-maps build/start --debug",
"start": "node build/start", "start": "node build/start",
"clean": "zsh -c \"rm -rf tsconfig.build.tsbuildinfo ./packages/*/tsconfig.tsbuildinfo ./packages/*/dist ./.coverage\"" "clean": "zsh -c \"rm -rf tsconfig.build.tsbuildinfo ./packages/*/tsconfig.tsbuildinfo ./packages/*/dist ./**/tscofig.json ./.coverage\""
}, },
"version": "1.0.0", "version": "1.0.0",
"license": "AGPL-3.0-only", "license": "AGPL-3.0-only",
+8 -2
View File
@@ -36,6 +36,7 @@ class UserLoginHandler extends Handler {
await user.setById(udoc._id, { loginat: new Date(), loginip: this.request.ip }); await user.setById(udoc._id, { loginat: new Date(), loginip: this.request.ip });
if (udoc.priv === PRIV.PRIV_NONE) throw new BlacklistedError(uname); if (udoc.priv === PRIV.PRIV_NONE) throw new BlacklistedError(uname);
this.session.uid = udoc._id; this.session.uid = udoc._id;
this.session.scope = PERM.PERM_ALL;
this.session.save = rememberme; this.session.save = rememberme;
this.response.redirect = this.request.referer.endsWith('/login') ? '/' : this.request.referer; this.response.redirect = this.request.referer.endsWith('/login') ? '/' : this.request.referer;
} }
@@ -48,6 +49,7 @@ class UserLogoutHandler extends Handler {
async post() { async post() {
this.session.uid = 0; this.session.uid = 0;
this.session.scope = PERM.PERM_ALL;
} }
} }
@@ -101,6 +103,7 @@ class UserRegisterWithCodeHandler extends Handler {
const uid = await user.create(mail, uname, password, undefined, this.request.ip); const uid = await user.create(mail, uname, password, undefined, this.request.ip);
await token.del(code, token.TYPE_REGISTRATION); await token.del(code, token.TYPE_REGISTRATION);
this.session.uid = uid; this.session.uid = uid;
this.session.scpoe = PERM.PERM_ALL;
this.response.redirect = this.url('homepage'); this.response.redirect = this.url('homepage');
} }
} }
@@ -229,8 +232,10 @@ class OauthCallbackHandler extends Handler {
if (global.Hydro.lib[`oauth_${args.type}`]) r = await global.Hydro.lib[`oauth_${args.type}`].callback.call(this, args); if (global.Hydro.lib[`oauth_${args.type}`]) r = await global.Hydro.lib[`oauth_${args.type}`].callback.call(this, args);
else throw new UserFacingError('Oauth type'); else throw new UserFacingError('Oauth type');
const uid = await oauth.get(r._id); const uid = await oauth.get(r._id);
if (uid) this.session.uid = uid; if (uid) {
else { this.session.uid = uid;
this.session.scope = PERM.PERM_ALL;
} else {
this.checkPriv(PRIV.PRIV_REGISTER_USER); this.checkPriv(PRIV.PRIV_REGISTER_USER);
let username = ''; let username = '';
r.uname = r.uname || []; r.uname = r.uname || [];
@@ -257,6 +262,7 @@ class OauthCallbackHandler extends Handler {
oauth.set(r.email, _id), oauth.set(r.email, _id),
]); ]);
this.session.uid = _id; this.session.uid = _id;
this.session.scope = PERM.PERM_ALL;
} }
} }
} }
+1
View File
@@ -74,6 +74,7 @@ export interface User extends Dictionary<any> {
regat: Date, regat: Date,
loginat: Date, loginat: Date,
perm: () => bigint, perm: () => bigint,
scope: () => bigint,
role: string, role: string,
regip: () => string, regip: () => string,
loginip: () => string, loginip: () => string,
+8 -5
View File
@@ -3,7 +3,7 @@ import * as system from './system';
import * as token from './token'; import * as token from './token';
import * as setting from './setting'; import * as setting from './setting';
import * as domain from './domain'; import * as domain from './domain';
import { BUILTIN_USERS, PRIV } from './builtin'; import { BUILTIN_USERS, PERM, PRIV } from './builtin';
import { UserNotFoundError, UserAlreadyExistError, LoginError } from '../error'; import { UserNotFoundError, UserAlreadyExistError, LoginError } from '../error';
import { User as _User, Udoc, Udict } from '../interface'; import { User as _User, Udoc, Udict } from '../interface';
import { Value } from '../typeutils'; import { Value } from '../typeutils';
@@ -73,9 +73,11 @@ export class User implements _User {
loginip: () => string; loginip: () => string;
scope: () => bigint;
[key: string]: any; [key: string]: any;
constructor(udoc: Udoc, dudoc) { constructor(udoc: Udoc, dudoc, scope = PERM.PERM_ALL) {
this.udoc = () => udoc; this.udoc = () => udoc;
this.dudoc = () => dudoc; this.dudoc = () => dudoc;
this._id = udoc._id; this._id = udoc._id;
@@ -90,6 +92,7 @@ export class User implements _User {
this.loginat = udoc.loginat; this.loginat = udoc.loginat;
this.loginip = () => udoc.loginip; this.loginip = () => udoc.loginip;
this.perm = () => dudoc.perm; this.perm = () => dudoc.perm;
this.scope = () => scope;
this.role = dudoc.role || 'default'; this.role = dudoc.role || 'default';
for (const key in setting.SETTINGS_BY_KEY) { for (const key in setting.SETTINGS_BY_KEY) {
@@ -111,7 +114,7 @@ export class User implements _User {
hasPerm(...perm: bigint[]) { hasPerm(...perm: bigint[]) {
for (const i in perm) { for (const i in perm) {
if ((this.perm() & perm[i]) === perm[i]) return true; if ((this.perm() * this.scope() & perm[i]) === perm[i]) return true;
} }
return false; return false;
} }
@@ -134,13 +137,13 @@ export class User implements _User {
} }
} }
export async function getById(domainId: string, _id: number): Promise<User | null> { export async function getById(domainId: string, _id: number, scope = PERM.PERM_ALL): Promise<User | null> {
const udoc = _id === 0 || _id === 1 const udoc = _id === 0 || _id === 1
? BUILTIN_USERS[_id] ? BUILTIN_USERS[_id]
: await coll.findOne({ _id }); : await coll.findOne({ _id });
if (!udoc) return null; if (!udoc) return null;
const dudoc = await domain.getDomainUser(domainId, udoc); const dudoc = await domain.getDomainUser(domainId, udoc);
return new User(udoc, dudoc); return new User(udoc, dudoc, scope);
} }
export async function getList(domainId: string, uids: number[]): Promise<Udict> { export async function getList(domainId: string, uids: number[]): Promise<Udict> {
+4 -2
View File
@@ -32,6 +32,7 @@ import * as system from '../model/system';
import * as blacklist from '../model/blacklist'; import * as blacklist from '../model/blacklist';
import * as token from '../model/token'; import * as token from '../model/token';
import * as opcount from '../model/opcount'; import * as opcount from '../model/opcount';
import { PERM } from '../model/builtin';
const logger = new Logger('server'); const logger = new Logger('server');
export const app = new Koa(); export const app = new Koa();
@@ -479,9 +480,10 @@ export class Handler {
if (!this.user) this.user = await user.getById('system', 0); if (!this.user) this.user = await user.getById('system', 0);
throw new NotFoundError(domainId); throw new NotFoundError(domainId);
} }
this.user = await user.getById(domainId, this.session.uid); this.user = await user.getById(domainId, this.session.uid, this.session.scope);
if (!this.user) { if (!this.user) {
this.session.uid = 0; this.session.uid = 0;
this.session.scope = PERM.PERM_ALL;
this.user = await user.getById(domainId, this.session.uid); this.user = await user.getById(domainId, this.session.uid);
} }
this.csrfToken = this.getCsrfToken(this.session._id || String.random(32)); this.csrfToken = this.getCsrfToken(this.session._id || String.random(32));
@@ -818,7 +820,7 @@ export class ConnectionHandler {
]); ]);
const bdoc = await blacklist.get(this.request.ip); const bdoc = await blacklist.get(this.request.ip);
if (bdoc) throw new BlacklistedError(this.request.ip); if (bdoc) throw new BlacklistedError(this.request.ip);
this.user = await user.getById(domainId, this.session.uid); this.user = await user.getById(domainId, this.session.uid, this.session.scope);
if (!this.user) throw new UserNotFoundError(this.session.uid); if (!this.user) throw new UserNotFoundError(this.session.uid);
} }
} }