1- import { SimpleLogger } from "@trigger.dev/core/v3/apps " ;
1+ import { SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger " ;
22import { Exec } from "./exec" ;
33import { setTimeout } from "timers/promises" ;
44
@@ -10,14 +10,18 @@ interface TempFileCleanerOptions {
1010}
1111
1212export class TempFileCleaner {
13- private logger = new SimpleLogger ( "[tmp-cleaner]" ) ;
1413 private enabled = false ;
15- private exec = new Exec ( { logger : this . logger } ) ;
1614
17- constructor ( private opts : TempFileCleanerOptions ) { }
15+ private logger : SimpleStructuredLogger ;
16+ private exec : Exec ;
17+
18+ constructor ( private opts : TempFileCleanerOptions ) {
19+ this . logger = new SimpleStructuredLogger ( "tmp-cleaner" , undefined , { ...this . opts } ) ;
20+ this . exec = new Exec ( { logger : this . logger } ) ;
21+ }
1822
1923 async start ( ) {
20- this . logger . log ( "start" , this . opts ) ;
24+ this . logger . log ( "TempFileCleaner. start" ) ;
2125 this . enabled = true ;
2226
2327 if ( ! this . opts . leadingEdge ) {
@@ -28,15 +32,15 @@ export class TempFileCleaner {
2832 try {
2933 await this . clean ( ) ;
3034 } catch ( error ) {
31- this . logger . error ( "error during tick" , error ) ;
35+ this . logger . error ( "error during tick" , { error } ) ;
3236 }
3337
3438 await this . wait ( ) ;
3539 }
3640 }
3741
3842 stop ( ) {
39- this . logger . log ( "stop" , this . opts ) ;
43+ this . logger . log ( "TempFileCleaner. stop" ) ;
4044 this . enabled = false ;
4145 }
4246
@@ -89,7 +93,7 @@ export class TempFileCleaner {
8993 const rmOutput = await rm ;
9094
9195 if ( rmOutput . stderr . length > 0 ) {
92- this . logger . error ( "delete unsuccessful" , rmOutput ) ;
96+ this . logger . error ( "delete unsuccessful" , { rmOutput } ) ;
9397 return ;
9498 }
9599
0 commit comments