🐞 fix: 拉格朗日链接bug [#I9SPTK]

This commit is contained in:
zhiyu1998 2024-05-28 17:00:28 +08:00
parent f7308d5970
commit 392233c96d
3 changed files with 5 additions and 4 deletions

View File

@ -64,7 +64,7 @@ export class switchers extends plugin {
driver = JSON.parse(await redis.get(REDIS_YUNZAI_LAGRANGE)).driver; driver = JSON.parse(await redis.get(REDIS_YUNZAI_LAGRANGE)).driver;
} }
// 设置 // 设置
driver = ~driver driver ^= 1;
await redis.set( await redis.set(
REDIS_YUNZAI_LAGRANGE, REDIS_YUNZAI_LAGRANGE,
JSON.stringify({ JSON.stringify({

View File

@ -1851,7 +1851,7 @@ export class tools extends plugin {
await redis.set( await redis.set(
REDIS_YUNZAI_LAGRANGE, REDIS_YUNZAI_LAGRANGE,
JSON.stringify({ JSON.stringify({
driver: false, driver: 0,
}), }),
); );
return true; return true;
@ -1881,8 +1881,9 @@ export class tools extends plugin {
* @param videoSizeLimit 发送转上传视频的大小限制默认70MB * @param videoSizeLimit 发送转上传视频的大小限制默认70MB
*/ */
async sendVideoToUpload(e, path, videoSizeLimit = 70) { async sendVideoToUpload(e, path, videoSizeLimit = 70) {
const isLag = await this.isLagRangeDriver();
// 判断是否是拉格朗日 // 判断是否是拉格朗日
if (await this.isLagRangeDriver()) { if (isLag === 1) {
// 构造拉格朗日适配器 // 构造拉格朗日适配器
const lagrange = new LagrangeAdapter(this.toolsConfig.lagrangeForwardWebSocket); const lagrange = new LagrangeAdapter(this.toolsConfig.lagrangeForwardWebSocket);
// 上传群文件 // 上传群文件

View File

@ -10,7 +10,7 @@ export async function checkAndRemoveFile(file) {
try { try {
await fs.promises.access(file); await fs.promises.access(file);
await fs.promises.unlink(file); await fs.promises.unlink(file);
logger.mark('视频已存在'); logger.mark('文件已存在');
} catch (err) { } catch (err) {
if (err.code !== 'ENOENT') { if (err.code !== 'ENOENT') {
throw err; throw err;