@@ -11,19 +11,19 @@ export default eventHandler(async (event) => {
1111 // }
1212 const { readable, writable } = new TransformStream ( )
1313
14- event . context . cloudflare . context . waitUntil ( Promise . all ( [
15- iterateAndDelete ( event , writable , signal , {
16- prefix : usePackagesBucket . base ,
17- limit : 100 ,
18- } ) ,
19-
20- iterateAndDelete ( event , writable , signal , {
21- prefix : useTemplatesBucket . base ,
22- limit : 100 ,
23- } )
24- ] ) . then ( ( ) => {
25- writable . close ( )
26- } ) )
14+ event . context . cloudflare . context . waitUntil (
15+ ( async ( ) => {
16+ await iterateAndDelete ( event , writable , signal , {
17+ prefix : usePackagesBucket . base ,
18+ limit : 100 ,
19+ } )
20+ await iterateAndDelete ( event , writable , signal , {
21+ prefix : useTemplatesBucket . base ,
22+ limit : 100 ,
23+ } )
24+ writable . close ( )
25+ } ) ( )
26+ )
2727
2828 return readable
2929} ) ;
@@ -51,7 +51,7 @@ async function iterateAndDelete(event: H3Event, writable: WritableStream, signal
5151 const uploaded = Date . parse ( object . uploaded . toString ( ) ) ;
5252 // remove the object anyway if it's 6 months old already
5353 if ( ( today - uploaded ) / ( 1000 * 3600 * 24 * 30 * 6 ) >= 1 ) {
54- writer . write ( JSON . stringify ( {
54+ await writer . write ( JSON . stringify ( {
5555 key : object . key ,
5656 uploaded : new Date ( object . uploaded ) ,
5757 downloadedAt : new Date ( ( await downloadedAtBucket . getItem ( object . key ) ) ! ) ,
@@ -67,7 +67,7 @@ async function iterateAndDelete(event: H3Event, writable: WritableStream, signal
6767 ! ( ( today - downloadedAt ) / ( 1000 * 3600 * 24 * 30 ) < 1 ) &&
6868 ( today - uploaded ) / ( 1000 * 3600 * 24 * 30 ) >= 1
6969 ) {
70- writer . write ( JSON . stringify ( {
70+ await writer . write ( JSON . stringify ( {
7171 key : object . key ,
7272 uploaded : new Date ( object . uploaded ) ,
7373 downloadedAt : new Date ( downloadedAt ) ,
0 commit comments