我想在nestjs中上传到cloudary后返回图像链接数组的响应



所以我需要一种方法来延迟控制器中的返回语句,直到foreach循环完成。我只需要正确处理异步操作,我不知道如何

响应返回一个空数组,因为该数组是在响应返回后填充的

uploads.controller.ts

import {
Controller,
Post,
UseInterceptors,
UploadedFiles,
} from '@nestjs/common';
import { FilesInterceptor } from '@nestjs/platform-express';
import { UploadsService } from './uploads.service';
import { v2 as cloudinary } from 'cloudinary';
@Controller('attachments')
export class UploadsController {
constructor(private readonly uploadsService: UploadsService) {}
@Post('images')
@UseInterceptors(FilesInterceptor('attachment'))
async uploadFile(@UploadedFiles() attachment: Array<Express.Multer.File>) {
cloudinary.config({
cloud_name: process.env.CLOUDINARY_CLOUD_NAME,
api_key: process.env.CLOUDINARY_API_KEY,
api_secret: process.env.CLOUDINARY_API_SECRET,
secure: true,
});
const response = [];
await attachment.forEach(async (file) => {
const fileResponse = await this.uploadsService.uploadImage(file);
response.push(fileResponse.secure_url);
console.log('1', response);
});
console.log('2', response);
return await response;
}
}

uploads.service.ts

import { UploadApiErrorResponse, UploadApiResponse, v2 } from 'cloudinary';
import toStream = require('buffer-to-stream');
@Injectable()
export class UploadsService {
async uploadImage(
file: Express.Multer.File,
): Promise<UploadApiResponse | UploadApiErrorResponse> {
return new Promise((resolve, reject) => {
const upload = v2.uploader.upload_stream((error, result) => {
if (error) return reject(error);
resolve(result);
});
toStream(file.buffer).pipe(upload);
});
}
}

问题就在这里。

await attachment.forEach(async (file) => {
const fileResponse = await this.uploadsService.uploadImage(file);
response.push(fileResponse.secure_url);
console.log('1', response);
});

不要传递async函数给Array.forEach。看看这个问题。

这将工作。

const response = await Promise.all(attachment.map(async (file) => {
const fileResponse = await this.uploadsService.uploadImage(file);
return fileResponse.secure_url;
}));

最新更新