@@ -54,38 +54,36 @@ class ConsoleLogger extends LoggerBase {
5454
5555class DiskLogger extends LoggerBase {
5656 private logWriter ?: MongoLogWriter ;
57-
58- constructor (
59- private logPath : string
60- ) {
57+
58+ constructor ( private logPath : string ) {
6159 super ( ) ;
6260 }
6361
64- async initialize ( ) : Promise < void > {
65- await fs . mkdir ( this . logPath , { recursive : true } ) ;
66-
67- const manager = new MongoLogManager ( {
68- directory : this . logPath ,
69- retentionDays : 30 ,
70- onwarn : console . warn ,
71- onerror : console . error ,
72- gzip : false ,
73- retentionGB : 1 ,
74- } ) ;
62+ async initialize ( ) : Promise < void > {
63+ await fs . mkdir ( this . logPath , { recursive : true } ) ;
64+
65+ const manager = new MongoLogManager ( {
66+ directory : this . logPath ,
67+ retentionDays : 30 ,
68+ onwarn : console . warn ,
69+ onerror : console . error ,
70+ gzip : false ,
71+ retentionGB : 1 ,
72+ } ) ;
7573
76- await manager . cleanupOldLogFiles ( ) ;
74+ await manager . cleanupOldLogFiles ( ) ;
7775
78- this . logWriter = await manager . createLogWriter ( ) ;
79- }
76+ this . logWriter = await manager . createLogWriter ( ) ;
77+ }
8078
8179 log ( level : LogLevel , id : MongoLogId , context : string , message : string ) : void {
8280 message = redact ( message ) ;
8381 const mongoDBLevel = this . mapToMongoDBLogLevel ( level ) ;
84-
82+
8583 if ( ! this . logWriter ) {
8684 throw new Error ( "DiskLogger is not initialized" ) ;
8785 }
88-
86+
8987 this . logWriter [ mongoDBLevel ] ( "MONGODB-MCP" , id , context , message ) ;
9088 }
9189
@@ -110,11 +108,8 @@ async initialize(): Promise<void> {
110108 }
111109}
112110
113-
114111class McpLogger extends LoggerBase {
115- constructor (
116- private server : McpServer
117- ) {
112+ constructor ( private server : McpServer ) {
118113 super ( ) ;
119114 }
120115
@@ -131,14 +126,15 @@ class CompositeLogger extends LoggerBase {
131126
132127 constructor ( ...loggers : LoggerBase [ ] ) {
133128 super ( ) ;
134- if ( loggers . length === 0 ) { // default to ConsoleLogger
129+ if ( loggers . length === 0 ) {
130+ // default to ConsoleLogger
135131 loggers . push ( new ConsoleLogger ( ) ) ;
136132 }
137133 this . loggers = [ ...loggers ] ;
138134 }
139135
140136 async initialize ( ) : Promise < void > {
141- for ( const logger of this . loggers ) {
137+ for ( const logger of this . loggers ) {
142138 await logger . initialize ( ) ;
143139 }
144140 }
@@ -148,7 +144,7 @@ class CompositeLogger extends LoggerBase {
148144 }
149145
150146 log ( level : LogLevel , id : MongoLogId , context : string , message : string ) : void {
151- for ( const logger of this . loggers ) {
147+ for ( const logger of this . loggers ) {
152148 logger . log ( level , id , context , message ) ;
153149 }
154150 }
@@ -158,9 +154,6 @@ const logger = new CompositeLogger();
158154export default logger ;
159155
160156export async function initializeLogger ( server : McpServer , logPath : string ) : Promise < void > {
161- logger . setLoggers (
162- new McpLogger ( server ) ,
163- new DiskLogger ( logPath ) ,
164- )
157+ logger . setLoggers ( new McpLogger ( server ) , new DiskLogger ( logPath ) ) ;
165158 await logger . initialize ( ) ;
166159}
0 commit comments