@@ -21,7 +21,8 @@ const s3Client = new S3Client({
2121
2222async function collectKeysToDelete ( bucketName , bucketDir ) {
2323 const keys = [ ]
24- core . info ( `Looking up files in S3 bucket ${ bucketName } with prefix ${ bucketDir } ` )
24+ core . info ( "Bucket name: " + bucketName )
25+ core . info ( `Looking up files with prefix '${ bucketDir } '` )
2526
2627 try {
2728 const params = {
@@ -30,7 +31,7 @@ async function collectKeysToDelete(bucketName, bucketDir) {
3031 }
3132 const paginator = paginateListObjectsV2 ( { client : s3Client } , params )
3233 for await ( const page of paginator ) {
33- page . Contents . forEach ( obj => {
34+ page . Contents ? .forEach ( obj => {
3435 keys . push ( obj . Key )
3536 } )
3637 }
@@ -45,27 +46,31 @@ async function collectKeysToDelete(bucketName, bucketDir) {
4546 } else {
4647 core . setFailed ( `Error while listing objects for "${ bucketName } ". ${ err . name } : ${ err . message } ` )
4748 }
49+ process . exit ( 1 )
4850 }
4951}
5052
5153async function deleteFiles ( bucketName , keys ) {
5254 try {
55+ core . info ( 'Deleting...' )
56+
5357 const { Deleted } = await s3Client . send (
5458 new DeleteObjectsCommand ( {
5559 Bucket : bucketName ,
5660 Delete : {
5761 Objects : keys . map ( ( k ) => ( { Key : k } ) ) ,
5862 } ,
59- } ) ,
60- ) ;
63+ } ) ,
64+ )
65+
6166 for ( const key in keys ) {
6267 await waitUntilObjectNotExists (
6368 { client : s3Client } ,
6469 { Bucket : bucketName , Key : key } ,
6570 )
6671 }
6772 core . info (
68- `Successfully deleted ${ Deleted ?. length || 0 } objects. Deleted objects: ` ,
73+ `Successfully deleted ${ Deleted ?. length || 0 } objects.` ,
6974 )
7075 core . info ( Deleted ?. map ( ( d ) => ` • ${ d . Key } ` ) . join ( "\n" ) )
7176 } catch ( err ) {
@@ -76,6 +81,7 @@ async function deleteFiles(bucketName, keys) {
7681 } else {
7782 core . setFailed ( `Error while deleting objects for "${ bucketName } ". ${ err . name } : ${ err . message } ` )
7883 }
84+ process . exit ( 1 )
7985 }
8086}
8187
0 commit comments