yujunjun/strapi
1
0
Fork 0
mirror of https://github.com/strapi/strapi.git synced 2025-09-26 17:00:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

implement uploadStream wrapping for actionOptions

Browse Source
This commit is contained in:
Pierre Noël 2022-03-14 17:14:12 +01:00
parent 3bf25de33e
commit 091a3d3d85
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
packages/core/upload/server/bootstrap.js vendored
View File

@ -51,6 +51,10 @@ const createProvider = config => {
return Object.assign(Object.create(baseProvider), { return Object.assign(Object.create(baseProvider), {
...providerInstance, ...providerInstance,
original: providerInstance,
uploadStream(file, options = actionOptions.upload) {
return providerInstance.uploadStream(file, options);
},
upload(file, options = actionOptions.upload) { upload(file, options = actionOptions.upload) {
return providerInstance.upload(file, options); return providerInstance.upload(file, options);
}, },
@ -64,6 +68,9 @@ const baseProvider = {
extend(obj) { extend(obj) {
Object.assign(this, obj); Object.assign(this, obj);
}, },
uploadStream() {
throw new Error('Provider uploadStream method is not implemented');
},
upload() { upload() {
throw new Error('Provider upload method is not implemented'); throw new Error('Provider upload method is not implemented');
}, },

2
packages/core/upload/server/services/provider.js
View File

@ -5,7 +5,7 @@ const { streamToBuffer } = require('../utils/file');
module.exports = ({ strapi }) => ({ module.exports = ({ strapi }) => ({
async upload(file) { async upload(file) {
if (isFunction(strapi.plugin('upload').provider.uploadStream)) { if (isFunction(strapi.plugin('upload').provider.original.uploadStream)) {
file.stream = file.getStream(); file.stream = file.getStream();
await strapi.plugin('upload').provider.uploadStream(file); await strapi.plugin('upload').provider.uploadStream(file);
delete file.stream; delete file.stream;