Jerry/crystelf-plugin
1
0
Fork 0
mirror of https://github.com/Jerryplusy/crystelf-plugin.git synced 2025-07-04 14:19:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

等待文件流读取完毕后再post

Browse Source
This commit is contained in:
Jerry 2025-05-14 13:11:33 +08:00
parent 80ca583b5f
commit cc9a6261f8
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/fanqie.js
View File

@ -6,6 +6,7 @@ import configControl from '../lib/config/configControl.js';
import Fanqie from '../models/apps/fanqie/fanqie.js'; import Fanqie from '../models/apps/fanqie/fanqie.js';
import axios from 'axios'; import axios from 'axios';
import FormData from 'form-data'; import FormData from 'form-data';
import { finished } from 'stream/promises';
let redis = global.redis; let redis = global.redis;
@ -236,6 +237,7 @@ export class xzq extends plugin {
}); });
form.append('file', fileStream); form.append('file', fileStream);
form.append('token', configControl.get('coreConfig')?.token); form.append('token', configControl.get('coreConfig')?.token);
await finished(fileStream);
const uploadUrl = `${configControl.get('coreConfig')?.coreUrl}/public/upload?dir=fanqie&expire=600`; const uploadUrl = `${configControl.get('coreConfig')?.coreUrl}/public/upload?dir=fanqie&expire=600`;
const response = await axios.post(uploadUrl, form, { const response = await axios.post(uploadUrl, form, {
headers: form.getHeaders(), headers: form.getHeaders(),