customizer tests

Author: liustve

aws-distro-opentelemetry-node-autoinstrumentation/src/aws-opentelemetry-configurator.ts

@@ -196,7 +196,7 @@ export class AwsOpentelemetryConfigurator {
     // default SpanProcessors with Span Exporters wrapped inside AwsMetricAttributesSpanExporter
     const awsSpanProcessorProvider: AwsSpanProcessorProvider = new AwsSpanProcessorProvider(this.resource);
     this.spanProcessors = awsSpanProcessorProvider.getSpanProcessors();
-    this.logRecordProcessors = new AwsLoggerProcessorProvider().getlogRecordProcessors();
+    this.logRecordProcessors = AwsLoggerProcessorProvider.getlogRecordProcessors();
     AwsOpentelemetryConfigurator.customizeSpanProcessors(this.spanProcessors, this.resource);
   }
 
@@ -424,18 +424,20 @@ export class ApplicationSignalsExporterProvider {
 // once we upgrade to @opentelemetry/core 2.0.0 or higher, which provides these methods natively.
 //
 export class AwsLoggerProcessorProvider {
-  private _logRecordProcessors: LogRecordProcessor[] = [];
+  public static getlogRecordProcessors(): LogRecordProcessor[] {
+    const exporters = AwsLoggerProcessorProvider.configureLogExportersFromEnv();
 
-  constructor() {
-    this.configureLoggerProviderFromEnv();
-  }
-
-  public getlogRecordProcessors() {
-    return this._logRecordProcessors;
+    return exporters.map(exporter => {
+      if (exporter instanceof ConsoleLogRecordExporter) {
+        return new SimpleLogRecordProcessor(exporter);
+      } else {
+        return new BatchLogRecordProcessor(exporter);
+      }
+    });
   }
 
-  private configureLoggerProviderFromEnv(): void {
-    const otlpExporterLogsEndpoint = process.env['OTEL_EXPORTER_OTLP_LOGS_ENDPOINT'];
+  static configureLogExportersFromEnv(): LogRecordExporter[] {
+    const otlpExporterLogsEndpoint = process.env.OTEL_EXPORTER_OTLP_LOGS_ENDPOINT;
     const enabledExporters = AwsLoggerProcessorProvider.getStringListFromEnv('OTEL_LOGS_EXPORTER') ?? [];
 
     if (enabledExporters.length === 0) {
@@ -445,7 +447,7 @@ export class AwsLoggerProcessorProvider {
 
     if (enabledExporters.includes('none')) {
       diag.info('OTEL_LOGS_EXPORTER contains "none". Logger provider will not be initialized.');
-      return;
+      return [];
     }
 
     const exporters: LogRecordExporter[] = [];
@@ -500,15 +502,7 @@ export class AwsLoggerProcessorProvider {
       }
     });
 
-    if (exporters.length > 0) {
-      this._logRecordProcessors = exporters.map(exporter => {
-        if (exporter instanceof ConsoleLogRecordExporter) {
-          return new SimpleLogRecordProcessor(exporter);
-        } else {
-          return new BatchLogRecordProcessor(exporter);
-        }
-      });
-    }
+    return exporters;
   }
 
   /**