@@ -58,7 +58,7 @@ export default async function routes(fastify: FastifyInstance) {
58
58
const { data : bucket } = bucketResponse
59
59
const bucketName = bucket . name
60
60
61
- let deleteError , objectError , objects , objectStatus
61
+ let deleteError , deleteData , objectError , objects , objectStatus
62
62
do {
63
63
; ( { data : objects , error : objectError , status : objectStatus } = await postgrest
64
64
. from < Obj > ( 'objects' )
@@ -73,14 +73,7 @@ export default async function routes(fastify: FastifyInstance) {
73
73
request . log . info ( { results : objects } , 'results' )
74
74
75
75
if ( objects && objects . length > 0 ) {
76
- const params = objects . map ( ( ele ) => {
77
- return {
78
- Key : `${ projectRef } /${ bucketName } /${ ele . name } ` ,
79
- }
80
- } )
81
- // delete files from s3 asynchronously
82
- deleteObjects ( client , globalS3Bucket , params )
83
- ; ( { error : deleteError } = await postgrest
76
+ ; ( { error : deleteError , data : deleteData } = await postgrest
84
77
. from < Obj > ( 'objects' )
85
78
. delete ( )
86
79
. in (
@@ -91,6 +84,16 @@ export default async function routes(fastify: FastifyInstance) {
91
84
if ( deleteError ) {
92
85
request . log . error ( { error : deleteError } , 'error bucket' )
93
86
}
87
+
88
+ if ( deleteData && deleteData . length > 0 ) {
89
+ const params = deleteData . map ( ( ele ) => {
90
+ return {
91
+ Key : `${ projectRef } /${ bucketName } /${ ele . name } ` ,
92
+ }
93
+ } )
94
+ // delete files from s3 asynchronously
95
+ deleteObjects ( client , globalS3Bucket , params )
96
+ }
94
97
}
95
98
} while ( ! deleteError && ! objectError && objects && objects . length > 0 )
96
99
0 commit comments