feat: sourt out loggers again

Author: AleksandrSl

cmp/compiler/src/plugin/next.ts

@@ -2,7 +2,7 @@ import type { NextConfig } from "next";
 
 import { getConfigPath } from "../utils/path-helpers";
 import { createLingoConfig } from "../utils/config-factory";
-import { logger, loggerRegistry } from "../utils/logger";
+import { logger } from "../utils/logger";
 import type { PartialLingoConfig } from "../types";
 import type { TurbopackOptions } from "next/dist/server/config-shared";
 
@@ -64,12 +64,6 @@ function buildLingoConfig(
 ): NextConfig {
   const lingoConfig = createLingoConfig(lingoOptions);
 
-  loggerRegistry.create("plugin", {
-    enableConsole: true,
-    // TODO (AleksandrSl 04/12/2025): Make configurable
-    enableDebug: true,
-  });
-
   // Prepare Turbopack loader configuration
   const loaderConfig = {
     loader: "@lingo.dev/_compiler/turbopack-loader",

cmp/compiler/src/utils/file-writer.ts …ompiler/src/translation-server/logger.tscmp/compiler/src/utils/file-writer.ts renamed to cmp/compiler/src/translation-server/logger.ts cmp/compiler/src/utils/file-writer.ts renamed to cmp/compiler/src/translation-server/logger.ts

@@ -1,10 +1,13 @@
+import { Logger, type LogLevel } from "../utils/logger";
+import { join } from "path";
+import type { TranslationMiddlewareConfig } from "../types";
+
 /**
  * Such weird separation of file writer from logger
  * is needed to avoid leaking node deps to the client build in next,
  * but still keep the main logger logic in one place.
  */
 import { appendFile } from "fs/promises";
-import { getLogger, type LogLevel } from "./logger";
 
 /**
  * Create a file writer function for a specific log file
@@ -36,13 +39,20 @@ export function createFileWriter(
   };
 }
 
-/**
- * Configure a logger with file output
- */
-export function configureFileLogger(
-  logger: ReturnType<typeof getLogger>,
-  filePath: string,
-): void {
-  const fileWriter = createFileWriter(filePath);
-  logger.setFileWriter(fileWriter);
+let logger: Logger | undefined = undefined;
+
+export function getLogger(config: TranslationMiddlewareConfig) {
+  if (!logger) {
+    const translationServerLogPath = join(
+      config.sourceRoot,
+      config.lingoDir,
+      "translation-server.log",
+    );
+    logger = new Logger({
+      enableConsole: false,
+      enableDebug: true,
+      writeToFile: createFileWriter(translationServerLogPath),
+    });
+  }
+  return logger;
 }

cmp/compiler/src/translation-server/translation-server.ts

@@ -14,15 +14,13 @@
 import http from "http";
 import { URL } from "url";
 import type { MetadataSchema, TranslationMiddlewareConfig } from "../types";
-import { getLogger, loggerRegistry } from "../utils/logger";
+import { getLogger } from "./logger";
 import {
   createTranslator,
   LocalTranslationCache,
   TranslationService,
 } from "../translators";
 import { createEmptyMetadata, loadMetadata } from "../metadata/manager";
-import { join } from "path";
-import { configureFileLogger } from "../utils/file-writer";
 
 export interface TranslationServerOptions {
   /**
@@ -63,20 +61,7 @@ export class TranslationServer {
     this.startPort = options.startPort || 60000;
     this.onReadyCallback = options.onReady;
     this.onErrorCallback = options.onError;
-    const translationServerLogger = loggerRegistry.create(
-      "translation-server",
-      {
-        enableConsole: false,
-        enableDebug: true,
-      },
-    );
-    const translationServerLogPath = join(
-      this.config.sourceRoot,
-      this.config.lingoDir,
-      "translation-server.log",
-    );
-    configureFileLogger(translationServerLogger, translationServerLogPath);
-    this.logger = getLogger("translation-server");
+    this.logger = getLogger(this.config);
   }
 
   /**
@@ -89,19 +74,27 @@ export class TranslationServer {
 
     this.logger.info(`🔧 Initializing translator...`);
 
-    const translator = createTranslator(this.config);
+    const translator = createTranslator(this.config, this.logger);
     const isPseudo = translator.constructor.name === "PseudoTranslator";
 
-    const cache = new LocalTranslationCache({
-      cacheDir: this.config.lingoDir,
-      sourceRoot: this.config.sourceRoot,
-    });
+    const cache = new LocalTranslationCache(
+      {
+        cacheDir: this.config.lingoDir,
+        sourceRoot: this.config.sourceRoot,
+      },
+      this.logger,
+    );
 
-    this.translationService = new TranslationService(translator, cache, {
-      sourceLocale: this.config.sourceLocale,
-      pluralization: this.config.pluralization,
-      isPseudo,
-    });
+    this.translationService = new TranslationService(
+      translator,
+      cache,
+      {
+        sourceLocale: this.config.sourceLocale,
+        pluralization: this.config.pluralization,
+        isPseudo,
+      },
+      this.logger,
+    );
 
     const port = await this.findAvailablePort(this.startPort);
 

cmp/compiler/src/translators/lcp/lcp-translator.test.ts

@@ -1,27 +1,34 @@
-import { describe, it, expect } from "vitest";
+import { describe, expect, it } from "vitest";
 import { LCPTranslator } from "./lcp-translator";
+import { logger } from "../../utils/logger";
 
 describe("LCPTranslator", () => {
   it("should create an instance with config", () => {
-    const translator = new LCPTranslator({
-      models: "lingo.dev",
-      sourceLocale: "en",
-    });
+    const translator = new LCPTranslator(
+      {
+        models: "lingo.dev",
+        sourceLocale: "en",
+      },
+      logger,
+    );
 
     expect(translator).toBeDefined();
     expect(translator.config.models).toBe("lingo.dev");
     expect(translator.config.sourceLocale).toBe("en");
   });
 
   it("should create an instance with custom models", () => {
-    const translator = new LCPTranslator({
-      models: {
-        "en:es": "google:gemini-2.0-flash",
-        "*:*": "groq:llama3-8b-8192",
+    const translator = new LCPTranslator(
+      {
+        models: {
+          "en:es": "google:gemini-2.0-flash",
+          "*:*": "groq:llama3-8b-8192",
+        },
+        sourceLocale: "en",
+        prompt: "Translate professionally",
       },
-      sourceLocale: "en",
-      prompt: "Translate professionally",
-    });
+      logger,
+    );
 
     expect(translator).toBeDefined();
     expect(translator.config.models).toEqual({
@@ -32,10 +39,13 @@ describe("LCPTranslator", () => {
   });
 
   it("should implement Translator interface methods", () => {
-    const translator = new LCPTranslator({
-      models: "lingo.dev",
-      sourceLocale: "en",
-    });
+    const translator = new LCPTranslator(
+      {
+        models: "lingo.dev",
+        sourceLocale: "en",
+      },
+      logger,
+    );
 
     expect(typeof translator.translate).toBe("function");
   });

cmp/compiler/src/translators/lcp/lcp-translator.ts

@@ -6,7 +6,7 @@ import { obj2xml, xml2obj } from "./xml2obj";
 import { shots } from "./shots";
 import { getLingoDotDevKey } from "./api-keys";
 import { createAiModel, getLocaleModel } from "./model-factory";
-import { getLogger } from "../../utils/logger";
+import { Logger } from "../../utils/logger";
 import { DEFAULT_TIMEOUTS, withTimeout } from "../../utils/timeout";
 
 /**
@@ -22,8 +22,10 @@ export interface LCPTranslatorConfig {
  * LCP-based translator using AI models
  */
 export class LCPTranslator implements Translator<LCPTranslatorConfig> {
-  private logger = getLogger("translation-server");
-  constructor(readonly config: LCPTranslatorConfig) {}
+  constructor(
+    readonly config: LCPTranslatorConfig,
+    private logger: Logger,
+  ) {}
 
   /**
    * Translate multiple entries

cmp/compiler/src/translators/lcp/prompt.ts

@@ -1,22 +1,16 @@
-import { getLogger } from "../../utils/logger";
-
 interface PromptArguments {
   sourceLocale: string;
   targetLocale: string;
   prompt?: string;
 }
 
-const logger = getLogger("translation-server");
-
 export function getSystemPrompt(args: PromptArguments): string {
   // If user provided custom prompt, use it
   if (args.prompt?.trim()) {
-    const userPrompt = args.prompt
+    return args.prompt
       .trim()
       .replace("{SOURCE_LOCALE}", args.sourceLocale)
       .replace("{TARGET_LOCALE}", args.targetLocale);
-    logger.info("✨ Using user-defined translation prompt");
-    return userPrompt;
   }
 
   // Otherwise use built-in prompt

cmp/compiler/src/translators/local-cache.ts

@@ -4,10 +4,10 @@
 
 import * as fs from "fs/promises";
 import * as path from "path";
-import type { TranslationCache, LocalCacheConfig } from "./cache";
-import { getLogger } from "../utils/logger";
+import type { LocalCacheConfig, TranslationCache } from "./cache";
 import type { DictionarySchema } from "./api";
-import { withTimeout, DEFAULT_TIMEOUTS } from "../utils/timeout";
+import { DEFAULT_TIMEOUTS, withTimeout } from "../utils/timeout";
+import type { Logger } from "../utils/logger";
 
 /**
  * Local file system cache for translations
@@ -16,7 +16,10 @@ import { withTimeout, DEFAULT_TIMEOUTS } from "../utils/timeout";
 export class LocalTranslationCache implements TranslationCache {
   private config: LocalCacheConfig;
 
-  constructor(config: LocalCacheConfig) {
+  constructor(
+    config: LocalCacheConfig,
+    private logger: Logger,
+  ) {
     this.config = config;
   }
 
@@ -77,8 +80,7 @@ export class LocalTranslationCache implements TranslationCache {
         `Write cache for ${locale}`,
       );
     } catch (error) {
-      const logger = getLogger("translation-server");
-      logger.error(`Failed to write cache for locale ${locale}:`, error);
+      this.logger.error(`Failed to write cache for locale ${locale}:`, error);
       throw error;
     }
   }

cmp/compiler/src/translators/pseudotranslator/index.ts

@@ -3,7 +3,7 @@
  */
 
 import type { TranslatableEntry, Translator } from "../api";
-import { getLogger } from "../../utils/logger";
+import { Logger } from "../../utils/logger";
 
 export interface PseudoTranslatorConfig {
   delayMedian?: number;
@@ -14,8 +14,10 @@ export interface PseudoTranslatorConfig {
  * Useful for testing i18n without actual translation APIs
  */
 export class PseudoTranslator implements Translator<PseudoTranslatorConfig> {
-  private readonly logger = getLogger("translation-server");
-  constructor(readonly config: PseudoTranslatorConfig) {}
+  constructor(
+    readonly config: PseudoTranslatorConfig,
+    private readonly logger: Logger,
+  ) {}
 
   translate(locale: string, entries: Record<string, TranslatableEntry>) {
     this.logger.debug(

cmp/compiler/src/translators/translation-service.ts

@@ -11,11 +11,10 @@
 import type { TranslationCache } from "./cache";
 import type { TranslatableEntry, Translator } from "./api";
 import type { MetadataSchema } from "../types";
-import { getLogger } from "../utils/logger";
-import {
-  processPluralization,
-  type PluralizationConfig,
-} from "./pluralization";
+import { processPluralization } from "./pluralization";
+import type { Logger } from "../utils/logger";
+import type { PartialPluralizationConfig } from "./pluralization/types";
+import type { LocaleCode } from "lingo.dev/spec";
 
 /**
  * Configuration for translation service
@@ -24,7 +23,8 @@ export interface TranslationServiceConfig {
   /**
    * Source locale (e.g., "en")
    */
-  sourceLocale: string;
+  // TODO (AleksandrSl 05/12/2025): Sort out these fields, they should most likely pick from the global config
+  sourceLocale: LocaleCode;
 
   /**
    * Whether the translator is a pseudo translator
@@ -36,7 +36,7 @@ export interface TranslationServiceConfig {
    * Pluralization configuration
    * If provided, enables automatic pluralization of source messages
    */
-  pluralization?: PluralizationConfig;
+  pluralization?: Omit<PartialPluralizationConfig, "sourceLocale">;
 }
 
 /**
@@ -79,12 +79,12 @@ export interface TranslationError {
 export class TranslationService {
   private useCache = true;
   private pluralizationProcessed = false;
-  private logger = getLogger("translation-server");
 
   constructor(
     private translator: Translator<any>,
     private cache: TranslationCache,
     private config: TranslationServiceConfig,
+    private logger: Logger,
   ) {
     this.useCache = !this.config.isPseudo;
   }
@@ -116,7 +116,11 @@ export class TranslationService {
       );
       const pluralStats = await processPluralization(
         metadata,
-        this.config.pluralization || { enabled: true },
+        {
+          ...this.config.pluralization,
+          sourceLocale: this.config.sourceLocale,
+        },
+        this.logger,
       );
       this.logger.info(
         `Pluralization stats: ${pluralStats.pluralized} pluralized, ${pluralStats.rejected} rejected, ${pluralStats.failed} failed`,