feat: 更新命令脚本名称,添加 CLI 入口文件,优化用户验证逻辑
This commit is contained in:
@@ -16,7 +16,7 @@
|
|||||||
},
|
},
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev": "bun run --watch --hot src/index.ts",
|
"dev": "bun run --watch --hot src/index.ts",
|
||||||
"cmd": "bun run src/run.ts ",
|
"cli": "bun run src/cli.ts ",
|
||||||
"prebuild": "rimraf dist && rimraf pack-dist",
|
"prebuild": "rimraf dist && rimraf pack-dist",
|
||||||
"build": "NODE_ENV=production bun bun.config.mjs",
|
"build": "NODE_ENV=production bun bun.config.mjs",
|
||||||
"postbuild": "ev pack",
|
"postbuild": "ev pack",
|
||||||
|
|||||||
@@ -166,7 +166,6 @@ export class RedisTokenStore implements Store<OauthUser> {
|
|||||||
} else {
|
} else {
|
||||||
expire = Math.min(expire, 60 * 60 * 24 * 30); // 默认的过期时间最大为30天
|
expire = Math.min(expire, 60 * 60 * 24 * 30); // 默认的过期时间最大为30天
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.set(accessToken, JSON.stringify(value), expire);
|
await this.set(accessToken, JSON.stringify(value), expire);
|
||||||
await this.set(userPrefix + ':token:' + accessToken, accessToken, expire);
|
await this.set(userPrefix + ':token:' + accessToken, accessToken, expire);
|
||||||
// refreshToken的过期时间比accessToken多expireDay天,确保在accessToken过期后,refreshToken仍然有效
|
// refreshToken的过期时间比accessToken多expireDay天,确保在accessToken过期后,refreshToken仍然有效
|
||||||
|
|||||||
8
src/cli.ts
Normal file
8
src/cli.ts
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
import { parse } from '@kevisual/router/commander'
|
||||||
|
|
||||||
|
import { app } from './app.ts';
|
||||||
|
import './route.ts';
|
||||||
|
|
||||||
|
parse({
|
||||||
|
app,
|
||||||
|
})
|
||||||
@@ -52,6 +52,7 @@ export const getLoginUserByToken = async (token: string) => {
|
|||||||
let tokenUser;
|
let tokenUser;
|
||||||
try {
|
try {
|
||||||
tokenUser = await User.verifyToken(token);
|
tokenUser = await User.verifyToken(token);
|
||||||
|
if (!tokenUser) return null;
|
||||||
return { tokenUser, token };
|
return { tokenUser, token };
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
return null;
|
return null;
|
||||||
@@ -66,6 +67,7 @@ export const getLoginUser = async (req: http.IncomingMessage) => {
|
|||||||
logger.debug('getLoginUser', token);
|
logger.debug('getLoginUser', token);
|
||||||
try {
|
try {
|
||||||
tokenUser = await User.verifyToken(token);
|
tokenUser = await User.verifyToken(token);
|
||||||
|
if (!tokenUser) return null;
|
||||||
return { tokenUser, token };
|
return { tokenUser, token };
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
return null;
|
return null;
|
||||||
|
|||||||
@@ -26,7 +26,6 @@ export const wssFun: WebSocketListenerFun = async (req, res) => {
|
|||||||
}
|
}
|
||||||
if (!user) {
|
if (!user) {
|
||||||
logger.debug('未提供用户名,无法注册 ws 连接');
|
logger.debug('未提供用户名,无法注册 ws 连接');
|
||||||
ws.close();
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
let userApp = user + '--' + id;
|
let userApp = user + '--' + id;
|
||||||
|
|||||||
Reference in New Issue
Block a user