small fix for s3
This commit is contained in:
@@ -78,7 +78,8 @@ class S3Actions implements IStorageActions {
|
||||
{ Bucket: bucket, Body: passThrough, Key: randomID },
|
||||
(err) => {
|
||||
if (err) {
|
||||
console.log("S3 upload err", err);
|
||||
emitter.emit("error", err);
|
||||
return;
|
||||
}
|
||||
emitter.emit("finish");
|
||||
}
|
||||
|
||||
@@ -134,17 +134,20 @@ const processData = (
|
||||
reject(e);
|
||||
});
|
||||
|
||||
cipher.pipe(writeStream);
|
||||
|
||||
if (emitter) {
|
||||
emitter.on("finish", () => {
|
||||
resolve({ filename, metadata });
|
||||
});
|
||||
emitter.on("error", (e: Error) => {
|
||||
reject(e);
|
||||
});
|
||||
} else {
|
||||
writeStream.on("finish", () => {
|
||||
resolve({ filename, metadata });
|
||||
});
|
||||
}
|
||||
|
||||
cipher.pipe(writeStream);
|
||||
}
|
||||
);
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user