1
- import { SimpleLogger } from "@trigger.dev/core/v3/apps " ;
1
+ import { SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger " ;
2
2
import { Exec } from "./exec" ;
3
3
import { setTimeout } from "timers/promises" ;
4
4
@@ -10,14 +10,18 @@ interface TempFileCleanerOptions {
10
10
}
11
11
12
12
export class TempFileCleaner {
13
- private logger = new SimpleLogger ( "[tmp-cleaner]" ) ;
14
13
private enabled = false ;
15
- private exec = new Exec ( { logger : this . logger } ) ;
16
14
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
+ }
18
22
19
23
async start ( ) {
20
- this . logger . log ( "start" , this . opts ) ;
24
+ this . logger . log ( "TempFileCleaner. start" ) ;
21
25
this . enabled = true ;
22
26
23
27
if ( ! this . opts . leadingEdge ) {
@@ -28,15 +32,15 @@ export class TempFileCleaner {
28
32
try {
29
33
await this . clean ( ) ;
30
34
} catch ( error ) {
31
- this . logger . error ( "error during tick" , error ) ;
35
+ this . logger . error ( "error during tick" , { error } ) ;
32
36
}
33
37
34
38
await this . wait ( ) ;
35
39
}
36
40
}
37
41
38
42
stop ( ) {
39
- this . logger . log ( "stop" , this . opts ) ;
43
+ this . logger . log ( "TempFileCleaner. stop" ) ;
40
44
this . enabled = false ;
41
45
}
42
46
@@ -89,7 +93,7 @@ export class TempFileCleaner {
89
93
const rmOutput = await rm ;
90
94
91
95
if ( rmOutput . stderr . length > 0 ) {
92
- this . logger . error ( "delete unsuccessful" , rmOutput ) ;
96
+ this . logger . error ( "delete unsuccessful" , { rmOutput } ) ;
93
97
return ;
94
98
}
95
99
0 commit comments