@@ -410,6 +410,7 @@ class NamespaceS3 {
410
410
await this . _prepare_sts_client ( ) ;
411
411
412
412
let res ;
413
+ let etag ;
413
414
if ( params . copy_source ) {
414
415
const { copy_source, copy_source_range } = s3_utils . format_copy_source ( params . copy_source ) ;
415
416
@@ -426,6 +427,8 @@ class NamespaceS3 {
426
427
this . _assign_encryption_to_request ( params , request ) ;
427
428
428
429
res = await this . s3 . uploadPartCopy ( request ) ;
430
+ dbg . log0 ( 'NamespaceS3.upload_multipart uploadPartCopy:' , this . bucket , inspect ( params ) , 'res' , inspect ( res ) ) ;
431
+ etag = s3_utils . parse_etag ( res . CopyPartResult . ETag ) ;
429
432
} else {
430
433
let count = 1 ;
431
434
const count_stream = stream_utils . get_tap_stream ( data => {
@@ -460,24 +463,24 @@ class NamespaceS3 {
460
463
} ) ;
461
464
throw err ;
462
465
}
466
+ dbg . log0 ( 'NamespaceS3.upload_multipart uploadPart:' , this . bucket , inspect ( params ) , 'res' , inspect ( res ) ) ;
467
+ etag = s3_utils . parse_etag ( res . ETag ) ;
463
468
}
464
- dbg . log0 ( 'NamespaceS3.upload_multipart:' , this . bucket , inspect ( params ) , 'res' , inspect ( res ) ) ;
465
- const etag = s3_utils . parse_etag ( res . ETag ) ;
466
469
return { etag } ;
467
470
}
468
471
469
472
async list_multiparts ( params , object_sdk ) {
470
473
dbg . log0 ( 'NamespaceS3.list_multiparts:' , this . bucket , inspect ( params ) ) ;
471
474
await this . _prepare_sts_client ( ) ;
472
-
473
- const res = await this . s3 . listParts ( {
475
+ /** @type { import("@aws-sdk/client-s3").ListPartsRequest } */
476
+ const req = {
474
477
Bucket : this . bucket ,
475
478
Key : params . key ,
476
479
UploadId : params . obj_id ,
477
480
MaxParts : params . max ,
478
- PartNumberMarker : params . num_marker ,
479
- } ) ;
480
-
481
+ PartNumberMarker : params . num_marker . toString ( ) ,
482
+ } ;
483
+ const res = await this . s3 . listParts ( req ) ;
481
484
dbg . log0 ( 'NamespaceS3.list_multiparts:' , this . bucket , inspect ( params ) , 'res' , inspect ( res ) ) ;
482
485
return {
483
486
is_truncated : res . IsTruncated ,
0 commit comments