ReadSeeker and usrMaxSize enabled

api_test.go

@@ -516,7 +516,7 @@ func putObjectMPU(ctx context.Context, svc *s3.Client, bucket, key string, data
 		Bucket:     &bucket,
 		Key:        &key,
 		PartNumber: aws.Int32(partNum),
-		Body:       bytes.NewReader(data),
+		Body:       io.ReadSeeker(bytes.NewReader(data)),
 	}
 	uploadPart, err := svc.UploadPart(ctx, uploadPartInput)
 	if err != nil {

concat.go

@@ -8,6 +8,7 @@ import (
 	"context"
 	"fmt"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
+	"io"
 	"path/filepath"
 	"time"
 
@@ -86,7 +87,7 @@ func (r *RecursiveConcat) uploadPart(object *S3Obj, uploadId string, bucket, key
 		Key:        &key,
 		PartNumber: aws.Int32(partNum),
 		UploadId:   &uploadId,
-		Body:       bytes.NewReader(object.Data),
+		Body:       io.ReadSeeker(bytes.NewReader(object.Data)),
 	}
 
 	res, err := r.Client.UploadPart(context.TODO(), input)

mem_concat.go

@@ -187,12 +187,14 @@ func uploadObject(ctx context.Context, client *s3.Client, bucket, key string, da
 }
 func uploadPart(ctx context.Context, client *s3.Client, uploadId, bucket, key string, data []byte, partNum *int32) (*s3.UploadPartOutput, error) {
 
+	body := io.ReadSeeker(bytes.NewReader(data))
+
 	rc, err := client.UploadPart(ctx, &s3.UploadPartInput{
 		UploadId:          &uploadId,
 		Bucket:            &bucket,
 		Key:               &key,
 		PartNumber:        partNum,
-		Body:              bytes.NewReader(data),
+		Body:              body,
 		ChecksumAlgorithm: types.ChecksumAlgorithmSha256,
 	})
 

s3tar.go

@@ -10,6 +10,7 @@ import (
 	"context"
 	"fmt"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
+	"io"
 	"log"
 	"path/filepath"
 	"sort"
@@ -606,6 +607,10 @@ func findMinimumPartSize(finalSizeBytes, userMaxSize int64) int64 {
 	const fiveMB = beginningPad
 	partSize := int64(fiveMB)
 
+	if userMaxSize > 0 {
+		partSize = userMaxSize * 1024 * 1024
+	}
+
 	for ; partSize <= partSizeMax; partSize = partSize + fiveMB {
 		if finalSizeBytes/int64(partSize) < maxPartNumLimit {
 			break
@@ -703,7 +708,7 @@ func concatObjects(ctx context.Context, client *s3.Client, trimFirstBytes int, o
 				Key:        &key,
 				PartNumber: &partNum,
 				UploadId:   &uploadId,
-				Body:       bytes.NewReader(object.Data),
+				Body:       io.ReadSeeker(bytes.NewReader(object.Data)),
 			}
 			swg.Add()
 			go func(input *s3.UploadPartInput) {