Merge branch 'beta' of github.com:SoftwareBrothers/admin-bro-upload into beta

wojtek-krysiak · wojtek-krysiak · commit c22d6c31ffd8 · 2020-10-12T20:38:48.000+02:00
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@admin-bro/upload",
-  "version": "1.2.0-beta.1",
+  "version": "1.2.0-beta.2",
   "main": "index.js",
   "types": "types/index.d.ts",
   "private": false,
diff --git a/src/features/upload-file/providers/aws-provider.ts b/src/features/upload-file/providers/aws-provider.ts
@@ -57,7 +57,8 @@ export class AWSProvider extends BaseProvider {
   }
 
   public async upload(file: UploadedFile, key: string): Promise<S3.ManagedUpload.SendData> {
-    const tmpFile = fs.readFileSync(file.path)
+    const uploadOptions = { partSize: 5 * 1024 * 1024, queueSize: 10 }
+    const tmpFile = fs.createReadStream(file.path)
     const params: S3.PutObjectRequest = {
       Bucket: this.bucket,
       Key: key,
@@ -66,7 +67,7 @@ export class AWSProvider extends BaseProvider {
     if (!this.expires) {
       params.ACL = 'public-read'
     }
-    return this.s3.upload(params).promise()
+    return this.s3.upload(params, uploadOptions).promise()
   }
 
   public async delete(key: string, bucket: string): Promise<S3.DeleteObjectOutput> {

Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,8 @@ export class AWSProvider extends BaseProvider {`
`57`	`57`	`}`
`58`	`58`
`59`	`59`	`public async upload(file: UploadedFile, key: string): Promise<S3.ManagedUpload.SendData> {`
`60`		`- const tmpFile = fs.readFileSync(file.path)`
	`60`	`+ const uploadOptions = { partSize: 5 * 1024 * 1024, queueSize: 10 }`
	`61`	`+ const tmpFile = fs.createReadStream(file.path)`
`61`	`62`	`const params: S3.PutObjectRequest = {`
`62`	`63`	`Bucket: this.bucket,`
`63`	`64`	`Key: key,`
`@@ -66,7 +67,7 @@ export class AWSProvider extends BaseProvider {`
`66`	`67`	`if (!this.expires) {`
`67`	`68`	`params.ACL = 'public-read'`
`68`	`69`	`}`
`69`		`- return this.s3.upload(params).promise()`
	`70`	`+ return this.s3.upload(params, uploadOptions).promise()`
`70`	`71`	`}`
`71`	`72`
`72`	`73`	`public async delete(key: string, bucket: string): Promise<S3.DeleteObjectOutput> {`