自定义下载改为仅支持主图和修改requestInSteam配置

Signed-off-by: zgf <zenggaofeng2@h-partners.com>
This commit is contained in:
zgf 2024-07-10 11:11:36 +08:00
parent 7ecc9faf9f
commit e6c468bd21
2 changed files with 12 additions and 9 deletions

View File

@ -1,5 +1,7 @@
## 3.0.0-rc.10 ## 3.0.0-rc.10
- 修复图形变换的闪退问题 - 修复图形变换的闪退问题
- 自定义下载customGetImage改为仅主图支持
- 修改网络请求requestInStream配置
## 3.0.0-rc.9 ## 3.0.0-rc.9
- 修复Resource类型$r(变量无法)加载 - 修复Resource类型$r(变量无法)加载

View File

@ -383,7 +383,7 @@ async function requestJob(request: RequestJobRequest, requestList?: List<ImageKn
let fileKey = request.engineKey.generateFileKey(request.src, request.signature) let fileKey = request.engineKey.generateFileKey(request.src, request.signature)
// 判断自定义下载 // 判断自定义下载
if (request.customGetImage !== undefined && typeof request.src === 'string' && (request.src.indexOf("http://") == 0 || request.src.indexOf("https://") == 0)) { if (request.customGetImage !== undefined && request.requestSource == ImageKnifeRequestSource.SRC) {
// 先从文件缓存获取 // 先从文件缓存获取
resBuf = FileCache.getFileCacheByFile(request.context, fileKey , request.fileCacheFolder) resBuf = FileCache.getFileCacheByFile(request.context, fileKey , request.fileCacheFolder)
if (resBuf === undefined) { if (resBuf === undefined) {
@ -417,14 +417,6 @@ async function requestJob(request: RequestJobRequest, requestList?: List<ImageKn
headerObj[key] = value headerObj[key] = value
}) })
} }
let promise = httpRequest.requestInStream(request.src, {
header: headerObj,
method: http.RequestMethod.GET,
connectTimeout: 6000,
readTimeout: 6000,
// header: new Header('application/json')
});
httpRequest.on("dataReceive", (data: ArrayBuffer) => { httpRequest.on("dataReceive", (data: ArrayBuffer) => {
arrayBuffers.push(data) arrayBuffers.push(data)
}); });
@ -451,6 +443,15 @@ async function requestJob(request: RequestJobRequest, requestList?: List<ImageKn
} }
}) })
} }
let promise = httpRequest.requestInStream(request.src, {
header: headerObj,
method: http.RequestMethod.GET,
expectDataType: http.HttpDataType.ARRAY_BUFFER,
connectTimeout: 6000,
readTimeout: 6000,
usingProtocol:http.HttpProtocol.HTTP1_1
// header: new Header('application/json')
});
await promise.then((data: number) => { await promise.then((data: number) => {
if (data == 200) { if (data == 200) {