Fix metric and export logs to file to support customer reach outs

Author: satyakigh

src/handlers/ConfigurationHandler.ts

@@ -7,9 +7,9 @@ const log = LoggerFactory.getLogger('ConfigurationHandler');
 
 export function configurationHandler(components: ServerComponents): (params: DidChangeConfigurationParams) => void {
     return (_params: DidChangeConfigurationParams): void => {
+        TelemetryService.instance.get('ConfigurationHandler').count('count', 1);
         // Pull configuration from LSP workspace and notify all components via subscriptions (fire-and-forget)
         components.settingsManager.syncConfiguration().catch((error) => {
-            TelemetryService.instance.get('ConfigurationHandler').count('count', 1);
             log.error(error, `Failed to sync configuration`);
         });
     };

src/telemetry/LoggerFactory.ts

@@ -1,7 +1,11 @@
 /* eslint-disable @typescript-eslint/no-unsafe-function-type */
+import { readdir, stat, unlink, readFile, writeFile } from 'fs/promises';
+import { join } from 'path';
+import { DateTime } from 'luxon';
 import pino, { LevelWithSilent, Logger } from 'pino';
-import { ExtensionName } from '../utils/ExtensionConfig';
-import { AwsMetadata, TelemetrySettings } from './TelemetryConfig';
+import { pathToArtifact } from '../utils/ArtifactsDir';
+import { ExtensionId, ExtensionName } from '../utils/ExtensionConfig';
+import { TelemetrySettings, AwsMetadata } from './TelemetryConfig';
 
 export const LogLevel: Record<LevelWithSilent, number> = {
     silent: 0,
@@ -14,6 +18,9 @@ export const LogLevel: Record<LevelWithSilent, number> = {
 } as const;
 
 export class LoggerFactory {
+    private static readonly LogsDirectory = pathToArtifact('logs');
+    private static readonly MaxFileSize = 100 * 1024 * 1024; // 100MB
+
     private static readonly _instance: LoggerFactory = new LoggerFactory();
 
     private readonly baseLogger: Logger;
@@ -27,15 +34,56 @@ export class LoggerFactory {
             name: ExtensionName,
             level: this.logLevel,
             transport: {
-                target: 'pino-pretty',
-                options: {
-                    colorize: false,
-                    translateTime: 'SYS:hh:MM:ss TT',
-                    ignore: 'pid,hostname,name,clazz',
-                    messageFormat: '[{clazz}] {msg}',
-                },
+                targets: [
+                    {
+                        target: 'pino-pretty',
+                        options: {
+                            colorize: false,
+                            translateTime: 'SYS:hh:MM:ss TT',
+                            ignore: 'pid,hostname,name,clazz',
+                            messageFormat: '[{clazz}] {msg}',
+                        },
+                    },
+                    {
+                        target: 'pino/file',
+                        options: {
+                            destination: join(
+                                LoggerFactory.LogsDirectory,
+                                `${ExtensionId}-${DateTime.utc().toFormat('yyyy-MM-dd')}.log`,
+                            ),
+                            mkdir: true,
+                        },
+                    },
+                ],
             },
         });
+
+        void this.cleanOldLogs();
+    }
+
+    private async cleanOldLogs() {
+        try {
+            const files = await readdir(LoggerFactory.LogsDirectory);
+            const oneWeekAgo = DateTime.utc().minus({ weeks: 1 });
+
+            for (const file of files) {
+                if (!file.endsWith('.log')) continue;
+
+                const filePath = join(LoggerFactory.LogsDirectory, file);
+                const stats = await stat(filePath);
+
+                if (DateTime.fromJSDate(stats.mtime) < oneWeekAgo) {
+                    await unlink(filePath);
+                } else if (stats.size > LoggerFactory.MaxFileSize) {
+                    const content = await readFile(filePath, 'utf8');
+                    const lines = content.split('\n');
+                    const trimmed = lines.slice(-Math.floor(lines.length / 2)).join('\n');
+                    await writeFile(filePath, trimmed);
+                }
+            }
+        } catch (err) {
+            this.baseLogger.error(err, 'Error cleaning up old logs');
+        }
     }
 
     private reconfigure(newLevel: LevelWithSilent) {